flt.utils.muxer: support stream messages with default clock snapshot

Signed-off-by: Francis Deslauriers <francis.deslauriers@efficios.com>
Change-Id: I46fef189f846999dbfedc3504a7ed5d908464e99
Reviewed-on: https://review.lttng.org/c/babeltrace/+/1724
Reviewed-by: Philippe Proulx <eeppeliteloop@gmail.com>
Tested-by: jenkins <jenkins@lttng.org>

diff --git a/src/plugins/utils/muxer/muxer.c b/src/plugins/utils/muxer/muxer.c
index e1603fedabb2225260a95395cd6ef095c78302e8..e68c372c0addaa43615c152abbe894a785af702b 100644 (file)
--- a/src/plugins/utils/muxer/muxer.c
+++ b/src/plugins/utils/muxer/muxer.c
@@ -601,6 +601,28 @@ int get_msg_ts_ns(struct muxer_comp *muxer_comp,
                }
 
                break;
+       case BT_MESSAGE_TYPE_STREAM_BEGINNING:
+       {
+               enum bt_message_stream_clock_snapshot_state snapshot_state =
+                       bt_message_stream_beginning_borrow_default_clock_snapshot_const(
+                               msg, &clock_snapshot);
+               if (snapshot_state == BT_MESSAGE_STREAM_CLOCK_SNAPSHOT_STATE_UNKNOWN) {
+                       goto no_clock_snapshot;
+               }
+
+               break;
+       }
+       case BT_MESSAGE_TYPE_STREAM_END:
+       {
+               enum bt_message_stream_clock_snapshot_state snapshot_state =
+                       bt_message_stream_end_borrow_default_clock_snapshot_const(
+                               msg, &clock_snapshot);
+               if (snapshot_state == BT_MESSAGE_STREAM_CLOCK_SNAPSHOT_STATE_UNKNOWN) {
+                       goto no_clock_snapshot;
+               }
+
+               break;
+       }
        case BT_MESSAGE_TYPE_DISCARDED_EVENTS:
                if (bt_stream_class_discarded_events_have_default_clock_snapshots(
                                stream_class)) {