return self.stream.cls.discarded_events_have_default_clock_snapshots
-class _DiscardedEventsMessage(_DiscardedMessage):
+class _DiscardedEventsMessage(_DiscardedEventsMessageConst, _DiscardedMessage):
_borrow_stream_ptr = staticmethod(native_bt.message_discarded_events_borrow_stream)
_set_count = staticmethod(native_bt.message_discarded_events_set_count)
msg = utils.run_in_message_iterator_next(create_stream_class, msg_iter_next)
self.assertIs(type(msg), bt2._DiscardedEventsMessage)
- # Broken at the moment.
- # self.assertIs(msg.count, None)
+ self.assertIs(msg.count, None)
# With event count.
def test_create_with_count(self):
msg = utils.run_in_message_iterator_next(create_stream_class, msg_iter_next)
self.assertIs(type(msg), bt2._DiscardedEventsMessage)
- # Broken at the moment.
- # self.assertEqual(msg.count, 242)
+ self.assertEqual(msg.count, 242)
# With clock snapshots.
def test_create_with_clock_snapshots(self):
msg = utils.run_in_message_iterator_next(create_stream_class, msg_iter_next)
self.assertIs(type(msg), bt2._DiscardedEventsMessage)
- # Broken at the moment.
- # self.assertEqual(msg.beginning_default_clock_snapshot, 10);
- # self.assertEqual(msg.end_default_clock_snapshot, 20);
+ self.assertEqual(msg.beginning_default_clock_snapshot, 10)
+ self.assertEqual(msg.end_default_clock_snapshot, 20)
# Trying to create when the stream does not support discarded events.
def test_create_unsupported_raises(self):