82c5dda455
By definition, passive mode means the node does not start sending lacp pdu until it first hears from the partner or remote. - Rename ptx machine's BEGIN state to NO_PERIODIC state. - Put periodic machine in NO_PERIDOIC state when the interface is enabled for lacp. ptx machine will transition out of NO_PERIODIC state when the local node hears from the remote or when the local node is configured for active mode. - Also add send and receive statistics for debugging. Change-Id: I747953b9595ed31328b2f4f3e7a8d15d01e04d7f Signed-off-by: Steven Luong <sluong@cisco.com>
108 lines
3.3 KiB
C
108 lines
3.3 KiB
C
/*
|
|
* 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.
|
|
*/
|
|
|
|
#ifndef ___LACP_PTX_MACHINE_H__
|
|
#define ___LACP_PTX_MACHINE_H__
|
|
|
|
#include <stdint.h>
|
|
#include <lacp/machine.h>
|
|
|
|
#define foreach_lacp_ptx_event \
|
|
_(0, NO_PERIODIC, "no periodic") \
|
|
_(1, LONG_TIMEOUT, "long tiemout") \
|
|
_(2, TIMER_EXPIRED, "timer expired") \
|
|
_(3, SHORT_TIMEOUT, "short timeout")
|
|
|
|
typedef enum
|
|
{
|
|
#define _(a, b, c) LACP_PTX_EVENT_##b = (a),
|
|
foreach_lacp_ptx_event
|
|
#undef _
|
|
} lacp_ptx_event_t;
|
|
|
|
#define foreach_lacp_ptx_sm_state \
|
|
_(0, NO_PERIODIC, "no periodic") \
|
|
_(1, FAST_PERIODIC, "fast periodic") \
|
|
_(2, SLOW_PERIODIC, "slow periodic") \
|
|
_(3, PERIODIC_TX, "periodic transmission")
|
|
|
|
typedef enum
|
|
{
|
|
#define _(a, b, c) LACP_PTX_STATE_##b = (a),
|
|
foreach_lacp_ptx_sm_state
|
|
#undef _
|
|
} lacp_ptx_sm_state_t;
|
|
|
|
extern lacp_machine_t lacp_ptx_machine;
|
|
|
|
int lacp_ptx_action_no_periodic (void *p1, void *p2);
|
|
int lacp_ptx_action_slow_periodic (void *p1, void *p2);
|
|
int lacp_ptx_action_fast_periodic (void *p1, void *p2);
|
|
int lacp_ptx_action_timer_expired (void *p1, void *p2);
|
|
void lacp_ptx_debug_func (slave_if_t * sif, int event, int state,
|
|
lacp_fsm_state_t * transition);
|
|
|
|
#define LACP_ACTION_NO_PERIODIC \
|
|
LACP_ACTION_ROUTINE(lacp_ptx_action_no_periodic)
|
|
#define LACP_ACTION_SLOW_PERIODIC \
|
|
LACP_ACTION_ROUTINE(lacp_ptx_action_slow_periodic)
|
|
#define LACP_ACTION_FAST_PERIODIC \
|
|
LACP_ACTION_ROUTINE(lacp_ptx_action_fast_periodic)
|
|
#define LACP_ACTION_TIMER_EXPIRED \
|
|
LACP_ACTION_ROUTINE(lacp_ptx_action_timer_expired)
|
|
|
|
static inline void
|
|
lacp_start_periodic_timer (vlib_main_t * vm, slave_if_t * sif, u8 expiration)
|
|
{
|
|
sif->periodic_timer = vlib_time_now (vm) + expiration;
|
|
}
|
|
|
|
static inline void
|
|
lacp_schedule_periodic_timer (vlib_main_t * vm, slave_if_t * sif)
|
|
{
|
|
// do fast rate if partner is in short timeout or
|
|
// we are not yet synchronized
|
|
if ((sif->partner.state & LACP_STATE_LACP_TIMEOUT) ||
|
|
(((sif->actor.state & (LACP_STATE_SYNCHRONIZATION |
|
|
LACP_STATE_COLLECTING |
|
|
LACP_STATE_DISTRIBUTING)) !=
|
|
(LACP_STATE_SYNCHRONIZATION | LACP_STATE_COLLECTING |
|
|
LACP_STATE_DISTRIBUTING))
|
|
&& (sif->partner.state & LACP_STATE_AGGREGATION)))
|
|
lacp_start_periodic_timer (vm, sif, LACP_FAST_PERIODIC_TIMER);
|
|
else
|
|
lacp_start_periodic_timer (vm, sif, LACP_SLOW_PERIODIC_TIMER);
|
|
}
|
|
|
|
static inline void
|
|
lacp_ptx_post_short_timeout_event (vlib_main_t * vm, slave_if_t * sif)
|
|
{
|
|
if (sif->lacp_enabled && sif->port_enabled &&
|
|
((sif->partner.state & LACP_STATE_LACP_ACTIVITY) ||
|
|
(sif->actor.state & LACP_STATE_LACP_ACTIVITY)))
|
|
lacp_machine_dispatch (&lacp_ptx_machine, vm, sif,
|
|
LACP_PTX_EVENT_SHORT_TIMEOUT, &sif->ptx_state);
|
|
}
|
|
|
|
#endif /* __LACP_PTX_MACHINE_H__ */
|
|
|
|
/*
|
|
* fd.io coding-style-patch-verification: ON
|
|
*
|
|
* Local Variables:
|
|
* eval: (c-set-style "gnu")
|
|
* End:
|
|
*/
|