X-Git-Url: https://git.lttng.org/?p=lttngtop.git;a=blobdiff_plain;f=src%2Flttngtop.c;h=8cec6d52c1ffeb0765cc56eb93f914c374493d47;hp=1378d6674294f6cb994ed7094ac78a2a4ace24e0;hb=3bcf0f6b3dc99e6328bc3191cb43f386cca5a44b;hpb=a18dc7c24b4ac751c46a96198aebcbb1dcd4cdd6 diff --git a/src/lttngtop.c b/src/lttngtop.c index 1378d66..8cec6d5 100644 --- a/src/lttngtop.c +++ b/src/lttngtop.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2011-2012 Julien Desfossez + * Copyright (C) 2013 Julien Desfossez * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License Version 2 as @@ -39,20 +39,27 @@ #include #include #include +#ifdef LTTNGTOP_MMAP_LIVE #include #include +#include "mmap-live.h" +#endif /* LTTNGTOP_MMAP_LIVE */ #include "lttngtoptypes.h" #include "cputop.h" #include "iostreamtop.h" #include "cursesdisplay.h" #include "common.h" +#include "network-live.h" + +#include "lttng-index.h" #define DEFAULT_FILE_ARRAY_SIZE 1 const char *opt_input_path; static int opt_textdump; static int opt_child; +static int opt_begin; int quit = 0; @@ -62,9 +69,10 @@ pthread_t timer_thread; unsigned long refresh_display = 1 * NSEC_PER_SEC; unsigned long last_display_update = 0; +unsigned long last_event_ts = 0; /* list of FDs available for being read with snapshots */ -struct mmap_stream_list mmap_list; +struct bt_mmap_stream_list mmap_list; GPtrArray *lttng_consumer_stream_array; int sessiond_metadata, consumerd_metadata; struct lttng_consumer_local_data *ctx = NULL; @@ -82,7 +90,9 @@ enum { OPT_PID, OPT_CHILD, OPT_HOSTNAME, + OPT_RELAY_HOSTNAME, OPT_KPROBES, + OPT_BEGIN, }; static struct poptOption long_options[] = { @@ -90,22 +100,25 @@ 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 }, + { "begin", 'b', POPT_ARG_NONE, NULL, OPT_BEGIN, NULL, NULL }, { "pid", 'p', POPT_ARG_STRING, &opt_tid, OPT_PID, NULL, NULL }, { "hostname", 'n', POPT_ARG_STRING, &opt_hostname, OPT_HOSTNAME, NULL, NULL }, + { "relay-hostname", 'r', POPT_ARG_STRING, &opt_relay_hostname, + OPT_RELAY_HOSTNAME, NULL, NULL }, { "kprobes", 'k', POPT_ARG_STRING, &opt_kprobes, OPT_KPROBES, NULL, NULL }, { NULL, 0, 0, NULL, 0, NULL, NULL }, }; +#ifdef LTTNGTOP_MMAP_LIVE static void handle_textdump_sigterm(int signal) { quit = 1; lttng_destroy_session("test"); } +#endif void *refresh_thread(void *p) { - struct mmap_stream *mmap_info; - while (1) { if (quit) { sem_post(&pause_sem); @@ -116,8 +129,9 @@ 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); +#ifdef LTTNGTOP_MMAP_LIVE + mmap_live_flush(mmap_list); +#endif } sem_wait(&pause_sem); sem_post(&pause_sem); @@ -161,9 +175,9 @@ void *ncurses_display(void *p) void print_fields(struct bt_ctf_event *event) { unsigned int cnt, i; - const struct definition *const * list; - const struct declaration *l; - const struct definition *scope; + const struct bt_definition *const * list; + const struct bt_declaration *l; + const struct bt_definition *scope; enum ctf_type_id type; const char *str; @@ -202,11 +216,17 @@ enum bt_cb_ret print_timestamp(struct bt_ctf_event *call_data, void *private_dat uint64_t ts_nsec_start; int pid, cpu_id; int64_t syscall_ret; - const struct definition *scope; + const struct bt_definition *scope; const char *hostname, *procname; timestamp = bt_ctf_get_timestamp(call_data); + /* can happen in network live when tracing is idle */ + if (timestamp < last_event_ts) + goto end_stop; + + last_event_ts = timestamp; + start = format_timestamp(timestamp); ts_nsec_start = timestamp % NSEC_PER_SEC; @@ -254,6 +274,8 @@ end: return BT_CB_OK; error: return BT_CB_ERROR_STOP; +end_stop: + return BT_CB_OK_STOP; } enum bt_cb_ret handle_kprobes(struct bt_ctf_event *call_data, void *private_data) @@ -284,6 +306,12 @@ enum bt_cb_ret check_timestamp(struct bt_ctf_event *call_data, void *private_dat if (timestamp == -1ULL) goto error; + /* can happen in network live when tracing is idle */ + if (timestamp < last_event_ts) + goto end_stop; + + last_event_ts = timestamp; + if (last_display_update == 0) last_display_update = timestamp; @@ -300,6 +328,9 @@ enum bt_cb_ret check_timestamp(struct bt_ctf_event *call_data, void *private_dat error: fprintf(stderr, "check_timestamp callback error\n"); return BT_CB_ERROR_STOP; + +end_stop: + return BT_CB_OK_STOP; } /* @@ -548,8 +579,8 @@ static struct kprobes *parse_probe_opts(char *opt) /* 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); + ret = asprintf(&kprobe->probe_name, "probe_%s", name); + ret = asprintf(&kprobe->symbol_name, "%s", name); if (strlen(s_hex) == 0) { fprintf(stderr, "Invalid probe offset %s", s_hex); @@ -565,8 +596,8 @@ static struct kprobes *parse_probe_opts(char *opt) 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); + ret = asprintf(&kprobe->probe_name, "probe_%s", name); + ret = asprintf(&kprobe->symbol_name, "%s", name); kprobe->probe_offset = 0; kprobe->probe_addr = 0; goto end; @@ -581,7 +612,7 @@ static struct kprobes *parse_probe_opts(char *opt) ret = -1; goto end; } - asprintf(&kprobe->probe_name, "probe_%s", s_hex); + ret = asprintf(&kprobe->probe_name, "probe_%s", s_hex); kprobe->probe_offset = 0; kprobe->probe_addr = strtoul(s_hex, NULL, 0); goto end; @@ -605,6 +636,8 @@ static int parse_options(int argc, char **argv) char *tmp_str; int *tid; + remote_live = 0; + pc = poptGetContext(NULL, argc, (const char **) argv, long_options, 0); poptReadDefaultConfig(pc, 0); @@ -634,6 +667,10 @@ static int parse_options(int argc, char **argv) tmp_str = strtok(NULL, ","); } break; + case OPT_BEGIN: + /* start reading the live trace from the beginning */ + opt_begin = 1; + break; case OPT_HOSTNAME: toggle_filter = 1; tmp_str = strtok(opt_hostname, ","); @@ -642,6 +679,9 @@ static int parse_options(int argc, char **argv) tmp_str = strtok(NULL, ","); } break; + case OPT_RELAY_HOSTNAME: + remote_live = 1; + break; case OPT_KPROBES: lttngtop.kprobes_table = g_ptr_array_new(); tmp_str = strtok(opt_kprobes, ","); @@ -821,7 +861,6 @@ int bt_context_add_traces_recursive(struct bt_context *ctx, const char *path, metafd = openat(dirfd, "metadata", O_RDONLY); if (metafd < 0) { close(dirfd); - ret = -1; continue; } else { int trace_id; @@ -920,7 +959,11 @@ int check_requirements(struct bt_context *ctx) int ppid_check = 0; int ret = 0; - bt_ctf_get_event_decl_list(0, ctx, &evt_list, &evt_cnt); + ret = bt_ctf_get_event_decl_list(0, ctx, &evt_list, &evt_cnt); + if (ret < 0) { + goto end; + } + for (i = 0; i < evt_cnt; i++) { bt_ctf_get_decl_fields(evt_list[i], BT_STREAM_EVENT_CONTEXT, &field_list, &field_cnt); @@ -958,372 +1001,14 @@ int check_requirements(struct bt_context *ctx) fprintf(stderr, "[error] missing procname context information\n"); } - return ret; -} - -ssize_t read_subbuffer(struct lttng_consumer_stream *kconsumerd_fd, - struct lttng_consumer_local_data *ctx) -{ - unsigned long len; - int err; - long ret = 0; - int infd = helper_get_lttng_consumer_stream_wait_fd(kconsumerd_fd); - - if (helper_get_lttng_consumer_stream_output(kconsumerd_fd) == LTTNG_EVENT_SPLICE) { - /* Get the next subbuffer */ - err = helper_kernctl_get_next_subbuf(infd); - if (err != 0) { - ret = errno; - perror("Reserving sub buffer failed (everything is normal, " - "it is due to concurrency)"); - goto end; - } - /* read the whole subbuffer */ - err = helper_kernctl_get_padded_subbuf_size(infd, &len); - if (err != 0) { - ret = errno; - perror("Getting sub-buffer len failed."); - goto end; - } - - /* splice the subbuffer to the tracefile */ - ret = helper_lttng_consumer_on_read_subbuffer_splice(ctx, kconsumerd_fd, len, 0); - if (ret < 0) { - /* - * display the error but continue processing to try - * to release the subbuffer - */ - fprintf(stderr,"Error splicing to tracefile\n"); - } - err = helper_kernctl_put_next_subbuf(infd); - if (err != 0) { - ret = errno; - perror("Reserving sub buffer failed (everything is normal, " - "it is due to concurrency)"); - goto end; - } - sem_post(&metadata_available); - } - -end: - return 0; -} - -int on_update_fd(int key, uint32_t state) -{ - /* let the lib handle the metadata FD */ - if (key == sessiond_metadata) - return 0; - return 1; -} - -int on_recv_fd(struct lttng_consumer_stream *kconsumerd_fd) -{ - int ret; - struct mmap_stream *new_mmap_stream; - - /* Opening the tracefile in write mode */ - if (helper_get_lttng_consumer_stream_path_name(kconsumerd_fd) != NULL) { - ret = open(helper_get_lttng_consumer_stream_path_name(kconsumerd_fd), - O_WRONLY|O_CREAT|O_TRUNC, S_IRWXU|S_IRWXG|S_IRWXO); - if (ret < 0) { - perror("open"); - goto end; - } - helper_set_lttng_consumer_stream_out_fd(kconsumerd_fd, ret); - } - - if (helper_get_lttng_consumer_stream_output(kconsumerd_fd) == LTTNG_EVENT_MMAP) { - new_mmap_stream = malloc(sizeof(struct mmap_stream)); - new_mmap_stream->fd = helper_get_lttng_consumer_stream_wait_fd( - kconsumerd_fd); - bt_list_add(&new_mmap_stream->list, &mmap_list.head); - - g_ptr_array_add(lttng_consumer_stream_array, kconsumerd_fd); - /* keep mmap FDs internally */ - ret = 1; - } else { - consumerd_metadata = helper_get_lttng_consumer_stream_wait_fd(kconsumerd_fd); - sessiond_metadata = helper_get_lttng_consumer_stream_key(kconsumerd_fd); - ret = 0; - } - - reload_trace = 1; - -end: - return ret; -} - -void live_consume(struct bt_context **bt_ctx) -{ - int ret; - FILE *metadata_fp; - - sem_wait(&metadata_available); - if (access("/tmp/livesession/kernel/metadata", F_OK) != 0) { - fprintf(stderr,"no metadata\n"); - goto end; - } - metadata_fp = fopen("/tmp/livesession/kernel/metadata", "r"); - - *bt_ctx = bt_context_create(); - ret = bt_context_add_trace(*bt_ctx, NULL, "ctf", - lttngtop_ctf_packet_seek, &mmap_list, metadata_fp); - if (ret < 0) { - printf("Error adding trace\n"); - goto end; - } - -end: - return; -} - -int setup_consumer(char *command_sock_path, pthread_t *threads, - struct lttng_consumer_local_data *ctx) -{ - int ret = 0; - - ctx = helper_lttng_consumer_create(HELPER_LTTNG_CONSUMER_KERNEL, - read_subbuffer, NULL, on_recv_fd, on_update_fd); - if (!ctx) - goto end; - - unlink(command_sock_path); - helper_lttng_consumer_set_command_sock_path(ctx, command_sock_path); - helper_lttng_consumer_init(); - - /* Create the thread to manage the receive of fd */ - ret = pthread_create(&threads[0], NULL, helper_lttng_consumer_thread_sessiond_poll, - (void *) ctx); - if (ret != 0) { - perror("pthread_create receive fd"); - goto end; - } - /* Create thread to manage the polling/writing of traces */ - ret = pthread_create(&threads[1], NULL, helper_lttng_consumer_thread_metadata_poll, - (void *) ctx); - if (ret != 0) { - perror("pthread_create poll fd"); - goto end; - } - 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; - - 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; - if (kprobe->symbol_name) - 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; - struct lttng_channel chan; - char *channel_name = "mmapchan"; - struct lttng_event ev; - int ret = 0; - char *command_sock_path = "/tmp/consumerd_sock"; - static pthread_t threads[2]; /* recv_fd, poll */ - struct lttng_event_context kctxpid, kctxcomm, kctxppid, kctxtid, - kctxperf1, kctxperf2; - - struct lttng_handle *handle; - - BT_INIT_LIST_HEAD(&mmap_list.head); - - lttng_consumer_stream_array = g_ptr_array_new(); - - if ((ret = setup_consumer(command_sock_path, threads, ctx)) < 0) { - fprintf(stderr,"error setting up consumer\n"); - goto error; - } - - available_snapshots = g_ptr_array_new(); - - /* setup the session */ - dom.type = LTTNG_DOMAIN_KERNEL; - - ret = unlink("/tmp/livesession"); - - lttng_destroy_session("test"); - if ((ret = lttng_create_session("test", "/tmp/livesession")) < 0) { - fprintf(stderr,"error creating the session : %s\n", - helper_lttcomm_get_readable_code(ret)); - goto error; - } - - if ((handle = lttng_create_handle("test", &dom)) == NULL) { - fprintf(stderr,"error creating handle\n"); - goto error_session; - } - - /* - * FIXME : need to let the - * helper_lttng_consumer_thread_receive_fds create the - * socket. - * Cleaner solution ? - */ - while (access(command_sock_path, F_OK)) { - sleep(0.1); - } - - if ((ret = lttng_register_consumer(handle, command_sock_path)) < 0) { - fprintf(stderr,"error registering consumer : %s\n", - helper_lttcomm_get_readable_code(ret)); - goto error_session; - } - - strcpy(chan.name, channel_name); - chan.attr.overwrite = 0; - if (opt_tid && opt_textdump) { - chan.attr.subbuf_size = 32768; - chan.attr.num_subbuf = 8; - } else { - //chan.attr.subbuf_size = 1048576; /* 1MB */ - chan.attr.subbuf_size = 2097152; /* 1MB */ - chan.attr.num_subbuf = 4; - } - chan.attr.switch_timer_interval = 0; - chan.attr.read_timer_interval = 200; - chan.attr.output = LTTNG_EVENT_MMAP; - - if ((ret = lttng_enable_channel(handle, &chan)) < 0) { - fprintf(stderr,"error creating channel : %s\n", - helper_lttcomm_get_readable_code(ret)); - goto error_session; - } - - memset(&ev, '\0', sizeof(struct lttng_event)); - ev.type = LTTNG_EVENT_TRACEPOINT; - sprintf(ev.name, "sched_switch"); - if ((ret = lttng_enable_event(handle, &ev, channel_name)) < 0) { - fprintf(stderr,"error enabling event %s : %s\n", - ev.name, - helper_lttcomm_get_readable_code(ret)); - goto error_session; - } - sprintf(ev.name, "sched_process_free"); - if ((ret = lttng_enable_event(handle, &ev, channel_name)) < 0) { - fprintf(stderr,"error enabling event %s : %s\n", - ev.name, - helper_lttcomm_get_readable_code(ret)); - goto error_session; - } - sprintf(ev.name, "lttng_statedump_process_state"); - if ((ret = lttng_enable_event(handle, &ev, channel_name)) < 0) { - fprintf(stderr,"error enabling event %s : %s\n", - ev.name, - helper_lttcomm_get_readable_code(ret)); - goto error_session; - } - sprintf(ev.name, "lttng_statedump_file_descriptor"); - if ((ret = lttng_enable_event(handle, &ev, channel_name)) < 0) { - fprintf(stderr,"error enabling event %s : %s\n", - ev.name, - helper_lttcomm_get_readable_code(ret)); - 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", - helper_lttcomm_get_readable_code(ret)); - goto error_session; - } - - if (lttngtop.kprobes_table) { - ret = enable_kprobes(handle, channel_name); - if (ret < 0) { - goto error_session; - } - } - - kctxperf1.ctx = LTTNG_EVENT_CONTEXT_PERF_COUNTER; - kctxperf1.u.perf_counter.type = 0; /* PERF_TYPE_HARDWARE */ - kctxperf1.u.perf_counter.config = 5; /* PERF_COUNT_HW_BRANCH_MISSES */ - sprintf(kctxperf1.u.perf_counter.name, "perf_branch_misses"); - ret = lttng_add_context(handle, &kctxperf1, NULL, NULL); - if (ret < 0) { - fprintf(stderr, "error enabling context %s\n", - kctxtid.u.perf_counter.name); - } - - kctxperf2.ctx = LTTNG_EVENT_CONTEXT_PERF_COUNTER; - kctxperf2.u.perf_counter.type = 1; /* PERF_TYPE_SOFTWARE */ - kctxperf2.u.perf_counter.config = 6; /* PERF_COUNT_SW_PAGE_FAULTS_MAJ */ - sprintf(kctxperf2.u.perf_counter.name, "perf_major_faults"); - ret = lttng_add_context(handle, &kctxperf2, NULL, NULL); - if (ret < 0) { - fprintf(stderr, "error enabling context %s\n", - kctxtid.u.perf_counter.name); - } - - 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); - 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", - helper_lttcomm_get_readable_code(ret)); - goto error_session; - } - - helper_kernctl_buffer_flush(consumerd_metadata); - - /* block until metadata is ready */ - sem_init(&metadata_available, 0, 0); - - return 0; - -error_session: - lttng_destroy_session("test"); -error: - return -1; -} - int main(int argc, char **argv) { int ret; struct bt_context *bt_ctx = NULL; - struct mmap_stream *mmap_info; - unsigned long mmap_len; init_lttngtop(); ret = parse_options(argc, argv); @@ -1335,56 +1020,14 @@ int main(int argc, char **argv) exit(EXIT_SUCCESS); } - if (!opt_input_path) { + if (!opt_input_path && !remote_live) { + /* mmap live */ +#ifdef LTTNGTOP_MMAP_LIVE if (opt_textdump) { signal(SIGTERM, handle_textdump_sigterm); signal(SIGINT, handle_textdump_sigterm); } - 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); - ret = check_requirements(bt_ctx); - if (ret < 0) { - fprintf(stderr, "[error] some mandatory contexts were missing, exiting.\n"); - goto end; - } - iter_trace(bt_ctx); - /* - * FIXME : pb with cleanup in libbabeltrace - ret = bt_context_remove_trace(bt_ctx, 0); - if (ret != 0) { - fprintf(stderr, "error removing trace\n"); - goto error; - } - */ - 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); - } - + mmap_live_loop(bt_ctx); pthread_join(timer_thread, NULL); quit = 1; pthread_join(display_thread, NULL); @@ -1393,6 +1036,21 @@ int main(int argc, char **argv) lttng_destroy_session("test"); goto end; +#else + fprintf(stderr, "Mmap live support not compiled\n"); + goto end; +#endif /* LTTNGTOP_MMAP_LIVE */ + } else if (!opt_input_path && remote_live) { + /* network live */ + ret = setup_network_live(opt_relay_hostname, opt_begin); + if (ret < 0) { + goto end; + } + + ret = open_trace(&bt_ctx); + if (ret < 0) { + goto end; + } } else { //init_lttngtop(); @@ -1402,28 +1060,27 @@ int main(int argc, char **argv) fprintf(stderr, "[error] Opening the trace\n"); goto end; } + } - ret = check_requirements(bt_ctx); - if (ret < 0) { - fprintf(stderr, "[error] some mandatory contexts were missing, exiting.\n"); - goto end; - } + ret = check_requirements(bt_ctx); + if (ret < 0) { + fprintf(stderr, "[error] some mandatory contexts were missing, exiting.\n"); + goto end; + } + if (!opt_textdump) { pthread_create(&display_thread, NULL, ncurses_display, (void *) NULL); pthread_create(&timer_thread, NULL, refresh_thread, (void *) NULL); + } - iter_trace(bt_ctx); + iter_trace(bt_ctx); - pthread_join(display_thread, NULL); - quit = 1; - pthread_join(timer_thread, NULL); - } + pthread_join(display_thread, NULL); + quit = 1; + pthread_join(timer_thread, NULL); end: if (bt_ctx) bt_context_put(bt_ctx); return 0; - -error: - return -1; }