diff options
Diffstat (limited to 'src/plugins/quic/quic.c')
| -rw-r--r-- | src/plugins/quic/quic.c | 61 |
1 files changed, 61 insertions, 0 deletions
diff --git a/src/plugins/quic/quic.c b/src/plugins/quic/quic.c index 54a2d9019ba..0a70dd2e02a 100644 --- a/src/plugins/quic/quic.c +++ b/src/plugins/quic/quic.c @@ -549,6 +549,7 @@ quic_on_stream_destroy (quicly_stream_t * stream, int err) stream_session->session_state = SESSION_STATE_CLOSED; session_transport_delete_notify (&sctx->connection); + quic_increment_counter (QUIC_ERROR_CLOSED_STREAM, 1); quic_ctx_free (sctx); clib_mem_free (stream->data); } @@ -1017,6 +1018,8 @@ quic_connect_stream (session_t * quic_session, u32 opaque) QUIC_DBG (2, "Stream open failed with %d", rv); return -1; } + quic_increment_counter (QUIC_ERROR_OPENED_STREAM, 1); + sctx->stream = stream; QUIC_DBG (2, "Opened stream %d, creating session", stream->stream_id); @@ -1053,6 +1056,7 @@ quic_connect_stream (session_t * quic_session, u32 opaque) if (app_worker_connect_notify (app_wrk, stream_session, opaque)) { QUIC_ERR ("failed to notify app"); + quic_increment_counter (QUIC_ERROR_CLOSED_STREAM, 1); quicly_reset_stream (stream, QUIC_APP_CONNECT_NOTIFY_ERROR); return -1; } @@ -1157,6 +1161,8 @@ quic_proto_on_close (u32 ctx_index, u32 thread_index) quicly_conn_t *conn = ctx->conn; /* Start connection closing. Keep sending packets until quicly_send returns QUICLY_ERROR_FREE_CONNECTION */ + + quic_increment_counter (QUIC_ERROR_CLOSED_CONNECTION, 1); quicly_close (conn, QUIC_APP_ERROR_CLOSE_NOTIFY, "Closed by peer"); /* This also causes all streams to be closed (and the cb called) */ quic_send_packets (ctx); @@ -2319,12 +2325,67 @@ quic_format_ctx_stat (u8 * s, va_list * args) return s; } +u64 +quic_get_counter_value (u32 event_code) +{ + vlib_node_t *n; + vlib_main_t *vm; + vlib_error_main_t *em; + + u32 code, i; + u64 c, sum = 0; + int index = 0; + + vm = vlib_get_main (); + em = &vm->error_main; + n = vlib_get_node (vm, quic_input_node.index); + code = event_code; + /* *INDENT-OFF* */ + foreach_vlib_main(({ + em = &this_vlib_main->error_main; + i = n->error_heap_index + code; + c = em->counters[i]; + + if (i < vec_len (em->counters_last_clear)) + c -= em->counters_last_clear[i]; + sum += c; + index++; + })); + /* *INDENT-ON* */ + return sum; +} + static clib_error_t * quic_plugin_showstats_command_fn (vlib_main_t * vm, unformat_input_t * input, vlib_cli_command_t * cmd) { quic_main_t *qm = &quic_main; + + vlib_cli_output (vm, "\n-------- Connections --------\n"); + vlib_cli_output (vm, "%=20s%10Ld%=20s%10Ld", "Opened:", + quic_get_counter_value (QUIC_ERROR_OPENED_CONNECTION), + "Closed:", + quic_get_counter_value (QUIC_ERROR_CLOSED_CONNECTION)); + + vlib_cli_output (vm, "\n---------- Streams ----------\n"); + vlib_cli_output (vm, "%=20s%10Ld%=20s%10Ld", "Opened:", + quic_get_counter_value (QUIC_ERROR_OPENED_STREAM), + "Closed:", + quic_get_counter_value (QUIC_ERROR_CLOSED_STREAM)); + + vlib_cli_output (vm, "\n--------- RX Packets ---------\n"); + vlib_cli_output (vm, "%=20s%10Ld", "Total:", + quic_get_counter_value (QUIC_ERROR_RX_PACKETS)); + vlib_cli_output (vm, "%=20s%10Ld", "0RTT :", + quic_get_counter_value (QUIC_ERROR_ZERO_RTT_RX_PACKETS)); + vlib_cli_output (vm, "%=20s%10Ld", "1RTT :", + quic_get_counter_value (QUIC_ERROR_ONE_RTT_RX_PACKETS)); + + vlib_cli_output (vm, "\n-------- TX Packets --------\n"); + vlib_cli_output (vm, "%=20s%10Ld", "Total:", + quic_get_counter_value (QUIC_ERROR_TX_PACKETS)); + quic_ctx_t *ctx = NULL; u32 num_workers = vlib_num_workers (); |