src/plugins/lacp/selection.c

   1 /*
   2  * Copyright (c) 2017 Cisco and/or its affiliates.
   3  * Licensed under the Apache License, Version 2.0 (the "License");
   4  * you may not use this file except in compliance with the License.
   5  * You may obtain a copy of the License at:
   6  *
   7  *     http://www.apache.org/licenses/LICENSE-2.0
   8  *
   9  * Unless required by applicable law or agreed to in writing, software
  10  * distributed under the License is distributed on an "AS IS" BASIS,
  11  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12  * See the License for the specific language governing permissions and
  13  * limitations under the License.
  14  */
  15
  16 #include <stdint.h>
  17 #include <vlib/vlib.h>
  18 #include <vlib/unix/unix.h>
  19 #include <vnet/bonding/node.h>
  20 #include <lacp/node.h>
  21
  22 static void
  23 lacp_set_port_selected (vlib_main_t * vm, slave_if_t * sif)
  24 {
  25   /* Handle loopback port */
  26   if (!memcmp (sif->partner.system, sif->actor.system, 6) &&
  27       (sif->partner.key == sif->actor.key))
  28     {
  29       sif->loopback_port = 1;
  30       sif->actor.state &= ~LACP_STATE_AGGREGATION;
  31     }
  32   sif->selected = LACP_PORT_SELECTED;
  33
  34   switch (sif->mux_state)
  35     {
  36     case LACP_MUX_STATE_DETACHED:
  37       break;
  38     case LACP_MUX_STATE_WAITING:
  39       if (!sif->ready)
  40         return;
  41       break;
  42     case LACP_MUX_STATE_ATTACHED:
  43       if (!(sif->partner.state & LACP_STATE_SYNCHRONIZATION))
  44         return;
  45       break;
  46     case LACP_MUX_STATE_COLLECTING_DISTRIBUTING:
  47       break;
  48     default:
  49       break;
  50     }
  51   lacp_machine_dispatch (&lacp_mux_machine, vm, sif, LACP_MUX_EVENT_SELECTED,
  52                          &sif->mux_state);
  53 }
  54
  55 void
  56 lacp_selection_logic (vlib_main_t * vm, slave_if_t * sif)
  57 {
  58   slave_if_t *sif2;
  59   bond_if_t *bif;
  60   u32 *sw_if_index;
  61
  62   bif = bond_get_master_by_dev_instance (sif->bif_dev_instance);
  63   vec_foreach (sw_if_index, bif->slaves)
  64   {
  65     sif2 = bond_get_slave_by_sw_if_index (*sw_if_index);
  66     if (sif2 && (sif2->actor.state & LACP_STATE_SYNCHRONIZATION) &&
  67         (sif2->ready_n == 0))
  68       goto out;
  69   }
  70
  71   vec_foreach (sw_if_index, bif->slaves)
  72   {
  73     sif2 = bond_get_slave_by_sw_if_index (*sw_if_index);
  74     if (sif2)
  75       {
  76         sif2->ready = 1;
  77         if (sif2->selected == LACP_PORT_SELECTED)
  78           lacp_machine_dispatch (&lacp_mux_machine, vm, sif2,
  79                                  LACP_MUX_EVENT_READY, &sif2->mux_state);
  80       }
  81   }
  82 out:
  83   lacp_set_port_selected (vm, sif);
  84 }
  85
  86 /*
  87  * fd.io coding-style-patch-verification: ON
  88  *
  89  * Local Variables:
  90  * eval: (c-set-style "gnu")
  91  * End:
  92  */