Lines Matching defs:lp
50 lacp_sm_mux(struct lacp_port *lp)
54 (lp->lp_partner.lip_state & LACP_STATE_SYNC) != 0;
56 (lp->lp_partner.lip_state & LACP_STATE_COLLECTING) != 0;
57 enum lacp_selected selected = lp->lp_selected;
60 /* LACP_DPRINTF((lp, "%s: state %d\n", __func__, lp->lp_mux_state)); */
63 la = lp->lp_aggregator;
64 KASSERT(lp->lp_mux_state == LACP_MUX_DETACHED || la != NULL);
65 new_state = lp->lp_mux_state;
66 switch (lp->lp_mux_state) {
74 !LACP_TIMER_ISARMED(lp, LACP_TIMER_WAIT_WHILE));
104 if (lp->lp_mux_state == new_state) {
110 lp->lp_state &= ~LACP_STATE_SYNC;
111 lacp_disable_distributing(lp);
112 lacp_disable_collecting(lp);
113 lacp_sm_assert_ntt(lp);
115 if (LACP_TIMER_ISARMED(lp, LACP_TIMER_WAIT_WHILE)) {
119 LACP_TIMER_DISARM(lp, LACP_TIMER_WAIT_WHILE);
120 lacp_unselect(lp);
123 LACP_TIMER_ARM(lp, LACP_TIMER_WAIT_WHILE,
128 lp->lp_state |= LACP_STATE_SYNC;
129 lacp_disable_collecting(lp);
130 lacp_sm_assert_ntt(lp);
133 lacp_enable_collecting(lp);
134 lp->lp_state |= LACP_STATE_COLLECTING;
135 lacp_disable_distributing(lp);
136 lacp_sm_assert_ntt(lp);
139 lacp_enable_distributing(lp);
145 LACP_DPRINTF((lp, "mux_state %d -> %d\n", lp->lp_mux_state, new_state));
147 lp->lp_mux_state = new_state;
152 lacp_sm_mux_timer(struct lacp_port *lp)
154 struct lacp_aggregator *la = lp->lp_aggregator;
162 LACP_DPRINTF((lp, "%s: aggregator %s, pending %d -> %d\n", __func__,