22 int verbose = va_arg (*args,
int);
23 session_event_t _e, *e = &_e;
30 if (verbose > 2 && ss->
rx_fifo->has_event)
33 s =
format (s,
" session node event: %s\n",
34 found ?
"found" :
"not found");
37 if (verbose > 2 && ss->
tx_fifo->has_event)
40 s =
format (s,
" session node event: %s\n",
41 found ?
"found" :
"not found");
58 int verbose = va_arg (*args,
int);
76 str =
format (0,
"%-10u%-10u", rxf, txf);
113 u8 *proto = va_arg (*args,
u8 *);
114 u32 *fib_index = va_arg (*args,
u32 *);
115 ip46_address_t *lcl = va_arg (*args, ip46_address_t *);
116 ip46_address_t *rmt = va_arg (*args, ip46_address_t *);
117 u16 *lcl_port = va_arg (*args,
u16 *);
118 u16 *rmt_port = va_arg (*args,
u16 *);
119 u8 *is_ip4 = va_arg (*args,
u8 *);
137 if (
unformat (input,
"vrf %u", &vrf))
167 u32 lcl_port = 0, rmt_port = 0, fib_index = 0;
168 ip46_address_t lcl, rmt;
174 &lcl, &rmt, &lcl_port, &rmt_port, &is_ip4))
179 clib_host_to_net_u16 (lcl_port),
180 clib_host_to_net_u16 (rmt_port), proto);
183 clib_host_to_net_u16 (lcl_port),
184 clib_host_to_net_u16 (rmt_port), proto);
198 u32 suggested_proto = va_arg (*args,
u32);
201 ip46_address_t lcl, rmt;
202 u32 lcl_port = 0, rmt_port = 0, fib_index = 0;
206 &lcl, &rmt, &lcl_port, &rmt_port, &is_ip4))
209 proto = (proto == (
u8) ~ 0) ? suggested_proto : proto;
210 if (proto == (
u8) ~ 0)
214 clib_host_to_net_u16 (lcl_port),
215 clib_host_to_net_u16 (rmt_port), proto);
218 clib_host_to_net_u16 (lcl_port),
219 clib_host_to_net_u16 (rmt_port), proto);
233 u8 one_session = 0, do_listeners = 0, sst, do_elog = 0;
235 u32 transport_proto = ~0, track_index;
249 if (
unformat (input,
"verbose %d", &verbose))
251 else if (
unformat (input,
"verbose"))
279 if (track_index != ~0)
294 if (s->session_state != SESSION_STATE_LISTENING
295 || s->session_type != sst)
297 app_wrk = app_worker_get (s->app_wrk_index);
298 app_name = application_name_from_index (app_wrk->app_index);
299 vlib_cli_output (vm,
"%U%-25v%", format_session, s, 0,
308 u32 once_per_pool = 1, n_closed = 0;
323 if (once_per_pool && verbose == 1)
326 "Connection",
"State",
"Rx-f",
"Tx-f");
355 .path =
"show session",
356 .short_help =
"show session [verbose [n]] [listeners <proto>] " 357 "[<session-id> [elog]]",
375 u32 thread_index = 0, clear_all = 0;
377 u32 session_index = ~0;
387 if (
unformat (input,
"thread %d", &thread_index))
389 else if (
unformat (input,
"session %d", &session_index))
398 if (!clear_all && session_index == ~0)
401 if (session_index != ~0)
406 session_index, thread_index);
416 clear_session (session);
428 .path =
"clear session",
429 .short_help =
"clear session thread <thread> session <index>",
440 u8 is_rx = 0, *str = 0;
478 .path =
"show session fifo trace",
479 .short_help =
"show session fifo trace <session>",
489 u8 is_rx = 0, *str = 0;
525 .path =
"session replay fifo",
526 .short_help =
"session replay fifo <session>",
544 if (
unformat (line_input,
"enable"))
546 else if (
unformat (line_input,
"disable"))
565 .short_help =
"session [enable|disable]",
u32 connection_index
Index of the transport connection associated to the session.
u8 * format_transport_connection(u8 *s, va_list *args)
u8 * format_session_fifos(u8 *s, va_list *args)
session_main_t session_main
static u8 session_tx_is_dgram(session_t *s)
format_function_t format_svm_fifo
u32 session_index
Index in thread pool where session was allocated.
elog_time_stamp_t init_time
Timestamps.
session_t * session_lookup_safe4(u32 fib_index, ip4_address_t *lcl, ip4_address_t *rmt, u16 lcl_port, u16 rmt_port, u8 proto)
Lookup session with ip4 and transport layer information.
clib_memset(h->entries, 0, sizeof(h->entries[0]) *entries)
transport_connection_t * session_get_transport(session_t *s)
svm_fifo_t * rx_fifo
Pointers to rx/tx buffers.
session_worker_t * wrk
Worker contexts.
static session_t * session_get_if_valid(u64 si, u32 thread_index)
static transport_proto_t session_get_transport_proto(session_t *s)
static int clear_session(session_t *s)
static clib_error_t * clear_session_command_fn(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
static void session_pool_remove_peeker(u32 thread_index)
session_t * session_lookup_safe6(u32 fib_index, ip6_address_t *lcl, ip6_address_t *rmt, u16 lcl_port, u16 rmt_port, u8 proto)
Lookup session with ip6 and transport layer information.
enum fib_protocol_t_ fib_protocol_t
Protocol Type.
session_t * sessions
Worker session pool.
transport_connection_t * session_lookup_connection6(u32 fib_index, ip6_address_t *lcl, ip6_address_t *rmt, u16 lcl_port, u16 rmt_port, u8 proto)
Lookup connection with ip6 and transport layer information.
#define pool_foreach(VAR, POOL, BODY)
Iterate through pool.
static u32 svm_fifo_max_dequeue(svm_fifo_t *f)
#define clib_error_return(e, args...)
static clib_error_t * show_session_command_fn(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
u32 fib_table_find(fib_protocol_t proto, u32 table_id)
Get the index of the FIB for a Table-ID.
transport_connection_t * session_lookup_connection4(u32 fib_index, ip4_address_t *lcl, ip4_address_t *rmt, u16 lcl_port, u16 rmt_port, u8 proto)
Lookup connection with ip4 and transport layer information.
static session_type_t session_type_from_proto_and_ip(transport_proto_t proto, u8 is_ip4)
u8 is_enabled
Session manager is enabled.
uword unformat_transport_connection(unformat_input_t *input, va_list *args)
uword unformat_session(unformat_input_t *input, va_list *args)
u8 * svm_fifo_replay(u8 *s, svm_fifo_t *f, u8 no_read, u8 verbose)
clib_error_t * vnet_session_enable_disable(vlib_main_t *vm, u8 is_en)
uword unformat_stream_session_id(unformat_input_t *input, va_list *args)
#define vec_free(V)
Free vector's memory (no header).
#define clib_warning(format, args...)
struct _transport_connection transport_connection_t
static u32 transport_elog_track_index(transport_connection_t *tc)
#define VLIB_CLI_COMMAND(x,...)
uword unformat_transport_proto(unformat_input_t *input, va_list *args)
u64 cpu
CPU cycle counter.
u8 * format_transport_half_open_connection(u8 *s, va_list *args)
u8 thread_index
Index of the thread that allocated the session.
u8 * format_session(u8 *s, va_list *args)
Format stream session as per the following format.
u8 * svm_fifo_dump_trace(u8 *s, svm_fifo_t *f)
app_worker_t * app_worker_get(u32 wrk_index)
#define vec_len(v)
Number of elements in vector (rvalue-only, NULL tolerant)
u8 * format_elog_track(u8 *s, va_list *args)
volatile u8 session_state
State in session layer state machine.
u8 * format_transport_listen_connection(u8 *s, va_list *args)
static clib_error_t * session_replay_fifo_command_fn(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
static clib_error_t * show_session_fifo_trace_command_fn(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
#define vec_foreach(var, vec)
Vector iterator.
u32 app_wrk_index
Index of the app worker that owns the session.
u8 session_node_lookup_fifo_event(svm_fifo_t *f, session_event_t *e)
static clib_error_t * session_enable_disable_fn(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
int app_worker_close_notify(app_worker_t *app_wrk, session_t *s)
void vlib_cli_output(vlib_main_t *vm, char *fmt,...)
static uword pool_elts(void *v)
Number of active elements in a pool.