#define SLAVE_AD_INFO(slave) ((slave)->ad_info)
  
  struct ad_bond_info {
 -      struct ad_system system;            /* 802.3ad system structure */
 -      u32 agg_select_timer;       // Timer to select aggregator after all adapter's hand shakes
 +      struct ad_system system;        /* 802.3ad system structure */
 +      u32 agg_select_timer;           /* Timer to select aggregator after all adapter's hand shakes */
+       u16 aggregator_identifier;
  };
  
  struct ad_slave_info {
 
                write_lock_bh(&bond->curr_slave_lock);
                bond_select_active_slave(bond);
                write_unlock_bh(&bond->curr_slave_lock);
+               unblock_netpoll_tx();
        }
  
 -      pr_info("%s: enslaving %s as a%s interface with a%s link.\n",
 +      pr_info("%s: Enslaving %s as %s interface with %s link\n",
                bond_dev->name, slave_dev->name,
 -              bond_is_active_slave(new_slave) ? "n active" : " backup",
 -              new_slave->link != BOND_LINK_DOWN ? "n up" : " down");
 +              bond_is_active_slave(new_slave) ? "an active" : "a backup",
 +              new_slave->link != BOND_LINK_DOWN ? "an up" : "a down");
  
        /* enslave is successful */
        return 0;
                        break;
                }
  
 -              pr_info("%s: Primary slave changed to %s, reselecting active slave.\n",
 -                      bond->dev->name, bond->primary_slave ? slave_dev->name :
 -                                                             "none");
 +              pr_info("%s: Primary slave changed to %s, reselecting active slave\n",
 +                      bond->dev->name,
 +                      bond->primary_slave ? slave_dev->name : "none");
+ 
+               block_netpoll_tx();
                write_lock_bh(&bond->curr_slave_lock);
                bond_select_active_slave(bond);
                write_unlock_bh(&bond->curr_slave_lock);
 
                                &l_ptr->newest_deferred_in, buf)) {
                l_ptr->deferred_inqueue_sz++;
                l_ptr->stats.deferred_recv++;
+               TIPC_SKB_CB(buf)->deferred = true;
                if ((l_ptr->deferred_inqueue_sz % 16) == 1)
 -                      tipc_link_send_proto_msg(l_ptr, STATE_MSG, 0, 0, 0, 0, 0);
 +                      tipc_link_proto_xmit(l_ptr, STATE_MSG, 0, 0, 0, 0, 0);
        } else
                l_ptr->stats.duplicates++;
  }