- printf("%02d:%02d:%02d.%09" PRIu64 " %s\n", start.tm_hour,
- start.tm_min, start.tm_sec, ts_nsec_start,
- bt_ctf_event_name(call_data));
+ pid = get_context_pid(call_data);
+ if (pid == -1ULL && opt_tid) {
+ goto error;
+ }
+
+ hostname = get_context_hostname(call_data);
+ if (!opt_tid && (opt_hostname && !lookup_hostname_list(hostname)))
+ goto end;
+ if (!opt_hostname && (opt_tid && !lookup_tid_list(pid)))
+ goto end;
+ if ((opt_tid && !lookup_tid_list(pid)) &&
+ (opt_hostname && !lookup_hostname_list(hostname)))
+ goto end;
+
+ cpu_id = get_cpu_id(call_data);
+ procname = get_context_comm(call_data);
+
+ if ((strcmp(bt_ctf_event_name(call_data), "exit_syscall") == 0) &&
+ !last_textdump_print_newline) {
+ scope = bt_ctf_get_top_level_scope(call_data,
+ BT_EVENT_FIELDS);
+ syscall_ret = bt_ctf_get_int64(bt_ctf_get_field(call_data,
+ scope, "_ret"));
+ printf("= %ld\n", syscall_ret);
+ last_textdump_print_newline = 1;
+ } else {
+ /* we might have lost the exit_syscall event, so need to
+ * print the newline in this case */
+ if (last_textdump_print_newline == 0)
+ printf("\n");
+ printf("%02d:%02d:%02d.%09" PRIu64 " (%s) (cpu %d) [%s (%d)] %s (",
+ start.tm_hour, start.tm_min, start.tm_sec,
+ ts_nsec_start, hostname, cpu_id, procname, pid,
+ bt_ctf_event_name(call_data));
+ print_fields(call_data);
+ printf(") ");
+ if (strncmp(bt_ctf_event_name(call_data), "sys_", 4) != 0) {
+ printf("\n");
+ last_textdump_print_newline = 1;
+ } else {
+ last_textdump_print_newline = 0;
+ }
+ }
+
+end:
+ return BT_CB_OK;
+error:
+ return BT_CB_ERROR_STOP;
+}
+
+enum bt_cb_ret handle_kprobes(struct bt_ctf_event *call_data, void *private_data)
+{
+ int i;
+ struct kprobes *kprobe;
+
+ /* for kprobes */
+ for (i = 0; i < lttngtop.kprobes_table->len; i++) {
+ kprobe = g_ptr_array_index(lttngtop.kprobes_table, i);
+ if (strcmp(bt_ctf_event_name(call_data), kprobe->probe_name) == 0) {
+ kprobe->count++;
+ }
+ }
- fprintf(fp, "Usage : lttngtop /path/to/trace\n");
+ fprintf(fp, "Usage : lttngtop [OPTIONS] [TRACE]\n");
+ fprintf(fp, " TRACE Path to the trace to analyse (no trace path for live tracing)\n");
+ fprintf(fp, " -h, --help This help message\n");
+ fprintf(fp, " -t, --textdump Display live events in text-only\n");
+ fprintf(fp, " -p, --pid Comma-separated list of PIDs to display\n");
+ fprintf(fp, " -f, --child Follow threads associated with selected PIDs\n");
+ fprintf(fp, " -n, --hostname Comma-separated list of hostnames to display (require hostname context in trace)\n");
+}
+
+/*
+ * Parse probe options.
+ * Shamelessly stolen from lttng-tools :
+ * src/bin/lttng/commands/enable_events.c
+ */
+static struct kprobes *parse_probe_opts(char *opt)
+{
+ char s_hex[19];
+ char name[LTTNG_SYMBOL_NAME_LEN];
+ struct kprobes *kprobe;
+ int ret;
+
+ /*
+ kprobe->probe_addr = 0;
+ kprobe->probe_offset = 0;
+ asprintf(&kprobe->probe_name, "probe_sys_open");
+ asprintf(&kprobe->symbol_name, "sys_open");
+ */
+
+ if (opt == NULL) {
+ kprobe = NULL;
+ goto end;
+ }
+
+ kprobe = g_new0(struct kprobes, 1);
+
+ /* Check for symbol+offset */
+ ret = sscanf(opt, "%[^'+']+%s", name, s_hex);
+ if (ret == 2) {
+ asprintf(&kprobe->probe_name, "probe_%s", name);
+ asprintf(&kprobe->symbol_name, "%s", name);
+
+ if (strlen(s_hex) == 0) {
+ fprintf(stderr, "Invalid probe offset %s", s_hex);
+ ret = -1;
+ goto end;
+ }
+ kprobe->probe_offset = strtoul(s_hex, NULL, 0);
+ kprobe->probe_addr = 0;
+ goto end;
+ }
+
+ /* Check for symbol */
+ if (isalpha(name[0])) {
+ ret = sscanf(opt, "%s", name);
+ if (ret == 1) {
+ asprintf(&kprobe->probe_name, "probe_%s", name);
+ asprintf(&kprobe->symbol_name, "%s", name);
+ kprobe->probe_offset = 0;
+ kprobe->probe_addr = 0;
+ goto end;
+ }
+ }
+
+ /* Check for address */
+ ret = sscanf(opt, "%s", s_hex);
+ if (ret > 0) {
+ if (strlen(s_hex) == 0) {
+ fprintf(stderr, "Invalid probe address %s", s_hex);
+ ret = -1;
+ goto end;
+ }
+ asprintf(&kprobe->probe_name, "probe_%s", s_hex);
+ kprobe->probe_offset = 0;
+ kprobe->probe_addr = strtoul(s_hex, NULL, 0);
+ goto end;
+ }
+
+ /* No match */
+ kprobe = NULL;
+
+end:
+ return kprobe;
+ case OPT_TEXTDUMP:
+ opt_textdump = 1;
+ break;
+ case OPT_CHILD:
+ opt_textdump = 1;
+ opt_child = 1;
+ break;
+ case OPT_PID:
+ tid_list = g_hash_table_new(g_str_hash,
+ g_str_equal);
+ tmp_str = strtok(opt_tid, ",");
+ while (tmp_str) {
+ tid = malloc(sizeof(int));
+ *tid = atoi(tmp_str);
+ g_hash_table_insert(tid_list,
+ (gpointer) tid, tid);
+ tmp_str = strtok(NULL, ",");
+ }
+ break;
+ case OPT_HOSTNAME:
+ hostname_list = g_hash_table_new(g_str_hash,
+ g_str_equal);
+ tmp_str = strtok(opt_hostname, ",");
+ while (tmp_str) {
+ char *new_str = strdup(tmp_str);
+ g_hash_table_insert(hostname_list,
+ (gpointer) new_str,
+ (gpointer) new_str);
+ tmp_str = strtok(NULL, ",");
+ }
+ break;
+ case OPT_KPROBES:
+ lttngtop.kprobes_table = g_ptr_array_new();
+ tmp_str = strtok(opt_kprobes, ",");
+ while (tmp_str) {
+ struct kprobes *kprobe;
+
+ kprobe = parse_probe_opts(tmp_str);
+ if (kprobe) {
+ g_ptr_array_add(
+ lttngtop.kprobes_table,
+ kprobe);
+ } else {
+ ret = -EINVAL;
+ goto end;
+ }
+ tmp_str = strtok(NULL, ",");
+ }
+ break;
- bt_ctf_iter_add_callback(iter, 0, NULL, 0,
- print_timestamp,
- NULL, NULL, NULL);
-
-#if 0
- /* at each event check if we need to refresh */
- bt_ctf_iter_add_callback(iter, 0, NULL, 0,
- check_timestamp,
- NULL, NULL, NULL);
- /* at each event, verify the status of the process table */
- bt_ctf_iter_add_callback(iter, 0, NULL, 0,
- fix_process_table,
- NULL, NULL, NULL);
- /* to handle the scheduling events */
- bt_ctf_iter_add_callback(iter,
- g_quark_from_static_string("sched_switch"),
- NULL, 0, handle_sched_switch, NULL, NULL, NULL);
- /* to clean up the process table */
- bt_ctf_iter_add_callback(iter,
- g_quark_from_static_string("sched_process_free"),
- NULL, 0, handle_sched_process_free, NULL, NULL, NULL);
- /* to get all the process from the statedumps */
- bt_ctf_iter_add_callback(iter,
- g_quark_from_static_string(
- "lttng_statedump_process_state"),
- NULL, 0, handle_statedump_process_state,
- NULL, NULL, NULL);
-
- /* for IO top */
- bt_ctf_iter_add_callback(iter,
- g_quark_from_static_string("exit_syscall"),
- NULL, 0, handle_exit_syscall, NULL, NULL, NULL);
- bt_ctf_iter_add_callback(iter,
- g_quark_from_static_string("sys_write"),
- NULL, 0, handle_sys_write, NULL, NULL, NULL);
- bt_ctf_iter_add_callback(iter,
- g_quark_from_static_string("sys_read"),
- NULL, 0, handle_sys_read, NULL, NULL, NULL);
- bt_ctf_iter_add_callback(iter,
- g_quark_from_static_string("sys_open"),
- NULL, 0, handle_sys_open, NULL, NULL, NULL);
- bt_ctf_iter_add_callback(iter,
- g_quark_from_static_string("sys_close"),
- NULL, 0, handle_sys_close, NULL, NULL, NULL);
- bt_ctf_iter_add_callback(iter,
- g_quark_from_static_string(
+ if (opt_textdump) {
+ bt_ctf_iter_add_callback(iter, 0, NULL, 0,
+ print_timestamp,
+ NULL, NULL, NULL);
+ } else {
+ /* at each event check if we need to refresh */
+ bt_ctf_iter_add_callback(iter, 0, NULL, 0,
+ check_timestamp,
+ NULL, NULL, NULL);
+ /* at each event, verify the status of the process table */
+ bt_ctf_iter_add_callback(iter, 0, NULL, 0,
+ fix_process_table,
+ NULL, NULL, NULL);
+ /* to handle the scheduling events */
+ bt_ctf_iter_add_callback(iter,
+ g_quark_from_static_string("sched_switch"),
+ NULL, 0, handle_sched_switch, NULL, NULL, NULL);
+ /* to clean up the process table */
+ bt_ctf_iter_add_callback(iter,
+ g_quark_from_static_string("sched_process_free"),
+ NULL, 0, handle_sched_process_free, NULL, NULL, NULL);
+ /* to get all the process from the statedumps */
+ bt_ctf_iter_add_callback(iter,
+ g_quark_from_static_string(
+ "lttng_statedump_process_state"),
+ NULL, 0, handle_statedump_process_state,
+ NULL, NULL, NULL);
+
+ /* for IO top */
+ bt_ctf_iter_add_callback(iter,
+ g_quark_from_static_string("exit_syscall"),
+ NULL, 0, handle_exit_syscall, NULL, NULL, NULL);
+ bt_ctf_iter_add_callback(iter,
+ g_quark_from_static_string("sys_write"),
+ NULL, 0, handle_sys_write, NULL, NULL, NULL);
+ bt_ctf_iter_add_callback(iter,
+ g_quark_from_static_string("sys_read"),
+ NULL, 0, handle_sys_read, NULL, NULL, NULL);
+ bt_ctf_iter_add_callback(iter,
+ g_quark_from_static_string("sys_open"),
+ NULL, 0, handle_sys_open, NULL, NULL, NULL);
+ bt_ctf_iter_add_callback(iter,
+ g_quark_from_static_string("sys_close"),
+ NULL, 0, handle_sys_close, NULL, NULL, NULL);
+ bt_ctf_iter_add_callback(iter,
+ g_quark_from_static_string(
- pthread_create(&live_trace_thread, NULL, setup_live_tracing, (void *) NULL);
- sleep(2000);
- printf("STOPPING\n");
+ if (opt_textdump) {
+ signal(SIGTERM, handle_textdump_sigterm);
+ signal(SIGINT, handle_textdump_sigterm);
+ }
+ init_lttngtop();
+ ret = setup_live_tracing();
+ if (ret < 0) {
+ goto end;
+ }
+ if (!opt_textdump) {
+ pthread_create(&display_thread, NULL, ncurses_display, (void *) NULL);
+ pthread_create(&timer_thread, NULL, refresh_thread, (void *) NULL);
+ }
+ while (!quit) {
+ reload_trace = 0;
+ live_consume(&bt_ctx);
+ iter_trace(bt_ctx);
+ ret = bt_context_remove_trace(bt_ctx, 0);
+ if (ret != 0)
+ fprintf(stderr, "error removing trace\n");
+ if (bt_ctx) {
+ bt_context_put(bt_ctx);
+ }
+
+ /*
+ * since we receive all FDs every time there is an
+ * update and the FD number is different every time,
+ * we don't know which one are valid.
+ * so we check if all FDs are usable with a simple
+ * ioctl call.
+ */
+ bt_list_for_each_entry(mmap_info, &mmap_list.head, list) {
+ ret = helper_kernctl_get_mmap_len(mmap_info->fd, &mmap_len);
+ if (ret != 0) {
+ bt_list_del(&mmap_info->list);
+ }
+ }
+ sem_post(&metadata_available);
+ }
+
+ pthread_join(timer_thread, NULL);
+ quit = 1;
+ pthread_join(display_thread, NULL);
+