Lines Matching full:aggregator
99 static void ad_agg_selection_logic(struct aggregator *aggregator,
101 static void ad_clear_agg(struct aggregator *aggregator);
102 static void ad_initialize_agg(struct aggregator *aggregator);
132 * __get_first_agg - get the first aggregator in the bond
135 * Return the aggregator of the first slave in @bond, or %NULL if it can't be
139 static inline struct aggregator *__get_first_agg(struct port *port) in __get_first_agg()
143 struct aggregator *agg; in __get_first_agg()
151 agg = first_slave ? &(SLAVE_AD_INFO(first_slave)->aggregator) : NULL; in __get_first_agg()
161 * Return nonzero if aggregator has a partner (denoted by a non-zero ether
164 static inline int __agg_has_partner(struct aggregator *agg) in __agg_has_partner()
200 * __get_agg_selection_mode - get the aggregator selection mode
203 * Get the aggregator selection mode. Can be %STABLE, %BANDWIDTH or %COUNT.
623 * __agg_ports_are_ready - check if all ports in an aggregator are ready
624 * @aggregator: the aggregator we're looking at
627 static int __agg_ports_are_ready(struct aggregator *aggregator) in __agg_ports_are_ready() argument
632 if (aggregator) { in __agg_ports_are_ready()
633 /* scan all ports in this aggregator to verfy if they are in __agg_ports_are_ready()
636 for (port = aggregator->lag_ports; in __agg_ports_are_ready()
650 * __set_agg_ports_ready - set value of Ready bit in all ports of an aggregator
651 * @aggregator: the aggregator we're looking at
655 static void __set_agg_ports_ready(struct aggregator *aggregator, int val) in __set_agg_ports_ready() argument
659 for (port = aggregator->lag_ports; port; in __set_agg_ports_ready()
668 static int __agg_active_ports(struct aggregator *agg) in __agg_active_ports()
683 * __get_agg_bandwidth - get the total bandwidth of an aggregator
684 * @aggregator: the aggregator we're looking at
687 static u32 __get_agg_bandwidth(struct aggregator *aggregator) in __get_agg_bandwidth() argument
689 int nports = __agg_active_ports(aggregator); in __get_agg_bandwidth()
693 switch (__get_link_speed(aggregator->lag_ports)) { in __get_agg_bandwidth()
744 * __get_active_agg - get the current active aggregator
745 * @aggregator: the aggregator we're looking at
749 static struct aggregator *__get_active_agg(struct aggregator *aggregator) in __get_active_agg() argument
751 struct bonding *bond = aggregator->slave->bond; in __get_active_agg()
756 if (SLAVE_AD_INFO(slave)->aggregator.is_active) in __get_active_agg()
757 return &(SLAVE_AD_INFO(slave)->aggregator); in __get_active_agg()
942 __set_agg_ports_ready(port->aggregator, __agg_ports_are_ready(port->aggregator)); in ad_mux_machine()
957 __set_agg_ports_ready(port->aggregator, __agg_ports_are_ready(port->aggregator)); in ad_mux_machine()
973 if (port->aggregator->is_active) in ad_mux_machine()
985 __set_agg_ports_ready(port->aggregator, __agg_ports_are_ready(port->aggregator)); in ad_mux_machine()
987 } else if (port->aggregator->is_active) { in ad_mux_machine()
1001 * port in an active aggregator is enabled in ad_mux_machine()
1003 if (port->aggregator && in ad_mux_machine()
1004 port->aggregator->is_active && in ad_mux_machine()
1036 if (port->aggregator->is_active) in ad_mux_machine()
1376 struct aggregator *aggregator, *free_aggregator = NULL, *temp_aggregator; in ad_port_selection_logic() local
1389 /* if the port is connected to other aggregator, detach it */ in ad_port_selection_logic()
1390 if (port->aggregator) { in ad_port_selection_logic()
1391 /* detach the port from its former aggregator */ in ad_port_selection_logic()
1392 temp_aggregator = port->aggregator; in ad_port_selection_logic()
1399 * aggregator in ad_port_selection_logic()
1406 * aggregator in ad_port_selection_logic()
1413 * aggregator in ad_port_selection_logic()
1415 port->aggregator = NULL; in ad_port_selection_logic()
1422 /* if the aggregator is empty, clear its in ad_port_selection_logic()
1431 /* meaning: the port was related to an aggregator in ad_port_selection_logic()
1432 * but was not on the aggregator port list in ad_port_selection_logic()
1434 …net_warn_ratelimited("%s: (slave %s): Warning: Port %d was related to aggregator %d but was not on… in ad_port_selection_logic()
1438 port->aggregator->aggregator_identifier); in ad_port_selection_logic()
1441 /* search on all aggregators for a suitable aggregator for this port */ in ad_port_selection_logic()
1443 aggregator = &(SLAVE_AD_INFO(slave)->aggregator); in ad_port_selection_logic()
1445 /* keep a free aggregator for later use(if needed) */ in ad_port_selection_logic()
1446 if (!aggregator->lag_ports) { in ad_port_selection_logic()
1448 free_aggregator = aggregator; in ad_port_selection_logic()
1451 /* check if current aggregator suits us */ in ad_port_selection_logic()
1452 …if (((aggregator->actor_oper_aggregator_key == port->actor_oper_port_key) && /* if all parameters … in ad_port_selection_logic()
1453 MAC_ADDRESS_EQUAL(&(aggregator->partner_system), &(port->partner_oper.system)) && in ad_port_selection_logic()
1454 (aggregator->partner_system_priority == port->partner_oper.system_priority) && in ad_port_selection_logic()
1455 (aggregator->partner_oper_aggregator_key == port->partner_oper.key) in ad_port_selection_logic()
1458 !aggregator->is_individual) /* but is not individual OR */ in ad_port_selection_logic()
1461 /* attach to the founded aggregator */ in ad_port_selection_logic()
1462 port->aggregator = aggregator; in ad_port_selection_logic()
1464 port->aggregator->aggregator_identifier; in ad_port_selection_logic()
1465 port->next_port_in_aggregator = aggregator->lag_ports; in ad_port_selection_logic()
1466 port->aggregator->num_of_ports++; in ad_port_selection_logic()
1467 aggregator->lag_ports = port; in ad_port_selection_logic()
1470 port->aggregator->aggregator_identifier); in ad_port_selection_logic()
1479 /* the port couldn't find an aggregator - attach it to a new in ad_port_selection_logic()
1480 * aggregator in ad_port_selection_logic()
1484 /* assign port a new aggregator */ in ad_port_selection_logic()
1485 port->aggregator = free_aggregator; in ad_port_selection_logic()
1487 port->aggregator->aggregator_identifier; in ad_port_selection_logic()
1489 /* update the new aggregator's parameters in ad_port_selection_logic()
1494 port->aggregator->is_individual = false; in ad_port_selection_logic()
1496 port->aggregator->is_individual = true; in ad_port_selection_logic()
1498 port->aggregator->actor_admin_aggregator_key = in ad_port_selection_logic()
1500 port->aggregator->actor_oper_aggregator_key = in ad_port_selection_logic()
1502 port->aggregator->partner_system = in ad_port_selection_logic()
1504 port->aggregator->partner_system_priority = in ad_port_selection_logic()
1506 port->aggregator->partner_oper_aggregator_key = port->partner_oper.key; in ad_port_selection_logic()
1507 port->aggregator->receive_state = 1; in ad_port_selection_logic()
1508 port->aggregator->transmit_state = 1; in ad_port_selection_logic()
1509 port->aggregator->lag_ports = port; in ad_port_selection_logic()
1510 port->aggregator->num_of_ports++; in ad_port_selection_logic()
1517 port->aggregator->aggregator_identifier); in ad_port_selection_logic()
1520 "Port %d did not find a suitable aggregator\n", in ad_port_selection_logic()
1524 /* if all aggregator's ports are READY_N == TRUE, set ready=TRUE in ad_port_selection_logic()
1525 * in all aggregator's ports, else set ready=FALSE in all in ad_port_selection_logic()
1526 * aggregator's ports in ad_port_selection_logic()
1528 __set_agg_ports_ready(port->aggregator, in ad_port_selection_logic()
1529 __agg_ports_are_ready(port->aggregator)); in ad_port_selection_logic()
1531 aggregator = __get_first_agg(port); in ad_port_selection_logic()
1532 ad_agg_selection_logic(aggregator, update_slave_arr); in ad_port_selection_logic()
1534 if (!port->aggregator->is_active) in ad_port_selection_logic()
1538 /* Decide if "agg" is a better choice for the new active aggregator that
1541 static struct aggregator *ad_agg_selection_test(struct aggregator *best, in ad_agg_selection_test()
1542 struct aggregator *curr) in ad_agg_selection_test()
1610 static int agg_device_up(const struct aggregator *agg) in agg_device_up()
1629 * @agg: the aggregator we're looking at
1632 * It is assumed that only one aggregator may be selected for a team.
1634 * The logic of this function is to select the aggregator according to
1637 * BOND_AD_STABLE: select the aggregator with the most ports attached to
1638 * it, and to reselect the active aggregator only if the previous
1639 * aggregator has no more ports related to it.
1641 * BOND_AD_BANDWIDTH: select the aggregator with the highest total
1645 * BOND_AD_COUNT: select the aggregator with largest number of ports
1653 static void ad_agg_selection_logic(struct aggregator *agg, in ad_agg_selection_logic()
1656 struct aggregator *best, *active, *origin; in ad_agg_selection_logic()
1668 agg = &(SLAVE_AD_INFO(slave)->aggregator); in ad_agg_selection_logic()
1679 * aggregator if it's still active (it has an answering in ad_agg_selection_logic()
1701 /* if there is new best aggregator, activate it */ in ad_agg_selection_logic()
1714 agg = &(SLAVE_AD_INFO(slave)->aggregator); in ad_agg_selection_logic()
1752 /* if the selected aggregator is of join individuals in ad_agg_selection_logic()
1772 * ad_clear_agg - clear a given aggregator's parameters
1773 * @aggregator: the aggregator we're looking at
1775 static void ad_clear_agg(struct aggregator *aggregator) in ad_clear_agg() argument
1777 if (aggregator) { in ad_clear_agg()
1778 aggregator->is_individual = false; in ad_clear_agg()
1779 aggregator->actor_admin_aggregator_key = 0; in ad_clear_agg()
1780 aggregator->actor_oper_aggregator_key = 0; in ad_clear_agg()
1781 eth_zero_addr(aggregator->partner_system.mac_addr_value); in ad_clear_agg()
1782 aggregator->partner_system_priority = 0; in ad_clear_agg()
1783 aggregator->partner_oper_aggregator_key = 0; in ad_clear_agg()
1784 aggregator->receive_state = 0; in ad_clear_agg()
1785 aggregator->transmit_state = 0; in ad_clear_agg()
1786 aggregator->lag_ports = NULL; in ad_clear_agg()
1787 aggregator->is_active = 0; in ad_clear_agg()
1788 aggregator->num_of_ports = 0; in ad_clear_agg()
1790 aggregator->slave ? in ad_clear_agg()
1791 aggregator->slave->dev->name : "NULL", in ad_clear_agg()
1792 aggregator->aggregator_identifier); in ad_clear_agg()
1797 * ad_initialize_agg - initialize a given aggregator's parameters
1798 * @aggregator: the aggregator we're looking at
1800 static void ad_initialize_agg(struct aggregator *aggregator) in ad_initialize_agg() argument
1802 if (aggregator) { in ad_initialize_agg()
1803 ad_clear_agg(aggregator); in ad_initialize_agg()
1805 eth_zero_addr(aggregator->aggregator_mac_address.mac_addr_value); in ad_initialize_agg()
1806 aggregator->aggregator_identifier = 0; in ad_initialize_agg()
1807 aggregator->slave = NULL; in ad_initialize_agg()
1862 port->aggregator = NULL; in ad_initialize_port()
1882 * Enable @port if it's in an active aggregator
1887 if (port->aggregator->is_active) { in ad_enable_collecting_distributing()
1891 port->aggregator->aggregator_identifier); in ad_enable_collecting_distributing()
1906 if (port->aggregator && in ad_disable_collecting_distributing()
1907 !MAC_ADDRESS_EQUAL(&(port->aggregator->partner_system), in ad_disable_collecting_distributing()
1912 port->aggregator->aggregator_identifier); in ad_disable_collecting_distributing()
1968 * bond_3ad_initiate_agg_selection - initate aggregator selection
2027 struct aggregator *aggregator; in bond_3ad_bind_slave() local
2053 /* aggregator initialization */ in bond_3ad_bind_slave()
2054 aggregator = &(SLAVE_AD_INFO(slave)->aggregator); in bond_3ad_bind_slave()
2056 ad_initialize_agg(aggregator); in bond_3ad_bind_slave()
2058 aggregator->aggregator_mac_address = *((struct mac_addr *)bond->dev->dev_addr); in bond_3ad_bind_slave()
2059 aggregator->aggregator_identifier = ++BOND_AD_INFO(bond).aggregator_identifier; in bond_3ad_bind_slave()
2060 aggregator->slave = slave; in bond_3ad_bind_slave()
2061 aggregator->is_active = 0; in bond_3ad_bind_slave()
2062 aggregator->num_of_ports = 0; in bond_3ad_bind_slave()
2070 * Search for the aggregator that is related to this port, remove the
2071 * aggregator and assign another aggregator for other port related to it
2077 struct aggregator *aggregator, *new_aggregator, *temp_aggregator; in bond_3ad_unbind_slave() local
2086 aggregator = &(SLAVE_AD_INFO(slave)->aggregator); in bond_3ad_unbind_slave()
2096 aggregator->aggregator_identifier); in bond_3ad_unbind_slave()
2106 /* check if this aggregator is occupied */ in bond_3ad_unbind_slave()
2107 if (aggregator->lag_ports) { in bond_3ad_unbind_slave()
2108 /* check if there are other ports related to this aggregator in bond_3ad_unbind_slave()
2110 * there is a reason to search for new aggregator, and that we in bond_3ad_unbind_slave()
2113 if ((aggregator->lag_ports != port) || in bond_3ad_unbind_slave()
2114 (aggregator->lag_ports->next_port_in_aggregator)) { in bond_3ad_unbind_slave()
2115 /* find new aggregator for the related port(s) */ in bond_3ad_unbind_slave()
2117 new_aggregator = &(SLAVE_AD_INFO(slave_iter)->aggregator); in bond_3ad_unbind_slave()
2118 /* if the new aggregator is empty, or it is in bond_3ad_unbind_slave()
2129 /* if new aggregator found, copy the aggregator's in bond_3ad_unbind_slave()
2131 * new aggregator in bond_3ad_unbind_slave()
2135 aggregator->aggregator_identifier, in bond_3ad_unbind_slave()
2140 slave_info(bond->dev, slave->dev, "Removing an active aggregator\n"); in bond_3ad_unbind_slave()
2144 new_aggregator->is_individual = aggregator->is_individual; in bond_3ad_unbind_slave()
2145 new_aggregator->actor_admin_aggregator_key = aggregator->actor_admin_aggregator_key; in bond_3ad_unbind_slave()
2146 new_aggregator->actor_oper_aggregator_key = aggregator->actor_oper_aggregator_key; in bond_3ad_unbind_slave()
2147 new_aggregator->partner_system = aggregator->partner_system; in bond_3ad_unbind_slave()
2148 new_aggregator->partner_system_priority = aggregator->partner_system_priority; in bond_3ad_unbind_slave()
2149 new_aggregator->partner_oper_aggregator_key = aggregator->partner_oper_aggregator_key; in bond_3ad_unbind_slave()
2150 new_aggregator->receive_state = aggregator->receive_state; in bond_3ad_unbind_slave()
2151 new_aggregator->transmit_state = aggregator->transmit_state; in bond_3ad_unbind_slave()
2152 new_aggregator->lag_ports = aggregator->lag_ports; in bond_3ad_unbind_slave()
2153 new_aggregator->is_active = aggregator->is_active; in bond_3ad_unbind_slave()
2154 new_aggregator->num_of_ports = aggregator->num_of_ports; in bond_3ad_unbind_slave()
2157 * the ports about the aggregator in bond_3ad_unbind_slave()
2159 for (temp_port = aggregator->lag_ports; temp_port; in bond_3ad_unbind_slave()
2161 temp_port->aggregator = new_aggregator; in bond_3ad_unbind_slave()
2165 ad_clear_agg(aggregator); in bond_3ad_unbind_slave()
2171 …slave_warn(bond->dev, slave->dev, "unbinding aggregator, and could not find a new aggregator for i… in bond_3ad_unbind_slave()
2175 * aggregator is the one we want to remove in bond_3ad_unbind_slave()
2177 select_new_active_agg = aggregator->is_active; in bond_3ad_unbind_slave()
2178 ad_clear_agg(aggregator); in bond_3ad_unbind_slave()
2180 slave_info(bond->dev, slave->dev, "Removing an active aggregator\n"); in bond_3ad_unbind_slave()
2181 /* select new active aggregator */ in bond_3ad_unbind_slave()
2192 /* find the aggregator that this port is connected to */ in bond_3ad_unbind_slave()
2194 temp_aggregator = &(SLAVE_AD_INFO(slave_iter)->aggregator); in bond_3ad_unbind_slave()
2196 /* search the port in the aggregator's related ports */ in bond_3ad_unbind_slave()
2201 /* the aggregator found - detach the port from in bond_3ad_unbind_slave()
2202 * this aggregator in bond_3ad_unbind_slave()
2213 slave_info(bond->dev, slave->dev, "Removing an active aggregator\n"); in bond_3ad_unbind_slave()
2214 /* select new active aggregator */ in bond_3ad_unbind_slave()
2271 * times out, and it selects an aggregator for the ports that are yet not
2272 * related to any aggregator, and selects the active aggregator for a bond.
2278 struct aggregator *aggregator; in bond_3ad_state_machine_handler() local
2302 /* select the active aggregator for the bond */ in bond_3ad_state_machine_handler()
2310 aggregator = __get_first_agg(port); in bond_3ad_state_machine_handler()
2311 ad_agg_selection_logic(aggregator, &update_slave_arr); in bond_3ad_state_machine_handler()
2479 * Handle reselection of aggregator (if needed) for this port.
2506 * Handle reselection of aggregator (if needed) for this port.
2510 struct aggregator *agg; in bond_3ad_handle_link_change()
2557 * if we have an active aggregator, we're up, if not, we're down.
2558 * Presumes that we cannot have an active aggregator if there are
2568 struct aggregator *active; in bond_3ad_set_carrier()
2578 active = __get_active_agg(&(SLAVE_AD_INFO(first_slave)->aggregator)); in bond_3ad_set_carrier()
2599 * __bond_3ad_get_active_agg_info - get information of the active aggregator
2609 struct aggregator *aggregator = NULL; in __bond_3ad_get_active_agg_info() local
2616 if (port->aggregator && port->aggregator->is_active) { in __bond_3ad_get_active_agg_info()
2617 aggregator = port->aggregator; in __bond_3ad_get_active_agg_info()
2622 if (!aggregator) in __bond_3ad_get_active_agg_info()
2625 ad_info->aggregator_id = aggregator->aggregator_identifier; in __bond_3ad_get_active_agg_info()
2626 ad_info->ports = __agg_active_ports(aggregator); in __bond_3ad_get_active_agg_info()
2627 ad_info->actor_key = aggregator->actor_oper_aggregator_key; in __bond_3ad_get_active_agg_info()
2628 ad_info->partner_key = aggregator->partner_oper_aggregator_key; in __bond_3ad_get_active_agg_info()
2630 aggregator->partner_system.mac_addr_value); in __bond_3ad_get_active_agg_info()