Reading the count and clock snapshot properties on a _DiscardedEventsMessage
does not work. For example, this:
msg = self._create_discarded_events_message(stream, count=10)
print(msg.count)
Results in:
File "test.py", line 10, in __init__
print(msg.count)
File "/home/simark/build/babeltrace/src/bindings/python/bt2/build/build_lib/bt2/message.py", line 208, in count
avail, count = self._get_count(self._ptr)
AttributeError: '_DiscardedEventsMessage' object has no attribute '_get_count'
The problem is simply that _DiscardedEventsMessage is missing inheriting
from _DiscardedEventsMessageConst.
Change-Id: Id40ea54bb26b4e4aec264d84bda52ed815090341
Signed-off-by: Simon Marchi <simon.marchi@efficios.com>
Reviewed-on: https://review.lttng.org/c/babeltrace/+/3392
Tested-by: jenkins <jenkins@lttng.org>
Reviewed-by: Philippe Proulx <eeppeliteloop@gmail.com>
return self.stream.cls.discarded_events_have_default_clock_snapshots
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)
_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)
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):
# 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)
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):
# 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)
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):
# Trying to create when the stream does not support discarded events.
def test_create_unsupported_raises(self):