70 else if (src_port == stream->
src_port)
98 VLIB_NODE_STATE_DISABLED);
130 b0->
flags |= (VLIB_BUFFER_TOTAL_LENGTH_VALID | VNET_BUFFER_F_FLOW_REPORT);
161 *buffer_indexp = bi0;
175 u32 n_elts,
u32 * stream_indexp)
218 udp->
dst_port = clib_host_to_net_u16 (collector_port);
219 udp->
length = clib_host_to_net_u16 (
vec_len (rewrite) -
sizeof (*ip));
226 for (i = 0; i < n_elts; i++)
248 ip->
length = clib_host_to_net_u16 ((
u8 *) f - (
u8 *) ip);
260 u32 ip4_lookup_node_index;
269 uword *event_data = 0;
275 clib_warning (
"bogus kickoff event received, %d", event_type);
280 ip4_lookup_node_index = ip4_lookup_node->
index;
309 if (template_bi != ~0)
311 to_next[0] = template_bi;
317 nf, to_next, ip4_lookup_node_index);
330 .name =
"flow-report-process",
340 int found_index = ~0;
347 return VNET_API_ERROR_INVALID_VALUE;
348 if (si == -1 && a->
is_add == 0)
349 return VNET_API_ERROR_NO_SUCH_ENTRY;
367 if (found_index != ~0)
376 return VNET_API_ERROR_NO_SUCH_ENTRY;
379 if (found_index != ~0)
380 return VNET_API_ERROR_VALUE_EXIST;
421 case VNET_API_ERROR_NO_SUCH_ENTRY:
423 case VNET_API_ERROR_VALUE_EXIST:
425 case VNET_API_ERROR_INVALID_VALUE:
427 "for both domain_id and src_port " 428 "or already used values for both fields");
469 u32 old_domain_id,
u16 old_src_port,
470 u32 new_domain_id,
u16 new_src_port)
473 if (stream_index < 0)
478 if (old_domain_id != new_domain_id || old_src_port != new_src_port)
490 u16 collector_port = UDP_DST_PORT_ipfix;
497 u32 template_interval = 20;
509 else if (
unformat (input,
"fib-id %u", &fib_id))
517 else if (
unformat (input,
"path-mtu %u", &path_mtu))
519 else if (
unformat (input,
"template-interval %u", &template_interval))
521 else if (
unformat (input,
"udp-checksum"))
530 if (path_mtu > 1450 )
552 "fib index %d, path MTU %u, " 553 "template resend interval %us, " 557 fib_index, path_mtu, template_interval,
558 udp_checksum ?
"enabled" :
"disabled");
569 .path =
"set ipfix exporter",
570 .short_help =
"set ipfix exporter " 571 "collector <ip4-address> [port <port>] " 572 "src <ip4-address> [fib-id <fib-id>] " 573 "[path-mtu <path-mtu>] " 574 "[template-interval <template-interval>] " 592 .path =
"ipfix flush",
593 .short_help =
"flush the current ipfix data [for make test]",
#define vec_validate(V, I)
Make sure vector is long enough for given index (no header, unspecified alignment) ...
u32 flags
buffer flags: VLIB_BUFFER_FREE_LIST_INDEX_MASK: bits used to store free list index, VLIB_BUFFER_IS_TRACED: trace this buffer.
clib_error_t * flow_report_add_del_error_to_clib_error(int error)
static f64 vlib_process_wait_for_event_or_clock(vlib_main_t *vm, f64 dt)
Suspend a cooperative multi-tasking thread Waits for an event, or for the indicated number of seconds...
vlib_node_registration_t flow_report_process_node
(constructor) VLIB_REGISTER_NODE (flow_report_process_node)
u16 udp_checksum(udp_header_t *uh, u32 udp_len, void *ih, u8 version)
vnet_main_t * vnet_get_main(void)
i16 current_data
signed offset in data[], pre_data[] that we are currently processing.
unformat_function_t unformat_udp_port
#define clib_memcpy_fast(a, b, c)
static u32 ipfix_e_id_length(int e, u16 id, u16 length)
static f64 vlib_time_now(vlib_main_t *vm)
static clib_error_t * ipfix_flush_command_fn(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
int vnet_flow_report_add_del(flow_report_main_t *frm, vnet_flow_report_add_del_args_t *a, u16 *template_id)
u16 current_length
Nbytes between current data and the end of this buffer.
#define vec_add2(V, P, N)
Add N elements to end of vector V, return pointer to new elements in P.
ip4_address_t src_address
#define vec_validate_aligned(V, I, A)
Make sure vector is long enough for given index (no header, specified alignment)
#define vec_reset_length(v)
Reset vector length to zero NULL-pointer tolerant.
ip4_address_t ipfix_collector
vlib_node_registration_t ip4_lookup_node
(constructor) VLIB_REGISTER_NODE (ip4_lookup_node)
void vnet_stream_reset(flow_report_main_t *frm, u32 stream_index)
flow_report_stream_t * streams
#define static_always_inline
#define VLIB_INIT_FUNCTION(x)
static uword vlib_process_get_events(vlib_main_t *vm, uword **data_vector)
Return the first event type which has occurred and a vector of per-event data of that type...
vnet_flow_rewrite_callback_t * rewrite_callback
#define vec_elt_at_index(v, i)
Get vector value at index i checking that i is in bounds.
vlib_frame_t * vlib_get_frame_to_node(vlib_main_t *vm, u32 to_node_index)
#define clib_error_return(e, args...)
static uword flow_report_process(vlib_main_t *vm, vlib_node_runtime_t *rt, vlib_frame_t *f)
flow_report_main_t flow_report_main
ipfix_report_element_t * report_elements
vlib_node_t * vlib_get_node_by_name(vlib_main_t *vm, u8 *name)
uword * fib_index_by_table_id
Hash table mapping table id to fib index.
static void vlib_process_signal_event(vlib_main_t *vm, uword node_index, uword type_opaque, uword data)
static __clib_warn_unused_result u32 vlib_buffer_alloc(vlib_main_t *vm, u32 *buffers, u32 n_buffers)
Allocate buffers into supplied array.
void vlib_put_frame_to_node(vlib_main_t *vm, u32 to_node_index, vlib_frame_t *f)
static void * vlib_buffer_get_current(vlib_buffer_t *b)
Get pointer to current data to process.
vl_api_address_union_t src_address
static u32 version_length(u16 length)
int send_template_packet(flow_report_main_t *frm, flow_report_t *fr, u32 *buffer_indexp)
static_always_inline u32 vlib_buffer_get_default_data_size(vlib_main_t *vm)
vl_api_ip_port_and_mask_t src_port
static_always_inline flow_report_stream_t * add_stream(void)
#define VLIB_REGISTER_NODE(x,...)
sll srl srl sll sra u16x4 i
#define vec_free(V)
Free vector's memory (no header).
static u32 ipfix_id_count(u16 id, u16 count)
#define clib_warning(format, args...)
static clib_error_t * set_ipfix_exporter_command_fn(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
static_always_inline u8 stream_index_valid(u32 index)
#define VLIB_CLI_COMMAND(x,...)
void vlib_cli_output(vlib_main_t *vm, char *fmt,...)
u16 ip4_tcp_udp_compute_checksum(vlib_main_t *vm, vlib_buffer_t *p0, ip4_header_t *ip0)
#define vec_delete(V, N, M)
Delete N elements starting at element M.
ipfix_report_element_t * report_elements
static_always_inline void delete_stream(u32 index)
void vnet_flow_reports_reset(flow_report_main_t *frm)
static void vlib_node_set_state(vlib_main_t *vm, u32 node_index, vlib_node_state_t new_state)
Set node dispatch state.
vnet_flow_data_callback_t * flow_data_callback
static u32 ipfix_set_id_length(u16 set_id, u16 length)
u8 * vnet_flow_rewrite_generic_callback(flow_report_main_t *frm, flow_report_t *fr, ip4_address_t *collector_address, ip4_address_t *src_address, u16 collector_port, ipfix_report_element_t *report_elts, u32 n_elts, u32 *stream_indexp)
#define vec_len(v)
Number of elements in vector (rvalue-only, NULL tolerant)
#define VLIB_BUFFER_TRACE_TRAJECTORY_INIT(b)
int vnet_stream_change(flow_report_main_t *frm, u32 old_domain_id, u16 old_src_port, u32 new_domain_id, u16 new_src_port)
VLIB buffer representation.
static void * vlib_frame_vector_args(vlib_frame_t *f)
Get pointer to frame vector data.
vnet_flow_data_callback_t * flow_data_callback
static i32 find_stream(u32 domain_id, u16 src_port)
ip4_main_t ip4_main
Global ip4 main structure.
vnet_flow_rewrite_callback_t * rewrite_callback
#define vec_foreach(var, vec)
Vector iterator.
#define CLIB_CACHE_LINE_BYTES
static vlib_buffer_t * vlib_get_buffer(vlib_main_t *vm, u32 buffer_index)
Translate buffer index into buffer pointer.
static u16 ip4_header_checksum(ip4_header_t *i)
static clib_error_t * flow_report_init(vlib_main_t *vm)