FD.io VPP  v19.08-27-gf4dcae4
Vector Packet Processing
session_node.c File Reference
+ Include dependency graph for session_node.c:

Go to the source code of this file.

Data Structures

struct  session_queue_trace_t
 

Macros

#define foreach_session_queue_error
 

Enumerations

enum  session_queue_error_t { SESSION_QUEUE_N_ERROR }
 
enum  { SESSION_TX_NO_BUFFERS = -2, SESSION_TX_NO_DATA, SESSION_TX_OK }
 

Functions

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 u8format_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_tsession_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 (session_worker_t *wrk, vlib_node_runtime_t *node, session_evt_elt_t *elt, int *n_tx_packets, u8 peek_data)
 
int session_tx_fifo_peek_and_snd (session_worker_t *wrk, vlib_node_runtime_t *node, session_evt_elt_t *e, int *n_tx_packets)
 
int session_tx_fifo_dequeue_and_snd (session_worker_t *wrk, vlib_node_runtime_t *node, session_evt_elt_t *e, int *n_tx_packets)
 
int session_tx_fifo_dequeue_internal (session_worker_t *wrk, vlib_node_runtime_t *node, session_evt_elt_t *e, int *n_tx_packets)
 
static session_tsession_event_get_session (session_event_t *e, u8 thread_index)
 
static void session_event_dispatch (session_worker_t *wrk, vlib_node_runtime_t *node, session_evt_elt_t *elt, u32 thread_index, int *n_tx_packets)
 
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_tsession_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)
 

Variables

vlib_node_registration_t session_queue_node
 (constructor) VLIB_REGISTER_NODE (session_queue_node) More...
 
static char * session_queue_error_strings []
 
vlib_node_registration_t session_queue_process_node
 (constructor) VLIB_REGISTER_NODE (session_queue_process_node) More...
 
vlib_node_registration_t session_queue_pre_input_node
 (constructor) VLIB_REGISTER_NODE (session_queue_pre_input_node) More...
 

Macro Definition Documentation

#define foreach_session_queue_error
Value:
_(TX, "Packets transmitted") \
_(TIMER, "Timer events") \
_(NO_BUFFER, "Out of buffers")

Definition at line 313 of file session_node.c.

Enumeration Type Documentation

anonymous enum
Enumerator
SESSION_TX_NO_BUFFERS 
SESSION_TX_NO_DATA 
SESSION_TX_OK 

Definition at line 332 of file session_node.c.

Enumerator
SESSION_QUEUE_N_ERROR 

Definition at line 318 of file session_node.c.

Function Documentation

static void accepted_notify_cb ( void *  data,
u32  data_len 
)
static

Definition at line 31 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

void dump_thread_0_event_queue ( void  )

Definition at line 1080 of file session_node.c.

+ Here is the call graph for this function:

static u8* format_session_queue_trace ( u8 s,
va_list *  args 
)
static

Definition at line 302 of file session_node.c.

+ Here is the call graph for this function:

static void session_event_dispatch ( session_worker_t wrk,
vlib_node_runtime_t node,
session_evt_elt_t elt,
u32  thread_index,
int *  n_tx_packets 
)
inlinestatic

Definition at line 862 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

static session_t* session_event_get_session ( session_event_t *  e,
u8  thread_index 
)
inlinestatic

Definition at line 856 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

static void session_mq_accepted_reply_handler ( void *  data)
static

Definition at line 37 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

static void session_mq_disconnected_handler ( void *  data)
static

Definition at line 144 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

static void session_mq_disconnected_reply_handler ( void *  data)
static

Definition at line 189 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

static void session_mq_reset_reply_handler ( void *  data)
static

Definition at line 100 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

static void session_mq_worker_update_handler ( void *  data)
static

Definition at line 215 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

static u8 session_node_cmp_event ( session_event_t *  e,
svm_fifo_t f 
)
static

Definition at line 1139 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

u8 session_node_lookup_fifo_event ( svm_fifo_t f,
session_event_t *  e 
)

Definition at line 1169 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

static clib_error_t* session_queue_exit ( vlib_main_t vm)
static

Definition at line 1221 of file session_node.c.

+ Here is the call graph for this function:

static uword session_queue_node_fn ( vlib_main_t vm,
vlib_node_runtime_t node,
vlib_frame_t frame 
)
static

Definition at line 951 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

static_always_inline uword session_queue_pre_input_inline ( vlib_main_t vm,
vlib_node_runtime_t node,
vlib_frame_t frame 
)

Definition at line 1284 of file session_node.c.

+ Here is the call graph for this function:

static uword session_queue_process ( vlib_main_t vm,
vlib_node_runtime_t rt,
vlib_frame_t f 
)
static

Definition at line 1240 of file session_node.c.

+ Here is the call graph for this function:

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 
)
inlinestatic

Definition at line 360 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

int session_tx_fifo_dequeue_and_snd ( session_worker_t wrk,
vlib_node_runtime_t node,
session_evt_elt_t e,
int *  n_tx_packets 
)

Definition at line 834 of file session_node.c.

+ Here is the call graph for this function:

int session_tx_fifo_dequeue_internal ( session_worker_t wrk,
vlib_node_runtime_t node,
session_evt_elt_t e,
int *  n_tx_packets 
)

Definition at line 842 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

int session_tx_fifo_peek_and_snd ( session_worker_t wrk,
vlib_node_runtime_t node,
session_evt_elt_t e,
int *  n_tx_packets 
)

Definition at line 826 of file session_node.c.

+ Here is the call graph for this function:

static int session_tx_fifo_read_and_snd_i ( session_worker_t wrk,
vlib_node_runtime_t node,
session_evt_elt_t elt,
int *  n_tx_packets,
u8  peek_data 
)
inlinestatic

Definition at line 622 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

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 
)
inlinestatic

Definition at line 439 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

static transport_connection_t* session_tx_get_transport ( session_tx_context_t ctx,
u8  peek_data 
)
inlinestatic

Definition at line 535 of file session_node.c.

+ Here is the caller graph for this function:

static u8 session_tx_not_ready ( session_t s,
u8  peek_data 
)
inlinestatic

Definition at line 511 of file session_node.c.

+ Here is the caller graph for this function:

static void session_tx_set_dequeue_params ( vlib_main_t vm,
session_tx_context_t ctx,
u32  max_segs,
u8  peek_data 
)
inlinestatic

Definition at line 555 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

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

Definition at line 340 of file session_node.c.

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

Variable Documentation

char* session_queue_error_strings[]
static
Initial value:
= {
#define _(sym,string)
}
#define foreach_session_queue_error
Definition: session_node.c:313

Definition at line 326 of file session_node.c.

vlib_node_registration_t session_queue_node
Initial value:
=
{
.function = session_queue_node_fn,
.name = "session-queue",
.format_trace = format_session_queue_trace,
.error_strings = session_queue_error_strings,
.state = VLIB_NODE_STATE_DISABLED,
}
static uword session_queue_node_fn(vlib_main_t *vm, vlib_node_runtime_t *node, vlib_frame_t *frame)
Definition: session_node.c:951
static char * session_queue_error_strings[]
Definition: session_node.c:326
#define ARRAY_LEN(x)
Definition: clib.h:62
static u8 * format_session_queue_trace(u8 *s, va_list *args)
Definition: session_node.c:302

(constructor) VLIB_REGISTER_NODE (session_queue_node)

Definition at line 292 of file session_node.c.

vlib_node_registration_t session_queue_pre_input_node
Initial value:
=
{
.name = "session-queue-main",
.state = VLIB_NODE_STATE_DISABLED,
}
static_always_inline uword session_queue_pre_input_inline(vlib_main_t *vm, vlib_node_runtime_t *node, vlib_frame_t *frame)

(constructor) VLIB_REGISTER_NODE (session_queue_pre_input_node)

Definition at line 1294 of file session_node.c.

vlib_node_registration_t session_queue_process_node
Initial value:
=
{
.function = session_queue_process,
.name = "session-queue-process",
.state = VLIB_NODE_STATE_DISABLED,
}
static uword session_queue_process(vlib_main_t *vm, vlib_node_runtime_t *rt, vlib_frame_t *f)

(constructor) VLIB_REGISTER_NODE (session_queue_process_node)

Definition at line 1274 of file session_node.c.