diff options
Diffstat (limited to 'src/vnet/session/session_cli.c')
-rwxr-xr-x | src/vnet/session/session_cli.c | 48 |
1 files changed, 23 insertions, 25 deletions
diff --git a/src/vnet/session/session_cli.c b/src/vnet/session/session_cli.c index 99baf4431ac..e92d432c8a8 100755 --- a/src/vnet/session/session_cli.c +++ b/src/vnet/session/session_cli.c @@ -1,5 +1,5 @@ /* - * Copyright (c) 2017 Cisco and/or its affiliates. + * Copyright (c) 2017-2019 Cisco and/or its affiliates. * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at: @@ -18,27 +18,25 @@ u8 * format_session_fifos (u8 * s, va_list * args) { - stream_session_t *ss = va_arg (*args, stream_session_t *); + session_t *ss = va_arg (*args, session_t *); int verbose = va_arg (*args, int); session_event_t _e, *e = &_e; u8 found; - if (!ss->server_rx_fifo || !ss->server_tx_fifo) + if (!ss->rx_fifo || !ss->tx_fifo) return s; - s = format (s, " Rx fifo: %U", format_svm_fifo, ss->server_rx_fifo, - verbose); - if (verbose > 2 && ss->server_rx_fifo->has_event) + s = format (s, " Rx fifo: %U", format_svm_fifo, ss->rx_fifo, verbose); + if (verbose > 2 && ss->rx_fifo->has_event) { - found = session_node_lookup_fifo_event (ss->server_rx_fifo, e); + found = session_node_lookup_fifo_event (ss->rx_fifo, e); s = format (s, " session node event: %s\n", found ? "found" : "not found"); } - s = format (s, " Tx fifo: %U", format_svm_fifo, ss->server_tx_fifo, - verbose); - if (verbose > 2 && ss->server_tx_fifo->has_event) + s = format (s, " Tx fifo: %U", format_svm_fifo, ss->tx_fifo, verbose); + if (verbose > 2 && ss->tx_fifo->has_event) { - found = session_node_lookup_fifo_event (ss->server_tx_fifo, e); + found = session_node_lookup_fifo_event (ss->tx_fifo, e); s = format (s, " session node event: %s\n", found ? "found" : "not found"); } @@ -56,7 +54,7 @@ format_session_fifos (u8 * s, va_list * args) u8 * format_stream_session (u8 * s, va_list * args) { - stream_session_t *ss = va_arg (*args, stream_session_t *); + session_t *ss = va_arg (*args, session_t *); int verbose = va_arg (*args, int); u32 tp = session_get_transport_proto (ss); u8 *str = 0; @@ -73,8 +71,8 @@ format_stream_session (u8 * s, va_list * args) u8 hasf = post_accept | session_tx_is_dgram (ss); u32 rxf, txf; - rxf = hasf ? svm_fifo_max_dequeue (ss->server_rx_fifo) : 0; - txf = hasf ? svm_fifo_max_dequeue (ss->server_tx_fifo) : 0; + rxf = hasf ? svm_fifo_max_dequeue (ss->rx_fifo) : 0; + txf = hasf ? svm_fifo_max_dequeue (ss->tx_fifo) : 0; str = format (0, "%-10u%-10u", rxf, txf); } @@ -164,10 +162,10 @@ unformat_stream_session_id (unformat_input_t * input, va_list * args) uword unformat_stream_session (unformat_input_t * input, va_list * args) { - stream_session_t **result = va_arg (*args, stream_session_t **); + session_t **result = va_arg (*args, session_t **); u32 lcl_port = 0, rmt_port = 0, fib_index = 0; ip46_address_t lcl, rmt; - stream_session_t *s; + session_t *s; u8 proto = ~0; u8 is_ip4 = 0; @@ -234,7 +232,7 @@ show_session_command_fn (vlib_main_t * vm, unformat_input_t * input, u8 one_session = 0, do_listeners = 0, sst, do_elog = 0; session_manager_main_t *smm = &session_manager_main; u32 transport_proto = ~0, track_index; - stream_session_t *pool, *s; + session_t *pool, *s; transport_connection_t *tc; app_worker_t *app_wrk; int verbose = 0, i; @@ -361,7 +359,7 @@ VLIB_CLI_COMMAND (vlib_cli_show_session_command) = /* *INDENT-ON* */ static int -clear_session (stream_session_t * s) +clear_session (session_t * s) { app_worker_t *server_wrk = app_worker_get (s->app_wrk_index); application_t *server = application_get (server_wrk->app_index); @@ -377,7 +375,7 @@ clear_session_command_fn (vlib_main_t * vm, unformat_input_t * input, u32 thread_index = 0, clear_all = 0; session_manager_worker_t *wrk; u32 session_index = ~0; - stream_session_t *session; + session_t *session; if (!smm->is_enabled) { @@ -438,7 +436,7 @@ show_session_fifo_trace_command_fn (vlib_main_t * vm, unformat_input_t * input, vlib_cli_command_t * cmd) { - stream_session_t *s = 0; + session_t *s = 0; u8 is_rx = 0, *str = 0; while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT) @@ -467,8 +465,8 @@ show_session_fifo_trace_command_fn (vlib_main_t * vm, } str = is_rx ? - svm_fifo_dump_trace (str, s->server_rx_fifo) : - svm_fifo_dump_trace (str, s->server_tx_fifo); + svm_fifo_dump_trace (str, s->rx_fifo) : + svm_fifo_dump_trace (str, s->tx_fifo); vlib_cli_output (vm, "%v", str); return 0; @@ -487,7 +485,7 @@ static clib_error_t * session_replay_fifo_command_fn (vlib_main_t * vm, unformat_input_t * input, vlib_cli_command_t * cmd) { - stream_session_t *s = 0; + session_t *s = 0; u8 is_rx = 0, *str = 0; while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT) @@ -514,8 +512,8 @@ session_replay_fifo_command_fn (vlib_main_t * vm, unformat_input_t * input, } str = is_rx ? - svm_fifo_replay (str, s->server_rx_fifo, 0, 1) : - svm_fifo_replay (str, s->server_tx_fifo, 0, 1); + svm_fifo_replay (str, s->rx_fifo, 0, 1) : + svm_fifo_replay (str, s->tx_fifo, 0, 1); vlib_cli_output (vm, "%v", str); return 0; |