27 long i = va_arg (*args,
long);
28 struct sched_param sched_param;
31 switch (sched_getscheduler (i))
33 #define _(v,f,str) case SCHED_POLICY_##f: t = (u8 *) str; break; 37 if (sched_getparam (i, &sched_param) == 0)
38 return format (s,
"%s (%d)", t, sched_param.sched_priority);
40 return format (s,
"%s (n/a)", t);
51 "ID",
"Name",
"Type",
"LWP",
"Sched Policy (Priority)",
52 "lcore",
"Core",
"Socket",
"State");
54 #if !defined(__powerpc64__) 60 line =
format (line,
"%-7d%-20s%-12s%-8d",
73 pthread_getaffinity_np (w->
thread_id, sizeof (cpu_set_t), &cpuset);
77 for (c = 0; c < CPU_SETSIZE; c++)
78 if (CPU_ISSET (c, &cpuset))
95 const char *sys_cpu_path =
"/sys/devices/system/cpu/cpu";
100 p =
format (p,
"%s%u/topology/core_id%c", sys_cpu_path, lcore, 0);
106 "%s%u/topology/physical_package_id%c",
107 sys_cpu_path, lcore, 0);
111 line =
format (line,
"%-7u%-7u%-7u%", lcore, core_id, socket_id);
116 format (line,
"%-7s%-7s%-7s%", (lcore == -2) ?
"M" :
"n/a",
"n/a",
131 .path =
"show threads",
132 .short_help =
"Show threads",
162 else if (
unformat (line_input,
"off"))
164 else if (
unformat (line_input,
"index %u", &index))
189 "expecting valid worker handoff queue index");
208 for (fqix = 0; fqix < num_fq; fqix++)
215 memset (fqh, 0,
sizeof (*fqh));
227 .path =
"trace frame-queue",
228 .short_help =
"trace frame-queue (on|off)",
248 return (((two_counters[0] + two_counters[1]) * 100) +
249 (total - 1)) / total;
276 "16-17 18-19 20-21 22-23 24-25 26-27 28-29 30-31\n");
279 for (fqix = 0; fqix < num_fq; fqix++)
300 total += fqh->
count[nelt];
311 "%3d%% %3d%% %3d%% %3d%% %3d%% %3d%% %3d%% %3d%% " 312 "%3d%% %3d%% %3d%% %3d%% %3d%% %3d%% %3d%% %3d%%\n",
333 " vector-threshold %d ring size %d in use %d\n",
338 " %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d\n",
351 " %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d %3d\n",
377 vlib_cli_output (vm,
"Worker handoff queue index %u (next node '%U'):",
397 vlib_cli_output (vm,
"Worker handoff queue index %u (next node '%U'):",
409 .path =
"show frame-queue",
410 .short_help =
"show frame-queue trace",
417 .path =
"show frame-queue histogram",
418 .short_help =
"show frame-queue histogram",
445 if (
unformat (line_input,
"nelts %u", &nelts))
447 else if (
unformat (line_input,
"index %u", &index))
460 "expecting valid worker handoff queue index");
466 if ((nelts != 4) && (nelts != 8) && (nelts != 16) && (nelts != 32))
479 for (fqix = 0; fqix < num_fq; fqix++)
492 .path =
"test frame-queue nelts",
493 .short_help =
"test frame-queue nelts (4,8,16,32)",
520 if (
unformat (line_input,
"threshold %u", &threshold))
522 else if (
unformat (line_input,
"index %u", &index))
535 "expecting valid worker handoff queue index");
542 if (threshold == ~(
u32) 0)
558 for (fqix = 0; fqix < num_fq; fqix++)
571 .path =
"test frame-queue threshold",
572 .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
#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)
clib_error_t * clib_sysfs_read(char *file_name, char *fmt,...)
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,...)