projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fix: src.ctf.lttng-live: expect NEW_STREAM/METADATA for inactive streams
[babeltrace.git]
/
src
/
plugins
/
ctf
/
lttng-live
/
viewer-connection.c
diff --git
a/src/plugins/ctf/lttng-live/viewer-connection.c
b/src/plugins/ctf/lttng-live/viewer-connection.c
index f21dc21ca8e0216dcd526d16e5b8c88c05796613..9b3e24003ece58e26c961179d6bb28f4c36980f6 100644
(file)
--- 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);
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:
{
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;
}
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;
}
status = LTTNG_LIVE_ITERATOR_STATUS_OK;
break;
}
This page took
0.02276 seconds
and
4
git commands to generate.