X-Git-Url: http://git.efficios.com/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer.c;h=a26a41554d2e379c2e97ad4cca20929627571468;hp=94a0cc3efb1d557da732ed9a201848b0ee4dc3e4;hb=04ef1097c8f54a151c899c1773ac56907c97694d;hpb=feb78e88e113ec8c6918253e93136b5f6235ad31

diff --git a/src/common/consumer.c b/src/common/consumer.c
index 94a0cc3ef..a26a41554 100644
--- a/src/common/consumer.c
+++ b/src/common/consumer.c
@@ -1880,6 +1880,13 @@ void consumer_del_metadata_stream(struct lttng_consumer_stream *stream,
 		break;
 	case LTTNG_CONSUMER32_UST:
 	case LTTNG_CONSUMER64_UST:
+		if (stream->monitor) {
+			/* close the write-side in close_metadata */
+			ret = close(stream->ust_metadata_poll_pipe[0]);
+			if (ret < 0) {
+				PERROR("Close UST metadata read-side poll pipe");
+			}
+		}
 		lttng_ustconsumer_del_stream(stream);
 		break;
 	default:
@@ -2252,14 +2259,21 @@ restart:
 				DBG("Metadata available on fd %d", pollfd);
 				assert(stream->wait_fd == pollfd);
 
-				len = ctx->on_buffer_ready(stream, ctx);
+				do {
+					len = ctx->on_buffer_ready(stream, ctx);
+					/*
+					 * We don't check the return value here since if we get
+					 * a negative len, it means an error occured thus we
+					 * simply remove it from the poll set and free the
+					 * stream.
+					 */
+				} while (len > 0);
+
 				/* It's ok to have an unavailable sub-buffer */
 				if (len < 0 && len != -EAGAIN && len != -ENODATA) {
 					/* Clean up stream from consumer and free it. */
 					lttng_poll_del(&events, stream->wait_fd);
 					consumer_del_metadata_stream(stream, metadata_ht);
-				} else if (len > 0) {
-					stream->data_read = 1;
 				}
 			}