Lines Matching full:aggregator

695 	KASSERT(!TAILQ_EMPTY(&la->la_ports), ("no aggregator ports"));  in lacp_disable_distributing()
697 KASSERT(la->la_refcnt >= la->la_nports, ("aggregator refcnt invalid")); in lacp_disable_distributing()
699 LACP_DPRINTF((lp, "disable distributing on aggregator %s, " in lacp_disable_distributing()
711 /* regenerate the port map, the active aggregator has changed */ in lacp_disable_distributing()
734 LACP_DPRINTF((lp, "enable distributing on aggregator %s, " in lacp_enable_distributing()
739 KASSERT(la->la_refcnt > la->la_nports, ("aggregator refcnt invalid")); in lacp_enable_distributing()
750 /* try to become the active aggregator */ in lacp_enable_distributing()
804 ("aggregator still attached")); in lacp_detach()
852 LACP_DPRINTF((NULL, "%s: no active aggregator\n", __func__)); in lacp_select_tx_port_by_hash()
973 * lacp_select_active_aggregator: select an aggregator to be used to transmit
1000 * This aggregator is chosen if the partner has a better in lacp_select_active_aggregator()
1002 * or, it is already the chosen aggregator in lacp_select_active_aggregator()
1015 ("invalid aggregator refcnt")); in lacp_select_active_aggregator()
1017 ("invalid aggregator list")); in lacp_select_active_aggregator()
1020 LACP_DPRINTF((NULL, "active aggregator changed\n")); in lacp_select_active_aggregator()
1025 LACP_DPRINTF((NULL, "active aggregator not changed\n")); in lacp_select_active_aggregator()
1313 KASSERT(lsc->lsc_active_aggregator != la, ("aggregator active")); in lacp_aggregator_delref()
1321 * lacp_aggregator_get: allocate an aggregator.
1342 * lacp_fill_aggregator_id: setup a newly allocated aggregator from a port.
1364 * lacp_aggregator_is_compatible: check if a port can join to an aggregator.
1422 * lacp_select: select an aggregator. create one if necessary.
1455 LACP_DPRINTF((lp, "aggregator creation failed\n")); in lacp_select()
1464 LACP_DPRINTF((lp, "aggregator created\n")); in lacp_select()
1466 LACP_DPRINTF((lp, "compatible aggregator found\n")); in lacp_select()
1472 LACP_DPRINTF((lp, "aggregator lagid=%s\n", in lacp_select()
1634 LACP_DPRINTF((lp, "%s: aggregator %s, pending %d -> %d\n", __func__, in lacp_sm_mux_timer()