FD.io VPP  v21.10.1-2-g0a485f517
Vector Packet Processing
rx_machine.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 #define _GNU_SOURCE
17 
18 #include <vnet/bonding/node.h>
19 #include <lacp/node.h>
20 
21 /*
22  * LACP State = INITIALIZE
23  */
25  {LACP_ACTION_INITIALIZE, LACP_RX_STATE_PORT_DISABLED}, // event 0 BEGIN
26  {LACP_ACTION_INITIALIZE, LACP_RX_STATE_PORT_DISABLED}, // event 1 PORT_DISABLED
27  {LACP_ACTION_INITIALIZE, LACP_RX_STATE_PORT_DISABLED}, // event 2 PORT_MOVED
28  {LACP_NOACTION, LACP_RX_STATE_INITIALIZE}, // event 3 LACP_ENABLED
29  {LACP_NOACTION, LACP_RX_STATE_INITIALIZE}, // event 4 LACP_DISABLED
30  {LACP_NOACTION, LACP_RX_STATE_INITIALIZE}, // event 5 PDU_RECEIVED
31  {LACP_NOACTION, LACP_RX_STATE_INITIALIZE}, // event 6 TIMER_EXPIRED
32 };
33 
34 /*
35  * LACP State = PORT_DISABLED
36  */
38  {LACP_ACTION_PORT_DISABLED, LACP_RX_STATE_PORT_DISABLED}, // event 0 BEGIN
39  {LACP_ACTION_PORT_DISABLED, LACP_RX_STATE_PORT_DISABLED}, // event 1 PORT_DISABLED
40  {LACP_ACTION_INITIALIZE, LACP_RX_STATE_INITIALIZE}, // event 2 PORT_MOVED
41  {LACP_ACTION_EXPIRED, LACP_RX_STATE_EXPIRED}, // event 3 LACP_ENABLED
42  {LACP_ACTION_LACP_DISABLED, LACP_RX_STATE_LACP_DISABLED}, // event 4 LACP_DISABLED
43  {LACP_NOACTION, LACP_RX_STATE_PORT_DISABLED}, // event 5 PDU_RECEIVED
44  {LACP_NOACTION, LACP_RX_STATE_PORT_DISABLED}, // event 6 TIMER_EXPIRED
45 };
46 
47 /*
48  * LACP State = EXPIRED
49  */
51  {LACP_ACTION_INITIALIZE, LACP_RX_STATE_INITIALIZE}, // event 0 BEGIN
52  {LACP_NOACTION, LACP_RX_STATE_EXPIRED}, // event 1 PORT_DISABLED
53  {LACP_NOACTION, LACP_RX_STATE_EXPIRED}, // event 2 PORT_MOVED
54  {LACP_NOACTION, LACP_RX_STATE_EXPIRED}, // event 3 LACP_ENABLED
55  {LACP_NOACTION, LACP_RX_STATE_EXPIRED}, // event 4 LACP_DISABLED
56  {LACP_ACTION_CURRENT, LACP_RX_STATE_CURRENT}, // event 5 PDU_RECEIVED
57  {LACP_ACTION_DEFAULTED, LACP_RX_STATE_DEFAULTED}, // event 6 TIMER_EXPIRED
58 };
59 
60 /*
61  * LACP State = LACP_DISABLED
62  */
64  {LACP_ACTION_INITIALIZE, LACP_RX_STATE_INITIALIZE}, // event 0 BEGIN
65  {LACP_NOACTION, LACP_RX_STATE_LACP_DISABLED}, // event 1 PORT_DISABLED
66  {LACP_NOACTION, LACP_RX_STATE_LACP_DISABLED}, // event 2 PORT_MOVED
67  {LACP_ACTION_EXPIRED, LACP_RX_STATE_EXPIRED}, // event 3 LACP_ENABLED XXX
68  {LACP_ACTION_LACP_DISABLED, LACP_RX_STATE_LACP_DISABLED}, // event 4 LACP_DISABLED
69  {LACP_NOACTION, LACP_RX_STATE_LACP_DISABLED}, // event 5 PDU_RECEIVED
70  {LACP_NOACTION, LACP_RX_STATE_LACP_DISABLED}, // event 6 TIMER_EXPIRED
71 };
72 
73 /*
74  * LACP State = DEFAULTED
75  */
77  {LACP_ACTION_INITIALIZE, LACP_RX_STATE_INITIALIZE}, // event 0 BEGIN
78  {LACP_NOACTION, LACP_RX_STATE_DEFAULTED}, // event 1 PORT_DISABLED
79  {LACP_NOACTION, LACP_RX_STATE_DEFAULTED}, // event 2 PORT_MOVED
80  {LACP_NOACTION, LACP_RX_STATE_DEFAULTED}, // event 3 LACP_ENABLED
81  {LACP_ACTION_LACP_DISABLED, LACP_RX_STATE_LACP_DISABLED}, // event 4 LACP_DISABLED
82  {LACP_ACTION_CURRENT, LACP_RX_STATE_CURRENT}, // event 5 PDU_RECEIVED
83  {LACP_ACTION_DEFAULTED, LACP_RX_STATE_DEFAULTED}, // event 6 TIMER_EXPIRED
84 };
85 
86 /*
87  * LACP State = CURRENT
88  */
90  {LACP_ACTION_INITIALIZE, LACP_RX_STATE_INITIALIZE}, // event 0 BEGIN
91  {LACP_NOACTION, LACP_RX_STATE_CURRENT}, // event 1 PORT_DISABLED
92  {LACP_NOACTION, LACP_RX_STATE_CURRENT}, // event 1 PORT_MOVED
93  {LACP_NOACTION, LACP_RX_STATE_CURRENT}, // event 2 LACP_ENABLED
94  {LACP_ACTION_LACP_DISABLED, LACP_RX_STATE_LACP_DISABLED}, // event 3 LACP_DISABLED
95  {LACP_ACTION_CURRENT, LACP_RX_STATE_CURRENT}, // event 4 PDU_RECEIVED
96  {LACP_ACTION_EXPIRED, LACP_RX_STATE_EXPIRED}, // event 5 TIMER_EXPIRED
97 };
98 
106 };
107 
111 };
112 
113 static void
115 {
116  mif->selected = LACP_PORT_UNSELECTED;
117 
118  switch (mif->mux_state)
119  {
120  case LACP_MUX_STATE_DETACHED:
121  break;
122  case LACP_MUX_STATE_WAITING:
123  break;
124  case LACP_MUX_STATE_ATTACHED:
125  return;
126  break;
127  case LACP_MUX_STATE_COLLECTING_DISTRIBUTING:
128  if (mif->partner.state & LACP_STATE_SYNCHRONIZATION)
129  return;
130  break;
131  default:
132  break;
133  }
135  LACP_MUX_EVENT_UNSELECTED, &mif->mux_state);
136 }
137 
138 static void
140 {
141  if ((mif->partner_admin.state & LACP_STATE_AGGREGATION) !=
142  (mif->partner.state & LACP_STATE_AGGREGATION) ||
143  memcmp (&mif->partner, &mif->partner_admin,
144  sizeof (mif->partner) - sizeof (mif->partner.state)))
145  {
147  }
148 }
149 
150 static void
152 {
153  mif->partner = mif->partner_admin;
154  mif->actor.state |= LACP_STATE_DEFAULTED;
155 }
156 
157 static void
159 {
160  lacp_pdu_t *lacpdu = (lacp_pdu_t *) mif->last_rx_pkt;
161 
162  if ((lacpdu->actor.port_info.state & LACP_STATE_AGGREGATION) !=
163  (mif->partner.state & LACP_STATE_AGGREGATION) ||
164  memcmp (&mif->partner, &lacpdu->actor.port_info,
165  sizeof (mif->partner) - sizeof (mif->partner.state)))
166  {
168  }
169 }
170 
171 static void
173 {
174  lacp_pdu_t *lacpdu = (lacp_pdu_t *) mif->last_rx_pkt;
175  u8 states = LACP_STATE_LACP_ACTIVITY | LACP_STATE_LACP_TIMEOUT |
176  LACP_STATE_SYNCHRONIZATION | LACP_STATE_AGGREGATION;
177 
178  if ((states & lacpdu->partner.port_info.state) !=
179  (states & mif->actor.state)
180  || memcmp (&mif->actor, &lacpdu->partner.port_info,
181  sizeof (mif->actor) - sizeof (mif->actor.state)))
182  {
183  mif->ntt = 1;
184  lacp_start_periodic_timer (vm, mif, 0);
185  }
186 }
187 
188 /*
189  * compare lacpdu partner info against mif->partner. Return 1 if they match, 0
190  * otherwise.
191  */
192 static u8
194 {
195  lacp_pdu_t *lacpdu = (lacp_pdu_t *) mif->last_rx_pkt;
196 
197  if ((!memcmp (&mif->partner, &lacpdu->actor.port_info,
198  sizeof (mif->partner) - sizeof (mif->partner.state)) &&
199  ((mif->actor.state & LACP_STATE_AGGREGATION) ==
200  (lacpdu->partner.port_info.state & LACP_STATE_AGGREGATION))) ||
201  ((lacpdu->actor.port_info.state & LACP_STATE_AGGREGATION) == 0))
202  return 1;
203 
204  return 0;
205 }
206 
207 static void
209 {
210  lacp_pdu_t *lacpdu = (lacp_pdu_t *) mif->last_rx_pkt;
211  u8 match;
212 
213  /* Transition PTX out of NO_PERIODIC if needed */
214  if (!(mif->partner.state & LACP_STATE_LACP_ACTIVITY) &&
215  (lacpdu->actor.port_info.state & LACP_STATE_LACP_ACTIVITY))
217  match = lacp_compare_partner (mif);
218  mif->partner = lacpdu->actor.port_info;
219  mif->actor.state &= ~LACP_STATE_DEFAULTED;
220  if (match && (lacpdu->actor.port_info.state & LACP_STATE_SYNCHRONIZATION))
221  mif->partner.state |= LACP_STATE_SYNCHRONIZATION;
222  else
223  mif->partner.state &= ~LACP_STATE_SYNCHRONIZATION;
224 }
225 
226 static void
228 {
229  mif->port_moved = val;
230 
231  if (mif->port_moved)
233  LACP_RX_EVENT_PORT_MOVED, &mif->rx_state);
234  else if (!mif->port_enabled)
236  LACP_RX_EVENT_PORT_DISABLED, &mif->rx_state);
237 }
238 
239 int
240 lacp_rx_action_initialize (void *p1, void *p2)
241 {
242  vlib_main_t *vm = p1;
243  member_if_t *mif = p2;
244 
246  lacp_record_default (mif);
247  mif->actor.state &= ~LACP_STATE_EXPIRED;
248  lacp_set_port_moved (vm, mif, 0);
249  /* UCT */
251  LACP_RX_EVENT_BEGIN, &mif->rx_state);
252 
253  return 0;
254 }
255 
256 int
257 lacp_rx_action_port_disabled (void *p1, void *p2)
258 {
259  vlib_main_t *vm = p1;
260  member_if_t *mif = p2;
261 
262  mif->partner.state &= ~LACP_STATE_SYNCHRONIZATION;
263  if (mif->port_moved)
264  {
266  LACP_RX_EVENT_PORT_MOVED, &mif->rx_state);
267  }
268  if (mif->port_enabled)
269  {
270  if (mif->lacp_enabled)
272  LACP_RX_EVENT_LACP_ENABLED, &mif->rx_state);
273  else
275  LACP_RX_EVENT_LACP_DISABLED, &mif->rx_state);
276  }
277 
278  return 0;
279 }
280 
281 int
282 lacp_rx_action_expired (void *p1, void *p2)
283 {
284  vlib_main_t *vm = p1;
285  member_if_t *mif = p2;
286  u8 timer_expired;
287 
288  mif->partner.state &= ~LACP_STATE_SYNCHRONIZATION;
289  mif->partner.state |= LACP_STATE_LACP_TIMEOUT;
293  timer_expired = 1;
294  else
295  timer_expired = 0;
297  mif->actor.state |= LACP_STATE_EXPIRED;
298  if (timer_expired)
300  LACP_RX_EVENT_TIMER_EXPIRED, &mif->rx_state);
301  if (mif->last_rx_pkt && vec_len (mif->last_rx_pkt))
303  LACP_RX_EVENT_PDU_RECEIVED, &mif->rx_state);
304 
305  return 0;
306 }
307 
308 int
309 lacp_rx_action_lacp_disabled (void *p1, void *p2)
310 {
311  vlib_main_t *vm = p1;
312  member_if_t *mif = p2;
313 
315  lacp_record_default (mif);
316  mif->partner.state &= ~LACP_STATE_AGGREGATION;
317  mif->actor.state &= ~LACP_STATE_EXPIRED;
318 
319  return 0;
320 }
321 
322 int
323 lacp_rx_action_defaulted (void *p1, void *p2)
324 {
325  vlib_main_t *vm = p1;
326  member_if_t *mif = p2;
327 
330  lacp_record_default (mif);
331  mif->actor.state &= ~LACP_STATE_EXPIRED;
332  if (mif->last_rx_pkt && vec_len (mif->last_rx_pkt))
334  LACP_RX_EVENT_PDU_RECEIVED, &mif->rx_state);
335 
336  return 0;
337 }
338 
339 static int
341 {
342  bond_main_t *bm = &bond_main;
343  member_if_t *mif2;
344  lacp_pdu_t *lacpdu = (lacp_pdu_t *) mif->last_rx_pkt;
345 
346  /* *INDENT-OFF* */
347  pool_foreach (mif2, bm->neighbors) {
348  {
349  if ((mif != mif2) && (mif2->rx_state == LACP_RX_STATE_PORT_DISABLED) &&
350  !memcmp (mif2->partner.system,
351  lacpdu->partner.port_info.system, 6) &&
352  (mif2->partner.port_number == lacpdu->partner.port_info.port_number))
353  return 1;
354  }
355  }
356  /* *INDENT-ON* */
357 
358  return 0;
359 }
360 
361 int
362 lacp_rx_action_current (void *p1, void *p2)
363 {
364  vlib_main_t *vm = p1;
365  member_if_t *mif = p2;
366 
367  lacp_update_selected (vm, mif);
368  lacp_update_ntt (vm, mif);
369  lacp_record_pdu (vm, mif);
371  mif->actor.state &= ~LACP_STATE_EXPIRED;
372  if (lacp_port_is_moved (vm, mif))
373  lacp_set_port_moved (vm, mif, 1);
374 
375  return lacp_selection_logic (vm, mif);
376 }
377 
378 static u8 *
379 format_rx_event (u8 * s, va_list * args)
380 {
381  static lacp_event_struct lacp_rx_event_array[] = {
382 #define _(b, s, n) {.bit = b, .str = #s, },
384 #undef _
385  {.str = NULL}
386  };
387  int e = va_arg (*args, int);
388  lacp_event_struct *event_entry = lacp_rx_event_array;
389 
390  if (e >= (sizeof (lacp_rx_event_array) / sizeof (*event_entry)))
391  s = format (s, "Bad event %d", e);
392  else
393  s = format (s, "%s", event_entry[e].str);
394 
395  return s;
396 }
397 
398 void
399 lacp_rx_debug_func (member_if_t * mif, int event, int state,
400  lacp_fsm_state_t * transition)
401 {
403  /* *INDENT-OFF* */
404  ELOG_TYPE_DECLARE (e) =
405  {
406  .format = "%s",
407  .format_args = "T4",
408  };
409  /* *INDENT-ON* */
410  struct
411  {
412  u32 event;
413  } *ed = 0;
414 
416  ed->event = elog_string (&vlib_global_main.elog_main, "%U-RX: %U, %U->%U%c",
418  mif->sw_if_index, format_rx_event, event,
420  transition->next_state, 0);
421 }
422 
423 void
425 {
426  lacp_machine_dispatch (&lacp_rx_machine, vm, mif, LACP_RX_EVENT_BEGIN,
427  &mif->rx_state);
429  LACP_RX_EVENT_LACP_ENABLED, &mif->rx_state);
430 }
431 
432 /*
433  * fd.io coding-style-patch-verification: ON
434  *
435  * Local Variables:
436  * eval: (c-set-style "gnu")
437  * End:
438  */
lacp_timer_is_expired
static u8 lacp_timer_is_expired(vlib_main_t *vm, f64 timer)
Definition: node.h:174
lacp_record_pdu
static void lacp_record_pdu(vlib_main_t *vm, member_if_t *mif)
Definition: rx_machine.c:208
lacp_update_selected
static void lacp_update_selected(vlib_main_t *vm, member_if_t *mif)
Definition: rx_machine.c:158
lacp_rx_action_lacp_disabled
int lacp_rx_action_lacp_disabled(void *p1, void *p2)
Definition: rx_machine.c:309
format_rx_event
static u8 * format_rx_event(u8 *s, va_list *args)
Definition: rx_machine.c:379
lacp_timer_is_running
static u8 lacp_timer_is_running(f64 timer)
Definition: node.h:168
lacp_rx_state_current
static lacp_fsm_state_t lacp_rx_state_current[]
Definition: rx_machine.c:89
lacp_rx_debug_func
void lacp_rx_debug_func(member_if_t *mif, int event, int state, lacp_fsm_state_t *transition)
Definition: rx_machine.c:399
LACP_ACTION_INITIALIZE
#define LACP_ACTION_INITIALIZE
Definition: rx_machine.h:65
member_if_t::ntt
u8 ntt
Definition: node.h:262
lacp_rx_state_defaulted
static lacp_fsm_state_t lacp_rx_state_defaulted[]
Definition: rx_machine.c:76
format_rx_sm_state
static u8 * format_rx_sm_state(u8 *s, va_list *args)
Definition: node.h:182
bond_main
bond_main_t bond_main
Definition: node.c:25
lacp_rx_state_initialize
static lacp_fsm_state_t lacp_rx_state_initialize[]
Definition: rx_machine.c:24
lacp_event_struct
Definition: protocol.h:91
lacp_start_periodic_timer
static void lacp_start_periodic_timer(vlib_main_t *vm, member_if_t *mif, u8 expiration)
Definition: ptx_machine.h:67
member_if_t::ttl_in_seconds
f32 ttl_in_seconds
Definition: node.h:221
lacp_ptx_post_short_timeout_event
static void lacp_ptx_post_short_timeout_event(vlib_main_t *vm, member_if_t *mif)
Definition: ptx_machine.h:90
vm
vlib_main_t * vm
X-connect all packets from the HOST to the PHY.
Definition: nat44_ei.c:3047
state
vl_api_dhcp_client_state_t state
Definition: dhcp.api:201
elog_string
__clib_export u32 elog_string(elog_main_t *em, char *fmt,...)
add a string to the event-log string table
Definition: elog.c:582
lacp_fsm_state_t
Definition: machine.h:26
lacp_start_current_while_timer
static void lacp_start_current_while_timer(vlib_main_t *vm, member_if_t *mif, u8 expiration)
Definition: rx_machine.h:77
vlib_worker_threads
vlib_worker_thread_t * vlib_worker_threads
Definition: threads.c:35
member_if_t::rx_state
int rx_state
Definition: node.h:313
member_if_t::last_rx_pkt
u8 * last_rx_pkt
Definition: node.h:239
LACP_ACTION_LACP_DISABLED
#define LACP_ACTION_LACP_DISABLED
Definition: rx_machine.h:71
LACP_ACTION_EXPIRED
#define LACP_ACTION_EXPIRED
Definition: rx_machine.h:69
lacp_rx_state_lacp_disabled
static lacp_fsm_state_t lacp_rx_state_lacp_disabled[]
Definition: rx_machine.c:63
foreach_lacp_rx_event
@ foreach_lacp_rx_event
Definition: rx_machine.h:34
member_if_t::mux_state
int mux_state
Definition: node.h:315
pool_foreach
#define pool_foreach(VAR, POOL)
Iterate through pool.
Definition: pool.h:534
lacp_rx_machine
lacp_machine_t lacp_rx_machine
Definition: rx_machine.c:108
vec_len
#define vec_len(v)
Number of elements in vector (rvalue-only, NULL tolerant)
Definition: vec_bootstrap.h:142
ELOG_TYPE_DECLARE
#define ELOG_TYPE_DECLARE(f)
Definition: elog.h:442
ELOG_TRACK_DATA
#define ELOG_TRACK_DATA(em, f, track)
Definition: elog.h:478
lacp_selection_logic
int lacp_selection_logic(vlib_main_t *vm, member_if_t *mif)
Definition: selection.c:76
member_if_t::partner
lacp_port_info_t partner
Definition: node.h:254
vnet_get_main
vnet_main_t * vnet_get_main(void)
Definition: pnat_test_stubs.h:56
lacp_rx_state_port_disabled
static lacp_fsm_state_t lacp_rx_state_port_disabled[]
Definition: rx_machine.c:37
vlib_global_main
vlib_global_main_t vlib_global_main
Definition: main.c:1786
lacp_rx_action_port_disabled
int lacp_rx_action_port_disabled(void *p1, void *p2)
Definition: rx_machine.c:257
if
if(node->flags &VLIB_NODE_FLAG_TRACE) vnet_interface_output_trace(vm
lacp_rx_state_expired
static lacp_fsm_state_t lacp_rx_state_expired[]
Definition: rx_machine.c:50
member_if_t::actor
lacp_port_info_t actor
Definition: node.h:255
bond_main_t::neighbors
member_if_t * neighbors
Definition: node.h:370
node.h
lacp_fsm_machine_t
Definition: machine.h:35
lacp_record_default
static void lacp_record_default(member_if_t *mif)
Definition: rx_machine.c:151
member_if_t::sw_if_index
u32 sw_if_index
Definition: node.h:218
lacp_mux_machine
lacp_machine_t lacp_mux_machine
Definition: mux_machine.c:77
vlib_global_main_t::elog_main
elog_main_t elog_main
Definition: main.h:302
os_get_thread_index
static_always_inline uword os_get_thread_index(void)
Definition: os.h:63
member_if_t::selected
int selected
Definition: node.h:280
member_if_t::port_moved
u8 port_moved
Definition: node.h:283
lacp_machine_dispatch
int lacp_machine_dispatch(lacp_machine_t *machine, vlib_main_t *vm, member_if_t *mif, int event, int *state)
Definition: lacp.c:317
lacp_update_default_selected
static void lacp_update_default_selected(vlib_main_t *vm, member_if_t *mif)
Definition: rx_machine.c:139
member_if_t::port_enabled
u8 port_enabled
Definition: node.h:265
lacp_set_port_unselected
static void lacp_set_port_unselected(vlib_main_t *vm, member_if_t *mif)
Definition: rx_machine.c:114
format_vnet_sw_if_index_name
format_function_t format_vnet_sw_if_index_name
Definition: interface_funcs.h:458
member_if_t
Definition: node.h:213
format
description fragment has unexpected format
Definition: map.api:433
lacp_stop_timer
static void lacp_stop_timer(f64 *timer)
Definition: node.h:162
u32
unsigned int u32
Definition: types.h:88
member_if_t::current_while_timer
f64 current_while_timer
Definition: node.h:286
lacp_compare_partner
static u8 lacp_compare_partner(member_if_t *mif)
Definition: rx_machine.c:193
vlib_worker_thread_t
Definition: threads.h:81
vlib_worker_thread_t::elog_track
elog_track_t elog_track
Definition: threads.h:95
LACP_ACTION_CURRENT
#define LACP_ACTION_CURRENT
Definition: rx_machine.h:74
vlib_main_t
Definition: main.h:102
lacp_rx_action_current
int lacp_rx_action_current(void *p1, void *p2)
Definition: rx_machine.c:362
LACP_ACTION_DEFAULTED
#define LACP_ACTION_DEFAULTED
Definition: rx_machine.h:73
u8
unsigned char u8
Definition: types.h:56
member_if_t::partner_admin
lacp_port_info_t partner_admin
Definition: node.h:255
lacp_rx_action_initialize
int lacp_rx_action_initialize(void *p1, void *p2)
Definition: rx_machine.c:240
lacp_rx_fsm_table
static lacp_fsm_machine_t lacp_rx_fsm_table[]
Definition: rx_machine.c:99
lacp_port_is_moved
static int lacp_port_is_moved(vlib_main_t *vm, member_if_t *mif)
Definition: rx_machine.c:340
lacp_fsm_state_t::next_state
int next_state
Definition: machine.h:29
LACP_ACTION_PORT_DISABLED
#define LACP_ACTION_PORT_DISABLED
Definition: rx_machine.h:67
lacp_set_port_moved
static void lacp_set_port_moved(vlib_main_t *vm, member_if_t *mif, u8 val)
Definition: rx_machine.c:227
lacp_update_ntt
static void lacp_update_ntt(vlib_main_t *vm, member_if_t *mif)
Definition: rx_machine.c:172
bond_main_t
Definition: node.h:361
member_if_t::lacp_enabled
u8 lacp_enabled
Definition: node.h:271
LACP_NOACTION
#define LACP_NOACTION
Definition: machine.h:21
lacp_machine_t
Definition: machine.h:40
lacp_init_rx_machine
void lacp_init_rx_machine(vlib_main_t *vm, member_if_t *mif)
Definition: rx_machine.c:424
lacp_rx_action_defaulted
int lacp_rx_action_defaulted(void *p1, void *p2)
Definition: rx_machine.c:323
node.h
lacp_rx_action_expired
int lacp_rx_action_expired(void *p1, void *p2)
Definition: rx_machine.c:282