def __init__(self, config, self_port_output):
self._at = 0
self._with_stream_msgs_clock_snapshots = self_port_output.user_data.get(
def __init__(self, config, self_port_output):
self._at = 0
self._with_stream_msgs_clock_snapshots = self_port_output.user_data.get(
class MySrc(bt2._UserSourceComponent, message_iterator_class=MyIter):
def __init__(self, config, params, obj):
class MySrc(bt2._UserSourceComponent, message_iterator_class=MyIter):
def __init__(self, config, params, obj):
# Create payload field class
my_int_fc = tc.create_signed_integer_field_class(32)
payload_fc = tc.create_structure_field_class()
# Create payload field class
my_int_fc = tc.create_signed_integer_field_class(32)
payload_fc = tc.create_structure_field_class()
# Create specific context field class
my_int_fc = tc.create_signed_integer_field_class(32)
specific_fc = tc.create_structure_field_class()
# Create specific context field class
my_int_fc = tc.create_signed_integer_field_class(32)
specific_fc = tc.create_structure_field_class()
payload_field_class=payload_fc,
specific_context_field_class=specific_fc,
)
payload_field_class=payload_fc,
specific_context_field_class=specific_fc,
)
- params = {'with_cc': True}
- self._src_comp = self._graph.add_component(self._src, 'my_source', params)
+ params = {"with_cc": True}
+ self._src_comp = self._graph.add_component(self._src, "my_source", params)
- params = {'with_cc': False}
- self._src_comp = self._graph.add_component(self._src, 'my_source', params)
+ params = {"with_cc": False}
+ self._src_comp = self._graph.add_component(self._src, "my_source", params)
self.assertIs(type(msg.stream), bt2_stream._StreamConst)
self.assertEqual(msg.stream.addr, self._stream.addr)
with self.assertRaisesRegex(
self.assertIs(type(msg.stream), bt2_stream._StreamConst)
self.assertEqual(msg.stream.addr, self._stream.addr)
with self.assertRaisesRegex(
self.assertIs(type(msg.event.cls), bt2_event_class._EventClassConst)
self.assertEqual(msg.event.cls.addr, self._event_class.addr)
with self.assertRaisesRegex(
self.assertIs(type(msg.event.cls), bt2_event_class._EventClassConst)
self.assertEqual(msg.event.cls.addr, self._event_class.addr)
with self.assertRaisesRegex(
self.assertIs(type(msg.stream), bt2_stream._StreamConst)
self.assertEqual(msg.stream.addr, self._stream.addr)
with self.assertRaisesRegex(
self.assertIs(type(msg.stream), bt2_stream._StreamConst)
self.assertEqual(msg.stream.addr, self._stream.addr)
with self.assertRaisesRegex(
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
):
msg_iter._create_discarded_events_message(
stream, beg_clock_snapshot=10, end_clock_snapshot=20
):
msg_iter._create_discarded_events_message(
stream, beg_clock_snapshot=10, end_clock_snapshot=20
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
):
msg_iter._create_discarded_events_message(
stream, beg_clock_snapshot=20, end_clock_snapshot=10
):
msg_iter._create_discarded_events_message(
stream, beg_clock_snapshot=20, end_clock_snapshot=10
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
):
msg_iter._create_discarded_packets_message(
stream, beg_clock_snapshot=10, end_clock_snapshot=20
):
msg_iter._create_discarded_packets_message(
stream, beg_clock_snapshot=10, end_clock_snapshot=20
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
def msg_iter_next(msg_iter, stream):
with self.assertRaisesRegex(
ValueError,
):
msg_iter._create_discarded_packets_message(
stream, beg_clock_snapshot=20, end_clock_snapshot=10
):
msg_iter._create_discarded_packets_message(
stream, beg_clock_snapshot=20, end_clock_snapshot=10