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,
66 clear_session_dbg_clock_cycles_fn (vlib_main_t * vm, unformat_input_t * input,
67 vlib_cli_command_t * cmd)
69 session_dbg_evts_t *sde;
72 if (unformat_check_input (input) != UNFORMAT_END_OF_INPUT)
73 return clib_error_return (0, "unknown input `%U'", format_unformat_error,
76 for (thread = 0; thread < vec_len (session_dbg_main.wrk); thread++)
78 sde = &session_dbg_main.wrk[thread];
79 clib_memset (sde, 0, sizeof (session_dbg_evts_t));
80 sde->last_time = vlib_time_now (vlib_mains[thread]);
81 sde->start_time = sde->last_time;
89 VLIB_CLI_COMMAND (clear_session_clock_cycles_command, static) =
91 .path = "clear session dbg clock_cycles",
92 .short_help = "clear session dbg clock_cycles",
93 .function = clear_session_dbg_clock_cycles_fn,
98 session_debug_init (void)
100 vlib_thread_main_t *vtm = vlib_get_thread_main ();
101 session_dbg_main_t *sdm = &session_dbg_main;
102 u32 num_threads, thread;
104 num_threads = vtm->n_vlib_mains;
106 vec_validate_aligned (sdm->wrk, num_threads - 1, CLIB_CACHE_LINE_BYTES);
107 for (thread = 0; thread < num_threads; thread++)
109 clib_memset (&sdm->wrk[thread], 0, sizeof (session_dbg_evts_t));
110 sdm->wrk[thread].start_time = vlib_time_now (vlib_mains[thread]);
115 session_debug_init (void)
121 dump_thread_0_event_queue (void)
123 vlib_main_t *vm = &vlib_global_main;
124 u32 my_thread_index = vm->thread_index;
125 session_event_t _e, *e = &_e;
126 svm_msg_q_shared_queue_t *sq;
127 svm_msg_q_ring_t *ring;
129 svm_msg_q_msg_t *msg;
133 mq = session_main_get_vpp_event_queue (my_thread_index);
137 for (i = 0; i < sq->cursize; i++)
139 msg = (svm_msg_q_msg_t *) (&sq->data[0] + sq->elsize * index);
140 ring = svm_msg_q_ring (mq, msg->ring_index);
141 clib_memcpy_fast (e, svm_msg_q_msg_data (mq, msg), ring->elsize);
143 switch (e->event_type)
145 case SESSION_IO_EVT_TX:
146 s0 = session_get_if_valid (e->session_index, my_thread_index);
147 fformat (stdout, "[%04d] TX session %d\n", i, s0->session_index);
150 case SESSION_CTRL_EVT_CLOSE:
151 s0 = session_get_from_handle (e->session_handle);
152 fformat (stdout, "[%04d] disconnect session %d\n", i,
156 case SESSION_IO_EVT_BUILTIN_RX:
157 s0 = session_get_if_valid (e->session_index, my_thread_index);
158 fformat (stdout, "[%04d] builtin_rx %d\n", i, s0->session_index);
161 case SESSION_CTRL_EVT_RPC:
162 fformat (stdout, "[%04d] RPC call %llx with %llx\n",
163 i, (u64) (uword) (e->rpc_args.fp),
164 (u64) (uword) (e->rpc_args.arg));
168 fformat (stdout, "[%04d] unhandled event type %d\n",
175 if (index == sq->maxsize)
181 session_node_cmp_event (session_event_t * e, svm_fifo_t * f)
184 switch (e->event_type)
186 case SESSION_IO_EVT_RX:
187 case SESSION_IO_EVT_TX:
188 case SESSION_IO_EVT_BUILTIN_RX:
189 case SESSION_IO_EVT_BUILTIN_TX:
190 case SESSION_IO_EVT_TX_FLUSH:
191 if (e->session_index == f->shr->master_session_index)
194 case SESSION_CTRL_EVT_CLOSE:
196 case SESSION_CTRL_EVT_RPC:
197 s = session_get_from_handle (e->session_handle);
200 clib_warning ("session has event but doesn't exist!");
203 if (s->rx_fifo == f || s->tx_fifo == f)
213 session_node_lookup_fifo_event (svm_fifo_t * f, session_event_t * e)
215 svm_msg_q_shared_queue_t *sq;
216 session_evt_elt_t *elt;
217 session_worker_t *wrk;
218 int i, index, found = 0;
219 svm_msg_q_msg_t *msg;
220 svm_msg_q_ring_t *ring;
225 thread_index = f->master_thread_index;
226 wrk = session_main_get_worker (thread_index);
231 mq = wrk->vpp_event_queue;
234 for (i = 0; i < sq->cursize; i++)
236 msg = (svm_msg_q_msg_t *) (&sq->data[0] + sq->elsize * index);
237 ring = svm_msg_q_ring (mq, msg->ring_index);
238 clib_memcpy_fast (e, svm_msg_q_msg_data (mq, msg), ring->elsize);
239 found = session_node_cmp_event (e, f);
242 index = (index + 1) % sq->maxsize;
245 * Search pending events vector
249 clib_llist_foreach (wrk->event_elts, evt_list,
250 pool_elt_at_index (wrk->event_elts, wrk->new_head),
252 found = session_node_cmp_event (&elt->evt, f);
255 clib_memcpy_fast (e, &elt->evt, sizeof (*e));
262 clib_llist_foreach (wrk->event_elts, evt_list,
263 pool_elt_at_index (wrk->event_elts, wrk->old_head),
265 found = session_node_cmp_event (&elt->evt, f);
268 clib_memcpy_fast (e, &elt->evt, sizeof (*e));
279 * fd.io coding-style-patch-verification: ON
282 * eval: (c-set-style "gnu")