/*
* Copyright (c) 2016 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.
*/
#ifndef __FIB_WALK_H__
#define __FIB_WALK_H__
#include <vnet/fib/fib_node.h>
/**
* @brief Walk priorities.
* Strict priorities. All walks a priority n are completed before n+1 is started.
* Increasing numerical value implies decreasing priority.
*/
typedef enum fib_walk_priority_t_
{
FIB_WALK_PRIORITY_HIGH = 0,
FIB_WALK_PRIORITY_LOW = 1,
} fib_walk_priority_t;
#define FIB_WALK_PRIORITY_NUM ((fib_walk_priority_t)(FIB_WALK_PRIORITY_LOW+1))
#define FIB_WALK_PRIORITIES { \
[FIB_WALK_PRIORITY_HIGH] = "high", \
[FIB_WALK_PRIORITY_LOW] = "low", \
}
#define FOR_EACH_FIB_WALK_PRIORITY(_prio) \
for ((_prio) = FIB_WALK_PRIORITY_HIGH; \
(_prio) < FIB_WALK_PRIORITY_NUM; \
(_prio)++)
extern void fib_walk_module_init(void);
extern void fib_walk_async(fib_node_type_t parent_type,
fib_node_index_t parent_index,
fib_walk_priority_t prio,
fib_node_back_walk_ctx_t *ctx);
extern void fib_walk_sync(fib_node_type_t parent_type,
fib_node_index_t parent_index,
fib_node_back_walk_ctx_t *ctx);
extern u8* format_fib_walk_priority(u8 */*
* 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 = INITIALIZE
*/
static lacp_fsm_state_t lacp_rx_state_initialize[] = {
{LACP_ACTION_INITIALIZE, LACP_RX_STATE_PORT_DISABLED}, // event 0 BEGIN
{LACP_ACTION_INITIALIZE, LACP_RX_STATE_PORT_DISABLED}, // event 1 PORT_DISABLED
{LACP_ACTION_INITIALIZE, LACP_RX_STATE_PORT_DISABLED}, // event 2 PORT_MOVED
{LACP_NOACTION, LACP_RX_STATE_INITIALIZE}, // event 3 LACP_ENABLED
{LACP_NOACTION, LACP_RX_STATE_INITIALIZE}, // event 4 LACP_DISABLED
{LACP_NOACTION, LACP_RX_STATE_INITIALIZE}, // event 5 PDU_RECEIVED
{LACP_NOACTION, LACP_RX_STATE_INITIALIZE}, // event 6 TIMER_EXPIRED
};
/*
* LACP State = PORT_DISABLED
*/
static lacp_fsm_state_t lacp_rx_state_port_disabled[] = {
{LACP_ACTION_PORT_DISABLED, LACP_RX_STATE_PORT_DISABLED}, // event 0 BEGIN
{LACP_ACTION_PORT_DISABLED, LACP_RX_STATE_PORT_DISABLED}, // event 1 PORT_DISABLED
{LACP_ACTION_INITIALIZE, LACP_RX_STATE_INITIALIZE}, // event 2 PORT_MOVED
{LACP_ACTION_EXPIRED, LACP_RX_STATE_EXPIRED}, // event 3 LACP_ENABLED
{LACP_ACTION_LACP_DISABLED, LACP_RX_STATE_LACP_DISABLED}, // event 4 LACP_DISABLED
{LACP_NOACTION, LACP_RX_STATE_PORT_DISABLED}, // event 5 PDU_RECEIVED
{LACP_NOACTION, LACP_RX_STATE_PORT_DISABLED}, // event 6 TIMER_EXPIRED
};
/*
* LACP State = EXPIRED
*/
static lacp_fsm_state_t lacp_rx_state_expired[] = {
{LACP_ACTION_INITIALIZE, LACP_RX_STATE_INITIALIZE}, // event 0 BEGIN
{LACP_NOACTION, LACP_RX_STATE_EXPIRED}, // event 1 PORT_DISABLED
{LACP_NOACTION, LACP_RX_STATE_EXPIRED}, // event 2 PORT_MOVED
{LACP_NOACTION, LACP_RX_STATE_EXPIRED}, // event 3 LACP_ENABLED
{LACP_NOACTION, LACP_RX_STATE_EXPIRED}, // event 4 LACP_DISABLED
{LACP_ACTION_CURRENT, LACP_RX_STATE_CURRENT}, // event 5 PDU_RECEIVED
{LACP_ACTION_DEFAULTED, LACP_RX_STATE_DEFAULTED}, // event 6 TIMER_EXPIRED
};
/*
* LACP State = LACP_DISABLED
*/
static lacp_fsm_state_t lacp_rx_state_lacp_disabled[] = {
{LACP_ACTION_INITIALIZE, LACP_RX_STATE_INITIALIZE}, // event 0 BEGIN
{LACP_NOACTION, LACP_RX_STATE_LACP_DISABLED}, // event 1 PORT_DISABLED
{LACP_NOACTION, LACP_RX_STATE_LACP_DISABLED}, // event 2 PORT_MOVED
{LACP_ACTION_EXPIRED, LACP_RX_STATE_EXPIRED}, // event 3 LACP_ENABLED XXX
{LACP_ACTION_LACP_DISABLED, LACP_RX_STATE_LACP_DISABLED}, // event 4 LACP_DISABLED
{LACP_NOACTION, LACP_RX_STATE_LACP_DISABLED}, // event 5 PDU_RECEIVED
{LACP_NOACTION, LACP_RX_STATE_LACP_DISABLED}, // event 6 TIMER_EXPIRED
};
/*
* LACP State = DEFAULTED
*/
static lacp_fsm_state_t lacp_rx_state_defaulted[] = {
{LACP_ACTION_INITIALIZE, LACP_RX_STATE_INITIALIZE}, // event 0 BEGIN
{LACP_NOACTION, LACP_RX_STATE_DEFAULTED}, // event 1 PORT_DISABLED
{LACP_NOACTION, LACP_RX_STATE_DEFAULTED}, // event 2 PORT_MOVED
{LACP_NOACTION, LACP_RX_STATE_DEFAULTED}, // event 3 LACP_ENABLED
{LACP_ACTION_LACP_DISABLED, LACP_RX_STATE_LACP_DISABLED}, // event 4 LACP_DISABLED
{LACP_ACTION_CURRENT, LACP_RX_STATE_CURRENT}, // event 5 PDU_RECEIVED
{LACP_ACTION_DEFAULTED, LACP_RX_STATE_DEFAULTED}, // event 6 TIMER_EXPIRED
};
/*
* LACP State = CURRENT
*/
static lacp_fsm_state_t lacp_rx_state_current[] = {
{LACP_ACTION_INITIALIZE, LACP_RX_STATE_INITIALIZE}, // event 0 BEGIN
{LACP_NOACTION, LACP_RX_STATE_CURRENT}, // event 1 PORT_DISABLED
{LACP_NOACTION, LACP_RX_STATE_CURRENT}, // event 1 PORT_MOVED
{LACP_NOACTION, LACP_RX_STATE_CURRENT}, // event 2 LACP_ENABLED
{LACP_ACTION_LACP_DISABLED, LACP_RX_STATE_LACP_DISABLED}, // event 3 LACP_DISABLED
{LACP_ACTION_CURRENT, LACP_RX_STATE_CURRENT}, // event 4 PDU_RECEIVED
{LACP_ACTION_EXPIRED, LACP_RX_STATE_EXPIRED}, // event 5 TIMER_EXPIRED
};
static lacp_fsm_machine_t lacp_rx_fsm_table[] = {
{lacp_rx_state_initialize},
{lacp_rx_state_port_disabled},
{lacp_rx_state_expired},
{lacp_rx_state_lacp_disabled},
{lacp_rx_state_defaulted},
{lacp_rx_state_current},
};
lacp_machine_t lacp_rx_machine = {
lacp_rx_fsm_table,
lacp_rx_debug_func,
};
static void
lacp_set_port_unselected (vlib_main_t * vm, slave_if_t * sif)
{
sif->selected = LACP_PORT_UNSELECTED;
switch (sif->mux_state)
{
case LACP_MUX_STATE_DETACHED:
break;
case LACP_MUX_STATE_WAITING:
break;
case LACP_MUX_STATE_ATTACHED:
return;
break;
case LACP_MUX_STATE_COLLECTING_DISTRIBUTING:
if (sif->partner.state & LACP_STATE_SYNCHRONIZATION)
return;
break;
default:
break;
}
lacp_machine_dispatch (&lacp_mux_machine, vm, sif,
LACP_MUX_EVENT_UNSELECTED, &sif->mux_state);
}
static void
lacp_update_default_selected (vlib_main_t * vm, slave_if_t * sif)
{
if ((sif->partner_admin.state & LACP_STATE_AGGREGATION) !=
(sif->partner.state & LACP_STATE_AGGREGATION) ||
memcmp (&sif->partner, &sif->partner_admin,
sizeof (sif->partner) - sizeof (sif->partner.state)))
{
lacp_set_port_unselected (vm, sif);
}
}
static void
lacp_record_default (slave_if_t * sif)
{
sif->partner = sif->partner_admin;
sif->actor.state |= LACP_STATE_DEFAULTED;
}
static void
lacp_update_selected (vlib_main_t * vm, slave_if_t * sif)
{
lacp_pdu_t *lacpdu = (lacp_pdu_t *) sif->last_rx_pkt;
if ((lacpdu->actor.port_info.state & LACP_STATE_AGGREGATION) !=
(sif->partner.state & LACP_STATE_AGGREGATION) ||
memcmp (&sif->partner, &lacpdu->actor.port_info,
sizeof (sif->partner) - sizeof (sif->partner.state)))
{
lacp_set_port_unselected (vm, sif);
}
}
static void
lacp_update_ntt (vlib_main_t * vm, slave_if_t * sif)
{
lacp_pdu_t *lacpdu = (lacp_pdu_t *) sif->last_rx_pkt;
u8 states = LACP_STATE_LACP_ACTIVITY | LACP_STATE_LACP_TIMEOUT |
LACP_STATE_SYNCHRONIZATION | LACP_STATE_AGGREGATION;
lacp_main_t *lm = &lacp_main;
if ((states & lacpdu->partner.port_info.state) !=
(states & sif->actor.state)
|| memcmp (&sif->actor, &lacpdu->partner.port_info,
sizeof (sif->actor) - sizeof (sif->actor.state)))
{
sif->ntt = 1;
lacp_start_periodic_timer (lm->vlib_main, sif, 0);
}
}
/*
* compare lacpdu partner info against sif->partner. Return 1 if they match, 0
* otherwise.
*/
static u8
lacp_compare_partner (slave_if_t * sif)
{
lacp_pdu_t *lacpdu = (lacp_pdu_t *) sif->last_rx_pkt;
if ((!memcmp (&sif->partner, &lacpdu->actor.port_info,
sizeof (sif->partner) - sizeof (sif->partner.state)) &&
((sif->actor.state & LACP_STATE_AGGREGATION) ==
(lacpdu->partner.port_info.state & LACP_STATE_AGGREGATION))) ||
((lacpdu->actor.port_info.state & LACP_STATE_AGGREGATION) == 0))
return 1;
return 0;
}
static void
lacp_record_pdu (vlib_main_t * vm, slave_if_t * sif)
{
lacp_pdu_t *lacpdu = (lacp_pdu_t *) sif->last_rx_pkt;
u8 match;
/* Transition PTX out of NO_PERIODIC if needed */
if (!(sif->partner.state & LACP_STATE_LACP_ACTIVITY) &&
(lacpdu->actor.port_info.state & LACP_STATE_LACP_ACTIVITY))
lacp_ptx_post_short_timeout_event (vm, sif);
match = lacp_compare_partner (sif);
sif->partner = lacpdu->actor.port_info;
sif->actor.state &= ~LACP_STATE_DEFAULTED;
if (match && (lacpdu->actor.port_info.state & LACP_STATE_SYNCHRONIZATION))
sif->partner.state |= LACP_STATE_SYNCHRONIZATION;
else
sif->partner.state &= ~LACP_STATE_SYNCHRONIZATION;
}
static void
lacp_set_port_moved (vlib_main_t * vm, slave_if_t * sif, u8 val)
{
sif->port_moved = val;
if (sif->port_moved)
lacp_machine_dispatch (&lacp_rx_machine, vm, sif,
LACP_RX_EVENT_PORT_MOVED, &sif->rx_state);
else if (!sif->port_enabled)
lacp_machine_dispatch (&lacp_rx_machine, vm, sif,
LACP_RX_EVENT_PORT_DISABLED, &sif->rx_state);
}
int
lacp_rx_action_initialize (void *p1, void *p2)
{
vlib_main_t *vm = p1;
slave_if_t *sif = p2;
lacp_set_port_unselected (vm, sif);
lacp_record_default (sif);
sif->actor.state &= ~LACP_STATE_EXPIRED;
lacp_set_port_moved (vm, sif, 0);
/* UCT */
lacp_machine_dispatch (&lacp_rx_machine, vm, sif,
LACP_RX_EVENT_BEGIN, &sif->rx_state);
return 0;
}
int
lacp_rx_action_port_disabled (void *p1, void *p2)
{
vlib_main_t *vm = p1;
slave_if_t *sif = p2;
sif->partner.state &= ~LACP_STATE_SYNCHRONIZATION;
if (sif->port_moved)
{
lacp_machine_dispatch (&lacp_rx_machine, vm, sif,
LACP_RX_EVENT_PORT_MOVED, &sif->rx_state);
}
if (sif->port_enabled)
{
if (sif->lacp_enabled)
lacp_machine_dispatch (&lacp_rx_machine, vm, sif,
LACP_RX_EVENT_LACP_ENABLED, &sif->rx_state);
else
lacp_machine_dispatch (&lacp_rx_machine, vm, sif,
LACP_RX_EVENT_LACP_DISABLED, &sif->rx_state);
}
return 0;
}
int
lacp_rx_action_expired (void *p1, void *p2)
{
vlib_main_t *vm = p1;
slave_if_t *sif = p2;
u8 timer_expired;
lacp_main_t *lm = &lacp_main;
sif->partner.state &= ~LACP_STATE_SYNCHRONIZATION;
sif->partner.state |= LACP_STATE_LACP_TIMEOUT;
lacp_ptx_post_short_timeout_event (vm, sif);
if (lacp_timer_is_running (sif->current_while_timer) &&
lacp_timer_is_expired (lm->vlib_main, sif->current_while_timer))
timer_expired = 1;
else
timer_expired = 0;
lacp_start_current_while_timer (lm->vlib_main, sif, sif->ttl_in_seconds);
sif->actor.state |= LACP_STATE_EXPIRED;
if (timer_expired)
lacp_machine_dispatch (&lacp_rx_machine, vm, sif,
LACP_RX_EVENT_TIMER_EXPIRED, &sif->rx_state);
if (sif->last_rx_pkt && vec_len (sif->last_rx_pkt))
lacp_machine_dispatch (&lacp_rx_machine, vm, sif,
LACP_RX_EVENT_PDU_RECEIVED, &sif->rx_state);
return 0;
}
int
lacp_rx_action_lacp_disabled (void *p1, void *p2)
{
vlib_main_t *vm = p1;
slave_if_t *sif = p2;
lacp_set_port_unselected (vm, sif);
lacp_record_default (sif);
sif->partner.state &= ~LACP_STATE_AGGREGATION;
sif->actor.state &= ~LACP_STATE_EXPIRED;
return 0;
}
int
lacp_rx_action_defaulted (void *p1, void *p2)
{
vlib_main_t *vm = p1;
slave_if_t *sif = p2;
lacp_stop_timer (&sif->current_while_timer);
lacp_update_default_selected (vm, sif);
lacp_record_default (sif);
sif->actor.state &= ~LACP_STATE_EXPIRED;
if (sif->last_rx_pkt && vec_len (sif->last_rx_pkt))
lacp_machine_dispatch (&lacp_rx_machine, vm, sif,
LACP_RX_EVENT_PDU_RECEIVED, &sif->rx_state);
return 0;
}
static int
lacp_port_is_moved (vlib_main_t * vm, slave_if_t * sif)
{
bond_main_t *bm = &bond_main;
slave_if_t *sif2;
lacp_pdu_t *lacpdu = (lacp_pdu_t *) sif->last_rx_pkt;
/* *INDENT-OFF* */
pool_foreach (sif2, bm->neighbors, {
{
if ((sif != sif2) && (sif2->rx_state == LACP_RX_STATE_PORT_DISABLED) &&
!memcmp (sif2->partner.system,
lacpdu->partner.port_info.system, 6) &&
(sif2->partner.port_number == lacpdu->partner.port_info.port_number))
return 1;
}
});
/* *INDENT-ON* */
return 0;
}
int
lacp_rx_action_current (void *p1, void *p2)
{
vlib_main_t *vm = p1;
slave_if_t *sif = p2;
lacp_main_t *lm = &lacp_main;
lacp_update_selected (vm, sif);
lacp_update_ntt (vm, sif);
lacp_record_pdu (vm, sif);
lacp_start_current_while_timer (lm->vlib_main, sif, sif->ttl_in_seconds);
sif->actor.state &= ~LACP_STATE_EXPIRED;
if (lacp_port_is_moved (vm, sif))
lacp_set_port_moved (vm, sif, 1);
lacp_selection_logic (vm, sif);
return 0;
}
static u8 *
format_rx_event (u8 * s, va_list * args)
{
static lacp_event_struct lacp_rx_event_array[] = {
#define _(b, s, n) {.bit = b, .str = #s, },
foreach_lacp_rx_event
#undef _
{.str = NULL}
};
int e = va_arg (*args, int);
lacp_event_struct *event_entry = lacp_rx_event_array;
if (e >= (sizeof (lacp_rx_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_rx_debug_func (slave_if_t * sif, int event, int state,
lacp_fsm_state_t * transition)
{
vlib_worker_thread_t *w = vlib_worker_threads + os_get_thread_index ();
/* *INDENT-OFF* */
ELOG_TYPE_DECLARE (e) =
{
.format = "%s",
.format_args = "T4",
};
/* *INDENT-ON* */
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-RX: %U, %U->%U%c",
format_vnet_sw_if_index_name, vnet_get_main (),
sif->sw_if_index, format_rx_event, event,
format_rx_sm_state, state, format_rx_sm_state,
transition->next_state, 0);
}
void
lacp_init_rx_machine (vlib_main_t * vm, slave_if_t * sif)
{
lacp_machine_dispatch (&lacp_rx_machine, vm, sif, LACP_RX_EVENT_BEGIN,
&sif->rx_state);
lacp_machine_dispatch (&lacp_rx_machine, vm, sif,
LACP_RX_EVENT_LACP_ENABLED, &sif->rx_state);
}
/*
* fd.io coding-style-patch-verification: ON
*
* Local Variables:
* eval: (c-set-style "gnu")
* End:
*/
