142 	struct bonding *bond = __get_bond_by_port(port);  in __get_first_agg()  local
147 	if (bond == NULL)  in __get_first_agg()
151 	first_slave = bond_first_slave_rcu(bond);  in __get_first_agg()
208 	struct bonding *bond = __get_bond_by_port(port);  in __get_agg_selection_mode()  local
210 	if (bond == NULL)  in __get_agg_selection_mode()
213 	return bond->params.ad_select;  in __get_agg_selection_mode()
222 	struct bonding *bond = __get_bond_by_port(port);  in __check_agg_selection_timer()  local
224 	if (bond == NULL)  in __check_agg_selection_timer()
227 	return atomic_read(&BOND_AD_INFO(bond).agg_select_timer) ? 1 : 0;  in __check_agg_selection_timer()
320 					     slave->bond->dev->name,  in __get_link_speed()
328 	slave_dbg(slave->bond->dev, slave->dev, "Port %d Received link speed %d update from adapter\n",  in __get_link_speed()
353 …slave_dbg(slave->bond->dev, slave->dev, "Port %d Received status full duplex update from adapter\n…  in __get_duplex()
359 …slave_dbg(slave->bond->dev, slave->dev, "Port %d Received status NOT full duplex update from adapt…  in __get_duplex()
369 	const struct bonding *bond = bond_get_bond_by_slave(port->slave);  in __ad_actor_update_port()  local
371 	port->actor_system = BOND_AD_INFO(bond).system.sys_mac_addr;  in __ad_actor_update_port()
372 	port->actor_system_priority = BOND_AD_INFO(bond).system.sys_priority;  in __ad_actor_update_port()
494 			slave_dbg(port->slave->bond->dev, port->slave->dev,  in __record_pdu()
498 			slave_dbg(port->slave->bond->dev, port->slave->dev,  in __record_pdu()
752 	struct bonding *bond = aggregator->slave->bond;  in __get_active_agg()  local
756 	bond_for_each_slave_rcu(bond, slave, iter)  in __get_active_agg()
785 	slave_dbg(port->slave->bond->dev, port->slave->dev,  in __update_lacpdu_from_port()
833 	atomic64_inc(&BOND_AD_INFO(slave->bond).stats.lacpdu_tx);  in ad_lacpdu_send()
879 		atomic64_inc(&BOND_AD_INFO(slave->bond).stats.marker_tx);  in ad_marker_send()
883 		atomic64_inc(&BOND_AD_INFO(slave->bond).stats.marker_resp_tx);  in ad_marker_send()
1019 		slave_dbg(port->slave->bond->dev, port->slave->dev,  in ad_mux_machine()
1083 		atomic64_inc(&BOND_AD_INFO(port->slave->bond).stats.lacpdu_rx);  in ad_rx_machine()
1137 		slave_dbg(port->slave->bond->dev, port->slave->dev,  in ad_rx_machine()
1189 				slave_err(port->slave->bond->dev, port->slave->dev, "An illegal loopback occurred on slave\n"  in ad_rx_machine()
1259 				slave_dbg(port->slave->bond->dev,  in ad_tx_machine()
1341 		slave_dbg(port->slave->bond->dev, port->slave->dev,  in ad_periodic_machine()
1380 	struct bonding *bond;  in ad_port_selection_logic()  local
1388 	bond = __get_bond_by_port(port);  in ad_port_selection_logic()
1420 				slave_dbg(bond->dev, port->slave->dev, "Port %d left LAG %d\n",  in ad_port_selection_logic()
1436 					     port->slave->bond->dev->name,  in ad_port_selection_logic()
1443 	bond_for_each_slave(bond, slave, iter) {  in ad_port_selection_logic()
1469 			slave_dbg(bond->dev, slave->dev, "Port %d joined LAG %d (existing LAG)\n",  in ad_port_selection_logic()
1516 			slave_dbg(bond->dev, port->slave->dev, "Port %d joined LAG %d (new LAG)\n",  in ad_port_selection_logic()
1520 			slave_err(bond->dev, port->slave->dev,  in ad_port_selection_logic()
1602 				     curr->slave->bond->dev->name,  in ad_agg_selection_test()
1658 	struct bonding *bond = agg->slave->bond;  in ad_agg_selection_logic()  local
1668 	bond_for_each_slave_rcu(bond, slave, iter) {  in ad_agg_selection_logic()
1704 		netdev_dbg(bond->dev, "(slave %s): best Agg=%d; P=%d; a k=%d; p k=%d; Ind=%d; Act=%d\n",  in ad_agg_selection_logic()
1710 		netdev_dbg(bond->dev, "(slave %s): best ports %p slave %p\n",  in ad_agg_selection_logic()
1714 		bond_for_each_slave_rcu(bond, slave, iter) {  in ad_agg_selection_logic()
1717 			slave_dbg(bond->dev, slave->dev, "Agg=%d; P=%d; a k=%d; p k=%d; Ind=%d; Act=%d\n",  in ad_agg_selection_logic()
1727 					     bond->dev->name);  in ad_agg_selection_logic()
1730 		netdev_dbg(bond->dev, "(slave %s): LAG %d chosen as the active LAG\n",  in ad_agg_selection_logic()
1733 		netdev_dbg(bond->dev, "(slave %s): Agg=%d; P=%d; a k=%d; p k=%d; Ind=%d; Act=%d\n",  in ad_agg_selection_logic()
1770 	bond_3ad_set_carrier(bond);  in ad_agg_selection_logic()
1890 		slave_dbg(port->slave->bond->dev, port->slave->dev,  in ad_enable_collecting_distributing()
1911 		slave_dbg(port->slave->bond->dev, port->slave->dev,  in ad_disable_collecting_distributing()
1932 	atomic64_inc(&BOND_AD_INFO(port->slave->bond).stats.marker_rx);  in ad_marker_info_received()
1941 		slave_dbg(port->slave->bond->dev, port->slave->dev,  in ad_marker_info_received()
1959 	atomic64_inc(&BOND_AD_INFO(port->slave->bond).stats.marker_resp_rx);  in ad_marker_response_received()
1978 void bond_3ad_initiate_agg_selection(struct bonding *bond, int timeout)  in bond_3ad_initiate_agg_selection()  argument
1980 	atomic_set(&BOND_AD_INFO(bond).agg_select_timer, timeout);  in bond_3ad_initiate_agg_selection()
1990 void bond_3ad_initialize(struct bonding *bond, u16 tick_resolution)  in bond_3ad_initialize()  argument
1992 	BOND_AD_INFO(bond).aggregator_identifier = 0;  in bond_3ad_initialize()
1993 	BOND_AD_INFO(bond).system.sys_priority =  in bond_3ad_initialize()
1994 		bond->params.ad_actor_sys_prio;  in bond_3ad_initialize()
1995 	if (is_zero_ether_addr(bond->params.ad_actor_system))  in bond_3ad_initialize()
1996 		BOND_AD_INFO(bond).system.sys_mac_addr =  in bond_3ad_initialize()
1997 		    *((struct mac_addr *)bond->dev->dev_addr);  in bond_3ad_initialize()
1999 		BOND_AD_INFO(bond).system.sys_mac_addr =  in bond_3ad_initialize()
2000 		    *((struct mac_addr *)bond->params.ad_actor_system);  in bond_3ad_initialize()
2007 	bond_3ad_initiate_agg_selection(bond,  in bond_3ad_initialize()
2021 	struct bonding *bond = bond_get_bond_by_slave(slave);  in bond_3ad_bind_slave()  local
2031 		ad_initialize_port(port, bond->params.lacp_fast);  in bond_3ad_bind_slave()
2038 		port->actor_admin_port_key = bond->params.ad_user_port_key << 6;  in bond_3ad_bind_slave()
2054 		aggregator->aggregator_mac_address = *((struct mac_addr *)bond->dev->dev_addr);  in bond_3ad_bind_slave()
2055 		aggregator->aggregator_identifier = ++BOND_AD_INFO(bond).aggregator_identifier;  in bond_3ad_bind_slave()
2075 	struct bonding *bond = slave->bond;  in bond_3ad_unbind_slave()  local
2081 	spin_lock_bh(&bond->mode_lock);  in bond_3ad_unbind_slave()
2087 		slave_warn(bond->dev, slave->dev, "Trying to unbind an uninitialized port\n");  in bond_3ad_unbind_slave()
2091 	slave_dbg(bond->dev, slave->dev, "Unbinding Link Aggregation Group %d\n",  in bond_3ad_unbind_slave()
2112 			bond_for_each_slave(bond, slave_iter, iter) {  in bond_3ad_unbind_slave()
2130 				slave_dbg(bond->dev, slave->dev, "Some port(s) related to LAG %d - replacing with LAG %d\n",  in bond_3ad_unbind_slave()
2136 					slave_info(bond->dev, slave->dev, "Removing an active aggregator\n");  in bond_3ad_unbind_slave()
2167 …slave_warn(bond->dev, slave->dev, "unbinding aggregator, and could not find a new aggregator for i…  in bond_3ad_unbind_slave()
2176 				slave_info(bond->dev, slave->dev, "Removing an active aggregator\n");  in bond_3ad_unbind_slave()
2186 	slave_dbg(bond->dev, slave->dev, "Unbinding port %d\n", port->actor_port_number);  in bond_3ad_unbind_slave()
2189 	bond_for_each_slave(bond, slave_iter, iter) {  in bond_3ad_unbind_slave()
2210 						slave_info(bond->dev, slave->dev, "Removing an active aggregator\n");  in bond_3ad_unbind_slave()
2223 	spin_unlock_bh(&bond->mode_lock);  in bond_3ad_unbind_slave()
2233 void bond_3ad_update_ad_actor_settings(struct bonding *bond)  in bond_3ad_update_ad_actor_settings()  argument
2240 	BOND_AD_INFO(bond).system.sys_priority = bond->params.ad_actor_sys_prio;  in bond_3ad_update_ad_actor_settings()
2241 	if (is_zero_ether_addr(bond->params.ad_actor_system))  in bond_3ad_update_ad_actor_settings()
2242 		BOND_AD_INFO(bond).system.sys_mac_addr =  in bond_3ad_update_ad_actor_settings()
2243 		    *((struct mac_addr *)bond->dev->dev_addr);  in bond_3ad_update_ad_actor_settings()
2245 		BOND_AD_INFO(bond).system.sys_mac_addr =  in bond_3ad_update_ad_actor_settings()
2246 		    *((struct mac_addr *)bond->params.ad_actor_system);  in bond_3ad_update_ad_actor_settings()
2248 	spin_lock_bh(&bond->mode_lock);  in bond_3ad_update_ad_actor_settings()
2249 	bond_for_each_slave(bond, slave, iter) {  in bond_3ad_update_ad_actor_settings()
2255 	spin_unlock_bh(&bond->mode_lock);  in bond_3ad_update_ad_actor_settings()
2264 static bool bond_agg_timer_advance(struct bonding *bond)  in bond_agg_timer_advance()  argument
2269 		val = atomic_read(&BOND_AD_INFO(bond).agg_select_timer);  in bond_agg_timer_advance()
2273 		if (atomic_cmpxchg(&BOND_AD_INFO(bond).agg_select_timer,  in bond_agg_timer_advance()
2295 	struct bonding *bond = container_of(work, struct bonding,  in bond_3ad_state_machine_handler()  local
2308 	spin_lock_bh(&bond->mode_lock);  in bond_3ad_state_machine_handler()
2312 	if (!bond_has_slaves(bond))  in bond_3ad_state_machine_handler()
2315 	if (bond_agg_timer_advance(bond)) {  in bond_3ad_state_machine_handler()
2316 		slave = bond_first_slave_rcu(bond);  in bond_3ad_state_machine_handler()
2323 						     bond->dev->name);  in bond_3ad_state_machine_handler()
2330 		bond_3ad_set_carrier(bond);  in bond_3ad_state_machine_handler()
2334 	bond_for_each_slave_rcu(bond, slave, iter) {  in bond_3ad_state_machine_handler()
2338 					    bond->dev->name);  in bond_3ad_state_machine_handler()
2355 	bond_for_each_slave_rcu(bond, slave, iter) {  in bond_3ad_state_machine_handler()
2362 	spin_unlock_bh(&bond->mode_lock);  in bond_3ad_state_machine_handler()
2365 		bond_slave_arr_work_rearm(bond, 0);  in bond_3ad_state_machine_handler()
2368 		bond_slave_state_notify(bond);  in bond_3ad_state_machine_handler()
2371 	queue_delayed_work(bond->wq, &bond->ad_work, ad_delta_in_ticks);  in bond_3ad_state_machine_handler()
2385 	struct bonding *bond = slave->bond;  in bond_3ad_rx_indication()  local
2394 				     slave->dev->name, slave->bond->dev->name);  in bond_3ad_rx_indication()
2401 		slave_dbg(slave->bond->dev, slave->dev,  in bond_3ad_rx_indication()
2405 		spin_lock(&slave->bond->mode_lock);  in bond_3ad_rx_indication()
2407 		spin_unlock(&slave->bond->mode_lock);  in bond_3ad_rx_indication()
2417 			slave_dbg(slave->bond->dev, slave->dev, "Received Marker Information on port %d\n",  in bond_3ad_rx_indication()
2422 			slave_dbg(slave->bond->dev, slave->dev, "Received Marker Response on port %d\n",  in bond_3ad_rx_indication()
2427 			slave_dbg(slave->bond->dev, slave->dev, "Received an unknown Marker subtype on port %d\n",  in bond_3ad_rx_indication()
2431 			stat = &BOND_AD_INFO(bond).stats.marker_unknown_rx;  in bond_3ad_rx_indication()
2437 		atomic64_inc(&BOND_AD_INFO(bond).stats.lacpdu_unknown_rx);  in bond_3ad_rx_indication()
2478 				slave_err(port->slave->bond->dev,  in ad_update_actor_keys()
2506 		slave_warn(slave->bond->dev, slave->dev,  in bond_3ad_adapter_speed_duplex_changed()
2511 	spin_lock_bh(&slave->bond->mode_lock);  in bond_3ad_adapter_speed_duplex_changed()
2513 	spin_unlock_bh(&slave->bond->mode_lock);  in bond_3ad_adapter_speed_duplex_changed()
2514 	slave_dbg(slave->bond->dev, slave->dev, "Port %d changed speed/duplex\n",  in bond_3ad_adapter_speed_duplex_changed()
2535 		slave_warn(slave->bond->dev, slave->dev, "link status changed for uninitialized port\n");  in bond_3ad_handle_link_change()
2539 	spin_lock_bh(&slave->bond->mode_lock);  in bond_3ad_handle_link_change()
2558 	spin_unlock_bh(&slave->bond->mode_lock);  in bond_3ad_handle_link_change()
2560 	slave_dbg(slave->bond->dev, slave->dev, "Port %d changed link status to %s\n",  in bond_3ad_handle_link_change()
2567 	bond_update_slave_arr(slave->bond, NULL);  in bond_3ad_handle_link_change()
2583 int bond_3ad_set_carrier(struct bonding *bond)  in bond_3ad_set_carrier()  argument
2590 	first_slave = bond_first_slave_rcu(bond);  in bond_3ad_set_carrier()
2598 		if (__agg_active_ports(active) < bond->params.min_links) {  in bond_3ad_set_carrier()
2599 			if (netif_carrier_ok(bond->dev)) {  in bond_3ad_set_carrier()
2600 				netif_carrier_off(bond->dev);  in bond_3ad_set_carrier()
2603 		} else if (!netif_carrier_ok(bond->dev)) {  in bond_3ad_set_carrier()
2604 			netif_carrier_on(bond->dev);  in bond_3ad_set_carrier()
2607 	} else if (netif_carrier_ok(bond->dev)) {  in bond_3ad_set_carrier()
2608 		netif_carrier_off(bond->dev);  in bond_3ad_set_carrier()
2623 int __bond_3ad_get_active_agg_info(struct bonding *bond,  in __bond_3ad_get_active_agg_info()  argument
2631 	bond_for_each_slave_rcu(bond, slave, iter) {  in __bond_3ad_get_active_agg_info()
2651 int bond_3ad_get_active_agg_info(struct bonding *bond, struct ad_info *ad_info)  in bond_3ad_get_active_agg_info()  argument
2656 	ret = __bond_3ad_get_active_agg_info(bond, ad_info);  in bond_3ad_get_active_agg_info()
2662 int bond_3ad_lacpdu_recv(const struct sk_buff *skb, struct bonding *bond,  in bond_3ad_lacpdu_recv()  argument
2676 		atomic64_inc(&BOND_AD_INFO(bond).stats.lacpdu_illegal_rx);  in bond_3ad_lacpdu_recv()
2694 void bond_3ad_update_lacp_rate(struct bonding *bond)  in bond_3ad_update_lacp_rate()  argument
2701 	lacp_fast = bond->params.lacp_fast;  in bond_3ad_update_lacp_rate()
2702 	spin_lock_bh(&bond->mode_lock);  in bond_3ad_update_lacp_rate()
2703 	bond_for_each_slave(bond, slave, iter) {  in bond_3ad_update_lacp_rate()
2710 	spin_unlock_bh(&bond->mode_lock);  in bond_3ad_update_lacp_rate()