X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer.c;h=1af69ef93015c7e397c8028781dc3c97895c1790;hb=23f5f35da2bfb8e5162419bf84627714f920da2c;hp=c74d1f7ae3cbded46415430ca20054c8686de416;hpb=6191db77fd286967df592b572f4e232d586c7e1f;p=lttng-tools.git

diff --git a/src/common/consumer.c b/src/common/consumer.c
index c74d1f7ae..1af69ef93 100644
--- a/src/common/consumer.c
+++ b/src/common/consumer.c
@@ -2364,6 +2364,11 @@ void *consumer_thread_data_poll(void *data)
 				pipe_readlen = read(ctx->consumer_data_pipe[0], &new_stream,
 						sizeof(new_stream));
 			} while (pipe_readlen == -1 && errno == EINTR);
+			if (pipe_readlen < 0) {
+				PERROR("read consumer data pipe");
+				/* Continue so we can at least handle the current stream(s). */
+				continue;
+			}
 
 			/*
 			 * If the stream is NULL, just ignore it. It's also possible that