26 long i = va_arg (*args,
long);
27 struct sched_param sched_param;
30 switch (sched_getscheduler (i))
32 #define _(v,f,str) case SCHED_POLICY_##f: t = (u8 *) str; break; 36 if (sched_getparam (i, &sched_param) == 0)
37 return format (s,
"%s (%d)", t, sched_param.sched_priority);
39 return format (s,
"%s (n/a)", t);
50 "ID",
"Name",
"Type",
"LWP",
"Sched Policy (Priority)",
51 "lcore",
"Core",
"Socket",
"State");
53 #if !defined(__powerpc64__) 59 line =
format (line,
"%-7d%-20s%-12s%-8d",
72 pthread_getaffinity_np (w->
thread_id, sizeof (cpu_set_t), &cpuset);
76 for (c = 0; c < CPU_SETSIZE; c++)
77 if (CPU_ISSET (c, &cpuset))
94 const char *sys_cpu_path =
"/sys/devices/system/cpu/cpu";
99 p =
format (p,
"%s%u/topology/core_id%c", sys_cpu_path, lcore, 0);
105 "%s%u/topology/physical_package_id%c",
106 sys_cpu_path, lcore, 0);
110 line =
format (line,
"%-7u%-7u%-7u%", lcore, core_id, socket_id);
115 format (line,
"%-7s%-7s%-7s%", (lcore == -2) ?
"M" :
"n/a",
"n/a",
130 .path =
"show threads",
131 .short_help =
"Show threads",
161 else if (
unformat (line_input,
"off"))
163 else if (
unformat (line_input,
"index %u", &index))
188 "expecting valid worker handoff queue index");
207 for (fqix = 0; fqix < num_fq; fqix++)
214 memset (fqh, 0,
sizeof (*fqh));
226 .path =
"trace frame-queue",
227 .short_help =
"trace frame-queue (on|off)",
247 return (((two_counters[0] + two_counters[1]) * 100) +
248 (total - 1)) / total;
275 "16-17 18-19 20-21 22-23 24-25 26-27 28-29 30-31\n");
278 for (fqix = 0; fqix < num_fq; fqix++)
299 total += fqh->
count[nelt];
310 "%3d%% %3d%% %3d%% %3d%% %3d%% %3d%% %3d%% %3d%% " 311 "%3d%% %3d%% %3d%% %3d%% %3d%% %3d%% %3d%% %3d%%\n",
332 " vector-threshold %d ring size %d in use %d\n",
337 " %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d\n",
350 " %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d\n",
376 vlib_cli_output (vm,
"Worker handoff queue index %u (next node '%U'):",
396 vlib_cli_output (vm,
"Worker handoff queue index %u (next node '%U'):",
408 .path =
"show frame-queue",
409 .short_help =
"show frame-queue trace",
416 .path =
"show frame-queue histogram",
417 .short_help =
"show frame-queue histogram",
444 if (
unformat (line_input,
"nelts %u", &nelts))
446 else if (
unformat (line_input,
"index %u", &index))
459 "expecting valid worker handoff queue index");
465 if ((nelts != 4) && (nelts != 8) && (nelts != 16) && (nelts != 32))
478 for (fqix = 0; fqix < num_fq; fqix++)
491 .path =
"test frame-queue nelts",
492 .short_help =
"test frame-queue nelts (4,8,16,32)",
519 if (
unformat (line_input,
"threshold %u", &threshold))
521 else if (
unformat (line_input,
"index %u", &index))
534 "expecting valid worker handoff queue index");
541 if (threshold == ~(
u32) 0)
557 for (fqix = 0; fqix < num_fq; fqix++)
570 .path =
"test frame-queue threshold",
571 .short_help =
"test frame-queue threshold N (0=no limit)",
static u32 compute_percent(u64 *two_counters, u64 total)
static u8 * format_sched_policy_and_priority(u8 *s, va_list *args)
sll srl srl sll sra u16x4 i
format_function_t format_vlib_node_name
frame_queue_trace_t * frame_queue_traces
static clib_error_t * show_frame_queue_trace(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
#define vec_validate_aligned(V, I, A)
Make sure vector is long enough for given index (no header, specified alignment)
static clib_error_t * test_frame_queue_nelts(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
#define vec_reset_length(v)
Reset vector length to zero NULL-pointer tolerant.
u64 count[FRAME_QUEUE_MAX_NELTS]
#define vec_elt_at_index(v, i)
Get vector value at index i checking that i is in bounds.
#define clib_error_return(e, args...)
vlib_worker_thread_t * vlib_worker_threads
clib_error_t * vlib_sysfs_read(char *file_name, char *fmt,...)
#define FRAME_QUEUE_MAX_NELTS
static clib_error_t * show_frame_queue_internal(vlib_main_t *vm, vlib_frame_queue_main_t *fqm, u32 histogram)
i32 n_vectors[FRAME_QUEUE_MAX_NELTS]
vlib_frame_queue_t ** vlib_frame_queues
static clib_error_t * show_threads_fn(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
#define vec_free(V)
Free vector's memory (no header).
frame_queue_nelt_counter_t * frame_queue_histogram
static clib_error_t * show_frame_queue_histogram(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
#define VLIB_CLI_COMMAND(x,...)
static clib_error_t * trace_frame_queue(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
vlib_frame_queue_main_t * frame_queue_mains
static clib_error_t * test_frame_queue_threshold(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
#define vec_len(v)
Number of elements in vector (rvalue-only, NULL tolerant)
static vlib_thread_main_t * vlib_get_thread_main()
#define vec_foreach(var, vec)
Vector iterator.
#define foreach_sched_policy
#define CLIB_CACHE_LINE_BYTES
vlib_thread_registration_t * registration
void vlib_cli_output(vlib_main_t *vm, char *fmt,...)