FD.io VPP  v20.05.1-6-gf53edbc3b
Vector Packet Processing
lacp.c
Go to the documentation of this file.
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/plugin/plugin.h>
20 #include <vpp/app/version.h>
21 #include <vppinfra/hash.h>
22 #include <vnet/bonding/node.h>
23 #include <lacp/node.h>
24 #include <vpp/stats/stat_segment.h>
25 
27 
28 /*
29  * Generate lacp pdu
30  */
31 static void
32 lacp_fill_pdu (lacp_pdu_t * lacpdu, slave_if_t * sif)
33 {
34  /* Actor TLV */
35  lacpdu->actor.port_info = sif->actor;
36 
37  /* Partner TLV */
38  lacpdu->partner.port_info = sif->partner;
39 }
40 
41 /*
42  * send a lacp pkt on an ethernet interface
43  */
44 static void
46 {
47  lacp_main_t *lm = &lacp_main;
48  u32 *to_next;
49  ethernet_lacp_pdu_t *h0;
51  u32 bi0;
52  vlib_buffer_t *b0;
53  vlib_frame_t *f;
54  vnet_main_t *vnm = lm->vnet_main;
55 
56  /*
57  * see lacp_periodic_init() to understand what's already painted
58  * into the buffer by the packet template mechanism
59  */
61  (vm, &lm->packet_templates[sif->packet_template_index], &bi0);
62 
63  if (!h0)
64  return;
65 
66  /* Add the interface's ethernet source address */
67  hw = vnet_get_sup_hw_interface (vnm, sif->sw_if_index);
68 
69  clib_memcpy (h0->ethernet.src_address, hw->hw_address,
70  vec_len (hw->hw_address));
71 
72  lacp_fill_pdu (&h0->lacp, sif);
73 
74  /* Set the outbound packet length */
75  b0 = vlib_get_buffer (vm, bi0);
76  b0->current_length = sizeof (ethernet_lacp_pdu_t);
77  b0->current_data = 0;
79 
80  /* And the outbound interface */
81  vnet_buffer (b0)->sw_if_index[VLIB_TX] = hw->sw_if_index;
82 
83  /* And output the packet on the correct interface */
85 
86  to_next = vlib_frame_vector_args (f);
87  to_next[0] = bi0;
88  f->n_vectors = 1;
89 
91 
93  sif->pdu_sent++;
94 }
95 
96 /*
97  * Decide which lacp packet template to use
98  */
99 static int
101 {
103 
104  return 0;
105 }
106 
107 void
109 {
110  if ((sif->mode != BOND_MODE_LACP) || (sif->port_enabled == 0))
111  {
113  return;
114  }
115 
116  if (sif->packet_template_index == (u8) ~ 0)
117  {
118  /* If we don't know how to talk to this peer, don't try again */
119  if (lacp_pick_packet_template (sif))
120  {
122  return;
123  }
124  }
125 
126  switch (sif->packet_template_index)
127  {
129  lacp_send_ethernet_lacp_pdu (vm, sif);
130  break;
131 
132  default:
133  ASSERT (0);
134  }
135 }
136 
137 void
139 {
140  bond_main_t *bm = &bond_main;
141  slave_if_t *sif;
142  bond_if_t *bif;
143  u8 actor_state, partner_state;
144 
145  /* *INDENT-OFF* */
146  pool_foreach (sif, bm->neighbors,
147  ({
148  if (sif->port_enabled == 0)
149  continue;
150 
151  actor_state = sif->actor.state;
152  partner_state = sif->partner.state;
153  if (lacp_timer_is_running (sif->current_while_timer) &&
154  lacp_timer_is_expired (vm, sif->current_while_timer))
155  {
156  lacp_machine_dispatch (&lacp_rx_machine, vm, sif,
157  LACP_RX_EVENT_TIMER_EXPIRED, &sif->rx_state);
158  }
159 
162  {
163  lacp_machine_dispatch (&lacp_ptx_machine, vm, sif,
164  LACP_PTX_EVENT_TIMER_EXPIRED, &sif->ptx_state);
165  }
168  {
169  sif->ready_n = 1;
170  lacp_stop_timer (&sif->wait_while_timer);
171  lacp_selection_logic (vm, sif);
172  }
173  if (actor_state != sif->actor.state)
174  {
175  bif = bond_get_master_by_dev_instance (sif->bif_dev_instance);
176  stat_segment_set_state_counter (bm->stats[bif->sw_if_index]
177  [sif->sw_if_index].actor_state,
178  sif->actor.state);
179  }
180  if (partner_state != sif->partner.state)
181  {
182  bif = bond_get_master_by_dev_instance (sif->bif_dev_instance);
183  stat_segment_set_state_counter (bm->stats[bif->sw_if_index]
184  [sif->sw_if_index].partner_state,
185  sif->partner.state);
186  }
187  }));
188  /* *INDENT-ON* */
189 }
190 
191 static void
193  slave_if_t * sif, u8 enable)
194 {
195  lacp_main_t *lm = &lacp_main;
196  uword port_number;
197 
198  if (enable)
199  {
201  port_number = clib_bitmap_first_clear (bif->port_number_bitmap);
203  port_number, 1);
204  // bitmap starts at 0. Our port number starts at 1.
205  lacp_init_neighbor (sif, bif->hw_address, port_number + 1, sif->group);
206  lacp_init_state_machines (vm, sif);
207  lm->lacp_int++;
208  if (lm->lacp_int == 1)
209  {
212  }
213  }
214  else
215  {
216  ASSERT (lm->lacp_int >= 1);
217  if (lm->lacp_int == 0)
218  {
219  /* *INDENT-OFF* */
220  ELOG_TYPE_DECLARE (e) =
221  {
222  .format = "lacp-int-en-dis: BUG lacp_int == 0",
223  };
224  /* *INDENT-ON* */
226  }
227  else
228  {
229  lm->lacp_int--;
230  if (lm->lacp_int == 0)
233  }
234  }
235 }
236 
237 static clib_error_t *
239 {
240  lacp_main_t *lm = &lacp_main;
241  ethernet_lacp_pdu_t h;
242  ethernet_marker_pdu_t m;
243  u8 dst[] = { 0x01, 0x80, 0xc2, 0x00, 0x00, 0x02 };
244 
245  /* initialize binary API */
247 
248  /* Create the ethernet lacp packet template */
249 
250  clib_memset (&h, 0, sizeof (h));
251 
252  memcpy (h.ethernet.dst_address, dst, sizeof (h.ethernet.dst_address));
253 
254  /* leave src address blank (fill in at send time) */
255 
256  h.ethernet.type = htons (ETHERNET_TYPE_SLOW_PROTOCOLS);
257 
258  h.lacp.subtype = LACP_SUBTYPE;
259  h.lacp.version_number = LACP_ACTOR_LACP_VERSION;
260 
261  /* Actor TLV */
262  h.lacp.actor.tlv_type = LACP_ACTOR_INFORMATION;
263  h.lacp.actor.tlv_length = sizeof (lacp_actor_partner_t);
264 
265  /* Partner TLV */
266  h.lacp.partner.tlv_type = LACP_PARTNER_INFORMATION;
267  h.lacp.partner.tlv_length = sizeof (lacp_actor_partner_t);
268 
269  /* Collector TLV */
270  h.lacp.collector.tlv_type = LACP_COLLECTOR_INFORMATION;
271  h.lacp.collector.tlv_length = sizeof (lacp_collector_t);
272  h.lacp.collector.max_delay = 0;
273 
274  /* Terminator TLV */
275  h.lacp.terminator.tlv_type = LACP_TERMINATOR_INFORMATION;
276  h.lacp.terminator.tlv_length = 0;
277 
280  /* data */ &h,
281  sizeof (h),
282  /* alloc chunk size */ 8,
283  "lacp-ethernet");
284 
285  /* Create the ethernet marker protocol packet template */
286 
287  clib_memset (&m, 0, sizeof (m));
288 
289  memcpy (m.ethernet.dst_address, dst, sizeof (m.ethernet.dst_address));
290 
291  /* leave src address blank (fill in at send time) */
292 
293  m.ethernet.type = htons (ETHERNET_TYPE_SLOW_PROTOCOLS);
294 
295  m.marker.subtype = MARKER_SUBTYPE;
296  m.marker.version_number = MARKER_PROTOCOL_VERSION;
297 
298  m.marker.marker_info.tlv_length = sizeof (marker_information_t);
299 
300  /* Terminator TLV */
301  m.marker.terminator.tlv_type = MARKER_TERMINATOR_INFORMATION;
302  m.marker.terminator.tlv_length = 0;
303 
306  /* data */ &m,
307  sizeof (m),
308  /* alloc chunk size */ 8,
309  "marker-ethernet");
310 
312 
313  return 0;
314 }
315 
316 int
318  slave_if_t * sif, int event, int *state)
319 {
320  lacp_fsm_state_t *transition;
321  int rc = 0;
322 
323  transition = &machine->tables[*state].state_table[event];
324  LACP_DBG2 (sif, event, *state, machine, transition);
325  *state = transition->next_state;
326  if (transition->action)
327  rc = (*transition->action) ((void *) vm, (void *) sif);
328 
329  return rc;
330 }
331 
332 void
333 lacp_init_neighbor (slave_if_t * sif, u8 * hw_address, u16 port_number,
334  u32 group)
335 {
345  sif->lacp_enabled = 1;
346  sif->loopback_port = 0;
347  sif->ready = 0;
348  sif->ready_n = 0;
349  sif->port_moved = 0;
350  sif->ntt = 0;
351  sif->selected = LACP_PORT_UNSELECTED;
352  sif->actor.state = LACP_STATE_AGGREGATION;
354  sif->actor.state |= LACP_STATE_LACP_TIMEOUT;
355  if (sif->is_passive == 0)
356  sif->actor.state |= LACP_STATE_LACP_ACTIVITY;
357  clib_memcpy (sif->actor.system, hw_address, 6);
358  sif->actor.system_priority = htons (LACP_DEFAULT_SYSTEM_PRIORITY);
359  sif->actor.key = htons (group);
360  sif->actor.port_number = htons (port_number);
361  sif->actor.port_priority = htons (LACP_DEFAULT_PORT_PRIORITY);
362 
363  sif->partner.system_priority = htons (LACP_DEFAULT_SYSTEM_PRIORITY);
364  sif->partner.key = htons (group);
365  sif->partner.port_number = htons (port_number);
366  sif->partner.port_priority = htons (LACP_DEFAULT_PORT_PRIORITY);
367  sif->partner.state = 0;
368 
369  sif->actor_admin = sif->actor;
370  sif->partner_admin = sif->partner;
371 }
372 
373 void
375 {
376  bond_main_t *bm = &bond_main;
378 
379  lacp_init_tx_machine (vm, sif);
380  lacp_init_mux_machine (vm, sif);
381  lacp_init_ptx_machine (vm, sif);
382  lacp_init_rx_machine (vm, sif);
384  [sif->sw_if_index].actor_state,
385  sif->actor.state);
387  [sif->sw_if_index].partner_state,
388  sif->partner.state);
389 }
390 
392 
393 static clib_error_t *
395 {
396  lacp_main_t *lm = &lacp_main;
397  slave_if_t *sif;
398  vlib_main_t *vm = lm->vlib_main;
399 
400  sif = bond_get_slave_by_sw_if_index (sw_if_index);
401  if (sif)
402  {
403  if (sif->lacp_enabled == 0)
404  return 0;
405 
406  /* port_enabled is both admin up and hw link up */
407  sif->port_enabled = ((flags & VNET_SW_INTERFACE_FLAG_ADMIN_UP) &&
408  vnet_sw_interface_is_link_up (vnm, sw_if_index));
409  if (sif->port_enabled == 0)
410  {
411  lacp_init_neighbor (sif, sif->actor_admin.system,
412  ntohs (sif->actor_admin.port_number),
413  ntohs (sif->actor_admin.key));
414  lacp_init_state_machines (vm, sif);
415  }
416  }
417 
418  return 0;
419 }
420 
422 
423 static clib_error_t *
425 {
426  lacp_main_t *lm = &lacp_main;
427  slave_if_t *sif;
429  vlib_main_t *vm = lm->vlib_main;
430 
431  sw = vnet_get_hw_sw_interface (vnm, hw_if_index);
433  if (sif)
434  {
435  if (sif->lacp_enabled == 0)
436  return 0;
437 
438  /* port_enabled is both admin up and hw link up */
439  sif->port_enabled = ((flags & VNET_HW_INTERFACE_FLAG_LINK_UP) &&
441  sw->sw_if_index));
442  if (sif->port_enabled == 0)
443  {
444  lacp_init_neighbor (sif, sif->actor_admin.system,
445  ntohs (sif->actor_admin.port_number),
446  ntohs (sif->actor_admin.key));
447  lacp_init_state_machines (vm, sif);
448  }
449  }
450 
451  return 0;
452 }
453 
455 
456 /* *INDENT-OFF* */
458  .version = VPP_BUILD_VER,
459  .description = "Link Aggregation Control Protocol (LACP)",
460 };
461 /* *INDENT-ON* */
462 
463 /*
464  * fd.io coding-style-patch-verification: ON
465  *
466  * Local Variables:
467  * eval: (c-set-style "gnu")
468  * End:
469  */
void lacp_send_lacp_pdu(vlib_main_t *vm, slave_if_t *sif)
Definition: lacp.c:108
void lacp_init_mux_machine(vlib_main_t *vm, slave_if_t *sif)
Definition: mux_machine.c:233
vlib_main_t * vlib_main
Definition: node.h:121
vlib_main_t vlib_global_main
Definition: main.c:1999
lacp_stats_t ** stats
Definition: node.h:388
void lacp_init_ptx_machine(vlib_main_t *vm, slave_if_t *sif)
Definition: ptx_machine.c:220
int selected
Definition: node.h:280
static vnet_hw_interface_t * vnet_get_sup_hw_interface(vnet_main_t *vnm, u32 sw_if_index)
volatile u32 lacp_int
Definition: node.h:134
f64 last_lacpdu_recd_time
Definition: node.h:295
i16 current_data
signed offset in data[], pre_data[] that we are currently processing.
Definition: buffer.h:110
clib_memset(h->entries, 0, sizeof(h->entries[0]) *entries)
static f64 vlib_time_now(vlib_main_t *vm)
Definition: main.h:291
void lacp_init_neighbor(slave_if_t *sif, u8 *hw_address, u16 port_number, u32 group)
Definition: lacp.c:333
u16 current_length
Nbytes between current data and the end of this buffer.
Definition: buffer.h:113
static void lacp_send_ethernet_lacp_pdu(vlib_main_t *vm, slave_if_t *sif)
Definition: lacp.c:45
static uword * clib_bitmap_set(uword *ai, uword i, uword value)
Sets the ith bit of a bitmap to new_value Removes trailing zeros from the bitmap. ...
Definition: bitmap.h:167
f64 current_while_timer
Definition: node.h:286
u8 mode
Definition: node.h:328
static uword vnet_sw_interface_is_link_up(vnet_main_t *vnm, u32 sw_if_index)
unsigned char u8
Definition: types.h:56
lacp_fsm_state_t * state_table
Definition: machine.h:37
u8 ntt
Definition: node.h:262
static vnet_sw_interface_t * vnet_get_hw_sw_interface(vnet_main_t *vnm, u32 hw_if_index)
#define clib_memcpy(d, s, n)
Definition: string.h:180
f64 periodic_timer
Definition: node.h:304
static void bond_register_callback(lacp_enable_disable_func func)
Definition: node.h:493
f32 ttl_in_seconds
Definition: node.h:221
void * vlib_packet_template_get_packet(vlib_main_t *vm, vlib_packet_template_t *t, u32 *bi_result)
Definition: buffer.c:400
static u8 lacp_timer_is_running(f64 timer)
Definition: node.h:166
#define pool_foreach(VAR, POOL, BODY)
Iterate through pool.
Definition: pool.h:513
vl_api_interface_index_t sw_if_index
Definition: gre.api:53
#define VLIB_INIT_FUNCTION(x)
Definition: init.h:173
vnet_main_t * vnet_main
Definition: node.h:122
VNET_SW_INTERFACE_ADMIN_UP_DOWN_FUNCTION(lacp_sw_interface_up_down)
vlib_packet_template_t packet_templates[LACP_N_PACKET_TEMPLATES]
Definition: node.h:128
f64 last_marker_pdu_recd_time
Definition: node.h:301
action_func action
Definition: machine.h:28
u32 sw_if_index
Definition: node.h:184
lacp_port_info_t actor
Definition: node.h:255
static u8 lacp_timer_is_expired(vlib_main_t *vm, f64 timer)
Definition: node.h:172
vlib_frame_t * vlib_get_frame_to_node(vlib_main_t *vm, u32 to_node_index)
Definition: main.c:182
unsigned int u32
Definition: types.h:88
f64 partner_churn_timer
Definition: node.h:307
static void lacp_fill_pdu(lacp_pdu_t *lacpdu, slave_if_t *sif)
Definition: lacp.c:32
void lacp_create_periodic_process(void)
Definition: node.c:229
#define LACP_DEFAULT_SYSTEM_PRIORITY
Definition: protocol.h:99
void lacp_periodic(vlib_main_t *vm)
Definition: lacp.c:138
#define MARKER_SUBTYPE
Definition: protocol.h:132
u8 ready
Definition: node.h:277
void vlib_packet_template_init(vlib_main_t *vm, vlib_packet_template_t *t, void *packet_data, uword n_packet_data_bytes, uword min_n_buffers_each_alloc, char *fmt,...)
Definition: buffer.c:378
static void vlib_process_signal_event(vlib_main_t *vm, uword node_index, uword type_opaque, uword data)
Definition: node_funcs.h:934
f64 last_marker_pdu_sent_time
Definition: node.h:298
static void lacp_stop_timer(f64 *timer)
Definition: node.h:160
VLIB_PLUGIN_REGISTER()
unsigned short u16
Definition: types.h:57
u8 port_moved
Definition: node.h:283
void vlib_put_frame_to_node(vlib_main_t *vm, u32 to_node_index, vlib_frame_t *f)
Definition: main.c:216
static void lacp_interface_enable_disable(vlib_main_t *vm, bond_if_t *bif, slave_if_t *sif, u8 enable)
Definition: lacp.c:192
vec_header_t h
Definition: buffer.c:322
#define LACP_SUBTYPE
Definition: protocol.h:25
#define ELOG_DATA(em, f)
Definition: elog.h:484
#define LACP_SHORT_TIMOUT_TIME
Definition: node.h:26
vl_api_address_t dst
Definition: gre.api:55
#define MARKER_PROTOCOL_VERSION
Definition: protocol.h:133
static int lacp_pick_packet_template(slave_if_t *sif)
Definition: lacp.c:100
vlib_main_t * vm
Definition: in2out_ed.c:1599
static clib_error_t * lacp_periodic_init(vlib_main_t *vm)
Definition: lacp.c:238
u32 partner_state
Definition: node.h:357
u32 flags
Definition: vhost_user.h:248
u16 n_vectors
Definition: node.h:399
u8 is_passive
Definition: node.h:251
u32 sw_if_index
Definition: node.h:218
lacp_port_info_t partner
Definition: node.h:254
#define LACP_DEFAULT_PORT_PRIORITY
Definition: protocol.h:98
u32 group
Definition: node.h:319
elog_main_t elog_main
Definition: main.h:193
void lacp_init_rx_machine(vlib_main_t *vm, slave_if_t *sif)
Definition: rx_machine.c:425
lacp_main_t lacp_main
Definition: lacp.c:26
#define ELOG_TYPE_DECLARE(f)
Definition: elog.h:442
clib_error_t * lacp_plugin_api_hookup(vlib_main_t *vm)
Definition: lacp_api.c:119
f64 last_lacpdu_sent_time
Definition: node.h:292
u8 loopback_port
Definition: node.h:325
#define ASSERT(truth)
#define LACP_DBG2(n, e, s, m, t)
Definition: node.h:53
static bond_if_t * bond_get_master_by_dev_instance(u32 dev_instance)
Definition: node.h:516
bond_main_t bond_main
Definition: node.c:25
u32 bif_dev_instance
Definition: node.h:323
static clib_error_t * lacp_hw_interface_up_down(vnet_main_t *vnm, u32 hw_if_index, u32 flags)
Definition: lacp.c:424
vlib_packet_template_t marker_packet_templates[MARKER_N_PACKET_TEMPLATES]
Definition: node.h:131
u8 ready_n
Definition: node.h:274
static uword vnet_sw_interface_is_admin_up(vnet_main_t *vnm, u32 sw_if_index)
void lacp_init_tx_machine(vlib_main_t *vm, slave_if_t *sif)
Definition: tx_machine.c:108
u8 lacp_enabled
Definition: node.h:271
Definition: defs.h:47
u64 pdu_sent
Definition: node.h:337
u32 lacp_process_node_index
Definition: node.h:125
#define vec_len(v)
Number of elements in vector (rvalue-only, NULL tolerant)
VLIB buffer representation.
Definition: buffer.h:102
uword * port_number_bitmap
Definition: node.h:206
u64 uword
Definition: types.h:112
static void * vlib_frame_vector_args(vlib_frame_t *f)
Get pointer to frame vector data.
Definition: node_funcs.h:244
lacp_port_info_t partner_admin
Definition: node.h:255
VNET_HW_INTERFACE_LINK_UP_DOWN_FUNCTION(lacp_hw_interface_up_down)
#define vnet_buffer(b)
Definition: buffer.h:417
slave_if_t * neighbors
Definition: node.h:370
vl_api_dhcp_client_state_t state
Definition: dhcp.api:201
u32 actor_state
Definition: node.h:358
u8 hw_address[6]
Definition: node.h:208
f64 actor_churn_timer
Definition: node.h:289
u8 port_enabled
Definition: node.h:265
static slave_if_t * bond_get_slave_by_sw_if_index(u32 sw_if_index)
Definition: node.h:524
lacp_port_info_t actor_admin
Definition: node.h:259
static uword clib_bitmap_first_clear(uword *ai)
Return the lowest numbered clear bit in a bitmap.
Definition: bitmap.h:445
u32 total_length_not_including_first_buffer
Only valid for first buffer in chain.
Definition: buffer.h:167
u8 packet_template_index
Definition: node.h:230
void lacp_init_state_machines(vlib_main_t *vm, slave_if_t *sif)
Definition: lacp.c:374
f64 wait_while_timer
Definition: node.h:310
static vlib_buffer_t * vlib_get_buffer(vlib_main_t *vm, u32 buffer_index)
Translate buffer index into buffer pointer.
Definition: buffer_funcs.h:85
lacp_fsm_machine_t * tables
Definition: machine.h:42
static clib_error_t * lacp_sw_interface_up_down(vnet_main_t *vnm, u32 sw_if_index, u32 flags)
Definition: lacp.c:394
int lacp_machine_dispatch(lacp_machine_t *machine, vlib_main_t *vm, slave_if_t *sif, int event, int *state)
Definition: lacp.c:317
void stat_segment_set_state_counter(u32 index, u64 value)
Definition: stat_segment.c:961
#define LACP_ACTOR_LACP_VERSION
Definition: protocol.h:26