X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=formats%2Flttng-live%2Flttng-live-comm.c;h=8e701b2100ebadf1c2136bc7323a1814c29b737b;hb=c111d5d7cd66a6a74c48ad0466609843bd6fe3c7;hp=785f5f37022609a702cddf3341e20b32611d0d1c;hpb=b7e8a8e17de9b9e5b717d8b664b8385a2562aee8;p=babeltrace.git

diff --git a/formats/lttng-live/lttng-live-comm.c b/formats/lttng-live/lttng-live-comm.c
index 785f5f37..8e701b21 100644
--- a/formats/lttng-live/lttng-live-comm.c
+++ b/formats/lttng-live/lttng-live-comm.c
@@ -869,7 +869,7 @@ int get_new_metadata(struct lttng_live_ctx *ctx,
 {
 	int ret = 0;
 	struct lttng_live_viewer_stream *metadata_stream;
-	size_t size;
+	size_t size, len_read = 0;;
 
 	metadata_stream = viewer_stream->ctf_trace->metadata_stream;
 	if (!metadata_stream) {
@@ -890,7 +890,10 @@ int get_new_metadata(struct lttng_live_ctx *ctx,
 		 * negative value on error.
 		 */
 		ret = get_one_metadata_packet(ctx, metadata_stream);
-	} while (ret > 0);
+		if (ret > 0) {
+			len_read += ret;
+		}
+	} while (ret > 0 || !len_read);
 
 	if (fclose(metadata_stream->metadata_fp_write))
 		perror("fclose");