X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=kconsumerd%2Fkconsumerd.c;h=96051caafdfeba7dd09b4029c16404d28769cf08;hp=315095ee3c102794817176262d096e1b21089b96;hb=7e8c38c672e816ea3b0d9a7accdcae4d6e01c668;hpb=9cb983500508a95363a09a5a65d2f67774c38b69 diff --git a/kconsumerd/kconsumerd.c b/kconsumerd/kconsumerd.c index 315095ee3..96051caaf 100644 --- a/kconsumerd/kconsumerd.c +++ b/kconsumerd/kconsumerd.c @@ -511,13 +511,13 @@ static void *thread_receive_fds(void *data) goto error; } + /* Blocking call, waiting for transmission */ + sock = lttcomm_accept_unix_sock(client_socket); + if (sock <= 0) { + WARN("On accept, retrying"); + goto error; + } while (1) { - /* Blocking call, waiting for transmission */ - sock = lttcomm_accept_unix_sock(client_socket); - if (sock <= 0) { - WARN("On accept, retrying"); - continue; - } /* We first get the number of fd we are about to receive */ ret = lttcomm_recv_unix_sock(sock, &tmp,