Lines Matching refs:lacpdu
96 static void ad_rx_machine(struct lacpdu *lacpdu, struct port *port);
440 static void __choose_matched(struct lacpdu *lacpdu, struct port *port) in __choose_matched() argument
446 if (((ntohs(lacpdu->partner_port) == port->actor_port_number) && in __choose_matched()
447 (ntohs(lacpdu->partner_port_priority) == port->actor_port_priority) && in __choose_matched()
448 MAC_ADDRESS_EQUAL(&(lacpdu->partner_system), &(port->actor_system)) && in __choose_matched()
449 (ntohs(lacpdu->partner_system_priority) == port->actor_system_priority) && in __choose_matched()
450 (ntohs(lacpdu->partner_key) == port->actor_oper_port_key) && in __choose_matched()
451 …((lacpdu->partner_state & LACP_STATE_AGGREGATION) == (port->actor_oper_port_state & LACP_STATE_AGG… in __choose_matched()
452 ((lacpdu->actor_state & LACP_STATE_AGGREGATION) == 0) in __choose_matched()
469 static void __record_pdu(struct lacpdu *lacpdu, struct port *port) in __record_pdu() argument
471 if (lacpdu && port) { in __record_pdu()
474 __choose_matched(lacpdu, port); in __record_pdu()
478 partner->port_number = ntohs(lacpdu->actor_port); in __record_pdu()
479 partner->port_priority = ntohs(lacpdu->actor_port_priority); in __record_pdu()
480 partner->system = lacpdu->actor_system; in __record_pdu()
481 partner->system_priority = ntohs(lacpdu->actor_system_priority); in __record_pdu()
482 partner->key = ntohs(lacpdu->actor_key); in __record_pdu()
483 partner->port_state = lacpdu->actor_state; in __record_pdu()
492 (lacpdu->actor_state & LACP_STATE_SYNCHRONIZATION)) { in __record_pdu()
537 static void __update_selected(struct lacpdu *lacpdu, struct port *port) in __update_selected() argument
539 if (lacpdu && port) { in __update_selected()
545 if (ntohs(lacpdu->actor_port) != partner->port_number || in __update_selected()
546 ntohs(lacpdu->actor_port_priority) != partner->port_priority || in __update_selected()
547 !MAC_ADDRESS_EQUAL(&lacpdu->actor_system, &partner->system) || in __update_selected()
548 ntohs(lacpdu->actor_system_priority) != partner->system_priority || in __update_selected()
549 ntohs(lacpdu->actor_key) != partner->key || in __update_selected()
550 …(lacpdu->actor_state & LACP_STATE_AGGREGATION) != (partner->port_state & LACP_STATE_AGGREGATION)) { in __update_selected()
601 static void __update_ntt(struct lacpdu *lacpdu, struct port *port) in __update_ntt() argument
604 if (lacpdu && port) { in __update_ntt()
608 if ((ntohs(lacpdu->partner_port) != port->actor_port_number) || in __update_ntt()
609 (ntohs(lacpdu->partner_port_priority) != port->actor_port_priority) || in __update_ntt()
610 !MAC_ADDRESS_EQUAL(&(lacpdu->partner_system), &(port->actor_system)) || in __update_ntt()
611 (ntohs(lacpdu->partner_system_priority) != port->actor_system_priority) || in __update_ntt()
612 (ntohs(lacpdu->partner_key) != port->actor_oper_port_key) || in __update_ntt()
613 …((lacpdu->partner_state & LACP_STATE_LACP_ACTIVITY) != (port->actor_oper_port_state & LACP_STATE_L… in __update_ntt()
614 …((lacpdu->partner_state & LACP_STATE_LACP_TIMEOUT) != (port->actor_oper_port_state & LACP_STATE_LA… in __update_ntt()
615 …((lacpdu->partner_state & LACP_STATE_SYNCHRONIZATION) != (port->actor_oper_port_state & LACP_STATE… in __update_ntt()
616 …((lacpdu->partner_state & LACP_STATE_AGGREGATION) != (port->actor_oper_port_state & LACP_STATE_AGG… in __update_ntt()
769 struct lacpdu *lacpdu = &port->lacpdu; in __update_lacpdu_from_port() local
779 lacpdu->actor_system_priority = htons(port->actor_system_priority); in __update_lacpdu_from_port()
780 lacpdu->actor_system = port->actor_system; in __update_lacpdu_from_port()
781 lacpdu->actor_key = htons(port->actor_oper_port_key); in __update_lacpdu_from_port()
782 lacpdu->actor_port_priority = htons(port->actor_port_priority); in __update_lacpdu_from_port()
783 lacpdu->actor_port = htons(port->actor_port_number); in __update_lacpdu_from_port()
784 lacpdu->actor_state = port->actor_oper_port_state; in __update_lacpdu_from_port()
794 lacpdu->partner_system_priority = htons(partner->system_priority); in __update_lacpdu_from_port()
795 lacpdu->partner_system = partner->system; in __update_lacpdu_from_port()
796 lacpdu->partner_key = htons(partner->key); in __update_lacpdu_from_port()
797 lacpdu->partner_port_priority = htons(partner->port_priority); in __update_lacpdu_from_port()
798 lacpdu->partner_port = htons(partner->port_number); in __update_lacpdu_from_port()
799 lacpdu->partner_state = partner->port_state; in __update_lacpdu_from_port()
850 lacpdu_header->lacpdu = port->lacpdu; in ad_lacpdu_send()
1072 static void ad_rx_machine(struct lacpdu *lacpdu, struct port *port) in ad_rx_machine() argument
1081 if (lacpdu) { in ad_rx_machine()
1095 else if (lacpdu && ((port->sm_rx_state == AD_RX_EXPIRED) || in ad_rx_machine()
1136 if ((port->sm_rx_state != last_state) || (lacpdu)) { in ad_rx_machine()
1187 if (MAC_ADDRESS_EQUAL(&(lacpdu->actor_system), in ad_rx_machine()
1193 __update_selected(lacpdu, port); in ad_rx_machine()
1194 __update_ntt(lacpdu, port); in ad_rx_machine()
1195 __record_pdu(lacpdu, port); in ad_rx_machine()
1827 static const struct lacpdu lacpdu = { in ad_initialize_port() local
1875 memcpy(&port->lacpdu, &lacpdu, sizeof(lacpdu)); in ad_initialize_port()
2383 static int bond_3ad_rx_indication(struct lacpdu *lacpdu, struct slave *slave) in bond_3ad_rx_indication() argument
2398 switch (lacpdu->subtype) { in bond_3ad_rx_indication()
2406 ad_rx_machine(lacpdu, port); in bond_3ad_rx_indication()
2414 marker = (struct bond_marker *)lacpdu; in bond_3ad_rx_indication()
2665 struct lacpdu *lacpdu, _lacpdu; in bond_3ad_lacpdu_recv() local
2673 lacpdu = skb_header_pointer(skb, 0, sizeof(_lacpdu), &_lacpdu); in bond_3ad_lacpdu_recv()
2674 if (!lacpdu) { in bond_3ad_lacpdu_recv()
2680 return bond_3ad_rx_indication(lacpdu, slave); in bond_3ad_lacpdu_recv()