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	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 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, stream_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 int	session_output_try_get_buffers (vlib_main_t *vm, session_manager_main_t *smm, u32 thread_index, u16 *n_bufs, u32 wanted)
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 (stream_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_event_t *e, stream_session_t *s, int *n_tx_packets, u8 peek_data)
int	session_tx_fifo_peek_and_snd (vlib_main_t *vm, vlib_node_runtime_t *node, session_event_t *e, stream_session_t *s, int *n_tx_pkts)
int	session_tx_fifo_dequeue_and_snd (vlib_main_t *vm, vlib_node_runtime_t *node, session_event_t *e, stream_session_t *s, int *n_tx_pkts)
int	session_tx_fifo_dequeue_internal (vlib_main_t *vm, vlib_node_runtime_t *node, session_event_t *e, stream_session_t *s, int *n_tx_pkts)
static stream_session_t *	session_event_get_session (session_event_t *e, u8 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)

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...

Macro Definition Documentation

#define foreach_session_queue_error

Value:

_(TX, "Packets transmitted")                    \
_(TIMER, "Timer events")                        \
_(NO_BUFFER, "Out of buffers")

Definition at line 218 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 237 of file session_node.c.

enum session_queue_error_t

Enumerator
SESSION_QUEUE_N_ERROR

Definition at line 223 of file session_node.c.

Function Documentation

void dump_thread_0_event_queue

(

void

)

Definition at line 943 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 207 of file session_node.c.

Here is the call graph for this function:

static stream_session_t* session_event_get_session ( session_event_t *  e, u8  thread_index  )

inlinestatic

Definition at line 741 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 28 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 126 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 172 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 85 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 1001 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 1031 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static int session_output_try_get_buffers ( vlib_main_t *  vm, session_manager_main_t *  smm, u32  thread_index, u16 *  n_bufs, u32  wanted  )

inlinestatic

Definition at line 344 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 1076 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 747 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 1095 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 265 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	(	vlib_main_t *	vm,
		vlib_node_runtime_t *	node,
		session_event_t *	e,
		stream_session_t *	s,
		int *	n_tx_pkts
	)

Definition at line 719 of file session_node.c.

Here is the call graph for this function:

int session_tx_fifo_dequeue_internal	(	vlib_main_t *	vm,
		vlib_node_runtime_t *	node,
		session_event_t *	e,
		stream_session_t *	s,
		int *	n_tx_pkts
	)

Definition at line 727 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	(	vlib_main_t *	vm,
		vlib_node_runtime_t *	node,
		session_event_t *	e,
		stream_session_t *	s,
		int *	n_tx_pkts
	)

Definition at line 711 of file session_node.c.

Here is the call graph for this function:

static int session_tx_fifo_read_and_snd_i ( vlib_main_t *  vm, vlib_node_runtime_t *  node, session_event_t *  e, stream_session_t *  s, int *  n_tx_packets, u8  peek_data  )

inlinestatic

Definition at line 542 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 359 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 455 of file session_node.c.

Here is the caller graph for this function:

static u8 session_tx_not_ready ( stream_session_t *  s, u8  peek_data  )

inlinestatic

Definition at line 440 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 475 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, stream_session_t *  s, u32  n_trace  )

static

Definition at line 245 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) 
  foreach_session_queue_error

}

Definition at line 231 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,
  .type = VLIB_NODE_TYPE_INPUT,
  .n_errors = ARRAY_LEN (session_queue_error_strings),
  .error_strings = session_queue_error_strings,
  .state = VLIB_NODE_STATE_DISABLED,
}

(constructor) VLIB_REGISTER_NODE (session_queue_node)

Definition at line 197 of file session_node.c.

vlib_node_registration_t session_queue_process_node

Initial value:

=
{
  .function = session_queue_process,
  .type = VLIB_NODE_TYPE_PROCESS,
  .name = "session-queue-process",
  .state = VLIB_NODE_STATE_DISABLED,
}

(constructor) VLIB_REGISTER_NODE (session_queue_process_node)

Definition at line 1129 of file session_node.c.