X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Fbin%2Flttng-consumerd%2Flttng-consumerd.c;h=e226ebc69e973eb34faa74d7a1be56ab7c3ab090;hb=1f3130d5f91951f84ccb985ca66c2c6cb6816984;hp=4a9a7a4929200bfd53c838eed13b48f52dd0ae50;hpb=748b7b07caecdc5f7ac4a73e008a7d0a84d422c4;p=lttng-tools.git diff --git a/src/bin/lttng-consumerd/lttng-consumerd.c b/src/bin/lttng-consumerd/lttng-consumerd.c index 4a9a7a492..e226ebc69 100644 --- a/src/bin/lttng-consumerd/lttng-consumerd.c +++ b/src/bin/lttng-consumerd/lttng-consumerd.c @@ -341,7 +341,10 @@ int main(int argc, char **argv) } /* Init */ - lttng_consumer_init(); + if (lttng_consumer_init() < 0) { + goto error; + } + /* Init socket timeouts */ lttcomm_init(); lttcomm_inet_init(); @@ -405,9 +408,6 @@ int main(int argc, char **argv) ctx->type = opt_type; - /* Initialize communication library */ - lttcomm_init(); - ret = utils_create_pipe(health_quit_pipe); if (ret < 0) { goto error_health_pipe; @@ -426,7 +426,7 @@ int main(int argc, char **argv) * sessiond thread reply to the sessiond that we are ready. */ while (uatomic_read(<tng_consumer_ready)) { - sleep(1); + usleep(100000); } cmm_smp_mb(); /* Read ready before following operations */