X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Flive.c;h=55f5c80355afb7535e36056352218bc66967ecaa;hb=9911d21b154b53ed659415e6baa56d5fb0863716;hp=756efbedef8434c7126148a7fbdb09e28c57e1e5;hpb=fd20dac985126e84929d657f5a1042222c7d5017;p=lttng-tools.git diff --git a/src/bin/lttng-relayd/live.c b/src/bin/lttng-relayd/live.c index 756efbede..55f5c8035 100644 --- a/src/bin/lttng-relayd/live.c +++ b/src/bin/lttng-relayd/live.c @@ -2102,7 +2102,10 @@ int relayd_live_create(struct lttng_uri *uri, cds_wfcq_init(&viewer_conn_queue.head, &viewer_conn_queue.tail); /* Set up max poll set size */ - lttng_poll_set_max_size(); + if (lttng_poll_set_max_size()) { + retval = -1; + goto exit_init_data; + } /* Setup the dispatcher thread */ ret = pthread_create(&live_dispatcher_thread, NULL, @@ -2139,13 +2142,11 @@ int relayd_live_create(struct lttng_uri *uri, */ return retval; + /* + * Join on the live_listener_thread should anything be added after + * the live_listener thread's creation. + */ - ret = pthread_join(live_listener_thread, &status); - if (ret) { - errno = ret; - PERROR("pthread_join live listener"); - retval = -1; - } exit_listener_thread: ret = pthread_join(live_worker_thread, &status);