Fix consumer lttng_consumer_poll_socket poll revents check bug
authorMathieu Desnoyers <mathieu.desnoyers@efficios.com>
Wed, 11 Apr 2012 22:06:08 +0000 (18:06 -0400)
committerDavid Goulet <dgoulet@efficios.com>
Mon, 16 Apr 2012 15:27:16 +0000 (11:27 -0400)
Was causing the sessiond to fail to receive streams under heavy load,
because this test needs to be done with a mask rather than equality.
Testing equality was failing as soon as POLLPRI (or any other flag) was
set.

Signed-off-by: Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
src/common/consumer.c

index f81de8d556a66149c75e59193c50a7d2c96741bd..74a9b0ad2095216f8d11b6836a91305dba795300 100644 (file)
@@ -562,7 +562,7 @@ restart:
                perror("Poll error");
                goto exit;
        }
-       if (consumer_sockpoll[0].revents == POLLIN) {
+       if (consumer_sockpoll[0].revents & POLLIN) {
                DBG("consumer_should_quit wake up");
                goto exit;
        }
This page took 0.026014 seconds and 4 git commands to generate.