X-Git-Url: https://git.lttng.org/?p=lttngtop.git;a=blobdiff_plain;f=src%2Flttngtop.c;h=ae10e9fbe3ebd74480f7c6fd8a9eee1c765c462c;hp=28acebf6c1134851571acd243919d672bbe188e1;hb=246d59926e23f5cdf6f017ae7544f2582b666ef7;hpb=32b70e07fe8aa2f06988d2a9accddf5992b08746 diff --git a/src/lttngtop.c b/src/lttngtop.c index 28acebf..ae10e9f 100644 --- a/src/lttngtop.c +++ b/src/lttngtop.c @@ -52,7 +52,6 @@ const char *opt_input_path; static int opt_textdump; -static int opt_pid; static int opt_child; int quit = 0; @@ -74,12 +73,15 @@ GPtrArray *available_snapshots; sem_t metadata_available; int reload_trace = 0; +int last_textdump_print_newline = 1; + enum { OPT_NONE = 0, OPT_HELP, OPT_TEXTDUMP, OPT_PID, OPT_CHILD, + OPT_HOSTNAME, }; static struct poptOption long_options[] = { @@ -87,10 +89,17 @@ static struct poptOption long_options[] = { { "help", 'h', POPT_ARG_NONE, NULL, OPT_HELP, NULL, NULL }, { "textdump", 't', POPT_ARG_NONE, NULL, OPT_TEXTDUMP, NULL, NULL }, { "child", 'f', POPT_ARG_NONE, NULL, OPT_CHILD, NULL, NULL }, - { "pid", 'p', POPT_ARG_INT, &opt_pid, OPT_PID, NULL, NULL }, + { "pid", 'p', POPT_ARG_STRING, &opt_tid, OPT_PID, NULL, NULL }, + { "hostname", 'n', POPT_ARG_STRING, &opt_hostname, OPT_HOSTNAME, NULL, NULL }, { NULL, 0, 0, NULL, 0, NULL, NULL }, }; +static void handle_textdump_sigterm(int signal) +{ + quit = 1; + lttng_destroy_session("test"); +} + void *refresh_thread(void *p) { struct mmap_stream *mmap_info; @@ -105,8 +114,8 @@ void *refresh_thread(void *p) pthread_exit(0); } if (!opt_input_path) { - bt_list_for_each_entry(mmap_info, &mmap_list.head, list) - helper_kernctl_buffer_flush(mmap_info->fd); + bt_list_for_each_entry(mmap_info, &mmap_list.head, list) + helper_kernctl_buffer_flush(mmap_info->fd); } sem_wait(&pause_sem); sem_post(&pause_sem); @@ -147,6 +156,37 @@ void *ncurses_display(void *p) } } +void print_fields(struct bt_ctf_event *event) +{ + unsigned int cnt, i; + const struct definition *const * list; + const struct definition *scope; + enum ctf_type_id type; + const char *str; + + scope = bt_ctf_get_top_level_scope(event, BT_EVENT_FIELDS); + + bt_ctf_get_field_list(event, scope, &list, &cnt); + for (i = 0; i < cnt; i++) { + if (i != 0) + printf(", "); + printf("%s = ", bt_ctf_field_name(list[i])); + type = bt_ctf_field_type(list[i]); + if (type == CTF_TYPE_INTEGER) { + if (bt_ctf_get_int_signedness(list[i]) == 0) + printf("%" PRIu64 "", bt_ctf_get_uint64(list[i])); + else + printf("%" PRId64 "", bt_ctf_get_int64(list[i])); + } else if (type == CTF_TYPE_STRING) { + printf("%s", bt_ctf_get_string(list[i])); + } else if (type == CTF_TYPE_ARRAY) { + str = bt_ctf_get_char_array(list[i]); + if (!bt_ctf_field_get_error() && str) + printf("%s", str); + } + } +} + /* * hook on each event to check the timestamp and refresh the display if * necessary @@ -156,7 +196,10 @@ enum bt_cb_ret print_timestamp(struct bt_ctf_event *call_data, void *private_dat unsigned long timestamp; struct tm start; uint64_t ts_nsec_start; - int pid; + int pid, cpu_id; + int64_t syscall_ret; + const struct definition *scope; + const char *hostname, *procname; timestamp = bt_ctf_get_timestamp(call_data); @@ -164,16 +207,47 @@ enum bt_cb_ret print_timestamp(struct bt_ctf_event *call_data, void *private_dat ts_nsec_start = timestamp % NSEC_PER_SEC; pid = get_context_pid(call_data); - if (pid == -1ULL && opt_pid) { + if (pid == -1ULL && opt_tid) { goto error; } - if (opt_pid && opt_pid != pid) + 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; - printf("%02d:%02d:%02d.%09" PRIu64 " %d : %s\n", start.tm_hour, - start.tm_min, start.tm_sec, ts_nsec_start, - pid, bt_ctf_event_name(call_data)); + 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; @@ -181,6 +255,22 @@ 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++; + } + } + + return BT_CB_OK; +} + /* * hook on each event to check the timestamp and refresh the display if * necessary @@ -316,7 +406,7 @@ enum bt_cb_ret fix_process_table(struct bt_ctf_event *call_data, void *private_data) { int pid, tid, ppid, vpid, vtid, vppid; - char *comm; + char *comm, *hostname; struct processtop *parent, *child; unsigned long timestamp; @@ -328,6 +418,7 @@ enum bt_cb_ret fix_process_table(struct bt_ctf_event *call_data, if (pid == -1ULL) { goto error; } + tid = get_context_tid(call_data); if (tid == -1ULL) { goto error; @@ -352,19 +443,24 @@ enum bt_cb_ret fix_process_table(struct bt_ctf_event *call_data, if (!comm) { goto error; } + /* optional */ + hostname = get_context_hostname(call_data); /* find or create the current process */ child = find_process_tid(<tngtop, tid, comm); if (!child) child = add_proc(<tngtop, tid, comm, timestamp); - update_proc(child, pid, tid, ppid, vpid, vtid, vppid, comm); + if (!child) + goto end; + update_proc(child, pid, tid, ppid, vpid, vtid, vppid, comm, hostname); if (pid != tid) { /* find or create the parent */ parent = find_process_tid(<tngtop, pid, comm); if (!parent) { parent = add_proc(<tngtop, pid, comm, timestamp); - parent->pid = pid; + if (parent) + parent->pid = pid; } /* attach the parent to the current process */ @@ -374,6 +470,7 @@ enum bt_cb_ret fix_process_table(struct bt_ctf_event *call_data, update_perf_counter(child, call_data); +end: return BT_CB_OK; error: @@ -402,12 +499,19 @@ void init_lttngtop() lttngtop.process_table = g_ptr_array_new(); lttngtop.files_table = g_ptr_array_new(); lttngtop.cpu_table = g_ptr_array_new(); + lttngtop.kprobes_table = g_ptr_array_new(); } void usage(FILE *fp) { fprintf(fp, "LTTngTop %s\n\n", VERSION); - 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"); } /* @@ -418,6 +522,8 @@ static int parse_options(int argc, char **argv) { poptContext pc; int opt, ret = 0; + char *tmp_str; + int *tid; pc = poptGetContext(NULL, argc, (const char **) argv, long_options, 0); poptReadDefaultConfig(pc, 0); @@ -436,7 +542,28 @@ static int parse_options(int argc, char **argv) opt_child = 1; break; case OPT_PID: - opt_textdump = 1; + 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; default: ret = -EINVAL; @@ -457,16 +584,15 @@ void iter_trace(struct bt_context *bt_ctx) { struct bt_ctf_iter *iter; struct bt_iter_pos begin_pos; + struct kprobes *kprobe; const struct bt_ctf_event *event; + int i; int ret = 0; begin_pos.type = BT_SEEK_BEGIN; iter = bt_ctf_iter_create(bt_ctx, &begin_pos, NULL); if (opt_textdump) { - if (opt_pid) { - printf("PID : %d, Child : %d\n", opt_pid, opt_child); - } bt_ctf_iter_add_callback(iter, 0, NULL, 0, print_timestamp, NULL, NULL, NULL); @@ -515,9 +641,19 @@ void iter_trace(struct bt_context *bt_ctx) "lttng_statedump_file_descriptor"), NULL, 0, handle_statedump_file_descriptor, NULL, NULL, NULL); + + /* for kprobes */ + for (i = 0; i < lttngtop.kprobes_table->len; i++) { + kprobe = g_ptr_array_index(lttngtop.kprobes_table, i); + bt_ctf_iter_add_callback(iter, + g_quark_from_static_string( + kprobe->probe_name), + NULL, 0, handle_kprobes, + NULL, NULL, NULL); + } } - while ((event = bt_ctf_iter_read_event(iter, NULL)) != NULL) { + while ((event = bt_ctf_iter_read_event(iter)) != NULL) { if (quit || reload_trace) goto end_iter; ret = bt_iter_next(bt_ctf_get_iter(iter)); @@ -878,6 +1014,49 @@ end: return ret; } +int enable_kprobes(struct lttng_handle *handle, char *channel_name) +{ + struct lttng_event ev; + struct kprobes *kprobe; + int ret = 0; + int i; + + /* + kprobe = g_new0(struct kprobes, 1); + kprobe->probe_addr = 0; + kprobe->probe_offset = 0; + asprintf(&kprobe->probe_name, "probe_sys_open"); + asprintf(&kprobe->symbol_name, "sys_open"); + g_ptr_array_add(lttngtop.kprobes_table, kprobe); + + kprobe = g_new0(struct kprobes, 1); + kprobe->probe_addr = 0; + kprobe->probe_offset = 0; + asprintf(&kprobe->probe_name, "probe_sys_close"); + asprintf(&kprobe->symbol_name, "sys_close"); + g_ptr_array_add(lttngtop.kprobes_table, kprobe); + */ + + for (i = 0; i < lttngtop.kprobes_table->len; i++) { + kprobe = g_ptr_array_index(lttngtop.kprobes_table, i); + + memset(&ev, '\0', sizeof(struct lttng_event)); + ev.type = LTTNG_EVENT_PROBE; + sprintf(ev.attr.probe.symbol_name, "%s", kprobe->symbol_name); + sprintf(ev.name, "%s", kprobe->probe_name); + ev.attr.probe.addr = kprobe->probe_addr; + ev.attr.probe.offset = kprobe->probe_offset; + if ((ret = lttng_enable_event(handle, &ev, channel_name)) < 0) { + fprintf(stderr,"error enabling kprobes : %s\n", + helper_lttcomm_get_readable_code(ret)); + goto end; + } + } + +end: + return ret; +} + int setup_live_tracing() { struct lttng_domain dom; @@ -937,9 +1116,13 @@ int setup_live_tracing() strcpy(chan.name, channel_name); chan.attr.overwrite = 0; -// chan.attr.subbuf_size = 32768; - chan.attr.subbuf_size = 1048576; /* 1MB */ - chan.attr.num_subbuf = 4; + if (opt_tid && opt_textdump) { + chan.attr.subbuf_size = 32768; + chan.attr.num_subbuf = 8; + } else { + chan.attr.subbuf_size = 1048576; /* 1MB */ + chan.attr.num_subbuf = 4; + } chan.attr.switch_timer_interval = 0; chan.attr.read_timer_interval = 200; chan.attr.output = LTTNG_EVENT_MMAP; @@ -959,6 +1142,7 @@ int setup_live_tracing() goto error_session; } + memset(&ev, '\0', sizeof(struct lttng_event)); ev.type = LTTNG_EVENT_SYSCALL; if ((ret = lttng_enable_event(handle, &ev, channel_name)) < 0) { fprintf(stderr,"error enabling syscalls : %s\n", @@ -966,18 +1150,25 @@ int setup_live_tracing() goto error_session; } + ret = enable_kprobes(handle, channel_name); + if (ret < 0) { + goto error_session; + } + kctxpid.ctx = LTTNG_EVENT_CONTEXT_PID; lttng_add_context(handle, &kctxpid, NULL, NULL); + kctxtid.ctx = LTTNG_EVENT_CONTEXT_TID; + lttng_add_context(handle, &kctxtid, NULL, NULL); kctxppid.ctx = LTTNG_EVENT_CONTEXT_PPID; lttng_add_context(handle, &kctxppid, NULL, NULL); kctxcomm.ctx = LTTNG_EVENT_CONTEXT_PROCNAME; lttng_add_context(handle, &kctxcomm, NULL, NULL); - kctxtid.ctx = LTTNG_EVENT_CONTEXT_TID; - lttng_add_context(handle, &kctxtid, NULL, NULL); kctxpid.ctx = LTTNG_EVENT_CONTEXT_VPID; lttng_add_context(handle, &kctxpid, NULL, NULL); kctxtid.ctx = LTTNG_EVENT_CONTEXT_VTID; lttng_add_context(handle, &kctxtid, NULL, NULL); + kctxtid.ctx = LTTNG_EVENT_CONTEXT_HOSTNAME; + lttng_add_context(handle, &kctxtid, NULL, NULL); if ((ret = lttng_start_tracing("test")) < 0) { fprintf(stderr,"error starting tracing : %s\n", @@ -1015,11 +1206,15 @@ int main(int argc, char **argv) } if (!opt_input_path) { + if (opt_textdump) { + signal(SIGTERM, handle_textdump_sigterm); + signal(SIGINT, handle_textdump_sigterm); + } + init_lttngtop(); ret = setup_live_tracing(); if (ret < 0) { goto end; } - init_lttngtop(); if (!opt_textdump) { pthread_create(&display_thread, NULL, ncurses_display, (void *) NULL); pthread_create(&timer_thread, NULL, refresh_thread, (void *) NULL);