17 #ifndef __included_flowprobe_h__ 18 #define __included_flowprobe_h__ 31 #define FLOWPROBE_TIMER_ACTIVE (15) 32 #define FLOWPROBE_TIMER_PASSIVE 120 // XXXX: FOR TESTING (30*60) 33 #define FLOWPROBE_LOG2_HASHSIZE (18) 46 typedef enum __attribute__ ((__packed__))
58 "flowprobe_variant_t is expected to be 1 byte, " 59 "revisit padding in flowprobe_key_t");
61 #define FLOW_MAXIMUM_EXPORT_ENTRIES (1024) 76 typedef struct __attribute__ ((aligned (8))) {
138 TWT (tw_timer_wheel) ** timers_per_worker;
u32 ** expired_passive_per_worker
void flowprobe_flush_callback_ip6(void)
ip46_address_t src_address
flowprobe_record_t record
u8 * format_flowprobe_entry(u8 *s, va_list *args)
flowprobe_entry_t * stateless_entry
flowprobe_entry_t ** pool_per_worker
flowprobe_variant_t which
STATIC_ASSERT(sizeof(flowprobe_variant_t)==1, "flowprobe_variant_t is expected to be 1 byte, " "revisit padding in flowprobe_key_t")
vlib_frame_t ** frames_per_worker
frames containing ipfix buffers, per-worker thread
void flowprobe_flush_callback_ip4(void)
u64 nanosecond_time_0
Time reference pair.
u8 ht_log2len
Per CPU flow-state.
vnet_main_t * vnet_main
convenience vnet_main_t pointer
flowprobe_main_t flowprobe_main
timestamp_nsec_t flow_start
vl_api_mac_address_t src_mac
struct _vlib_node_registration vlib_node_registration_t
vlib_buffer_t ** buffers_per_worker
ipfix buffers under construction, per-worker thread
void flowprobe_flush_callback_l2(void)
VLIB buffer representation.
u16 msg_id_base
API message ID base.
ip46_address_t dst_address
vlib_node_registration_t flowprobe_walker_node
(constructor) VLIB_REGISTER_NODE (flowprobe_walker_node)
u16 * next_record_offset_per_worker
next record offset, per worker thread
timestamp_nsec_t flow_end
vlib_main_t * vlib_main
convenience vlib_main_t pointer