bonding: add support for numa awareness

This patch enables bonding numa awareness on multi-socket
server working in active-backeup mode.
The VPP adds capability for automatically preferring slave
with local numa node in order to reduces the load on the
QPI-bus and improve system overall performance in multi-socket
use cases. Users doesn't need to add any extra operation as
usual.

Change-Id: Iec267375fc399a9a0c0a7dca649fadb994d36671
Signed-off-by: Zhiyong Yang <zhiyong.yang@intel.com>

1 files changed, 80 insertions, 12 deletions

diff --git a/src/vnet/bonding/cli.c b/src/vnet/bonding/cli.c
index bccbb2c036e..cb344c611c2 100644
--- a/src/vnet/bonding/cli.c
+++ b/src/vnet/bonding/cli.c
@@ -28,6 +28,8 @@ bond_disable_collecting_distributing (vlib_main_t * vm, slave_if_t * sif)
   bond_if_t *bif;
   int i;
   uword p;
+  vnet_main_t *vnm = vnet_get_main ();
+  vnet_hw_interface_t *hw;
   u8 switching_active = 0;
 
   bif = bond_get_master_by_dev_instance (sif->bif_dev_instance);
@@ -37,22 +39,53 @@ bond_disable_collecting_distributing (vlib_main_t * vm, slave_if_t * sif)
     p = *vec_elt_at_index (bif->active_slaves, i);
     if (p == sif->sw_if_index)
       {
-	/* Are we disabling the very 1st slave? */
-	if (sif->sw_if_index == *vec_elt_at_index (bif->active_slaves, 0))
-	  switching_active = 1;
-
+	if (sif->sw_if_index == bif->sw_if_index_working)
+	  {
+	    switching_active = 1;
+	    if (bif->mode == BOND_MODE_ACTIVE_BACKUP)
+	      bif->is_local_numa = 0;
+	  }
 	vec_del1 (bif->active_slaves, i);
 	hash_unset (bif->active_slave_by_sw_if_index, sif->sw_if_index);
-
-	/* We got a new slave just becoming active? */
-	if ((vec_len (bif->active_slaves) >= 1) &&
-	    (bif->mode == BOND_MODE_ACTIVE_BACKUP) && switching_active)
-	  vlib_process_signal_event (bm->vlib_main, bond_process_node.index,
-				     BOND_SEND_GARP_NA, bif->hw_if_index);
 	break;
       }
   }
+
+  /* We get a new slave just becoming active */
+  if ((bif->mode == BOND_MODE_ACTIVE_BACKUP) && switching_active)
+    {
+      if ((vec_len (bif->active_slaves) >= 1))
+	{
+	  /* scan all slaves and try to find the first slave with local numa node. */
+	  vec_foreach_index (i, bif->active_slaves)
+	  {
+	    p = *vec_elt_at_index (bif->active_slaves, i);
+	    hw = vnet_get_sup_hw_interface (vnm, p);
+	    if (vm->numa_node == hw->numa_node)
+	      {
+		bif->sw_if_index_working = p;
+		bif->is_local_numa = 1;
+		vlib_process_signal_event (bm->vlib_main,
+					   bond_process_node.index,
+					   BOND_SEND_GARP_NA,
+					   bif->hw_if_index);
+		break;
+	      }
+	  }
+	}
+
+      /* No local numa node is found in the active slave set. Use the first slave */
+      if ((bif->is_local_numa == 0) && (vec_len (bif->active_slaves) >= 1))
+	{
+	  p = *vec_elt_at_index (bif->active_slaves, 0);
+	  bif->sw_if_index_working = p;
+	  vlib_process_signal_event (bm->vlib_main, bond_process_node.index,
+				     BOND_SEND_GARP_NA, bif->hw_if_index);
+	}
+    }
   clib_spinlock_unlock_if_init (&bif->lockp);
+
+  return;
 }
 
 void
@@ -60,6 +93,10 @@ bond_enable_collecting_distributing (vlib_main_t * vm, slave_if_t * sif)
 {
   bond_if_t *bif;
   bond_main_t *bm = &bond_main;
+  vnet_main_t *vnm = vnet_get_main ();
+  vnet_hw_interface_t *hw = vnet_get_sup_hw_interface (vnm, sif->sw_if_index);
+  int i;
+  uword p;
 
   bif = bond_get_master_by_dev_instance (sif->bif_dev_instance);
   clib_spinlock_lock_if_init (&bif->lockp);
@@ -72,10 +109,41 @@ bond_enable_collecting_distributing (vlib_main_t * vm, slave_if_t * sif)
       /* First slave becomes active? */
       if ((vec_len (bif->active_slaves) == 1) &&
 	  (bif->mode == BOND_MODE_ACTIVE_BACKUP))
-	vlib_process_signal_event (bm->vlib_main, bond_process_node.index,
-				   BOND_SEND_GARP_NA, bif->hw_if_index);
+	{
+	  bif->sw_if_index_working = sif->sw_if_index;
+	  bif->is_local_numa = (vm->numa_node == hw->numa_node) ? 1 : 0;
+	  vlib_process_signal_event (bm->vlib_main, bond_process_node.index,
+				     BOND_SEND_GARP_NA, bif->hw_if_index);
+	}
+      else if ((vec_len (bif->active_slaves) > 1)
+	       && (bif->mode == BOND_MODE_ACTIVE_BACKUP)
+	       && bif->is_local_numa == 0)
+	{
+	  if (vm->numa_node == hw->numa_node)
+	    {
+	      vec_foreach_index (i, bif->active_slaves)
+	      {
+		p = *vec_elt_at_index (bif->active_slaves, 0);
+		if (p == sif->sw_if_index)
+		  break;
+
+		vec_del1 (bif->active_slaves, 0);
+		hash_unset (bif->active_slave_by_sw_if_index, p);
+		vec_add1 (bif->active_slaves, p);
+		hash_set (bif->active_slave_by_sw_if_index, p, p);
+	      }
+	      bif->sw_if_index_working = sif->sw_if_index;
+	      bif->is_local_numa = 1;
+	      vlib_process_signal_event (bm->vlib_main,
+					 bond_process_node.index,
+					 BOND_SEND_GARP_NA, bif->hw_if_index);
+
+	    }
+	}
     }
   clib_spinlock_unlock_if_init (&bif->lockp);
+
+  return;
 }
 
 int