X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fcommon%2Fconsumer.c;h=45eede109bb5cdc5b019e480ea1ed0bae8f1f8b3;hb=12d1308838f30af13dc917323a4bcc70b5d97e81;hp=feec3562d64fcf46df09e834870377637fda75dc;hpb=f623cc0b347c449f302ac674937b1c0c647495ce;p=lttng-tools.git diff --git a/src/common/consumer.c b/src/common/consumer.c index feec3562d..45eede109 100644 --- a/src/common/consumer.c +++ b/src/common/consumer.c @@ -2873,12 +2873,6 @@ void *consumer_thread_sessiond_poll(void *data) goto end; } - ret = fcntl(client_socket, F_SETFL, O_NONBLOCK); - if (ret < 0) { - PERROR("fcntl O_NONBLOCK"); - goto end; - } - /* prepare the FDs to poll : to client socket and the should_quit pipe */ consumer_sockpoll[0].fd = ctx->consumer_should_quit[0]; consumer_sockpoll[0].events = POLLIN | POLLPRI; @@ -2896,11 +2890,6 @@ void *consumer_thread_sessiond_poll(void *data) WARN("On accept"); goto end; } - ret = fcntl(sock, F_SETFL, O_NONBLOCK); - if (ret < 0) { - PERROR("fcntl O_NONBLOCK"); - goto end; - } /* * Setup metadata socket which is the second socket connection on the