27 #include <vpp/app/version.h> 35 #include <flowprobe/flowprobe.api_enum.h> 36 #include <flowprobe/flowprobe.api_types.h> 43 #define REPLY_MSG_ID_BASE fm->msg_id_base 50 .arc_name =
"ip4-output",
51 .node_name =
"flowprobe-ip4",
57 .arc_name =
"ip6-output",
58 .node_name =
"flowprobe-ip6",
64 .arc_name =
"interface-output",
65 .node_name =
"flowprobe-l2",
71 #define vl_print(handle, ...) vlib_cli_output (handle, __VA_ARGS__) 74 vl_print (handle, (char *)s); \ 81 #define flowprobe_template_ip4_field_count() 4 84 sourceIPv4Address, 4);
88 destinationIPv4Address, 4);
92 protocolIdentifier, 1);
104 #define flowprobe_template_ip6_field_count() 4 107 sourceIPv6Address, 16);
111 destinationIPv6Address, 16);
115 protocolIdentifier, 1);
127 #define flowprobe_template_l2_field_count() 3 130 sourceMacAddress, 6);
134 destinationMacAddress, 6);
146 #define flowprobe_template_common_field_count() 5 149 ingressInterface, 4);
159 packetDeltaCount, 8);
164 flowStartNanoseconds, 8);
169 flowEndNanoseconds, 8);
178 #define flowprobe_template_l4_field_count() 3 181 sourceTransportPort, 2);
185 destinationTransportPort, 2);
225 bool collect_ip4 =
false, collect_ip6 =
false;
269 udp->
dst_port = clib_host_to_net_u16 (collector_port);
270 udp->
length = clib_host_to_net_u16 (
vec_len (rewrite) -
sizeof (*ip));
279 if (flags & FLOW_RECORD_L2)
285 if (flags & FLOW_RECORD_L4)
305 ip->
length = clib_host_to_net_u16 ((
u8 *) f - (
u8 *) ip);
318 u32 n_elts,
u32 * stream_index)
321 (frm, fr, collector_address, src_address, collector_port,
332 u32 n_elts,
u32 * stream_index)
335 (frm, fr, collector_address, src_address, collector_port,
346 u32 n_elts,
u32 * stream_index)
349 (frm, fr, collector_address, src_address, collector_port,
360 u32 n_elts,
u32 * stream_index)
363 (frm, fr, collector_address, src_address, collector_port,
374 u32 n_elts,
u32 * stream_index)
377 (frm, fr, collector_address, src_address, collector_port,
423 bool is_add,
u16 * template_id)
427 .rewrite_callback = rewrite_callback,
428 .flow_data_callback = flow_data_callback,
430 .domain_id = domain_id,
432 .opaque.as_uword =
flags,
446 for (i = 0; i <
vec_len (expired_timers); i++)
448 poolindex = expired_timers[
i] & 0x7FFFFFFF;
477 for (i = 0; i < num_threads; i++)
484 fm->timers_per_worker[i] =
486 tw_timer_wheel_init_2t_1w_2048sl (fm->timers_per_worker[i],
496 for (i = 0; i < num_threads; i++)
550 is_add, &template_id);
557 is_add, &template_id);
559 (is_add) ? template_id : 0;
564 is_add, &template_id);
566 (is_add) ? template_id : 0;
581 is_add, &template_id);
586 is_add, &template_id);
588 if (rv && rv != VNET_API_ERROR_VALUE_EXIST)
590 clib_warning (
"vnet_flow_report_add_del returned %d", rv);
594 if (which != (
u8) ~ 0)
602 sw_if_index, is_add, 0, 0);
605 sw_if_index, is_add, 0, 0);
608 sw_if_index, is_add, 0, 0);
629 vl_api_flowprobe_tx_interface_add_del_reply_t *rmp;
637 clib_warning (
"Please specify flowprobe params record first...");
638 rv = VNET_API_ERROR_CANNOT_ENABLE_DISABLE_FEATURE;
643 if ((rv == 1 && mp->
is_add == 1) || rv == 0)
645 rv = VNET_API_ERROR_CANNOT_ENABLE_DISABLE_FEATURE;
655 REPLY_MACRO (VL_API_FLOWPROBE_TX_INTERFACE_ADD_DEL_REPLY);
669 s =
format (0,
"SCRIPT: flowprobe_tx_interface_add_del ");
670 s =
format (s,
"sw_if_index %d is_add %d which %d ",
676 #define vec_neg_search(v,E) \ 679 while (_v(i) < vec_len(v) && v[_v(i)] == E) \ 683 if (_v(i) == vec_len(v)) \ 690 u8 record_l3,
u8 record_l4,
691 u32 active_timer,
u32 passive_timer)
722 vl_api_flowprobe_params_reply_t *rmp;
738 .version = VPP_BUILD_VER,
739 .description =
"Flow per Packet",
751 s =
format (s,
" %U -> %U",
776 vlib_cli_output (vm,
"%U",
777 format_flowprobe_entry,
834 "Please specify flowprobe params record first...");
836 if (sw_if_index == ~0)
844 "Datapath is already enabled for given interface...");
848 "Interface has enable different datapath ...");
857 case VNET_API_ERROR_INVALID_SW_IF_INDEX:
859 (0,
"Invalid interface, only works on physical ports");
862 case VNET_API_ERROR_UNIMPLEMENTED:
879 bool record_l2 =
false, record_l3 =
false, record_l4 =
false;
880 u32 active_timer = ~0;
881 u32 passive_timer = ~0;
885 if (
unformat (input,
"active %d", &active_timer))
887 else if (
unformat (input,
"passive %d", &passive_timer))
889 else if (
unformat (input,
"record"))
905 if (passive_timer > 0 && active_timer > passive_timer)
907 "Passive timer has to be greater than active one...");
910 active_timer, passive_timer))
912 "Couldn't change flowperpacket params when feature is enabled on some interface ...");
932 .path =
"flowprobe feature add-del",
934 "flowprobe feature add-del <interface-name> <l2|ip4|ip6> disable",
938 .path =
"flowprobe params",
940 "flowprobe params record <[l2] [l3] [l4]> [active <timer> passive <timer>]",
944 .path =
"show flowprobe table",
945 .short_help =
"show flowprobe table",
949 .path =
"show flowprobe statistics",
950 .short_help =
"show flowprobe statistics",
962 uword *event_data = 0;
970 clib_warning (
"bogus kickoff event received, %d", event_type);
985 f64 sleep_duration = 0.1;
990 sleep_duration = 0.1;
991 for (i = 0; i <
vec_len (worker_vms); i++)
993 worker_vm = worker_vms[
i];
1010 .name =
"flowprobe-timer-process",
1015 #include <flowprobe/flowprobe.api.c>
#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...
vl_api_interface_index_t sw_if_index
vl_api_wireguard_peer_flags_t flags
ip46_address_t src_address
#define FLOWPROBE_TIMER_PASSIVE
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)
vl_api_flowprobe_which_flags_t which
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)
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.
format_function_t format_ip46_address
vl_api_ip_port_and_mask_t src_port
#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)
sll srl srl sll sra u16x4 i
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,...)
void vlib_cli_output(vlib_main_t *vm, char *fmt,...)
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
static void setup_message_id_table(snat_main_t *sm, api_main_t *am)
vlib_node_registration_t flowprobe_walker_node
(constructor) VLIB_REGISTER_NODE (flowprobe_walker_node)
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.
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)
vl_api_interface_index_t sw_if_index
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)
vl_api_flowprobe_record_flags_t record_flags
static uword pool_elts(void *v)
Number of active elements in a pool.