bonding: add support for numa awareness

[vpp.git] / src / vnet / bonding / cli.c

diff --git a/src/vnet/bonding/cli.c b/src/vnet/bonding/cli.c
index bccbb2c..cb344c6 100644 (file)
--- 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