24 #ifndef CLIB_MARCH_VARIANT 28 #define foreach_bond_input_error \ 30 _(IF_DOWN, "interface down") \ 31 _(PASSIVE_IF, "traffic received on passive interface") \ 32 _(PASS_THRU, "pass through (CDP, LLDP, slow protocols)") 36 #define _(f,s) BOND_INPUT_ERROR_##f, 55 s =
format (s,
"src %U, dst %U, %U -> %U",
81 return ((eth->
type == htons (ETHERNET_TYPE_CDP)) ||
83 (snap->protocol == htons (0x2000)) &&
84 (snap->oui[0] == 0) && (snap->oui[1] == 0) &&
85 (snap->oui[2] == 0x0C)));
91 u32 * n_rx_packets,
u32 * n_rx_bytes)
93 u16 *ethertype_p, ethertype;
103 if (
PREDICT_TRUE ((ethertype != htons (ETHERNET_TYPE_SLOW_PROTOCOLS))
105 && (ethertype != htons (ETHERNET_TYPE_802_1_LLDP))))
114 vlan = (
void *) (eth + 1);
115 ethertype_p = &vlan->
type;
117 if (ethertype == ntohs (ETHERNET_TYPE_VLAN))
120 ethertype_p = &vlan->
type;
123 if (
PREDICT_TRUE ((ethertype != htons (ETHERNET_TYPE_SLOW_PROTOCOLS))
124 && (ethertype != htons (ETHERNET_TYPE_CDP))
125 && (ethertype != htons (ETHERNET_TYPE_802_1_LLDP))))
139 u32 * last_slave_sw_if_index,
u32 slave_sw_if_index,
149 if (
PREDICT_TRUE (*last_slave_sw_if_index == slave_sw_if_index))
152 *last_slave_sw_if_index = slave_sw_if_index;
164 *bond_sw_if_index = slave_sw_if_index;
165 *error = node->
errors[BOND_INPUT_ERROR_IF_DOWN];
172 *bond_sw_if_index = slave_sw_if_index;
173 *error = node->
errors[BOND_INPUT_ERROR_PASSIVE_IF];
187 u32 tmp0, tmp1, tmp2, tmp3;
205 u32 last_slave_sw_if_index = ~0;
206 u32 bond_sw_if_index = 0;
209 u32 n_rx_bytes = 0, n_rx_packets = 0;
215 n_left =
frame->n_vectors;
221 sw_if_index = sw_if_indices;
245 x |= sw_if_index[0] ^ last_slave_sw_if_index;
246 x |= sw_if_index[1] ^ last_slave_sw_if_index;
247 x |= sw_if_index[2] ^ last_slave_sw_if_index;
248 x |= sw_if_index[3] ^ last_slave_sw_if_index;
265 last_slave_sw_if_index) > 1))
268 next[0] = next[1] = next[2] = next[3] = next_index;
279 &n_rx_packets, &n_rx_bytes);
281 &n_rx_packets, &n_rx_bytes);
283 &n_rx_packets, &n_rx_bytes);
285 &n_rx_packets, &n_rx_bytes);
291 &bond_sw_if_index, b[0], &next_index, &error);
292 next[0] = next_index;
297 &n_rx_packets, &n_rx_bytes);
300 &bond_sw_if_index, b[1], &next_index, &error);
301 next[1] = next_index;
306 &n_rx_packets, &n_rx_bytes);
309 &bond_sw_if_index, b[2], &next_index, &error);
310 next[2] = next_index;
315 &n_rx_packets, &n_rx_bytes);
318 &bond_sw_if_index, b[3], &next_index, &error);
319 next[3] = next_index;
324 &n_rx_packets, &n_rx_bytes);
343 &bond_sw_if_index, b[0], &next_index, &error);
344 next[0] = next_index;
349 &n_rx_packets, &n_rx_bytes);
362 n_left =
frame->n_vectors;
364 sw_if_index = sw_if_indices;
392 BOND_INPUT_ERROR_NONE,
frame->n_vectors);
394 return frame->n_vectors;
405 .name =
"bond-input",
406 .vector_size =
sizeof (
u32),
423 .arc_name =
"device-input",
424 .node_name =
"bond-input",
#define foreach_bond_input_error
VNET_SW_INTERFACE_ADMIN_UP_DOWN_FUNCTION(bond_sw_interface_up_down)
static void vlib_increment_combined_counter(vlib_combined_counter_main_t *cm, u32 thread_index, u32 index, u64 n_packets, u64 n_bytes)
Increment a combined counter.
vnet_main_t * vnet_get_main(void)
VNET_FEATURE_INIT(lb_nat4_in2out_node_fn, static)
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)
u16 current_length
Nbytes between current data and the end of this buffer.
static_always_inline u32 vnet_get_feature_count(u8 arc, u32 sw_if_index)
#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 uword vnet_sw_interface_is_link_up(vnet_main_t *vnm, u32 sw_if_index)
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)
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 *bond_sw_if_index, vlib_buffer_t *b, u32 *next_index, vlib_error_t *error)
vl_api_interface_index_t sw_if_index
#define VLIB_INIT_FUNCTION(x)
vlib_combined_counter_main_t * combined_sw_if_counters
#define vlib_prefetch_buffer_header(b, type)
Prefetch buffer metadata.
static_always_inline void bond_update_next_x4(vlib_buffer_t *b0, vlib_buffer_t *b1, vlib_buffer_t *b2, vlib_buffer_t *b3)
static clib_error_t * bond_sw_interface_up_down(vnet_main_t *vnm, u32 sw_if_index, u32 flags)
static void bond_sw_if_idx_rewrite(vlib_main_t *vm, vlib_node_runtime_t *node, vlib_buffer_t *b, u32 bond_sw_if_index, u32 *n_rx_packets, u32 *n_rx_bytes)
vl_api_fib_path_type_t type
vlib_error_t error
Error code for buffers to be enqueued to error handler.
static void * vlib_buffer_get_current(vlib_buffer_t *b)
Get pointer to current data to process.
u32 node_index
Node index.
static u8 * format_bond_input_trace(u8 *s, va_list *args)
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)
vlib_main_t vlib_node_runtime_t * node
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 uword vnet_sw_interface_is_admin_up(vnet_main_t *vnm, u32 sw_if_index)
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)
VLIB buffer representation.
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)
vlib_main_t vlib_node_runtime_t vlib_frame_t * frame
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