|
static void | session_mq_accepted_reply_handler (void *data) |
|
static void | accepted_notify_cb (void *data, u32 data_len) |
|
static void | session_mq_reset_reply_handler (void *data) |
|
static void | session_mq_disconnected_handler (void *data) |
|
static void | session_mq_disconnected_reply_handler (void *data) |
|
static void | session_mq_worker_update_handler (void *data) |
|
static u8 * | format_session_queue_trace (u8 *s, va_list *args) |
|
static void | session_tx_trace_frame (vlib_main_t *vm, vlib_node_runtime_t *node, u32 next_index, u32 *to_next, u16 n_segs, session_t *s, u32 n_trace) |
|
static void | session_tx_fifo_chain_tail (vlib_main_t *vm, session_tx_context_t *ctx, vlib_buffer_t *b, u16 *n_bufs, u8 peek_data) |
|
static void | session_tx_fill_buffer (vlib_main_t *vm, session_tx_context_t *ctx, vlib_buffer_t *b, u16 *n_bufs, u8 peek_data) |
|
static u8 | session_tx_not_ready (session_t *s, u8 peek_data) |
|
static transport_connection_t * | session_tx_get_transport (session_tx_context_t *ctx, u8 peek_data) |
|
static void | session_tx_set_dequeue_params (vlib_main_t *vm, session_tx_context_t *ctx, u32 max_segs, u8 peek_data) |
|
static int | session_tx_fifo_read_and_snd_i (vlib_main_t *vm, vlib_node_runtime_t *node, session_worker_t *wrk, session_event_t *e, int *n_tx_packets, u8 peek_data) |
|
int | session_tx_fifo_peek_and_snd (vlib_main_t *vm, vlib_node_runtime_t *node, session_worker_t *wrk, session_event_t *e, int *n_tx_pkts) |
|
int | session_tx_fifo_dequeue_and_snd (vlib_main_t *vm, vlib_node_runtime_t *node, session_worker_t *wrk, session_event_t *e, int *n_tx_pkts) |
|
int | session_tx_fifo_dequeue_internal (vlib_main_t *vm, vlib_node_runtime_t *node, session_worker_t *wrk, session_event_t *e, int *n_tx_pkts) |
|
static session_t * | session_event_get_session (session_event_t *e, u8 thread_index) |
|
static void | session_update_dispatch_period (session_worker_t *wrk, f64 now, u32 thread_index) |
|
static uword | session_queue_node_fn (vlib_main_t *vm, vlib_node_runtime_t *node, vlib_frame_t *frame) |
|
void | dump_thread_0_event_queue (void) |
|
static u8 | session_node_cmp_event (session_event_t *e, svm_fifo_t *f) |
|
u8 | session_node_lookup_fifo_event (svm_fifo_t *f, session_event_t *e) |
|
static clib_error_t * | session_queue_exit (vlib_main_t *vm) |
|
static uword | session_queue_process (vlib_main_t *vm, vlib_node_runtime_t *rt, vlib_frame_t *f) |
|
static_always_inline uword | session_queue_pre_input_inline (vlib_main_t *vm, vlib_node_runtime_t *node, vlib_frame_t *frame) |
|