1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
|
/*
* Copyright (c) 2017 Cisco and/or its affiliates.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at:
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#define _GNU_SOURCE
#include <vnet/bonding/node.h>
#include <lacp/node.h>
/*
* LACP State = TRANSMIT
*/
static lacp_fsm_state_t lacp_tx_state_transmit[] = {
{LACP_ACTION_TRANSMIT, LACP_TX_STATE_TRANSMIT}, // event 0 BEGIN
{LACP_ACTION_TRANSMIT, LACP_TX_STATE_TRANSMIT}, // event 1 NTT
};
static lacp_fsm_machine_t lacp_tx_fsm_table[] = {
{lacp_tx_state_transmit},
};
lacp_machine_t lacp_tx_machine = {
lacp_tx_fsm_table,
lacp_tx_debug_func,
};
int
lacp_tx_action_transmit (void *p1, void *p2)
{
vlib_main_t *vm = p1;
member_if_t *mif = p2;
f64 now = vlib_time_now (vm);
if (!lacp_timer_is_running (mif->periodic_timer))
return 0;
// No more than 3 LACPDUs per fast interval
if (now <= (mif->last_lacpdu_sent_time + 0.333))
return 0;
if (mif->ntt)
{
lacp_send_lacp_pdu (vm, mif);
lacp_schedule_periodic_timer (vm, mif);
}
mif->ntt = 0;
return 0;
}
static u8 *
format_tx_event (u8 * s, va_list * args)
{
static lacp_event_struct lacp_tx_event_array[] = {
#define _(b, s, n) {.bit = b, .str = #s, },
foreach_lacp_tx_event
#undef _
{.str = NULL}
};
int e = va_arg (*args, int);
lacp_event_struct *event_entry = lacp_tx_event_array;
if (e >= (sizeof (lacp_tx_event_array) / sizeof (*event_entry)))
s = format (s, "Bad event %d", e);
else
s = format (s, "%s", event_entry[e].str);
return s;
}
void
lacp_tx_debug_func (member_if_t * mif, int event, int state,
lacp_fsm_state_t * transition)
{
vlib_worker_thread_t *w = vlib_worker_threads + os_get_thread_index ();
ELOG_TYPE_DECLARE (e) =
{
.format = "%s",
.format_args = "T4",
};
struct
{
u32 event;
} *ed = 0;
ed = ELOG_TRACK_DATA (&vlib_global_main.elog_main, e, w->elog_track);
ed->event = elog_string (&vlib_global_main.elog_main, "%U-TX: %U, %U->%U%c",
format_vnet_sw_if_index_name, vnet_get_main (),
mif->sw_if_index, format_tx_event, event,
format_tx_sm_state, state, format_tx_sm_state,
transition->next_state, 0);
}
void
lacp_init_tx_machine (vlib_main_t * vm, member_if_t * mif)
{
lacp_machine_dispatch (&lacp_tx_machine, vm, mif, LACP_TX_EVENT_BEGIN,
&mif->tx_state);
}
/*
* fd.io coding-style-patch-verification: ON
*
* Local Variables:
* eval: (c-set-style "gnu")
* End:
*/
|
