27 #include <vpp/app/version.h> 48 #define vl_print(handle, ...) vlib_cli_output (handle, __VA_ARGS__) 60 #define vl_api_version(n,v) static u32 api_version=(v); 64 #define REPLY_MSG_ID_BASE fm->msg_id_base 71 .arc_name =
"ip4-output",
72 .node_name =
"flowprobe-ip4",
78 .arc_name =
"ip6-output",
79 .node_name =
"flowprobe-ip6",
85 .arc_name =
"interface-output",
86 .node_name =
"flowprobe-l2",
94 vl_print (handle, (char *)s); \ 101 #define flowprobe_template_ip4_field_count() 4 104 sourceIPv4Address, 4);
108 destinationIPv4Address, 4);
112 protocolIdentifier, 1);
124 #define flowprobe_template_ip6_field_count() 4 127 sourceIPv6Address, 16);
131 destinationIPv6Address, 16);
135 protocolIdentifier, 1);
147 #define flowprobe_template_l2_field_count() 3 150 sourceMacAddress, 6);
154 destinationMacAddress, 6);
166 #define flowprobe_template_common_field_count() 5 169 ingressInterface, 4);
179 packetDeltaCount, 8);
184 flowStartNanoseconds, 8);
189 flowEndNanoseconds, 8);
198 #define flowprobe_template_l4_field_count() 3 201 sourceTransportPort, 2);
205 destinationTransportPort, 2);
245 bool collect_ip4 =
false, collect_ip6 =
false;
289 udp->
dst_port = clib_host_to_net_u16 (collector_port);
290 udp->
length = clib_host_to_net_u16 (
vec_len (rewrite) -
sizeof (*ip));
299 if (flags & FLOW_RECORD_L2)
305 if (flags & FLOW_RECORD_L4)
325 ip->
length = clib_host_to_net_u16 ((
u8 *) f - (
u8 *) ip);
338 u32 n_elts,
u32 * stream_index)
341 (frm, fr, collector_address, src_address, collector_port,
352 u32 n_elts,
u32 * stream_index)
355 (frm, fr, collector_address, src_address, collector_port,
366 u32 n_elts,
u32 * stream_index)
369 (frm, fr, collector_address, src_address, collector_port,
380 u32 n_elts,
u32 * stream_index)
383 (frm, fr, collector_address, src_address, collector_port,
394 u32 n_elts,
u32 * stream_index)
397 (frm, fr, collector_address, src_address, collector_port,
443 bool is_add,
u16 * template_id)
447 .rewrite_callback = rewrite_callback,
448 .flow_data_callback = flow_data_callback,
450 .domain_id = domain_id,
452 .opaque.as_uword =
flags,
466 for (i = 0; i <
vec_len (expired_timers); i++)
468 poolindex = expired_timers[
i] & 0x7FFFFFFF;
497 for (i = 0; i < num_threads; i++)
504 fm->timers_per_worker[i] =
506 tw_timer_wheel_init_2t_1w_2048sl (fm->timers_per_worker[i],
516 for (i = 0; i < num_threads; i++)
570 is_add, &template_id);
577 is_add, &template_id);
579 (is_add) ? template_id : 0;
584 is_add, &template_id);
586 (is_add) ? template_id : 0;
601 is_add, &template_id);
606 is_add, &template_id);
608 if (rv && rv != VNET_API_ERROR_VALUE_EXIST)
610 clib_warning (
"vnet_flow_report_add_del returned %d", rv);
614 if (which != (
u8) ~ 0)
622 sw_if_index, is_add, 0, 0);
625 sw_if_index, is_add, 0, 0);
628 sw_if_index, is_add, 0, 0);
649 vl_api_flowprobe_tx_interface_add_del_reply_t *rmp;
658 rv = VNET_API_ERROR_UNIMPLEMENTED;
664 clib_warning (
"Please specify flowprobe params record first...");
665 rv = VNET_API_ERROR_CANNOT_ENABLE_DISABLE_FEATURE;
670 if ((rv == 1 && mp->
is_add == 1) || rv == 0)
672 rv = VNET_API_ERROR_CANNOT_ENABLE_DISABLE_FEATURE;
682 REPLY_MACRO (VL_API_FLOWPROBE_TX_INTERFACE_ADD_DEL_REPLY);
696 s =
format (0,
"SCRIPT: flowprobe_tx_interface_add_del ");
697 s =
format (s,
"sw_if_index %d is_add %d which %d ",
703 #define vec_neg_search(v,E) \ 706 while (_v(i) < vec_len(v) && v[_v(i)] == E) \ 710 if (_v(i) == vec_len(v)) \ 717 u8 record_l3,
u8 record_l4,
718 u32 active_timer,
u32 passive_timer)
749 vl_api_flowprobe_params_reply_t *rmp;
761 #define foreach_flowprobe_plugin_api_msg \ 762 _(FLOWPROBE_TX_INTERFACE_ADD_DEL, flowprobe_tx_interface_add_del) \ 763 _(FLOWPROBE_PARAMS, flowprobe_params) 767 .version = VPP_BUILD_VER,
768 .description =
"Flow per Packet",
780 s =
format (s,
" %U -> %U",
805 vlib_cli_output (vm,
"%U",
806 format_flowprobe_entry,
863 "Please specify flowprobe params record first...");
865 if (sw_if_index == ~0)
873 "Datapath is already enabled for given interface...");
877 "Interface has enable different datapath ...");
886 case VNET_API_ERROR_INVALID_SW_IF_INDEX:
888 (0,
"Invalid interface, only works on physical ports");
891 case VNET_API_ERROR_UNIMPLEMENTED:
908 bool record_l2 =
false, record_l3 =
false, record_l4 =
false;
909 u32 active_timer = ~0;
910 u32 passive_timer = ~0;
914 if (
unformat (input,
"active %d", &active_timer))
916 else if (
unformat (input,
"passive %d", &passive_timer))
918 else if (
unformat (input,
"record"))
934 if (passive_timer > 0 && active_timer > passive_timer)
936 "Passive timer has to be greater than active one...");
939 active_timer, passive_timer))
941 "Couldn't change flowperpacket params when feature is enabled on some interface ...");
961 .path =
"flowprobe feature add-del",
963 "flowprobe feature add-del <interface-name> <l2|ip4|ip6> disable",
967 .path =
"flowprobe params",
969 "flowprobe params record <[l2] [l3] [l4]> [active <timer> passive <timer>]",
973 .path =
"show flowprobe table",
974 .short_help =
"show flowprobe table",
978 .path =
"show flowprobe statistics",
979 .short_help =
"show flowprobe statistics",
994 vl_msg_api_set_handlers((VL_API_##N + fm->msg_id_base), \ 996 vl_api_##n##_t_handler, \ 998 vl_api_##n##_t_endian, \ 999 vl_api_##n##_t_print, \ 1000 sizeof(vl_api_##n##_t), 1); 1007 #define vl_msg_name_crc_list 1009 #undef vl_msg_name_crc_list 1014 #define _(id,n,crc) \ 1015 vl_msg_api_add_msg_name_crc (am, #n "_" #crc, id + fm->msg_id_base); 1016 foreach_vl_msg_name_crc_flowprobe;
1027 uword *event_data = 0;
1034 if (event_type != 1)
1035 clib_warning (
"bogus kickoff event received, %d", event_type);
1050 f64 sleep_duration = 0.1;
1055 sleep_duration = 0.1;
1056 for (i = 0; i <
vec_len (worker_vms); i++)
1058 worker_vm = worker_vms[
i];
1062 flowprobe_walker_node.index);
1075 .name =
"flowprobe-timer-process",
1098 name =
format (0,
"flowprobe_%08x%c", api_version, 0);
#define vec_validate(V, I)
Make sure vector is long enough for given index (no header, unspecified alignment) ...
uword flowprobe_walker_process(vlib_main_t *vm, vlib_node_runtime_t *rt, vlib_frame_t *f)
flowprobe_protocol_context_t context[FLOW_N_VARIANTS]
vlib_frame_t * flowprobe_data_callback_ip4(flow_report_main_t *frm, flow_report_t *fr, vlib_frame_t *f, u32 *to_next, u32 node_index)
Flush accumulated data.
u32 ** expired_passive_per_worker
#define FLOWPROBE_LOG2_HASHSIZE
void flowprobe_flush_callback_ip6(void)
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...
ip46_address_t src_address
#define FLOWPROBE_TIMER_PASSIVE
static void setup_message_id_table(flowprobe_main_t *fm, api_main_t *am)
static clib_error_t * flowprobe_plugin_api_hookup(vlib_main_t *vm)
Set up the API message handling tables.
vnet_main_t * vnet_get_main(void)
static u8 * flowprobe_template_rewrite_ip6(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 *elts, u32 n_elts, u32 *stream_index)
#define pool_alloc(P, N)
Allocate N more free elements to pool (unspecified alignment).
static void vlib_node_set_interrupt_pending(vlib_main_t *vm, u32 node_index)
static u32 ipfix_e_id_length(int e, u16 id, u16 length)
clib_memset(h->entries, 0, sizeof(h->entries[0]) *entries)
static f64 vlib_time_now(vlib_main_t *vm)
int vnet_flow_report_add_del(flow_report_main_t *frm, vnet_flow_report_add_del_args_t *a, u16 *template_id)
flowprobe_record_t record
#define vec_add1(V, E)
Add 1 element to end of vector (unspecified alignment).
#define flowprobe_template_l2_field_count()
flowprobe_entry_t * stateless_entry
u16 template_reports[FLOW_N_RECORDS]
unformat_function_t unformat_vnet_sw_interface
vlib_frame_t *() vnet_flow_data_callback_t(struct flow_report_main *, struct flow_report *, vlib_frame_t *, u32 *, u32)
#define vec_validate_aligned(V, I, A)
Make sure vector is long enough for given index (no header, specified alignment)
vlib_main_t ** vlib_mains
static ipfix_field_specifier_t * flowprobe_template_common_fields(ipfix_field_specifier_t *f)
#define vec_reset_length(v)
Reset vector length to zero NULL-pointer tolerant.
flowprobe_entry_t ** pool_per_worker
Enable / disable per-packet IPFIX recording on an interface.
flow_report_stream_t * streams
static uword vlib_process_suspend(vlib_main_t *vm, f64 dt)
Suspend a vlib cooperative multi-tasking thread for a period of time.
static ipfix_field_specifier_t * flowprobe_template_ip4_fields(ipfix_field_specifier_t *f)
flow-per-packet plugin header file
u8 * format_ethernet_address(u8 *s, va_list *args)
#define pool_foreach(VAR, POOL, BODY)
Iterate through pool.
#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...
vlib_frame_t ** frames_per_worker
frames containing ipfix buffers, per-worker thread
static u8 * flowprobe_template_rewrite_ip4(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 *elts, u32 n_elts, u32 *stream_index)
static u8 * flowprobe_template_rewrite_l2(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 *elts, u32 n_elts, u32 *stream_index)
#define flowprobe_template_l4_field_count()
#define clib_error_return(e, args...)
#define vec_resize(V, N)
Resize a vector (no header, unspecified alignment) Add N elements to end of given vector V...
void flowprobe_flush_callback_ip4(void)
#define foreach_flowprobe_plugin_api_msg
u64 nanosecond_time_0
Time reference pair.
static int flowprobe_params(flowprobe_main_t *fm, u8 record_l2, u8 record_l3, u8 record_l4, u32 active_timer, u32 passive_timer)
u8 ht_log2len
Per CPU flow-state.
flow_report_main_t flow_report_main
static int flowprobe_tx_interface_add_del_feature(flowprobe_main_t *fm, u32 sw_if_index, u8 which, int is_add)
configure / deconfigure the IPFIX flow-per-packet
static void vlib_process_signal_event(vlib_main_t *vm, uword node_index, uword type_opaque, uword data)
VNET_FEATURE_INIT(flow_perpacket_ip4, static)
#define flowprobe_template_ip4_field_count()
u16 template_per_flow[FLOW_N_VARIANTS]
static u8 * flowprobe_template_rewrite_l2_ip6(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 *elts, u32 n_elts, u32 *stream_index)
vl_api_address_union_t src_address
static u8 * flowprobe_template_rewrite_l2_ip4(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 *elts, u32 n_elts, u32 *stream_index)
u8 *() vnet_flow_rewrite_callback_t(struct flow_report_main *, struct flow_report *, ip4_address_t *, ip4_address_t *, u16, ipfix_report_element_t *elts, u32 n_elts, u32 *stream_index)
static void flowprobe_expired_timer_callback(u32 *expired_timers)
static u32 version_length(u16 length)
vlib_thread_main_t vlib_thread_main
void vl_api_flowprobe_tx_interface_add_del_t_handler(vl_api_flowprobe_tx_interface_add_del_t *mp)
API message handler.
API main structure, used by both vpp and binary API clients.
#define BAD_SW_IF_INDEX_LABEL
#define VLIB_REGISTER_NODE(x,...)
#define flowprobe_template_ip6_field_count()
static clib_error_t * flowprobe_show_stats_fn(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cm)
#define FLOWPROBE_TIMER_ACTIVE
static int flowprobe_template_add_del(u32 domain_id, u16 src_port, flowprobe_record_t flags, vnet_flow_data_callback_t *flow_data_callback, vnet_flow_rewrite_callback_t *rewrite_callback, bool is_add, u16 *template_id)
#define vec_free(V)
Free vector's memory (no header).
vlib_node_registration_t flowprobe_walker_node
vnet_main_t * vnet_main
convenience vnet_main_t pointer
static u32 ipfix_id_count(u16 id, u16 count)
#define clib_warning(format, args...)
#define vec_neg_search(v, E)
static u64 unix_time_now_nsec(void)
static clib_error_t * flowprobe_init(vlib_main_t *vm)
Set up the API message handling tables.
#define VLIB_CLI_COMMAND(x,...)
vlib_frame_t * flowprobe_data_callback_l2(flow_report_main_t *frm, flow_report_t *fr, vlib_frame_t *f, u32 *to_next, u32 node_index)
static ipfix_field_specifier_t * flowprobe_template_ip6_fields(ipfix_field_specifier_t *f)
static void * clib_mem_alloc(uword size)
#define VNET_FEATURES(...)
static vlib_main_t * vlib_get_main(void)
flowprobe_main_t flowprobe_main
struct _vlib_node_registration vlib_node_registration_t
static u32 ipfix_set_id_length(u16 set_id, u16 length)
vlib_buffer_t ** buffers_per_worker
ipfix buffers under construction, per-worker thread
#define flowprobe_template_common_field_count()
void flowprobe_flush_callback_l2(void)
#define vec_len(v)
Number of elements in vector (rvalue-only, NULL tolerant)
u16 template_size[FLOW_N_RECORDS]
static ipfix_field_specifier_t * flowprobe_template_l4_fields(ipfix_field_specifier_t *f)
u16 msg_id_base
API message ID base.
void vl_api_flowprobe_params_t_handler(vl_api_flowprobe_params_t *mp)
u8 * format_flowprobe_entry(u8 *s, va_list *args)
static ipfix_field_specifier_t * flowprobe_template_l2_fields(ipfix_field_specifier_t *f)
static int validate_feature_on_interface(flowprobe_main_t *fm, u32 sw_if_index, u8 which)
ip46_address_t dst_address
vlib_frame_t * flowprobe_data_callback_ip6(flow_report_main_t *frm, flow_report_t *fr, vlib_frame_t *f, u32 *to_next, u32 node_index)
u16 * next_record_offset_per_worker
next record offset, per worker thread
static void * vl_api_flowprobe_tx_interface_add_del_t_print(vl_api_flowprobe_tx_interface_add_del_t *mp, void *handle)
API message custom-dump function.
static uword timer_process(vlib_main_t *vm, vlib_node_runtime_t *rt, vlib_frame_t *f)
#define vec_validate_init_empty(V, I, INIT)
Make sure vector is long enough for given index and initialize empty space (no header, unspecified alignment)
#define CLIB_CACHE_LINE_BYTES
static clib_error_t * flowprobe_show_table_fn(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cm)
static clib_error_t * flowprobe_tx_interface_add_del_feature_command_fn(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
static clib_error_t * flowprobe_params_command_fn(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
static u8 * flowprobe_template_rewrite_inline(flow_report_main_t *frm, flow_report_t *fr, ip4_address_t *collector_address, ip4_address_t *src_address, u16 collector_port, flowprobe_variant_t which)
Create an IPFIX template packet rewrite string.
void vlib_cli_output(vlib_main_t *vm, char *fmt,...)
static vlib_node_registration_t flowprobe_timer_node
(constructor) VLIB_REGISTER_NODE (flowprobe_timer_node)
static clib_error_t * flowprobe_create_state_tables(u32 active_timer)
static u16 ip4_header_checksum(ip4_header_t *i)
int vnet_feature_enable_disable(const char *arc_name, const char *node_name, u32 sw_if_index, int enable_disable, void *feature_config, u32 n_feature_config_bytes)
#define VALIDATE_SW_IF_INDEX(mp)
u16 vl_msg_api_get_msg_ids(const char *name, int n)
static uword pool_elts(void *v)
Number of active elements in a pool.