X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=src%2Fplugins%2Fctf%2Flttng-live%2Fviewer-connection.c;fp=src%2Fplugins%2Fctf%2Flttng-live%2Fviewer-connection.c;h=9b3e24003ece58e26c961179d6bb28f4c36980f6;hp=f21dc21ca8e0216dcd526d16e5b8c88c05796613;hb=f84425c54b94cd14cd288c21475db7f4958fc6ae;hpb=1ea4d1b1b2f57a49931c6349cd9c1dcd67b88c27

diff --git a/src/plugins/ctf/lttng-live/viewer-connection.c b/src/plugins/ctf/lttng-live/viewer-connection.c
index f21dc21c..9b3e2400 100644
--- a/src/plugins/ctf/lttng-live/viewer-connection.c
+++ b/src/plugins/ctf/lttng-live/viewer-connection.c
@@ -1449,6 +1449,13 @@ enum lttng_live_iterator_status lttng_live_get_next_index(
 	flags = be32toh(rp.flags);
 	rp_status = be32toh(rp.status);
 
+	if (flags & LTTNG_VIEWER_FLAG_NEW_STREAM) {
+		BT_COMP_LOGD("Marking all sessions as possibly needing new streams: "
+			"response=%"PRId32 ", response-flag=NEW_STREAM",
+			rp_status);
+		lttng_live_need_new_streams(lttng_live_msg_iter);
+	}
+
 	switch (rp_status) {
 	case LTTNG_VIEWER_INDEX_INACTIVE:
 	{
@@ -1489,10 +1496,6 @@ enum lttng_live_iterator_status lttng_live_get_next_index(
 			BT_COMP_LOGD("Received get_next_index response: new metadata needed");
 			trace->metadata_stream_state = LTTNG_LIVE_METADATA_STREAM_STATE_NEEDED;
 		}
-		if (flags & LTTNG_VIEWER_FLAG_NEW_STREAM) {
-			BT_COMP_LOGD("Received get_next_index response: new streams needed");
-			lttng_live_need_new_streams(lttng_live_msg_iter);
-		}
 		status = LTTNG_LIVE_ITERATOR_STATUS_OK;
 		break;
 	}