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);
122 session_debug_init (void)
128 dump_thread_0_event_queue (void)
130 vlib_main_t *vm = vlib_get_first_main ();
131 u32 my_thread_index = vm->thread_index;
132 session_event_t _e, *e = &_e;
133 svm_msg_q_shared_queue_t *sq;
134 svm_msg_q_ring_t *ring;
136 svm_msg_q_msg_t *msg;
140 mq = session_main_get_vpp_event_queue (my_thread_index);
144 for (i = 0; i < sq->cursize; i++)
146 msg = (svm_msg_q_msg_t *) (&sq->data[0] + sq->elsize * index);
147 ring = svm_msg_q_ring (mq, msg->ring_index);
148 clib_memcpy_fast (e, svm_msg_q_msg_data (mq, msg), ring->elsize);
150 switch (e->event_type)
152 case SESSION_IO_EVT_TX:
153 s0 = session_get_if_valid (e->session_index, my_thread_index);
156 fformat (stdout, "[%04d] TX session %d\n", i, s0->session_index);
159 case SESSION_CTRL_EVT_CLOSE:
160 s0 = session_get_from_handle (e->session_handle);
161 fformat (stdout, "[%04d] disconnect session %d\n", i,
165 case SESSION_IO_EVT_BUILTIN_RX:
166 s0 = session_get_if_valid (e->session_index, my_thread_index);
169 fformat (stdout, "[%04d] builtin_rx %d\n", i, s0->session_index);
172 case SESSION_CTRL_EVT_RPC:
173 fformat (stdout, "[%04d] RPC call %llx with %llx\n",
174 i, (u64) (uword) (e->rpc_args.fp),
175 (u64) (uword) (e->rpc_args.arg));
179 fformat (stdout, "[%04d] unhandled event type %d\n",
186 if (index == sq->maxsize)
192 session_node_cmp_event (session_event_t * e, svm_fifo_t * f)
194 switch (e->event_type)
196 case SESSION_IO_EVT_RX:
197 case SESSION_IO_EVT_TX:
198 case SESSION_IO_EVT_BUILTIN_RX:
199 case SESSION_IO_EVT_BUILTIN_TX:
200 case SESSION_IO_EVT_TX_FLUSH:
201 if (e->session_index == f->shr->master_session_index)
204 case SESSION_CTRL_EVT_CLOSE:
205 case SESSION_CTRL_EVT_RPC:
214 session_node_lookup_fifo_event (svm_fifo_t * f, session_event_t * e)
216 svm_msg_q_shared_queue_t *sq;
217 session_evt_elt_t *elt;
218 session_worker_t *wrk;
219 int i, index, found = 0;
220 svm_msg_q_msg_t *msg;
221 svm_msg_q_ring_t *ring;
226 thread_index = f->master_thread_index;
227 wrk = session_main_get_worker (thread_index);
232 mq = wrk->vpp_event_queue;
235 for (i = 0; i < sq->cursize; i++)
237 msg = (svm_msg_q_msg_t *) (&sq->data[0] + sq->elsize * index);
238 ring = svm_msg_q_ring (mq, msg->ring_index);
239 clib_memcpy_fast (e, svm_msg_q_msg_data (mq, msg), ring->elsize);
240 found = session_node_cmp_event (e, f);
243 index = (index + 1) % sq->maxsize;
246 * Search pending events vector
250 clib_llist_foreach (wrk->event_elts, evt_list,
251 pool_elt_at_index (wrk->event_elts, wrk->new_head),
253 found = session_node_cmp_event (&elt->evt, f);
256 clib_memcpy_fast (e, &elt->evt, sizeof (*e));
263 clib_llist_foreach (wrk->event_elts, evt_list,
264 pool_elt_at_index (wrk->event_elts, wrk->old_head),
266 found = session_node_cmp_event (&elt->evt, f);
269 clib_memcpy_fast (e, &elt->evt, sizeof (*e));
280 * fd.io coding-style-patch-verification: ON
283 * eval: (c-set-style "gnu")