self._msgs = [
self._create_stream_beginning_message(stream),
- self._create_stream_activity_beginning_message(stream),
self._create_packet_beginning_message(packet),
event_message,
event_message,
class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter):
def __init__(self, params):
tc = self._create_trace_class()
- sc = tc.create_stream_class()
+ sc = tc.create_stream_class(supports_packets=True)
ec = sc.create_event_class()
self._add_output_port('out', (tc, sc, ec))
it = graph.create_output_port_message_iterator(src.output_ports['out'])
# Skip beginning messages.
- next(it)
- next(it)
- next(it)
+ msg = next(it)
+ self.assertIsInstance(msg, bt2.message._StreamBeginningMessage)
+ msg = next(it)
+ self.assertIsInstance(msg, bt2.message._PacketBeginningMessage)
msg_ev1 = next(it)
msg_ev2 = next(it)
self._msgs = [
self._create_stream_beginning_message(stream),
- self._create_stream_activity_beginning_message(stream),
self._create_packet_beginning_message(packet),
self._create_event_message(ec, packet),
self._create_event_message(ec, packet),
self._create_packet_end_message(packet),
- self._create_stream_activity_end_message(stream),
self._create_stream_end_message(stream),
]
self._at = 0
message_iterator_class=MySourceIter):
def __init__(self, params):
tc = self._create_trace_class()
- sc = tc.create_stream_class()
+ sc = tc.create_stream_class(supports_packets=True)
ec = sc.create_event_class()
self._add_output_port('out', (tc, sc, ec))
msg = next(it)
self.assertIsInstance(msg, bt2.message._StreamBeginningMessage)
msg = next(it)
- self.assertIsInstance(msg, bt2.message._StreamActivityBeginningMessage)
+ self.assertIsInstance(msg, bt2.message._PacketBeginningMessage)
it.seek_beginning()
self._add_output_port('out')
trace_class = self._create_trace_class()
- stream_class = trace_class.create_stream_class()
+ stream_class = trace_class.create_stream_class(supports_packets=True)
# Create payload field class
my_int_ft = trace_class.create_signed_integer_field_class(32)