From: Mathieu Bain Date: Fri, 23 Mar 2012 18:56:07 +0000 (-0400) Subject: Handle the file descriptor statedump X-Git-Tag: v0.2~48 X-Git-Url: https://git.lttng.org./?a=commitdiff_plain;h=59288610ca44efca4b68b954b7ffccd06fecd2b7;p=lttngtop.git Handle the file descriptor statedump Now the files opened for each process before the trace is recorded are associated with the corresponding processes, this removes a lot of unknown file descriptors. Signed-off-by: Mathieu Bain Signed-off-by: Julien Desfossez --- diff --git a/src/common.c b/src/common.c index 5887933..b18eafd 100644 --- a/src/common.c +++ b/src/common.c @@ -100,6 +100,12 @@ char *get_context_comm(const struct bt_ctf_event *event) return comm; } +/* + * To get the parent process, put the pid in the tid field + * because the parent process gets pid = tid + * + * FIXME : char *comm useful ??? + */ struct processtop *find_process_tid(struct lttngtop *ctx, int tid, char *comm) { gint i; @@ -132,6 +138,7 @@ struct processtop* add_proc(struct lttngtop *ctx, int tid, char *comm, newproc->fileread = 0; newproc->filewrite = 0; newproc->syscall_info = NULL; + newproc->threadparent = NULL; newproc->threads = g_ptr_array_new(); newproc->perf = g_hash_table_new(g_str_hash, g_str_equal); g_ptr_array_add(ctx->process_table, newproc); @@ -185,6 +192,16 @@ struct processtop* get_proc(struct lttngtop *ctx, int tid, char *comm, return add_proc(ctx, tid, comm, timestamp); } +struct processtop *get_proc_pid(struct lttngtop *ctx, int tid, int pid, + unsigned long timestamp) +{ + struct processtop *tmp; + tmp = find_process_tid(ctx, tid, NULL); + if (tmp && tmp->pid == pid) + return tmp; + return add_proc(ctx, tid, "Unknown", timestamp); +} + void add_thread(struct processtop *parent, struct processtop *thread) { gint i; @@ -258,7 +275,7 @@ void reset_perf_counter(gpointer key, gpointer value, gpointer user_data) void copy_perf_counter(gpointer key, gpointer value, gpointer new_table) { struct perfcounter *newperf; - + newperf = g_new0(struct perfcounter, 1); newperf->count = ((struct perfcounter *) value)->count; newperf->visible = ((struct perfcounter *) value)->visible; diff --git a/src/common.h b/src/common.h index a9befb0..21df7b1 100644 --- a/src/common.h +++ b/src/common.h @@ -41,6 +41,10 @@ struct processtop* update_proc(struct processtop* proc, int pid, int tid, void add_thread(struct processtop *parent, struct processtop *thread); struct processtop* get_proc(struct lttngtop *ctx, int tid, char *comm, unsigned long timestamp); + +struct processtop *get_proc_pid(struct lttngtop *ctx, int tid, int pid, + unsigned long timestamp); + void death_proc(struct lttngtop *ctx, int tid, char *comm, unsigned long timestamp); struct cputime* add_cpu(int cpu); diff --git a/src/iostreamtop.c b/src/iostreamtop.c index 35a58a4..62b926e 100644 --- a/src/iostreamtop.c +++ b/src/iostreamtop.c @@ -29,10 +29,13 @@ void add_file(struct processtop *proc, struct files *file, int fd) { struct files *tmp_file; + struct processtop *parent; int size; size = proc->process_files_table->len; - + parent = proc->threadparent; + if (parent) + insert_file(parent, fd); if (size <= fd) { g_ptr_array_set_size(proc->process_files_table, fd); g_ptr_array_add(proc->process_files_table, file); @@ -44,7 +47,7 @@ void add_file(struct processtop *proc, struct files *file, int fd) if (strcmp(tmp_file->name, file->name) != 0) { size = proc->process_files_table->len; g_ptr_array_set_size(proc->process_files_table, - size+1); + size+1); g_ptr_array_index(proc->process_files_table, size) = tmp_file; g_ptr_array_index(proc->process_files_table, @@ -53,38 +56,53 @@ void add_file(struct processtop *proc, struct files *file, int fd) tmp_file->flag = __NR_open; } } - file->fd = fd; - file->flag = __NR_open; - lttngtop.nbfiles++; - lttngtop.nbnewfiles++; + /* + * The file may have be created in the parent + */ + if (file->flag == -1) { + file->fd = fd; + file->flag = __NR_open; + lttngtop.nbfiles++; + lttngtop.nbnewfiles++; + } } -/* TODO */ -/* To be done */ +/* + * Edit the file + * Called by handled_statedump_filename + */ void edit_file(struct processtop *proc, struct files *file, int fd) { int size = proc->process_files_table->len; struct files *tmpfile; - if (size <= fd) - return; - else { + if (fd >= size) { + add_file(proc, file, fd); + } else { tmpfile = g_ptr_array_index(proc->process_files_table, fd); - tmpfile->name = strdup(file->name); - free(file); + if (tmpfile) { + tmpfile->name = strdup(file->name); + free(file); + } else + add_file(proc, file, fd); } } void insert_file(struct processtop *proc, int fd) { struct files *tmp; + struct files *tmp_parent; + struct processtop *parent; + if (fd < 0) + return; if (fd >= proc->process_files_table->len) { tmp = g_new0(struct files, 1); tmp->name = "Unknown"; tmp->read = 0; tmp->write = 0; tmp->fd = fd; + tmp->flag = -1; add_file(proc, tmp, fd); } else { tmp = g_ptr_array_index(proc->process_files_table, fd); @@ -94,7 +112,17 @@ void insert_file(struct processtop *proc, int fd) tmp->read = 0; tmp->write = 0; tmp->fd = fd; + tmp->flag = -1; add_file(proc, tmp, fd); + } else { + parent = proc->threadparent; + if (parent) { + tmp_parent = g_ptr_array_index( + parent->process_files_table, fd); + if (tmp_parent && + (strcmp(tmp->name, tmp_parent->name)) != 0) + tmp->name = strdup(tmp_parent->name); + } } } } @@ -216,6 +244,7 @@ struct file_history *create_file(struct file_history *history, char *file_name) new_file->name = strdup(file_name); new_file->read = 0; new_file->write = 0; + new_file->flag = -1; new_history->file = new_file; new_history->next = history; @@ -271,18 +300,18 @@ enum bt_cb_ret handle_sys_write(struct bt_ctf_event *call_data, struct processtop *tmp; unsigned long timestamp; uint64_t cpu_id; - char *comm; - int64_t tid; + int64_t tid, pid; int fd; timestamp = bt_ctf_get_timestamp(call_data); if (timestamp == -1ULL) goto error; - comm = get_context_comm(call_data); tid = get_context_tid(call_data); cpu_id = get_cpu_id(call_data); + pid = get_context_pid(call_data); + scope = bt_ctf_get_top_level_scope(call_data, BT_EVENT_FIELDS); fd = bt_ctf_get_uint64(bt_ctf_get_field(call_data, @@ -292,7 +321,7 @@ enum bt_cb_ret handle_sys_write(struct bt_ctf_event *call_data, goto error; } - tmp = get_proc(<tngtop, tid, comm, timestamp); + tmp = get_proc_pid(<tngtop, tid, pid, timestamp); tmp->syscall_info = create_syscall_info(__NR_write, cpu_id, tid, fd); insert_file(tmp, fd); @@ -310,18 +339,18 @@ enum bt_cb_ret handle_sys_read(struct bt_ctf_event *call_data, const struct definition *scope; unsigned long timestamp; uint64_t cpu_id; - char *comm; - int64_t tid; + int64_t tid, pid; int fd; timestamp = bt_ctf_get_timestamp(call_data); if (timestamp == -1ULL) goto error; - comm = get_context_comm(call_data); tid = get_context_tid(call_data); cpu_id = get_cpu_id(call_data); + pid = get_context_pid(call_data); + scope = bt_ctf_get_top_level_scope(call_data, BT_EVENT_FIELDS); fd = bt_ctf_get_uint64(bt_ctf_get_field(call_data, @@ -331,7 +360,7 @@ enum bt_cb_ret handle_sys_read(struct bt_ctf_event *call_data, goto error; } - tmp = get_proc(<tngtop, tid, comm, timestamp); + tmp = get_proc_pid(<tngtop, tid, pid, timestamp); tmp->syscall_info = create_syscall_info(__NR_read, cpu_id, tid, fd); insert_file(tmp, fd); @@ -351,18 +380,18 @@ enum bt_cb_ret handle_sys_open(struct bt_ctf_event *call_data, const struct definition *scope; unsigned long timestamp; uint64_t cpu_id; - char *comm; - int64_t tid; + int64_t tid, pid; char *file; timestamp = bt_ctf_get_timestamp(call_data); if (timestamp == -1ULL) goto error; - comm = get_context_comm(call_data); tid = get_context_tid(call_data); cpu_id = get_cpu_id(call_data); + pid = get_context_pid(call_data); + scope = bt_ctf_get_top_level_scope(call_data, BT_EVENT_FIELDS); file = bt_ctf_get_string(bt_ctf_get_field(call_data, @@ -372,7 +401,7 @@ enum bt_cb_ret handle_sys_open(struct bt_ctf_event *call_data, goto error; } - tmp = get_proc(<tngtop, tid, comm, timestamp); + tmp = get_proc_pid(<tngtop, tid, pid, timestamp); tmp->syscall_info = create_syscall_info(__NR_open, cpu_id, tid, -1); tmp->files_history = create_file(tmp->files_history, file); @@ -389,18 +418,18 @@ enum bt_cb_ret handle_sys_close(struct bt_ctf_event *call_data, { const struct definition *scope; unsigned long timestamp; - int64_t tid; + int64_t tid, pid; struct processtop *tmp; - char *comm; int fd; timestamp = bt_ctf_get_timestamp(call_data); if (timestamp == -1ULL) goto error; - comm = get_context_comm(call_data); tid = get_context_tid(call_data); + pid = get_context_pid(call_data); + scope = bt_ctf_get_top_level_scope(call_data, BT_EVENT_FIELDS); fd = bt_ctf_get_uint64(bt_ctf_get_field(call_data, @@ -410,7 +439,7 @@ enum bt_cb_ret handle_sys_close(struct bt_ctf_event *call_data, goto error; } - tmp = get_proc(<tngtop, tid, comm, timestamp); + tmp = get_proc_pid(<tngtop, tid, pid, timestamp); close_file(tmp, fd); @@ -419,28 +448,26 @@ enum bt_cb_ret handle_sys_close(struct bt_ctf_event *call_data, error: return BT_CB_ERROR_STOP; } -/* + enum bt_cb_ret handle_statedump_file_descriptor(struct bt_ctf_event *call_data, void *private_data) { - struct definition *scope; + const struct definition *scope; + struct processtop *parent; struct files *file; unsigned long timestamp; - int64_t tid; - struct processtop *tmp; - char *comm, *file_name; + int64_t pid; + char *file_name; int fd; timestamp = bt_ctf_get_timestamp(call_data); if (timestamp == -1ULL) goto error; - comm = get_context_comm(call_data); - scope = bt_ctf_get_top_level_scope(call_data, BT_EVENT_FIELDS); - tid = bt_ctf_get_uint64(bt_ctf_get_field(call_data, - scope, "_tid")); + pid = bt_ctf_get_int64(bt_ctf_get_field(call_data, + scope, "_pid")); if (bt_ctf_field_get_error()) { fprintf(stderr, "Missing tid context info\n"); goto error; @@ -448,7 +475,7 @@ enum bt_cb_ret handle_statedump_file_descriptor(struct bt_ctf_event *call_data, scope = bt_ctf_get_top_level_scope(call_data, BT_EVENT_FIELDS); - fd = bt_ctf_get_uint64(bt_ctf_get_field(call_data, + fd = bt_ctf_get_int64(bt_ctf_get_field(call_data, scope, "_fd")); if (bt_ctf_field_get_error()) { fprintf(stderr, "Missing fd context info\n"); @@ -464,17 +491,13 @@ enum bt_cb_ret handle_statedump_file_descriptor(struct bt_ctf_event *call_data, goto error; } - file = g_new0(struct files, 1); - file->name = strdup(file_name); - file->fd = fd; - tmp = find_process_tid(<tngtop, tid, comm); - edit_file(tmp, file, fd); - - fprintf(stderr, "%lu %s\n", tmp->tid, file_name); + parent = get_proc_pid(<tngtop, pid, pid, timestamp); + parent->files_history = create_file(parent->files_history, file_name); + file = parent->files_history->file; + edit_file(parent, file, fd); return BT_CB_OK; error: return BT_CB_ERROR_STOP; } -*/ diff --git a/src/iostreamtop.h b/src/iostreamtop.h index 2c80d49..fe2e5db 100644 --- a/src/iostreamtop.h +++ b/src/iostreamtop.h @@ -26,6 +26,7 @@ struct files *get_file(struct processtop *proc, int fd); void show_table(GPtrArray *tab); +void insert_file(struct processtop *proc, int fd); enum bt_cb_ret handle_exit_syscall(struct bt_ctf_event *call_data, void *private_data); diff --git a/src/lttngtop.c b/src/lttngtop.c index dfa1d14..dc5711e 100644 --- a/src/lttngtop.c +++ b/src/lttngtop.c @@ -429,13 +429,12 @@ void iter_trace(struct bt_context *bt_ctx) 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( "lttng_statedump_file_descriptor"), NULL, 0, handle_statedump_file_descriptor, NULL, NULL, NULL); -*/ + while ((event = bt_ctf_iter_read_event(iter)) != NULL) { ret = bt_iter_next(bt_ctf_get_iter(iter)); if (ret < 0)