#define BT_LOG_TAG "PLUGIN-UTILS-MUXER-FLT"
#include "logging.h"
-#include <babeltrace/babeltrace-internal.h>
-#include <babeltrace/compat/uuid-internal.h>
-#include <babeltrace/babeltrace.h>
-#include <babeltrace/value-internal.h>
-#include <babeltrace/graph/component-internal.h>
-#include <babeltrace/graph/message-iterator-internal.h>
-#include <babeltrace/graph/connection-internal.h>
+#include <babeltrace2/babeltrace-internal.h>
+#include <babeltrace2/compat/uuid-internal.h>
+#include <babeltrace2/babeltrace.h>
+#include <babeltrace2/value-internal.h>
+#include <babeltrace2/graph/component-internal.h>
+#include <babeltrace2/graph/message-iterator-internal.h>
+#include <babeltrace2/graph/connection-internal.h>
#include <plugins-common.h>
#include <glib.h>
#include <stdbool.h>
#include <inttypes.h>
-#include <babeltrace/assert-internal.h>
-#include <babeltrace/common-internal.h>
+#include <babeltrace2/assert-internal.h>
+#include <babeltrace2/common-internal.h>
#include <stdlib.h>
#include <string.h>
bt_packet_borrow_stream_const(
bt_message_packet_end_borrow_packet_const(
msg)));
+ } else if (unlikely(msg_type == BT_MESSAGE_TYPE_DISCARDED_EVENTS)) {
+ stream_class = bt_stream_borrow_class_const(
+ bt_message_discarded_events_borrow_stream_const(msg));
+ } else if (unlikely(msg_type == BT_MESSAGE_TYPE_DISCARDED_PACKETS)) {
+ stream_class = bt_stream_borrow_class_const(
+ bt_message_discarded_packets_borrow_stream_const(msg));
}
switch (msg_type) {
msg);
break;
case BT_MESSAGE_TYPE_PACKET_BEGINNING:
- if (bt_stream_class_packets_have_default_beginning_clock_snapshot(
+ if (bt_stream_class_packets_have_beginning_default_clock_snapshot(
stream_class)) {
clock_snapshot = bt_message_packet_beginning_borrow_default_clock_snapshot_const(
msg);
break;
case BT_MESSAGE_TYPE_PACKET_END:
- if (bt_stream_class_packets_have_default_end_clock_snapshot(
+ if (bt_stream_class_packets_have_end_default_clock_snapshot(
stream_class)) {
clock_snapshot = bt_message_packet_end_borrow_default_clock_snapshot_const(
msg);
break;
case BT_MESSAGE_TYPE_DISCARDED_EVENTS:
- BT_ASSERT(bt_message_discarded_events_borrow_stream_class_default_clock_class_const(
- msg));
- clock_snapshot = bt_message_discarded_events_borrow_default_beginning_clock_snapshot_const(
- msg);
+ if (bt_stream_class_discarded_events_have_default_clock_snapshots(
+ stream_class)) {
+ clock_snapshot = bt_message_discarded_events_borrow_beginning_default_clock_snapshot_const(
+ msg);
+ } else {
+ goto no_clock_snapshot;
+ }
+
break;
case BT_MESSAGE_TYPE_DISCARDED_PACKETS:
- BT_ASSERT(bt_message_discarded_packets_borrow_stream_class_default_clock_class_const(
- msg));
- clock_snapshot = bt_message_discarded_packets_borrow_default_beginning_clock_snapshot_const(
- msg);
+ if (bt_stream_class_discarded_packets_have_default_clock_snapshots(
+ stream_class)) {
+ clock_snapshot = bt_message_discarded_packets_borrow_beginning_default_clock_snapshot_const(
+ msg);
+ } else {
+ goto no_clock_snapshot;
+ }
+
break;
case BT_MESSAGE_TYPE_STREAM_ACTIVITY_BEGINNING:
BT_ASSERT(bt_message_stream_activity_beginning_borrow_stream_class_default_clock_class_const(