2 * Copyright (c) 2020 Cisco and/or its affiliates.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at:
7 * http://www.apache.org/licenses/LICENSE-2.0
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
16 #include <vnet/session/session_debug.h>
17 #include <vnet/session/session.h>
21 session_dbg_main_t session_dbg_main;
24 show_session_dbg_clock_cycles_fn (vlib_main_t * vm, unformat_input_t * input,
25 vlib_cli_command_t * cmd)
29 if (unformat_check_input (input) != UNFORMAT_END_OF_INPUT)
30 return clib_error_return (0, "unknown input `%U'", format_unformat_error,
33 for (thread = 0; thread < vec_len (session_dbg_main.wrk); thread++)
35 vlib_cli_output (vm, "Threads %u:\n", thread);
36 session_dbg_evts_t *sdm = &session_dbg_main.wrk[thread];
38 #define _(sym, disp, type, str) \
42 vlib_cli_output (vm, "\t %25s : %12lu ", str, \
43 sdm->counters[SESS_Q_##sym].u64); \
45 vlib_cli_output (vm, "\t %25s : %12.3f ", str, \
46 sdm->counters[SESS_Q_##sym].f64); \
48 foreach_session_events
56 VLIB_CLI_COMMAND (show_session_dbg_clock_cycles_command, static) =
58 .path = "show session dbg clock_cycles",
59 .short_help = "show session dbg clock_cycles",
60 .function = show_session_dbg_clock_cycles_fn,
64 static_always_inline f64
65 session_dbg_time_now (u32 thread)
67 vlib_main_t *vm = vlib_get_main_by_index (thread);
69 return clib_time_now (&vm->clib_time) + vm->time_offset;
73 clear_session_dbg_clock_cycles_fn (vlib_main_t * vm, unformat_input_t * input,
74 vlib_cli_command_t * cmd)
76 session_dbg_evts_t *sde;
79 if (unformat_check_input (input) != UNFORMAT_END_OF_INPUT)
80 return clib_error_return (0, "unknown input `%U'", format_unformat_error,
83 for (thread = 0; thread < vec_len (session_dbg_main.wrk); thread++)
85 sde = &session_dbg_main.wrk[thread];
86 clib_memset (sde, 0, sizeof (session_dbg_evts_t));
87 sde->last_time = session_dbg_time_now (thread);
88 sde->start_time = sde->last_time;
96 VLIB_CLI_COMMAND (clear_session_clock_cycles_command, static) =
98 .path = "clear session dbg clock_cycles",
99 .short_help = "clear session dbg clock_cycles",
100 .function = clear_session_dbg_clock_cycles_fn,
105 session_debug_init (void)
107 vlib_thread_main_t *vtm = vlib_get_thread_main ();
108 session_dbg_main_t *sdm = &session_dbg_main;
109 u32 num_threads, thread;
111 num_threads = vtm->n_vlib_mains;
113 vec_validate_aligned (sdm->wrk, num_threads - 1, CLIB_CACHE_LINE_BYTES);
114 for (thread = 0; thread < num_threads; thread++)
116 clib_memset (&sdm->wrk[thread], 0, sizeof (session_dbg_evts_t));
117 sdm->wrk[thread].start_time = session_dbg_time_now (thread);
121 static const char *session_evt_grp_str[] = {
122 #define _(sym, str) str,
123 foreach_session_evt_grp
128 session_debug_show_groups (vlib_main_t *vm)
130 session_dbg_main_t *sdm = &session_dbg_main;
133 vlib_cli_output (vm, "%-10s%-30s%-10s", "Index", "Group", "Level");
135 for (i = 0; i < SESSION_EVT_N_GRP; i++)
136 vlib_cli_output (vm, "%-10d%-30s%-10d", i, session_evt_grp_str[i],
137 sdm->grp_dbg_lvl[i]);
140 static clib_error_t *
141 session_debug_fn (vlib_main_t *vm, unformat_input_t *input,
142 vlib_cli_command_t *cmd)
144 session_dbg_main_t *sdm = &session_dbg_main;
145 u32 group, level = ~0;
146 clib_error_t *error = 0;
150 while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT)
152 if (unformat (input, "show"))
154 else if (unformat (input, "group %U", unformat_bitmap_list, &bitmap))
156 else if (unformat (input, "level %d", &level))
160 error = clib_error_return (0, "unknown input `%U'",
161 format_unformat_error, input);
168 session_debug_show_groups (vm);
173 vlib_cli_output (vm, "level must be entered");
177 group = clib_bitmap_last_set (bitmap);
180 vlib_cli_output (vm, "group must be entered");
183 if (group >= SESSION_EVT_N_GRP)
185 vlib_cli_output (vm, "group out of bounds");
188 clib_bitmap_foreach (group, bitmap)
189 sdm->grp_dbg_lvl[group] = level;
193 clib_bitmap_free (bitmap);
197 VLIB_CLI_COMMAND (session_debug_command, static) = {
198 .path = "session debug",
199 .short_help = "session debug {show | debug group <list> level <n>}",
200 .function = session_debug_fn,
206 session_debug_init (void)
209 #endif /* SESSION_DEBUG */
212 dump_thread_0_event_queue (void)
214 vlib_main_t *vm = vlib_get_first_main ();
215 u32 my_thread_index = vm->thread_index;
216 session_event_t _e, *e = &_e;
217 svm_msg_q_shared_queue_t *sq;
218 svm_msg_q_ring_t *ring;
220 svm_msg_q_msg_t *msg;
224 mq = session_main_get_vpp_event_queue (my_thread_index);
228 for (i = 0; i < sq->cursize; i++)
230 msg = (svm_msg_q_msg_t *) (&sq->data[0] + sq->elsize * index);
231 ring = svm_msg_q_ring (mq, msg->ring_index);
232 clib_memcpy_fast (e, svm_msg_q_msg_data (mq, msg), ring->elsize);
234 switch (e->event_type)
236 case SESSION_IO_EVT_TX:
237 s0 = session_get_if_valid (e->session_index, my_thread_index);
240 fformat (stdout, "[%04d] TX session %d\n", i, s0->session_index);
243 case SESSION_CTRL_EVT_CLOSE:
244 s0 = session_get_from_handle (e->session_handle);
245 fformat (stdout, "[%04d] disconnect session %d\n", i,
249 case SESSION_IO_EVT_BUILTIN_RX:
250 s0 = session_get_if_valid (e->session_index, my_thread_index);
253 fformat (stdout, "[%04d] builtin_rx %d\n", i, s0->session_index);
256 case SESSION_CTRL_EVT_RPC:
257 fformat (stdout, "[%04d] RPC call %llx with %llx\n",
258 i, (u64) (uword) (e->rpc_args.fp),
259 (u64) (uword) (e->rpc_args.arg));
263 fformat (stdout, "[%04d] unhandled event type %d\n",
270 if (index == sq->maxsize)
276 session_node_cmp_event (session_event_t * e, svm_fifo_t * f)
278 switch (e->event_type)
280 case SESSION_IO_EVT_RX:
281 case SESSION_IO_EVT_TX:
282 case SESSION_IO_EVT_BUILTIN_RX:
283 case SESSION_IO_EVT_TX_MAIN:
284 case SESSION_IO_EVT_TX_FLUSH:
285 if (e->session_index == f->shr->master_session_index)
288 case SESSION_CTRL_EVT_CLOSE:
289 case SESSION_CTRL_EVT_RPC:
298 session_node_lookup_fifo_event (svm_fifo_t * f, session_event_t * e)
300 svm_msg_q_shared_queue_t *sq;
301 session_evt_elt_t *elt;
302 session_worker_t *wrk;
303 int i, index, found = 0;
304 svm_msg_q_msg_t *msg;
309 thread_index = f->master_thread_index;
310 wrk = session_main_get_worker (thread_index);
315 mq = wrk->vpp_event_queue;
318 for (i = 0; i < sq->cursize; i++)
320 msg = (svm_msg_q_msg_t *) (&sq->data[0] + sq->elsize * index);
321 clib_memcpy_fast (e, svm_msg_q_msg_data (mq, msg), sizeof (*e));
322 found = session_node_cmp_event (e, f);
325 index = (index + 1) % sq->maxsize;
328 * Search pending events vector
332 clib_llist_foreach (wrk->event_elts, evt_list,
333 pool_elt_at_index (wrk->event_elts, wrk->new_head),
335 found = session_node_cmp_event (&elt->evt, f);
338 clib_memcpy_fast (e, &elt->evt, sizeof (*e));
345 clib_llist_foreach (wrk->event_elts, evt_list,
346 pool_elt_at_index (wrk->event_elts, wrk->old_head),
348 found = session_node_cmp_event (&elt->evt, f);
351 clib_memcpy_fast (e, &elt->evt, sizeof (*e));
362 * fd.io coding-style-patch-verification: ON
365 * eval: (c-set-style "gnu")