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");
47 #define _(sym, str) str, 66 #define _(sym, str) str, 78 if (ss->
flags & (1 << i))
81 for (i = 0; i <
last; i++)
83 if (ss->
flags & (1 << i))
104 int verbose = va_arg (*args,
int);
117 u8 hasf = post_accept
123 str =
format (0,
"%-10u%-10u", rxf, txf);
132 s =
format (s,
"%v", str);
136 s =
format (s,
" session: state: %U opaque: 0x%x flags: %U\n",
166 u32 *fib_index = va_arg (*args,
u32 *);
167 ip46_address_t *lcl = va_arg (*args, ip46_address_t *);
168 ip46_address_t *rmt = va_arg (*args, ip46_address_t *);
169 u16 *lcl_port = va_arg (*args,
u16 *);
170 u16 *rmt_port = va_arg (*args,
u16 *);
180 *proto = TRANSPORT_PROTO_TCP;
184 *proto = TRANSPORT_PROTO_UDP;
189 if (
unformat (input,
"vrf %u", &vrf))
222 #define _(sym, str) \ 223 if (unformat (input, str)) \ 225 *state = SESSION_STATE_ ## sym; \ 240 u32 lcl_port = 0, rmt_port = 0, fib_index = 0;
241 ip46_address_t lcl, rmt;
247 &lcl, &rmt, &lcl_port, &rmt_port, &is_ip4))
252 clib_host_to_net_u16 (lcl_port),
253 clib_host_to_net_u16 (rmt_port), proto);
256 clib_host_to_net_u16 (lcl_port),
257 clib_host_to_net_u16 (rmt_port), proto);
271 u32 suggested_proto = va_arg (*args,
u32);
274 ip46_address_t lcl, rmt;
275 u32 lcl_port = 0, rmt_port = 0, fib_index = 0;
279 &lcl, &rmt, &lcl_port, &rmt_port, &is_ip4))
282 proto = (proto == (
u8) ~ 0) ? suggested_proto :
proto;
283 if (proto == (
u8) ~ 0)
287 clib_host_to_net_u16 (lcl_port),
288 clib_host_to_net_u16 (rmt_port), proto);
291 clib_host_to_net_u16 (lcl_port),
292 clib_host_to_net_u16 (rmt_port), proto);
306 u32 n_closed, thread_index;
309 for (thread_index = 0; thread_index <
vec_len (smm->
wrk); thread_index++)
329 "suppressed. For more details use filters.",
336 thread_index ?
"\n" :
"",
337 "Connection",
"State",
"Rx-f",
"Tx-f");
357 thread_index,
pool_elts (pool) - n_closed, n_closed);
369 goto check_transport;
386 u8 output_suppressed = 0;
402 && (start == 0 && end == ~0))
410 for (i = start; i <=
clib_min (end, max_index); i++)
422 if (count > 50 || (verbose > 1 && count > 10))
424 output_suppressed = 1;
433 if (!output_suppressed)
435 thread_index, count);
438 " shown. Use finer grained filter.", thread_index,
445 #define _(sym, str, sstr) vlib_cli_output (vm, str); 453 #define _(sym, str) vlib_cli_output (vm, str); 462 u8 one_session = 0, do_listeners = 0, sst, do_elog = 0, do_filter = 0;
463 u32 track_index, thread_index = 0, start = 0,
end = ~0, session_index;
485 if (
unformat (line_input,
"verbose %d", &verbose))
487 else if (
unformat (line_input,
"verbose"))
496 else if (
unformat (line_input,
"thread %u index %u", &thread_index,
507 else if (
unformat (line_input,
"thread %u", &thread_index))
517 else if (
unformat (line_input,
"proto %U index %u",
527 " allocated", transport_index, thread_index);
534 "thread %u does not exist", transport_index,
543 else if (
unformat (line_input,
"range %u %u", &start, &
end))
545 else if (
unformat (line_input,
"range %u", &start))
550 else if (
unformat (line_input,
"elog"))
552 else if (
unformat (line_input,
"protos"))
557 else if (
unformat (line_input,
"states"))
583 if (track_index != ~0)
598 if (s->session_state != SESSION_STATE_LISTENING
599 || s->session_type != sst)
601 app_wrk = app_worker_get (s->app_wrk_index);
602 app_name = application_name_from_index (app_wrk->app_index);
603 vlib_cli_output (vm,
"%U%-25v%", format_session, s, 0,
619 transport_proto, verbose);
634 .path =
"show session",
635 .short_help =
"show session [verbose [n]] [listeners <proto>] " 636 "[<session-id> [elog]] [thread <n> [index <n>] " 637 "[proto <proto>] [state <state>] [range <min> [<max>]] " 638 "[protos] [states] ",
656 u32 thread_index = 0, clear_all = 0;
658 u32 session_index = ~0;
668 if (
unformat (input,
"thread %d", &thread_index))
670 else if (
unformat (input,
"session %d", &session_index))
679 if (!clear_all && session_index == ~0)
682 if (session_index != ~0)
687 session_index, thread_index);
697 clear_session (session);
709 .path =
"clear session",
710 .short_help =
"clear session thread <thread> session <index>",
721 u8 is_rx = 0, *str = 0;
759 .path =
"show session fifo trace",
760 .short_help =
"show session fifo trace <session>",
770 u8 is_rx = 0, *str = 0;
806 .path =
"session replay fifo",
807 .short_help =
"session replay fifo <session>",
825 if (
unformat (line_input,
"enable"))
827 else if (
unformat (line_input,
"disable"))
846 .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
format_function_t format_svm_fifo
u32 session_index
Index in thread pool where session was allocated.
#define session_cli_return_if_not_enabled()
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)
#define vec_add1(V, E)
Add 1 element to end of vector (unspecified alignment).
static transport_proto_t session_get_transport_proto(session_t *s)
static heap_elt_t * last(heap_header_t *h)
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.
u8 * format_session_state(u8 *s, va_list *args)
#define pool_len(p)
Number of elements in pool vector.
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.
#define foreach_transport_proto
static u32 svm_fifo_max_dequeue(svm_fifo_t *f)
Fifo max bytes to dequeue.
#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.
uword unformat_session_state(unformat_input_t *input, va_list *args)
static session_type_t session_type_from_proto_and_ip(transport_proto_t proto, u8 is_ip4)
#define pool_elt_at_index(p, i)
Returns pointer to element at given index.
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)
static transport_connection_t * transport_get_connection(transport_proto_t tp, u32 conn_index, u8 thread_index)
#define vec_free(V)
Free vector's memory (no header).
static void session_cli_print_session_states(vlib_main_t *vm)
const char * session_flags_str[]
#define clib_warning(format, args...)
struct _transport_connection transport_connection_t
#define pool_is_free_index(P, I)
Use free bitmap to query whether given index is free.
static u32 transport_elog_track_index(transport_connection_t *tc)
#define VLIB_CLI_COMMAND(x,...)
const char * session_state_str[]
static void session_cli_show_session_filter(vlib_main_t *vm, u32 thread_index, u32 start, u32 end, session_state_t *states, transport_proto_t tp, int verbose)
uword unformat_transport_proto(unformat_input_t *input, va_list *args)
static void session_cli_print_transport_protos(vlib_main_t *vm)
u64 cpu
CPU cycle counter.
static int session_cli_filter_check(session_t *s, session_state_t *states, transport_proto_t tp)
#define foreach_session_state
u8 * format_transport_half_open_connection(u8 *s, va_list *args)
enum _transport_proto transport_proto_t
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.
u32 opaque
Opaque, for general use.
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)
u8 * format_session_flags(u8 *s, va_list *args)
vl_api_dhcp_client_state_t state
#define vec_foreach(var, vec)
Vector iterator.
u32 app_wrk_index
Index of the app worker that owns the session.
f64 end
end of the time range
u8 session_node_lookup_fifo_event(svm_fifo_t *f, session_event_t *e)
static void session_cli_show_all_sessions(vlib_main_t *vm, int verbose)
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)
static transport_service_type_t session_transport_service_type(session_t *s)
void vlib_cli_output(vlib_main_t *vm, char *fmt,...)
static session_worker_t * session_main_get_worker_if_valid(u32 thread_index)
static uword pool_elts(void *v)
Number of active elements in a pool.