Lines Matching full:aggregator
125 static void ad_agg_selection_logic(struct aggregator *aggregator,
127 static void ad_clear_agg(struct aggregator *aggregator);
128 static void ad_initialize_agg(struct aggregator *aggregator);
158 * __get_first_agg - get the first aggregator in the bond
161 * Return the aggregator of the first slave in @bond, or %NULL if it can't be
165 static inline struct aggregator *__get_first_agg(struct port *port) in __get_first_agg()
169 struct aggregator *agg; in __get_first_agg()
177 agg = first_slave ? &(SLAVE_AD_INFO(first_slave)->aggregator) : NULL; in __get_first_agg()
187 * Return nonzero if aggregator has a partner (denoted by a non-zero ether
190 static inline int __agg_has_partner(struct aggregator *agg) in __agg_has_partner()
226 * __get_agg_selection_mode - get the aggregator selection mode
229 * Get the aggregator selection mode. Can be %STABLE, %BANDWIDTH or %COUNT.
647 * __agg_ports_are_ready - check if all ports in an aggregator are ready
648 * @aggregator: the aggregator we're looking at
651 static int __agg_ports_are_ready(struct aggregator *aggregator) in __agg_ports_are_ready() argument
656 if (aggregator) { in __agg_ports_are_ready()
657 /* scan all ports in this aggregator to verfy if they are in __agg_ports_are_ready()
660 for (port = aggregator->lag_ports; in __agg_ports_are_ready()
674 * __set_agg_ports_ready - set value of Ready bit in all ports of an aggregator
675 * @aggregator: the aggregator we're looking at
679 static void __set_agg_ports_ready(struct aggregator *aggregator, int val) in __set_agg_ports_ready() argument
683 for (port = aggregator->lag_ports; port; in __set_agg_ports_ready()
692 static int __agg_active_ports(struct aggregator *agg) in __agg_active_ports()
707 * __get_agg_bandwidth - get the total bandwidth of an aggregator
708 * @aggregator: the aggregator we're looking at
711 static u32 __get_agg_bandwidth(struct aggregator *aggregator) in __get_agg_bandwidth() argument
713 int nports = __agg_active_ports(aggregator); in __get_agg_bandwidth()
717 switch (__get_link_speed(aggregator->lag_ports)) { in __get_agg_bandwidth()
768 * __get_active_agg - get the current active aggregator
769 * @aggregator: the aggregator we're looking at
773 static struct aggregator *__get_active_agg(struct aggregator *aggregator) in __get_active_agg() argument
775 struct bonding *bond = aggregator->slave->bond; in __get_active_agg()
780 if (SLAVE_AD_INFO(slave)->aggregator.is_active) in __get_active_agg()
781 return &(SLAVE_AD_INFO(slave)->aggregator); in __get_active_agg()
951 __set_agg_ports_ready(port->aggregator, __agg_ports_are_ready(port->aggregator)); in ad_mux_machine()
966 __set_agg_ports_ready(port->aggregator, __agg_ports_are_ready(port->aggregator)); in ad_mux_machine()
982 if (port->aggregator->is_active) in ad_mux_machine()
994 __set_agg_ports_ready(port->aggregator, __agg_ports_are_ready(port->aggregator)); in ad_mux_machine()
996 } else if (port->aggregator->is_active) { in ad_mux_machine()
1010 * port in an active aggregator is enabled in ad_mux_machine()
1012 if (port->aggregator && in ad_mux_machine()
1013 port->aggregator->is_active && in ad_mux_machine()
1045 if (port->aggregator->is_active) in ad_mux_machine()
1379 struct aggregator *aggregator, *free_aggregator = NULL, *temp_aggregator; in ad_port_selection_logic() local
1392 /* if the port is connected to other aggregator, detach it */ in ad_port_selection_logic()
1393 if (port->aggregator) { in ad_port_selection_logic()
1394 /* detach the port from its former aggregator */ in ad_port_selection_logic()
1395 temp_aggregator = port->aggregator; in ad_port_selection_logic()
1402 * aggregator in ad_port_selection_logic()
1409 * aggregator in ad_port_selection_logic()
1416 * aggregator in ad_port_selection_logic()
1418 port->aggregator = NULL; in ad_port_selection_logic()
1425 /* if the aggregator is empty, clear its in ad_port_selection_logic()
1434 /* meaning: the port was related to an aggregator in ad_port_selection_logic()
1435 * but was not on the aggregator port list in ad_port_selection_logic()
1437 …net_warn_ratelimited("%s: Warning: Port %d (on %s) was related to aggregator %d but was not on its… in ad_port_selection_logic()
1441 port->aggregator->aggregator_identifier); in ad_port_selection_logic()
1444 /* search on all aggregators for a suitable aggregator for this port */ in ad_port_selection_logic()
1446 aggregator = &(SLAVE_AD_INFO(slave)->aggregator); in ad_port_selection_logic()
1448 /* keep a free aggregator for later use(if needed) */ in ad_port_selection_logic()
1449 if (!aggregator->lag_ports) { in ad_port_selection_logic()
1451 free_aggregator = aggregator; in ad_port_selection_logic()
1454 /* check if current aggregator suits us */ in ad_port_selection_logic()
1455 …if (((aggregator->actor_oper_aggregator_key == port->actor_oper_port_key) && /* if all parameters … in ad_port_selection_logic()
1456 MAC_ADDRESS_EQUAL(&(aggregator->partner_system), &(port->partner_oper.system)) && in ad_port_selection_logic()
1457 (aggregator->partner_system_priority == port->partner_oper.system_priority) && in ad_port_selection_logic()
1458 (aggregator->partner_oper_aggregator_key == port->partner_oper.key) in ad_port_selection_logic()
1461 !aggregator->is_individual) /* but is not individual OR */ in ad_port_selection_logic()
1464 /* attach to the founded aggregator */ in ad_port_selection_logic()
1465 port->aggregator = aggregator; in ad_port_selection_logic()
1467 port->aggregator->aggregator_identifier; in ad_port_selection_logic()
1468 port->next_port_in_aggregator = aggregator->lag_ports; in ad_port_selection_logic()
1469 port->aggregator->num_of_ports++; in ad_port_selection_logic()
1470 aggregator->lag_ports = port; in ad_port_selection_logic()
1473 port->aggregator->aggregator_identifier); in ad_port_selection_logic()
1482 /* the port couldn't find an aggregator - attach it to a new in ad_port_selection_logic()
1483 * aggregator in ad_port_selection_logic()
1487 /* assign port a new aggregator */ in ad_port_selection_logic()
1488 port->aggregator = free_aggregator; in ad_port_selection_logic()
1490 port->aggregator->aggregator_identifier; in ad_port_selection_logic()
1492 /* update the new aggregator's parameters in ad_port_selection_logic()
1497 port->aggregator->is_individual = false; in ad_port_selection_logic()
1499 port->aggregator->is_individual = true; in ad_port_selection_logic()
1501 port->aggregator->actor_admin_aggregator_key = in ad_port_selection_logic()
1503 port->aggregator->actor_oper_aggregator_key = in ad_port_selection_logic()
1505 port->aggregator->partner_system = in ad_port_selection_logic()
1507 port->aggregator->partner_system_priority = in ad_port_selection_logic()
1509 port->aggregator->partner_oper_aggregator_key = port->partner_oper.key; in ad_port_selection_logic()
1510 port->aggregator->receive_state = 1; in ad_port_selection_logic()
1511 port->aggregator->transmit_state = 1; in ad_port_selection_logic()
1512 port->aggregator->lag_ports = port; in ad_port_selection_logic()
1513 port->aggregator->num_of_ports++; in ad_port_selection_logic()
1520 port->aggregator->aggregator_identifier); in ad_port_selection_logic()
1522 netdev_err(bond->dev, "Port %d (on %s) did not find a suitable aggregator\n", in ad_port_selection_logic()
1526 /* if all aggregator's ports are READY_N == TRUE, set ready=TRUE in ad_port_selection_logic()
1527 * in all aggregator's ports, else set ready=FALSE in all in ad_port_selection_logic()
1528 * aggregator's ports in ad_port_selection_logic()
1530 __set_agg_ports_ready(port->aggregator, in ad_port_selection_logic()
1531 __agg_ports_are_ready(port->aggregator)); in ad_port_selection_logic()
1533 aggregator = __get_first_agg(port); in ad_port_selection_logic()
1534 ad_agg_selection_logic(aggregator, update_slave_arr); in ad_port_selection_logic()
1536 if (!port->aggregator->is_active) in ad_port_selection_logic()
1540 /* Decide if "agg" is a better choice for the new active aggregator that
1543 static struct aggregator *ad_agg_selection_test(struct aggregator *best, in ad_agg_selection_test()
1544 struct aggregator *curr) in ad_agg_selection_test()
1611 static int agg_device_up(const struct aggregator *agg) in agg_device_up()
1630 * @aggregator: the aggregator we're looking at
1633 * It is assumed that only one aggregator may be selected for a team.
1635 * The logic of this function is to select the aggregator according to
1638 * BOND_AD_STABLE: select the aggregator with the most ports attached to
1639 * it, and to reselect the active aggregator only if the previous
1640 * aggregator has no more ports related to it.
1642 * BOND_AD_BANDWIDTH: select the aggregator with the highest total
1646 * BOND_AD_COUNT: select the aggregator with largest number of ports
1654 static void ad_agg_selection_logic(struct aggregator *agg, in ad_agg_selection_logic()
1657 struct aggregator *best, *active, *origin; in ad_agg_selection_logic()
1669 agg = &(SLAVE_AD_INFO(slave)->aggregator); in ad_agg_selection_logic()
1680 * aggregator if it's still active (it has an answering in ad_agg_selection_logic()
1702 /* 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->aggregator_identifier); in ad_clear_agg()
1795 * ad_initialize_agg - initialize a given aggregator's parameters
1796 * @aggregator: the aggregator we're looking at
1798 static void ad_initialize_agg(struct aggregator *aggregator) in ad_initialize_agg() argument
1800 if (aggregator) { in ad_initialize_agg()
1801 ad_clear_agg(aggregator); in ad_initialize_agg()
1803 eth_zero_addr(aggregator->aggregator_mac_address.mac_addr_value); in ad_initialize_agg()
1804 aggregator->aggregator_identifier = 0; in ad_initialize_agg()
1805 aggregator->slave = NULL; in ad_initialize_agg()
1811 * @aggregator: the aggregator we're looking at
1860 port->aggregator = NULL; in ad_initialize_port()
1880 * Enable @port if it's in an active aggregator
1885 if (port->aggregator->is_active) { in ad_enable_collecting_distributing()
1888 port->aggregator->aggregator_identifier); in ad_enable_collecting_distributing()
1903 if (port->aggregator && in ad_disable_collecting_distributing()
1904 !MAC_ADDRESS_EQUAL(&(port->aggregator->partner_system), in ad_disable_collecting_distributing()
1908 port->aggregator->aggregator_identifier); in ad_disable_collecting_distributing()
1958 * bond_3ad_initiate_agg_selection - initate aggregator selection
2016 struct aggregator *aggregator; in bond_3ad_bind_slave() local
2042 /* aggregator initialization */ in bond_3ad_bind_slave()
2043 aggregator = &(SLAVE_AD_INFO(slave)->aggregator); in bond_3ad_bind_slave()
2045 ad_initialize_agg(aggregator); in bond_3ad_bind_slave()
2047 aggregator->aggregator_mac_address = *((struct mac_addr *)bond->dev->dev_addr); in bond_3ad_bind_slave()
2048 aggregator->aggregator_identifier = ++BOND_AD_INFO(bond).aggregator_identifier; in bond_3ad_bind_slave()
2049 aggregator->slave = slave; in bond_3ad_bind_slave()
2050 aggregator->is_active = 0; in bond_3ad_bind_slave()
2051 aggregator->num_of_ports = 0; in bond_3ad_bind_slave()
2059 * Search for the aggregator that is related to this port, remove the
2060 * aggregator and assign another aggregator for other port related to it
2066 struct aggregator *aggregator, *new_aggregator, *temp_aggregator; in bond_3ad_unbind_slave() local
2075 aggregator = &(SLAVE_AD_INFO(slave)->aggregator); in bond_3ad_unbind_slave()
2086 aggregator->aggregator_identifier); in bond_3ad_unbind_slave()
2096 /* check if this aggregator is occupied */ in bond_3ad_unbind_slave()
2097 if (aggregator->lag_ports) { in bond_3ad_unbind_slave()
2098 /* check if there are other ports related to this aggregator in bond_3ad_unbind_slave()
2100 * there is a reason to search for new aggregator, and that we in bond_3ad_unbind_slave()
2103 if ((aggregator->lag_ports != port) || in bond_3ad_unbind_slave()
2104 (aggregator->lag_ports->next_port_in_aggregator)) { in bond_3ad_unbind_slave()
2105 /* find new aggregator for the related port(s) */ in bond_3ad_unbind_slave()
2107 new_aggregator = &(SLAVE_AD_INFO(slave_iter)->aggregator); in bond_3ad_unbind_slave()
2108 /* if the new aggregator is empty, or it is in bond_3ad_unbind_slave()
2119 /* if new aggregator found, copy the aggregator's in bond_3ad_unbind_slave()
2121 * new aggregator in bond_3ad_unbind_slave()
2125 aggregator->aggregator_identifier, in bond_3ad_unbind_slave()
2130 netdev_info(bond->dev, "Removing an active aggregator\n"); in bond_3ad_unbind_slave()
2134 new_aggregator->is_individual = aggregator->is_individual; in bond_3ad_unbind_slave()
2135 new_aggregator->actor_admin_aggregator_key = aggregator->actor_admin_aggregator_key; in bond_3ad_unbind_slave()
2136 new_aggregator->actor_oper_aggregator_key = aggregator->actor_oper_aggregator_key; in bond_3ad_unbind_slave()
2137 new_aggregator->partner_system = aggregator->partner_system; in bond_3ad_unbind_slave()
2138 new_aggregator->partner_system_priority = aggregator->partner_system_priority; in bond_3ad_unbind_slave()
2139 new_aggregator->partner_oper_aggregator_key = aggregator->partner_oper_aggregator_key; in bond_3ad_unbind_slave()
2140 new_aggregator->receive_state = aggregator->receive_state; in bond_3ad_unbind_slave()
2141 new_aggregator->transmit_state = aggregator->transmit_state; in bond_3ad_unbind_slave()
2142 new_aggregator->lag_ports = aggregator->lag_ports; in bond_3ad_unbind_slave()
2143 new_aggregator->is_active = aggregator->is_active; in bond_3ad_unbind_slave()
2144 new_aggregator->num_of_ports = aggregator->num_of_ports; in bond_3ad_unbind_slave()
2147 * the ports about the aggregator in bond_3ad_unbind_slave()
2149 for (temp_port = aggregator->lag_ports; temp_port; in bond_3ad_unbind_slave()
2151 temp_port->aggregator = new_aggregator; in bond_3ad_unbind_slave()
2155 ad_clear_agg(aggregator); in bond_3ad_unbind_slave()
2161 …netdev_warn(bond->dev, "unbinding aggregator, and could not find a new aggregator for its ports\n"… in bond_3ad_unbind_slave()
2165 * aggregator is the one we want to remove in bond_3ad_unbind_slave()
2167 select_new_active_agg = aggregator->is_active; in bond_3ad_unbind_slave()
2168 ad_clear_agg(aggregator); in bond_3ad_unbind_slave()
2170 netdev_info(bond->dev, "Removing an active aggregator\n"); in bond_3ad_unbind_slave()
2171 /* select new active aggregator */ in bond_3ad_unbind_slave()
2182 /* find the aggregator that this port is connected to */ in bond_3ad_unbind_slave()
2184 temp_aggregator = &(SLAVE_AD_INFO(slave_iter)->aggregator); in bond_3ad_unbind_slave()
2186 /* search the port in the aggregator's related ports */ in bond_3ad_unbind_slave()
2191 /* the aggregator found - detach the port from in bond_3ad_unbind_slave()
2192 * this aggregator in bond_3ad_unbind_slave()
2203 netdev_info(bond->dev, "Removing an active aggregator\n"); in bond_3ad_unbind_slave()
2204 /* select new active aggregator */ in bond_3ad_unbind_slave()
2261 * times out, and it selects an aggregator for the ports that are yet not
2262 * related to any aggregator, and selects the active aggregator for a bond.
2268 struct aggregator *aggregator; in bond_3ad_state_machine_handler() local
2292 /* select the active aggregator for the bond */ in bond_3ad_state_machine_handler()
2300 aggregator = __get_first_agg(port); in bond_3ad_state_machine_handler()
2301 ad_agg_selection_logic(aggregator, &update_slave_arr); in bond_3ad_state_machine_handler()
2466 * Handle reselection of aggregator (if needed) for this port.
2494 * Handle reselection of aggregator (if needed) for this port.
2498 struct aggregator *agg; in bond_3ad_handle_link_change()
2546 * if we have an active aggregator, we're up, if not, we're down.
2547 * Presumes that we cannot have an active aggregator if there are
2557 struct aggregator *active; in bond_3ad_set_carrier()
2567 active = __get_active_agg(&(SLAVE_AD_INFO(first_slave)->aggregator)); in bond_3ad_set_carrier()
2588 * __bond_3ad_get_active_agg_info - get information of the active aggregator
2598 struct aggregator *aggregator = NULL; in __bond_3ad_get_active_agg_info() local
2605 if (port->aggregator && port->aggregator->is_active) { in __bond_3ad_get_active_agg_info()
2606 aggregator = port->aggregator; in __bond_3ad_get_active_agg_info()
2611 if (!aggregator) in __bond_3ad_get_active_agg_info()
2614 ad_info->aggregator_id = aggregator->aggregator_identifier; in __bond_3ad_get_active_agg_info()
2615 ad_info->ports = __agg_active_ports(aggregator); in __bond_3ad_get_active_agg_info()
2616 ad_info->actor_key = aggregator->actor_oper_aggregator_key; in __bond_3ad_get_active_agg_info()
2617 ad_info->partner_key = aggregator->partner_oper_aggregator_key; in __bond_3ad_get_active_agg_info()
2619 aggregator->partner_system.mac_addr_value); in __bond_3ad_get_active_agg_info()