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	app_check_thread_and_barrier(_fn, _arg)
#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_wrk_timerfd_update (session_worker_t *wrk, u64 time_ns)
static u64	session_wrk_tfd_timeout (session_wrk_state_t state, u32 thread_index)
static void	session_wrk_set_state (session_worker_t *wrk, session_wrk_state_t state)
static transport_endpt_ext_cfg_t *	session_mq_get_ext_config (application_t *app, uword offset)
static void	session_mq_free_ext_config (application_t *app, uword offset)
static void	session_mq_listen_handler (void *data)
static void	session_mq_listen_uri_handler (void *data)
static void	session_mq_connect_one (session_connect_msg_t *mp)
static void	session_mq_handle_connects_rpc (void *arg)
static void	session_mq_connect_handler (session_worker_t *wrk, session_evt_elt_t *elt)
static void	session_mq_connect_uri_handler (void *data)
static void	session_mq_shutdown_handler (void *data)
static void	session_mq_disconnect_handler (void *data)
static void	app_mq_detach_handler (void *data)
static void	session_mq_unlisten_rpc (session_unlisten_msg_t *mp)
static void	session_mq_unlisten_handler (session_worker_t *wrk, session_evt_elt_t *elt)
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 void	session_mq_worker_update_handler (void *data)
static void	session_mq_app_wrk_rpc_handler (void *data)
static void	session_mq_transport_attr_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 void	session_tx_maybe_reschedule (session_worker_t *wrk, session_tx_context_t *ctx, session_evt_elt_t *elt)
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 *elt, int *n_tx_packets)
static session_t *	session_event_get_session (session_worker_t *wrk, session_event_t *e)
static void	session_event_dispatch_ctrl (session_worker_t *wrk, session_evt_elt_t *elt)
static void	session_event_dispatch_io (session_worker_t *wrk, vlib_node_runtime_t *node, session_evt_elt_t *elt, int *n_tx_packets)
static void	session_evt_add_to_list (session_worker_t *wrk, session_event_t *evt)
static void	session_flush_pending_tx_buffers (session_worker_t *wrk, vlib_node_runtime_t *node)
int	session_wrk_handle_mq (session_worker_t *wrk, svm_msg_q_t *mq)
static void	session_wrk_update_state (session_worker_t *wrk)
static uword	session_queue_node_fn (vlib_main_t *vm, vlib_node_runtime_t *node, vlib_frame_t *frame)
static clib_error_t *	session_wrk_tfd_read_ready (clib_file_t *cf)
static clib_error_t *	session_wrk_tfd_write_ready (clib_file_t *cf)
void	session_wrk_enable_adaptive_mode (session_worker_t *wrk)
static clib_error_t *	session_queue_exit (vlib_main_t *vm)
static uword	session_queue_run_on_main (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 []
static const u32	session_evt_msg_sizes []
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

app_check_thread_and_barrier

#define app_check_thread_and_barrier	(		_fn,
			_arg
	)

Value:

  if (!vlib_thread_is_main_w_barrier ())                                \
    {                                                                   \
     vlib_rpc_call_main_thread (_fn, (u8 *) _arg, sizeof(*_arg));       \
      return;                                                           \
   }

Definition at line 29 of file session_node.c.

foreach_session_queue_error

#define foreach_session_queue_error

Value:

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

Definition at line 798 of file session_node.c.

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
SESSION_TX_NO_BUFFERS
SESSION_TX_NO_DATA
SESSION_TX_OK

Definition at line 817 of file session_node.c.

session_queue_error_t

enum session_queue_error_t

Enumerator
SESSION_QUEUE_N_ERROR

Definition at line 803 of file session_node.c.

Function Documentation

app_mq_detach_handler()

static void app_mq_detach_handler ( void *  data )

static

Definition at line 373 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

format_session_queue_trace()

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

static

Definition at line 787 of file session_node.c.

session_event_dispatch_ctrl()

static void session_event_dispatch_ctrl ( session_worker_t *  wrk, session_evt_elt_t *  elt  )

inlinestatic

Definition at line 1467 of file session_node.c.

Here is the call graph for this function:

session_event_dispatch_io()

static void session_event_dispatch_io ( session_worker_t *  wrk, vlib_node_runtime_t *  node, session_evt_elt_t *  elt, int *  n_tx_packets  )

inlinestatic

Definition at line 1564 of file session_node.c.

Here is the call graph for this function:

session_event_get_session()

static session_t* session_event_get_session ( session_worker_t *  wrk, session_event_t *  e  )

inlinestatic

Definition at line 1457 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_evt_add_to_list()

static void session_evt_add_to_list ( session_worker_t *  wrk, session_event_t *  evt  )

inlinestatic

Definition at line 1632 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_flush_pending_tx_buffers()

static void session_flush_pending_tx_buffers ( session_worker_t *  wrk, vlib_node_runtime_t *  node  )

static

Definition at line 1660 of file session_node.c.

Here is the call graph for this function:

session_mq_accepted_reply_handler()

static void session_mq_accepted_reply_handler ( void *  data )

static

Definition at line 448 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_app_wrk_rpc_handler()

static void session_mq_app_wrk_rpc_handler ( void *  data )

static

Definition at line 706 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_connect_handler()

static void session_mq_connect_handler ( session_worker_t *  wrk, session_evt_elt_t *  elt  )

static

Definition at line 281 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_connect_one()

static void session_mq_connect_one ( session_connect_msg_t *  mp )

static

Definition at line 159 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_connect_uri_handler()

static void session_mq_connect_uri_handler ( void *  data )

static

Definition at line 314 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_disconnect_handler()

static void session_mq_disconnect_handler ( void *  data )

static

Definition at line 357 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_disconnected_handler()

static void session_mq_disconnected_handler ( void *  data )

static

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:

session_mq_disconnected_reply_handler()

static void session_mq_disconnected_reply_handler ( void *  data )

static

Definition at line 600 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_free_ext_config()

static void session_mq_free_ext_config ( application_t *  app, uword  offset  )

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:

session_mq_get_ext_config()

static transport_endpt_ext_cfg_t* session_mq_get_ext_config ( application_t *  app, uword  offset  )

static

Definition at line 74 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_handle_connects_rpc()

static void session_mq_handle_connects_rpc ( void *  arg )

static

Definition at line 205 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_listen_handler()

static void session_mq_listen_handler ( void *  data )

static

Definition at line 96 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_listen_uri_handler()

static void session_mq_listen_uri_handler ( void *  data )

static

Definition at line 135 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_reset_reply_handler()

static void session_mq_reset_reply_handler ( void *  data )

static

Definition at line 511 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_shutdown_handler()

static void session_mq_shutdown_handler ( void *  data )

static

Definition at line 341 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_transport_attr_handler()

static void session_mq_transport_attr_handler ( void *  data )

static

Definition at line 733 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_unlisten_handler()

static void session_mq_unlisten_handler ( session_worker_t *  wrk, session_evt_elt_t *  elt  )

static

Definition at line 429 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_unlisten_rpc()

static void session_mq_unlisten_rpc ( session_unlisten_msg_t *  mp )

static

Definition at line 391 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_mq_worker_update_handler()

static void session_mq_worker_update_handler ( void *  data )

static

Definition at line 626 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_queue_exit()

static clib_error_t* session_queue_exit ( vlib_main_t *  vm )

static

Definition at line 1889 of file session_node.c.

Here is the call graph for this function:

session_queue_node_fn()

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

static

Definition at line 1728 of file session_node.c.

Here is the caller graph for this function:

session_queue_pre_input_inline()

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 1961 of file session_node.c.

Here is the call graph for this function:

session_queue_process()

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

static

Definition at line 1917 of file session_node.c.

Here is the call graph for this function:

session_queue_run_on_main()

static uword session_queue_run_on_main ( vlib_main_t *  vm )

static

Definition at line 1908 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_tx_fifo_chain_tail()

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 849 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_tx_fifo_dequeue_and_snd()

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 1409 of file session_node.c.

Here is the call graph for this function:

session_tx_fifo_dequeue_internal()

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

Definition at line 1417 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_tx_fifo_peek_and_snd()

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 1401 of file session_node.c.

Here is the call graph for this function:

session_tx_fifo_read_and_snd_i()

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 1196 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_tx_fill_buffer()

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 934 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_tx_get_transport()

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

inlinestatic

Definition at line 1044 of file session_node.c.

Here is the caller graph for this function:

session_tx_maybe_reschedule()

static void session_tx_maybe_reschedule ( session_worker_t *  wrk, session_tx_context_t *  ctx, session_evt_elt_t *  elt  )

inlinestatic

Definition at line 1183 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_tx_not_ready()

static u8 session_tx_not_ready ( session_t *  s, u8  peek_data  )

inlinestatic

Definition at line 1012 of file session_node.c.

Here is the caller graph for this function:

session_tx_set_dequeue_params()

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 1064 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_tx_trace_frame()

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 825 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_wrk_enable_adaptive_mode()

void session_wrk_enable_adaptive_mode

(

session_worker_t *

wrk

)

Definition at line 1869 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_wrk_handle_mq()

int session_wrk_handle_mq	(	session_worker_t *	wrk,
		svm_msg_q_t *	mq
	)

Definition at line 1671 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_wrk_set_state()

static void session_wrk_set_state ( session_worker_t *  wrk, session_wrk_state_t  state  )

inlinestatic

Definition at line 62 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_wrk_tfd_read_ready()

static clib_error_t* session_wrk_tfd_read_ready ( clib_file_t *  cf )

static

Definition at line 1849 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_wrk_tfd_timeout()

static u64 session_wrk_tfd_timeout ( session_wrk_state_t  state, u32  thread_index  )

inlinestatic

Definition at line 51 of file session_node.c.

Here is the call graph for this function:

Here is the caller graph for this function:

session_wrk_tfd_write_ready()

static clib_error_t* session_wrk_tfd_write_ready ( clib_file_t *  cf )

static

Definition at line 1863 of file session_node.c.

Here is the caller graph for this function:

session_wrk_timerfd_update()

static void session_wrk_timerfd_update ( session_worker_t *  wrk, u64  time_ns  )

static

Definition at line 37 of file session_node.c.

Here is the caller graph for this function:

session_wrk_update_state()

static void session_wrk_update_state ( session_worker_t *  wrk )

static

Definition at line 1690 of file session_node.c.

Here is the call graph for this function:

Variable Documentation

session_evt_msg_sizes

const u32 session_evt_msg_sizes[]

static

Initial value:

= {
#define _(symc, sym)                                                    
 
  foreach_session_ctrl_evt
 
}

Definition at line 1623 of file session_node.c.

session_queue_error_strings

char* session_queue_error_strings[]

static

Initial value:

= {
#define _(sym,string) 
  foreach_session_queue_error
 
}

Definition at line 811 of file session_node.c.

session_queue_node

vlib_node_registration_t session_queue_node

Initial value:

=
{
  .function = session_queue_node_fn,
  .flags = VLIB_NODE_FLAG_TRACE_SUPPORTED,
  .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 777 of file session_node.c.

session_queue_pre_input_node

vlib_node_registration_t session_queue_pre_input_node

Initial value:

=
{
  .function = session_queue_pre_input_inline,
  .type = VLIB_NODE_TYPE_PRE_INPUT,
  .name = "session-queue-main",
  .state = VLIB_NODE_STATE_DISABLED,
}

(constructor) VLIB_REGISTER_NODE (session_queue_pre_input_node)

Definition at line 1972 of file session_node.c.

session_queue_process_node

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 1951 of file session_node.c.