Fix: kernel channel destroy on consumer if sent
[lttng-tools.git] / src / bin / lttng / commands / list.c
CommitLineData
f3ed775e
DG
1/*
2 * Copyright (C) 2011 - David Goulet <david.goulet@polymtl.ca>
3 *
d14d33bf
AM
4 * This program is free software; you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License, version 2 only,
6 * as published by the Free Software Foundation.
f3ed775e
DG
7 *
8 * This program is distributed in the hope that it will be useful,
9 * but WITHOUT ANY WARRANTY; without even the implied warranty of
10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11 * GNU General Public License for more details.
12 *
d14d33bf
AM
13 * You should have received a copy of the GNU General Public License along
14 * with this program; if not, write to the Free Software Foundation, Inc.,
15 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
f3ed775e
DG
16 */
17
18#define _GNU_SOURCE
9f19cc17 19#include <inttypes.h>
f3ed775e
DG
20#include <popt.h>
21#include <stdio.h>
22#include <stdlib.h>
23#include <string.h>
7a3d1328 24#include <assert.h>
f3ed775e 25
c399183f 26#include "../command.h"
f3ed775e 27
9f19cc17
DG
28static int opt_userspace;
29static int opt_kernel;
3c6a091f 30static int opt_jul;
9f19cc17
DG
31static char *opt_channel;
32static int opt_domain;
f37d259d 33static int opt_fields;
d78d6610
DG
34#if 0
35/* Not implemented yet */
36static char *opt_cmd_name;
37static pid_t opt_pid;
38#endif
9f19cc17
DG
39
40const char *indent4 = " ";
41const char *indent6 = " ";
42const char *indent8 = " ";
f3ed775e
DG
43
44enum {
45 OPT_HELP = 1,
eeac7d46 46 OPT_USERSPACE,
679b4943 47 OPT_LIST_OPTIONS,
f3ed775e
DG
48};
49
cd80958d
DG
50static struct lttng_handle *handle;
51
f3ed775e
DG
52static struct poptOption long_options[] = {
53 /* longName, shortName, argInfo, argPtr, value, descrip, argDesc */
54 {"help", 'h', POPT_ARG_NONE, 0, OPT_HELP, 0, 0},
9f19cc17 55 {"kernel", 'k', POPT_ARG_VAL, &opt_kernel, 1, 0, 0},
3c6a091f 56 {"jul", 'j', POPT_ARG_VAL, &opt_jul, 1, 0, 0},
d78d6610
DG
57#if 0
58 /* Not implemented yet */
59 {"userspace", 'u', POPT_ARG_STRING | POPT_ARGFLAG_OPTIONAL, &opt_cmd_name, OPT_USERSPACE, 0, 0},
60 {"pid", 'p', POPT_ARG_INT, &opt_pid, 0, 0, 0},
61#else
62 {"userspace", 'u', POPT_ARG_NONE, 0, OPT_USERSPACE, 0, 0},
63#endif
9f19cc17
DG
64 {"channel", 'c', POPT_ARG_STRING, &opt_channel, 0, 0, 0},
65 {"domain", 'd', POPT_ARG_VAL, &opt_domain, 1, 0, 0},
f37d259d 66 {"fields", 'f', POPT_ARG_VAL, &opt_fields, 1, 0, 0},
679b4943 67 {"list-options", 0, POPT_ARG_NONE, NULL, OPT_LIST_OPTIONS, NULL, NULL},
f3ed775e
DG
68 {0, 0, 0, 0, 0, 0, 0}
69};
70
71/*
72 * usage
73 */
74static void usage(FILE *ofp)
75{
747361fe 76 fprintf(ofp, "usage: lttng list [OPTIONS] [SESSION [SESSION OPTIONS]]\n");
9f19cc17
DG
77 fprintf(ofp, "\n");
78 fprintf(ofp, "With no arguments, list available tracing session(s)\n");
79 fprintf(ofp, "\n");
27221701
DG
80 fprintf(ofp, "Without a session, -k lists available kernel events\n");
81 fprintf(ofp, "Without a session, -u lists available userspace events\n");
9f19cc17
DG
82 fprintf(ofp, "\n");
83 fprintf(ofp, " -h, --help Show this help\n");
27221701 84 fprintf(ofp, " --list-options Simple listing of options\n");
9f19cc17
DG
85 fprintf(ofp, " -k, --kernel Select kernel domain\n");
86 fprintf(ofp, " -u, --userspace Select user-space domain.\n");
3c6a091f 87 fprintf(ofp, " -j, --jul Apply for Java application using JUL\n");
f37d259d 88 fprintf(ofp, " -f, --fields List event fields.\n");
d78d6610 89#if 0
9f19cc17 90 fprintf(ofp, " -p, --pid PID List user-space events by PID\n");
d78d6610 91#endif
f3ed775e 92 fprintf(ofp, "\n");
27221701 93 fprintf(ofp, "Session Options:\n");
9f19cc17
DG
94 fprintf(ofp, " -c, --channel NAME List details of a channel\n");
95 fprintf(ofp, " -d, --domain List available domain(s)\n");
f3ed775e
DG
96 fprintf(ofp, "\n");
97}
98
99/*
9f19cc17 100 * Get command line from /proc for a specific pid.
f3ed775e 101 *
9f19cc17
DG
102 * On success, return an allocated string pointer to the proc cmdline.
103 * On error, return NULL.
f3ed775e
DG
104 */
105static char *get_cmdline_by_pid(pid_t pid)
106{
107 int ret;
108 FILE *fp;
109 char *cmdline = NULL;
110 char path[24]; /* Can't go bigger than /proc/65535/cmdline */
111
112 snprintf(path, sizeof(path), "/proc/%d/cmdline", pid);
113 fp = fopen(path, "r");
114 if (fp == NULL) {
115 goto end;
116 }
117
118 /* Caller must free() *cmdline */
119 cmdline = malloc(PATH_MAX);
120 ret = fread(cmdline, 1, PATH_MAX, fp);
f40799e8
DG
121 if (ret < 0) {
122 perror("fread proc list");
123 }
f3ed775e
DG
124 fclose(fp);
125
126end:
127 return cmdline;
128}
b551a063 129
464dd62d
MD
130static
131const char *active_string(int value)
132{
133 switch (value) {
2cbf8fed
DG
134 case 0: return "inactive";
135 case 1: return "active";
464dd62d
MD
136 case -1: return "";
137 default: return NULL;
138 }
139}
140
2cbf8fed
DG
141static const char *snapshot_string(int value)
142{
143 switch (value) {
144 case 1:
145 return " snapshot";
146 default:
147 return "";
148 }
149}
150
464dd62d
MD
151static
152const char *enabled_string(int value)
153{
154 switch (value) {
b09f0429
MD
155 case 0: return " [disabled]";
156 case 1: return " [enabled]";
464dd62d
MD
157 case -1: return "";
158 default: return NULL;
159 }
160}
161
fceb65df
MD
162static
163const char *filter_string(int value)
164{
165 switch (value) {
166 case 1: return " [with filter]";
167 default: return "";
168 }
169}
170
4634f12e
JI
171static
172const char *exclusion_string(int value)
173{
174 switch (value) {
175 case 1: return " [has exclusions]";
176 default: return "";
177 }
178}
179
8005f29a
MD
180static const char *loglevel_string(int value)
181{
182 switch (value) {
255a5dab
MD
183 case -1:
184 return "";
185 case LTTNG_LOGLEVEL_EMERG:
186 return "TRACE_EMERG";
187 case LTTNG_LOGLEVEL_ALERT:
188 return "TRACE_ALERT";
189 case LTTNG_LOGLEVEL_CRIT:
190 return "TRACE_CRIT";
191 case LTTNG_LOGLEVEL_ERR:
192 return "TRACE_ERR";
193 case LTTNG_LOGLEVEL_WARNING:
194 return "TRACE_WARNING";
195 case LTTNG_LOGLEVEL_NOTICE:
196 return "TRACE_NOTICE";
197 case LTTNG_LOGLEVEL_INFO:
198 return "TRACE_INFO";
199 case LTTNG_LOGLEVEL_DEBUG_SYSTEM:
200 return "TRACE_DEBUG_SYSTEM";
201 case LTTNG_LOGLEVEL_DEBUG_PROGRAM:
202 return "TRACE_DEBUG_PROGRAM";
203 case LTTNG_LOGLEVEL_DEBUG_PROCESS:
204 return "TRACE_DEBUG_PROCESS";
205 case LTTNG_LOGLEVEL_DEBUG_MODULE:
206 return "TRACE_DEBUG_MODULE";
207 case LTTNG_LOGLEVEL_DEBUG_UNIT:
208 return "TRACE_DEBUG_UNIT";
209 case LTTNG_LOGLEVEL_DEBUG_FUNCTION:
210 return "TRACE_DEBUG_FUNCTION";
211 case LTTNG_LOGLEVEL_DEBUG_LINE:
212 return "TRACE_DEBUG_LINE";
213 case LTTNG_LOGLEVEL_DEBUG:
214 return "TRACE_DEBUG";
215 default:
216 return "<<UNKNOWN>>";
8005f29a
MD
217 }
218}
219
b551a063
DG
220/*
221 * Pretty print single event.
222 */
223static void print_events(struct lttng_event *event)
224{
225 switch (event->type) {
226 case LTTNG_EVENT_TRACEPOINT:
e4baff1e 227 {
8b703175 228 if (event->loglevel != -1) {
4634f12e 229 MSG("%s%s (loglevel: %s (%d)) (type: tracepoint)%s%s%s",
8b703175 230 indent6,
81afa345 231 event->name,
8005f29a 232 loglevel_string(event->loglevel),
8b703175 233 event->loglevel,
fceb65df 234 enabled_string(event->enabled),
4634f12e 235 exclusion_string(event->exclusion),
fceb65df 236 filter_string(event->filter));
8b703175 237 } else {
4634f12e 238 MSG("%s%s (type: tracepoint)%s%s%s",
8b703175
MD
239 indent6,
240 event->name,
fceb65df 241 enabled_string(event->enabled),
4634f12e 242 exclusion_string(event->exclusion),
fceb65df 243 filter_string(event->filter));
8b703175 244 }
b551a063 245 break;
e4baff1e 246 }
1896972b
DG
247 case LTTNG_EVENT_FUNCTION:
248 MSG("%s%s (type: function)%s%s", indent6,
249 event->name, enabled_string(event->enabled),
250 filter_string(event->filter));
251 if (event->attr.probe.addr != 0) {
252 MSG("%saddr: 0x%" PRIx64, indent8, event->attr.probe.addr);
253 } else {
254 MSG("%soffset: 0x%" PRIx64, indent8, event->attr.probe.offset);
255 MSG("%ssymbol: %s", indent8, event->attr.probe.symbol_name);
256 }
257 break;
b551a063 258 case LTTNG_EVENT_PROBE:
fceb65df
MD
259 MSG("%s%s (type: probe)%s%s", indent6,
260 event->name, enabled_string(event->enabled),
261 filter_string(event->filter));
b551a063
DG
262 if (event->attr.probe.addr != 0) {
263 MSG("%saddr: 0x%" PRIx64, indent8, event->attr.probe.addr);
264 } else {
265 MSG("%soffset: 0x%" PRIx64, indent8, event->attr.probe.offset);
266 MSG("%ssymbol: %s", indent8, event->attr.probe.symbol_name);
267 }
268 break;
b551a063 269 case LTTNG_EVENT_FUNCTION_ENTRY:
fceb65df
MD
270 MSG("%s%s (type: function)%s%s", indent6,
271 event->name, enabled_string(event->enabled),
272 filter_string(event->filter));
b551a063
DG
273 MSG("%ssymbol: \"%s\"", indent8, event->attr.ftrace.symbol_name);
274 break;
275 case LTTNG_EVENT_SYSCALL:
fceb65df
MD
276 MSG("%ssyscalls (type: syscall)%s%s", indent6,
277 enabled_string(event->enabled),
278 filter_string(event->filter));
b551a063
DG
279 break;
280 case LTTNG_EVENT_NOOP:
fceb65df
MD
281 MSG("%s (type: noop)%s%s", indent6,
282 enabled_string(event->enabled),
283 filter_string(event->filter));
b551a063
DG
284 break;
285 case LTTNG_EVENT_ALL:
286 /* We should never have "all" events in list. */
287 assert(0);
288 break;
289 }
290}
291
f37d259d
MD
292static const char *field_type(struct lttng_event_field *field)
293{
294 switch(field->type) {
295 case LTTNG_EVENT_FIELD_INTEGER:
296 return "integer";
297 case LTTNG_EVENT_FIELD_ENUM:
298 return "enum";
299 case LTTNG_EVENT_FIELD_FLOAT:
300 return "float";
301 case LTTNG_EVENT_FIELD_STRING:
302 return "string";
303 case LTTNG_EVENT_FIELD_OTHER:
304 default: /* fall-through */
305 return "unknown";
306 }
307}
308
309/*
310 * Pretty print single event fields.
311 */
312static void print_event_field(struct lttng_event_field *field)
313{
314 if (!field->field_name[0]) {
315 return;
316 }
d8fbe2a9 317 MSG("%sfield: %s (%s)%s", indent8, field->field_name,
45a32634 318 field_type(field), field->nowrite ? " [no write]" : "");
f37d259d
MD
319}
320
3c6a091f
DG
321static int list_jul_events(void)
322{
323 int i, size;
324 struct lttng_domain domain;
325 struct lttng_handle *handle;
326 struct lttng_event *event_list;
327 pid_t cur_pid = 0;
328 char *cmdline = NULL;
329
330 DBG("Getting JUL tracing events");
331
332 memset(&domain, 0, sizeof(domain));
333 domain.type = LTTNG_DOMAIN_JUL;
334
335 handle = lttng_create_handle(NULL, &domain);
336 if (handle == NULL) {
337 goto error;
338 }
339
340 size = lttng_list_tracepoints(handle, &event_list);
341 if (size < 0) {
342 ERR("Unable to list JUL events: %s", lttng_strerror(size));
343 lttng_destroy_handle(handle);
344 return size;
345 }
346
347 MSG("JUL events (Logger name):\n-------------------------");
348
349 if (size == 0) {
350 MSG("None");
351 }
352
353 for (i = 0; i < size; i++) {
354 if (cur_pid != event_list[i].pid) {
355 cur_pid = event_list[i].pid;
356 cmdline = get_cmdline_by_pid(cur_pid);
357 MSG("\nPID: %d - Name: %s", cur_pid, cmdline);
358 free(cmdline);
359 }
360 MSG("%s- %s", indent6, event_list[i].name);
361 }
362
363 MSG("");
364
365 free(event_list);
366 lttng_destroy_handle(handle);
367
368 return CMD_SUCCESS;
369
370error:
371 lttng_destroy_handle(handle);
372 return -1;
373}
374
b551a063
DG
375/*
376 * Ask session daemon for all user space tracepoints available.
377 */
378static int list_ust_events(void)
379{
380 int i, size;
381 struct lttng_domain domain;
382 struct lttng_handle *handle;
383 struct lttng_event *event_list;
384 pid_t cur_pid = 0;
ea5cbc00 385 char *cmdline = NULL;
b551a063 386
441c16a7
MD
387 memset(&domain, 0, sizeof(domain));
388
b551a063
DG
389 DBG("Getting UST tracing events");
390
391 domain.type = LTTNG_DOMAIN_UST;
392
393 handle = lttng_create_handle(NULL, &domain);
394 if (handle == NULL) {
395 goto error;
396 }
397
398 size = lttng_list_tracepoints(handle, &event_list);
399 if (size < 0) {
60e835ca 400 ERR("Unable to list UST events: %s", lttng_strerror(size));
ef021732 401 lttng_destroy_handle(handle);
b551a063
DG
402 return size;
403 }
404
405 MSG("UST events:\n-------------");
406
407 if (size == 0) {
408 MSG("None");
409 }
410
411 for (i = 0; i < size; i++) {
412 if (cur_pid != event_list[i].pid) {
413 cur_pid = event_list[i].pid;
ea5cbc00
CB
414 cmdline = get_cmdline_by_pid(cur_pid);
415 MSG("\nPID: %d - Name: %s", cur_pid, cmdline);
416 free(cmdline);
b551a063
DG
417 }
418 print_events(&event_list[i]);
419 }
420
421 MSG("");
422
423 free(event_list);
ef021732 424 lttng_destroy_handle(handle);
b551a063
DG
425
426 return CMD_SUCCESS;
427
428error:
ef021732 429 lttng_destroy_handle(handle);
b551a063
DG
430 return -1;
431}
f3ed775e 432
f37d259d
MD
433/*
434 * Ask session daemon for all user space tracepoint fields available.
435 */
436static int list_ust_event_fields(void)
437{
438 int i, size;
439 struct lttng_domain domain;
440 struct lttng_handle *handle;
441 struct lttng_event_field *event_field_list;
442 pid_t cur_pid = 0;
ea5cbc00
CB
443 char *cmdline = NULL;
444
f37d259d
MD
445 struct lttng_event cur_event;
446
447 memset(&domain, 0, sizeof(domain));
448 memset(&cur_event, 0, sizeof(cur_event));
449
450 DBG("Getting UST tracing event fields");
451
452 domain.type = LTTNG_DOMAIN_UST;
453
454 handle = lttng_create_handle(NULL, &domain);
455 if (handle == NULL) {
456 goto error;
457 }
458
459 size = lttng_list_tracepoint_fields(handle, &event_field_list);
460 if (size < 0) {
60e835ca 461 ERR("Unable to list UST event fields: %s", lttng_strerror(size));
f37d259d
MD
462 lttng_destroy_handle(handle);
463 return size;
464 }
465
466 MSG("UST events:\n-------------");
467
468 if (size == 0) {
469 MSG("None");
470 }
471
472 for (i = 0; i < size; i++) {
473 if (cur_pid != event_field_list[i].event.pid) {
474 cur_pid = event_field_list[i].event.pid;
ea5cbc00
CB
475 cmdline = get_cmdline_by_pid(cur_pid);
476 MSG("\nPID: %d - Name: %s", cur_pid, cmdline);
477 free(cmdline);
8966b2b0
DG
478 /* Wipe current event since we are about to print a new PID. */
479 memset(&cur_event, 0, sizeof(cur_event));
f37d259d
MD
480 }
481 if (strcmp(cur_event.name, event_field_list[i].event.name) != 0) {
482 print_events(&event_field_list[i].event);
483 memcpy(&cur_event, &event_field_list[i].event,
484 sizeof(cur_event));
485 }
486 print_event_field(&event_field_list[i]);
487 }
488
489 MSG("");
490
491 free(event_field_list);
492 lttng_destroy_handle(handle);
493
494 return CMD_SUCCESS;
495
496error:
497 lttng_destroy_handle(handle);
498 return -1;
499}
500
f3ed775e 501/*
9f19cc17 502 * Ask for all trace events in the kernel and pretty print them.
f3ed775e 503 */
9f19cc17 504static int list_kernel_events(void)
f3ed775e 505{
9f19cc17 506 int i, size;
b551a063
DG
507 struct lttng_domain domain;
508 struct lttng_handle *handle;
9f19cc17 509 struct lttng_event *event_list;
f3ed775e 510
441c16a7
MD
511 memset(&domain, 0, sizeof(domain));
512
b551a063
DG
513 DBG("Getting kernel tracing events");
514
515 domain.type = LTTNG_DOMAIN_KERNEL;
516
517 handle = lttng_create_handle(NULL, &domain);
518 if (handle == NULL) {
519 goto error;
520 }
f3ed775e 521
cd80958d 522 size = lttng_list_tracepoints(handle, &event_list);
9f19cc17 523 if (size < 0) {
60e835ca 524 ERR("Unable to list kernel events: %s", lttng_strerror(size));
ef021732 525 lttng_destroy_handle(handle);
9f19cc17 526 return size;
f3ed775e
DG
527 }
528
9f19cc17 529 MSG("Kernel events:\n-------------");
f3ed775e 530
9f19cc17 531 for (i = 0; i < size; i++) {
b551a063 532 print_events(&event_list[i]);
f3ed775e
DG
533 }
534
b551a063
DG
535 MSG("");
536
f3ed775e
DG
537 free(event_list);
538
ef021732 539 lttng_destroy_handle(handle);
f3ed775e 540 return CMD_SUCCESS;
b551a063
DG
541
542error:
ef021732 543 lttng_destroy_handle(handle);
b551a063 544 return -1;
f3ed775e
DG
545}
546
3c6a091f
DG
547/*
548 * List JUL events for a specific session using the handle.
549 *
550 * Return CMD_SUCCESS on success else a negative value.
551 */
552static int list_session_jul_events(void)
553{
554 int ret, count, i;
555 struct lttng_event *events = NULL;
556
557 count = lttng_list_events(handle, "", &events);
558 if (count < 0) {
559 ret = count;
560 ERR("%s", lttng_strerror(ret));
561 goto error;
562 }
563
564 MSG("Events (Logger name):\n---------------------");
565 if (count == 0) {
566 MSG("%sNone\n", indent6);
567 goto end;
568 }
569
570 for (i = 0; i < count; i++) {
571 MSG("%s- %s%s", indent4, events[i].name,
572 enabled_string(events[i].enabled));
573 }
574
575 MSG("");
576
577end:
578 free(events);
579 ret = CMD_SUCCESS;
580
581error:
582 return ret;
583}
584
f3ed775e 585/*
9f19cc17 586 * List events of channel of session and domain.
f3ed775e 587 */
cd80958d 588static int list_events(const char *channel_name)
f3ed775e
DG
589{
590 int ret, count, i;
9f19cc17 591 struct lttng_event *events = NULL;
f3ed775e 592
cd80958d 593 count = lttng_list_events(handle, channel_name, &events);
f3ed775e
DG
594 if (count < 0) {
595 ret = count;
60e835ca 596 ERR("%s", lttng_strerror(ret));
f3ed775e
DG
597 goto error;
598 }
599
9f19cc17
DG
600 MSG("\n%sEvents:", indent4);
601 if (count == 0) {
5edd7e09 602 MSG("%sNone\n", indent6);
9f19cc17
DG
603 goto end;
604 }
605
f3ed775e 606 for (i = 0; i < count; i++) {
b551a063 607 print_events(&events[i]);
f3ed775e
DG
608 }
609
9f19cc17 610 MSG("");
f3ed775e 611
9f19cc17 612end:
0e428499 613 free(events);
9f19cc17 614 ret = CMD_SUCCESS;
f3ed775e
DG
615
616error:
617 return ret;
618}
619
620/*
9f19cc17
DG
621 * Pretty print channel
622 */
623static void print_channel(struct lttng_channel *channel)
624{
464dd62d 625 MSG("- %s:%s\n", channel->name, enabled_string(channel->enabled));
9f19cc17
DG
626
627 MSG("%sAttributes:", indent4);
a5bbe8f6
DG
628 MSG("%soverwrite mode: %d", indent6, channel->attr.overwrite);
629 MSG("%ssubbufers size: %" PRIu64, indent6, channel->attr.subbuf_size);
9f19cc17 630 MSG("%snumber of subbufers: %" PRIu64, indent6, channel->attr.num_subbuf);
a5bbe8f6
DG
631 MSG("%sswitch timer interval: %u", indent6, channel->attr.switch_timer_interval);
632 MSG("%sread timer interval: %u", indent6, channel->attr.read_timer_interval);
9f19cc17
DG
633 switch (channel->attr.output) {
634 case LTTNG_EVENT_SPLICE:
635 MSG("%soutput: splice()", indent6);
636 break;
637 case LTTNG_EVENT_MMAP:
638 MSG("%soutput: mmap()", indent6);
639 break;
640 }
641}
642
643/*
644 * List channel(s) of session and domain.
f3ed775e 645 *
9f19cc17 646 * If channel_name is NULL, all channels are listed.
f3ed775e 647 */
cd80958d 648static int list_channels(const char *channel_name)
f3ed775e 649{
9f19cc17
DG
650 int count, i, ret = CMD_SUCCESS;
651 unsigned int chan_found = 0;
652 struct lttng_channel *channels = NULL;
f3ed775e 653
3e25cb20 654 DBG("Listing channel(s) (%s)", channel_name ? : "<all>");
9f19cc17 655
cd80958d 656 count = lttng_list_channels(handle, &channels);
f3ed775e 657 if (count < 0) {
c7d620a2
DG
658 switch (-count) {
659 case LTTNG_ERR_KERN_CHAN_NOT_FOUND:
660 ret = CMD_SUCCESS;
661 WARN("No kernel channel");
662 break;
663 default:
664 /* We had a real error */
665 ret = count;
666 ERR("%s", lttng_strerror(ret));
60e835ca 667 break;
c7d620a2 668 }
ae856491 669 goto error_channels;
f3ed775e
DG
670 }
671
9f19cc17
DG
672 if (channel_name == NULL) {
673 MSG("Channels:\n-------------");
674 }
675
676 for (i = 0; i < count; i++) {
677 if (channel_name != NULL) {
678 if (strncmp(channels[i].name, channel_name, NAME_MAX) == 0) {
679 chan_found = 1;
680 } else {
681 continue;
682 }
683 }
684 print_channel(&channels[i]);
685
686 /* Listing events per channel */
cd80958d 687 ret = list_events(channels[i].name);
9f19cc17 688 if (ret < 0) {
60e835ca 689 ERR("%s", lttng_strerror(ret));
9f19cc17
DG
690 }
691
692 if (chan_found) {
693 break;
f3ed775e 694 }
f3ed775e
DG
695 }
696
9f19cc17 697 if (!chan_found && channel_name != NULL) {
ae856491
DG
698 ERR("Channel %s not found", channel_name);
699 goto error;
9f19cc17 700 }
f3ed775e 701
9f19cc17 702 ret = CMD_SUCCESS;
f3ed775e
DG
703
704error:
ae856491
DG
705 free(channels);
706
707error_channels:
f3ed775e
DG
708 return ret;
709}
710
711/*
9f19cc17 712 * List available tracing session. List only basic information.
f3ed775e 713 *
9f19cc17 714 * If session_name is NULL, all sessions are listed.
f3ed775e 715 */
9f19cc17 716static int list_sessions(const char *session_name)
f3ed775e 717{
9f19cc17
DG
718 int ret, count, i;
719 unsigned int session_found = 0;
720 struct lttng_session *sessions;
721
722 count = lttng_list_sessions(&sessions);
723 DBG("Session count %d", count);
724 if (count < 0) {
725 ret = count;
8f3f773f 726 ERR("%s", lttng_strerror(ret));
9f19cc17 727 goto error;
d32fb093
DG
728 } else if (count == 0) {
729 MSG("Currently no available tracing session");
730 goto end;
9f19cc17
DG
731 }
732
733 if (session_name == NULL) {
734 MSG("Available tracing sessions:");
735 }
736
737 for (i = 0; i < count; i++) {
738 if (session_name != NULL) {
739 if (strncmp(sessions[i].name, session_name, NAME_MAX) == 0) {
740 session_found = 1;
2cbf8fed
DG
741 MSG("Tracing session %s: [%s%s]", session_name,
742 active_string(sessions[i].enabled),
743 snapshot_string(sessions[i].snapshot_mode));
9f19cc17
DG
744 MSG("%sTrace path: %s\n", indent4, sessions[i].path);
745 break;
746 }
3842aa86 747 } else {
2cbf8fed
DG
748 MSG(" %d) %s (%s) [%s%s]", i + 1, sessions[i].name, sessions[i].path,
749 active_string(sessions[i].enabled),
750 snapshot_string(sessions[i].snapshot_mode));
9f19cc17
DG
751 }
752 }
753
754 free(sessions);
755
756 if (!session_found && session_name != NULL) {
b6913340
DG
757 ERR("Session '%s' not found", session_name);
758 ret = CMD_ERROR;
759 goto error;
9f19cc17
DG
760 }
761
762 if (session_name == NULL) {
6e0de39b 763 MSG("\nUse lttng list <session_name> for more details");
9f19cc17 764 }
f3ed775e 765
d32fb093 766end:
f3ed775e
DG
767 return CMD_SUCCESS;
768
769error:
770 return ret;
771}
f3ed775e
DG
772
773/*
9f19cc17 774 * List available domain(s) for a session.
f3ed775e 775 */
330be774 776static int list_domains(const char *session_name)
f3ed775e 777{
9f19cc17
DG
778 int i, count, ret = CMD_SUCCESS;
779 struct lttng_domain *domains = NULL;
780
781 MSG("Domains:\n-------------");
782
330be774 783 count = lttng_list_domains(session_name, &domains);
9f19cc17
DG
784 if (count < 0) {
785 ret = count;
60e835ca 786 ERR("%s", lttng_strerror(ret));
9f19cc17
DG
787 goto error;
788 } else if (count == 0) {
789 MSG(" None");
790 goto end;
791 }
792
793 for (i = 0; i < count; i++) {
794 switch (domains[i].type) {
795 case LTTNG_DOMAIN_KERNEL:
796 MSG(" - Kernel");
b551a063
DG
797 break;
798 case LTTNG_DOMAIN_UST:
799 MSG(" - UST global");
800 break;
3c6a091f
DG
801 case LTTNG_DOMAIN_JUL:
802 MSG(" - JUL (Java Util Logging)");
803 break;
9f19cc17
DG
804 default:
805 break;
806 }
807 }
808
809end:
810 free(domains);
811
812error:
813 return ret;
f3ed775e 814}
f3ed775e
DG
815
816/*
9f19cc17 817 * The 'list <options>' first level command
f3ed775e
DG
818 */
819int cmd_list(int argc, const char **argv)
820{
c617c0c6 821 int opt, ret = CMD_SUCCESS;
9f19cc17 822 const char *session_name;
f3ed775e 823 static poptContext pc;
9f19cc17
DG
824 struct lttng_domain domain;
825 struct lttng_domain *domains = NULL;
f3ed775e 826
441c16a7
MD
827 memset(&domain, 0, sizeof(domain));
828
9f19cc17 829 if (argc < 1) {
f3ed775e 830 usage(stderr);
ca1c3607 831 ret = CMD_ERROR;
f3ed775e
DG
832 goto end;
833 }
834
835 pc = poptGetContext(NULL, argc, argv, long_options, 0);
836 poptReadDefaultConfig(pc, 0);
837
838 while ((opt = poptGetNextOpt(pc)) != -1) {
839 switch (opt) {
840 case OPT_HELP:
ca1c3607 841 usage(stdout);
f3ed775e 842 goto end;
eeac7d46
MD
843 case OPT_USERSPACE:
844 opt_userspace = 1;
eeac7d46 845 break;
679b4943
SM
846 case OPT_LIST_OPTIONS:
847 list_cmd_options(stdout, long_options);
679b4943 848 goto end;
f3ed775e
DG
849 default:
850 usage(stderr);
851 ret = CMD_UNDEFINED;
852 goto end;
853 }
854 }
855
9f19cc17
DG
856 /* Get session name (trailing argument) */
857 session_name = poptGetArg(pc);
b551a063 858 DBG2("Session name: %s", session_name);
9f19cc17 859
cd80958d
DG
860 if (opt_kernel) {
861 domain.type = LTTNG_DOMAIN_KERNEL;
b551a063
DG
862 } else if (opt_userspace) {
863 DBG2("Listing userspace global domain");
864 domain.type = LTTNG_DOMAIN_UST;
3c6a091f
DG
865 } else if (opt_jul) {
866 DBG2("Listing JUL domain");
867 domain.type = LTTNG_DOMAIN_JUL;
cd80958d
DG
868 }
869
3c6a091f 870 if (opt_kernel || opt_userspace || opt_jul) {
aa5de748
MD
871 handle = lttng_create_handle(session_name, &domain);
872 if (handle == NULL) {
873 ret = CMD_FATAL;
874 goto end;
875 }
cd80958d
DG
876 }
877
9f19cc17 878 if (session_name == NULL) {
3c6a091f 879 if (!opt_kernel && !opt_userspace && !opt_jul) {
b551a063 880 ret = list_sessions(NULL);
b6913340 881 if (ret != 0) {
b551a063
DG
882 goto end;
883 }
884 }
9f19cc17
DG
885 if (opt_kernel) {
886 ret = list_kernel_events();
887 if (ret < 0) {
6191db77 888 ret = CMD_ERROR;
9f19cc17
DG
889 goto end;
890 }
b551a063
DG
891 }
892 if (opt_userspace) {
f37d259d
MD
893 if (opt_fields) {
894 ret = list_ust_event_fields();
895 } else {
896 ret = list_ust_events();
897 }
9f19cc17 898 if (ret < 0) {
6191db77 899 ret = CMD_ERROR;
9f19cc17
DG
900 goto end;
901 }
902 }
3c6a091f
DG
903 if (opt_jul) {
904 ret = list_jul_events();
905 if (ret < 0) {
906 ret = CMD_ERROR;
907 goto end;
908 }
909 }
9f19cc17
DG
910 } else {
911 /* List session attributes */
912 ret = list_sessions(session_name);
b6913340 913 if (ret != 0) {
9f19cc17
DG
914 goto end;
915 }
916
917 /* Domain listing */
918 if (opt_domain) {
330be774 919 ret = list_domains(session_name);
9f19cc17
DG
920 goto end;
921 }
922
923 if (opt_kernel) {
9f19cc17 924 /* Channel listing */
cd80958d 925 ret = list_channels(opt_channel);
9f19cc17
DG
926 if (ret < 0) {
927 goto end;
928 }
9f19cc17 929 } else {
c617c0c6
MD
930 int i, nb_domain;
931
9f19cc17 932 /* We want all domain(s) */
330be774 933 nb_domain = lttng_list_domains(session_name, &domains);
b551a063 934 if (nb_domain < 0) {
67635185 935 ret = nb_domain;
60e835ca 936 ERR("%s", lttng_strerror(ret));
9f19cc17
DG
937 goto end;
938 }
939
b551a063 940 for (i = 0; i < nb_domain; i++) {
9f19cc17
DG
941 switch (domains[i].type) {
942 case LTTNG_DOMAIN_KERNEL:
943 MSG("=== Domain: Kernel ===\n");
944 break;
b551a063
DG
945 case LTTNG_DOMAIN_UST:
946 MSG("=== Domain: UST global ===\n");
88c5f0d8
DG
947 MSG("Buffer type: %s\n",
948 domains[i].buf_type ==
949 LTTNG_BUFFER_PER_PID ? "per PID" : "per UID");
b551a063 950 break;
3c6a091f
DG
951 case LTTNG_DOMAIN_JUL:
952 MSG("=== Domain: JUL (Java Util Logging) ===\n");
953 break;
9f19cc17
DG
954 default:
955 MSG("=== Domain: Unimplemented ===\n");
956 break;
957 }
958
cd80958d 959 /* Clean handle before creating a new one */
aa5de748
MD
960 if (handle) {
961 lttng_destroy_handle(handle);
962 }
cd80958d
DG
963
964 handle = lttng_create_handle(session_name, &domains[i]);
965 if (handle == NULL) {
ca1c3607 966 ret = CMD_FATAL;
cd80958d
DG
967 goto end;
968 }
969
3c6a091f
DG
970 if (domains[i].type == LTTNG_DOMAIN_JUL) {
971 ret = list_session_jul_events();
972 if (ret < 0) {
973 goto end;
974 }
975 continue;
976 }
977
cd80958d 978 ret = list_channels(opt_channel);
9f19cc17
DG
979 if (ret < 0) {
980 goto end;
981 }
982 }
983 }
f3ed775e
DG
984 }
985
986end:
0e428499 987 free(domains);
aa5de748
MD
988 if (handle) {
989 lttng_destroy_handle(handle);
990 }
cd80958d 991
ca1c3607 992 poptFreeContext(pc);
f3ed775e
DG
993 return ret;
994}
This page took 0.09238 seconds and 5 git commands to generate.