26 #define foreach_bond_input_error \ 28 _(IF_DOWN, "interface down") \ 29 _(PASS_THRU, "pass through (CDP, LLDP, slow protocols)") 33 #define _(f,s) BOND_INPUT_ERROR_##f, 52 s =
format (s,
"src %U, dst %U, %U -> %U",
78 return ((eth->
type == htons (ETHERNET_TYPE_CDP)) ||
80 (snap->protocol == htons (0x2000)) &&
81 (snap->oui[0] == 0) && (snap->oui[1] == 0) &&
82 (snap->oui[2] == 0x0C)));
89 u16 *ethertype_p, ethertype;
97 if (
PREDICT_TRUE ((ethertype != htons (ETHERNET_TYPE_SLOW_PROTOCOLS))
99 && (ethertype != htons (ETHERNET_TYPE_802_1_LLDP))))
108 vlan = (
void *) (eth + 1);
109 ethertype_p = &vlan->
type;
111 if (ethertype == ntohs (ETHERNET_TYPE_VLAN))
114 ethertype_p = &vlan->
type;
117 if (
PREDICT_TRUE ((ethertype != htons (ETHERNET_TYPE_SLOW_PROTOCOLS))
118 && (ethertype != htons (ETHERNET_TYPE_CDP))
119 && (ethertype != htons (ETHERNET_TYPE_802_1_LLDP))))
133 u32 * last_slave_sw_if_index,
u32 slave_sw_if_index,
142 if (
PREDICT_TRUE (*last_slave_sw_if_index == slave_sw_if_index))
148 *last_slave_sw_if_index, packet_count);
150 *last_slave_sw_if_index = slave_sw_if_index;
163 *bond_sw_if_index = slave_sw_if_index;
164 *error = node->
errors[BOND_INPUT_ERROR_IF_DOWN];
181 u32 last_slave_sw_if_index = ~0;
182 u32 bond_sw_if_index = 0;
191 n_left = frame->n_vectors;
197 sw_if_index = sw_if_indices;
221 x |= sw_if_index[0] ^ last_slave_sw_if_index;
222 x |= sw_if_index[1] ^ last_slave_sw_if_index;
223 x |= sw_if_index[2] ^ last_slave_sw_if_index;
224 x |= sw_if_index[3] ^ last_slave_sw_if_index;
228 next[0] = next[1] = next[2] = next[3] = next_index;
252 cnt, &bond_sw_if_index, b[0], &next_index,
254 next[0] = next_index;
261 cnt, &bond_sw_if_index, b[1], &next_index,
263 next[1] = next_index;
270 cnt, &bond_sw_if_index, b[2], &next_index,
272 next[2] = next_index;
279 cnt, &bond_sw_if_index, b[3], &next_index,
281 next[3] = next_index;
304 cnt, &bond_sw_if_index, b[0], &next_index, &error);
305 next[0] = next_index;
322 n_left = frame->n_vectors;
324 sw_if_index = sw_if_indices;
351 BOND_INPUT_ERROR_NONE, frame->n_vectors);
353 return frame->n_vectors;
364 .name =
"bond-input",
365 .vector_size =
sizeof (
u32),
382 .arc_name =
"device-input",
383 .node_name =
"bond-input",
#define foreach_bond_input_error
VNET_SW_INTERFACE_ADMIN_UP_DOWN_FUNCTION(bond_sw_interface_up_down)
static u32 bond_sw_if_idx_rewrite(vlib_main_t *vm, vlib_node_runtime_t *node, vlib_buffer_t *b, u32 bond_sw_if_index)
vnet_main_t * vnet_get_main(void)
static vnet_hw_interface_t * vnet_get_sup_hw_interface(vnet_main_t *vnm, u32 sw_if_index)
static clib_error_t * bond_input_init(vlib_main_t *vm)
vnet_interface_main_t interface_main
static void vlib_error_count(vlib_main_t *vm, uword node_index, uword counter, uword increment)
#define clib_memcpy_fast(a, b, c)
static void vlib_increment_simple_counter(vlib_simple_counter_main_t *cm, u32 thread_index, u32 index, u64 increment)
Increment a simple counter.
#define VLIB_NODE_FN(node)
vlib_error_t * errors
Vector of errors for this node.
void bond_enable_collecting_distributing(vlib_main_t *vm, slave_if_t *sif)
format_function_t format_vnet_sw_if_index_name
static vnet_sw_interface_t * vnet_get_hw_sw_interface(vnet_main_t *vnm, u32 hw_if_index)
VNET_HW_INTERFACE_LINK_UP_DOWN_FUNCTION(bond_hw_interface_up_down)
vlib_node_registration_t bond_input_node
(constructor) VLIB_REGISTER_NODE (bond_input_node)
#define static_always_inline
u8 * format_ethernet_address(u8 *s, va_list *args)
#define VLIB_INIT_FUNCTION(x)
vnet_hw_interface_flags_t flags
#define vlib_prefetch_buffer_header(b, type)
Prefetch buffer metadata.
static clib_error_t * bond_sw_interface_up_down(vnet_main_t *vnm, u32 sw_if_index, u32 flags)
static void * vlib_buffer_get_current(vlib_buffer_t *b)
Get pointer to current data to process.
vlib_simple_counter_main_t * sw_if_counters
u32 node_index
Node index.
static u8 * format_bond_input_trace(u8 *s, va_list *args)
vlib_error_t error
Error code for buffers to be enqueued to error handler.
static void vlib_node_increment_counter(vlib_main_t *vm, u32 node_index, u32 counter_index, u64 increment)
u8 * format_ethernet_header_with_length(u8 *s, va_list *args)
#define VLIB_REGISTER_NODE(x,...)
static_always_inline void vlib_buffer_enqueue_to_next(vlib_main_t *vm, vlib_node_runtime_t *node, u32 *buffers, u16 *nexts, uword count)
static_always_inline void vnet_feature_next(u32 *next0, vlib_buffer_t *b0)
ethernet_header_t ethernet
void bond_disable_collecting_distributing(vlib_main_t *vm, slave_if_t *sif)
#define vlib_prefetch_buffer_data(b, type)
VNET_FEATURE_INIT(bond_input, static)
static_always_inline u8 packet_is_cdp(ethernet_header_t *eth)
static bond_if_t * bond_get_master_by_dev_instance(u32 dev_instance)
static_always_inline int ethernet_frame_is_tagged(u16 type)
#define clib_mem_unaligned(pointer, type)
static char * bond_input_error_strings[]
#define VNET_FEATURES(...)
static void * vlib_add_trace(vlib_main_t *vm, vlib_node_runtime_t *r, vlib_buffer_t *b, u32 n_data_bytes)
#define vec_len(v)
Number of elements in vector (rvalue-only, NULL tolerant)
#define VLIB_BUFFER_TRACE_TRAJECTORY_INIT(b)
static void * vlib_frame_vector_args(vlib_frame_t *f)
Get pointer to frame vector data.
static clib_error_t * bond_hw_interface_up_down(vnet_main_t *vnm, u32 hw_if_index, u32 flags)
static slave_if_t * bond_get_slave_by_sw_if_index(u32 sw_if_index)
static_always_inline void vlib_get_buffers(vlib_main_t *vm, u32 *bi, vlib_buffer_t **b, int count)
Translate array of buffer indices into buffer pointers.
#define VLIB_NODE_FLAG_TRACE
static void bond_update_next(vlib_main_t *vm, vlib_node_runtime_t *node, u32 *last_slave_sw_if_index, u32 slave_sw_if_index, u32 packet_count, u32 *bond_sw_if_index, vlib_buffer_t *b, u32 *next_index, vlib_error_t *error)