+# SPDX-License-Identifier: GPL-2.0-only
+#
+# Copyright (C) 2019 EfficiOS Inc.
+#
+
import bt2
class TheIteratorOfConfusion(bt2._UserMessageIterator):
- def __init__(self, port):
+ def __init__(self, config, port):
self._at = 0
test_name = port.user_data[0]
TEST_CASES[test_name].create_msgs(self, port.user_data[1:])
class TheSourceOfConfusion(
bt2._UserSourceComponent, message_iterator_class=TheIteratorOfConfusion
):
- def __init__(self, params, obj):
- test_name = str(params['test-name'])
+ def __init__(self, config, params, obj):
+ test_name = str(params["test-name"])
TEST_CASES[test_name].source_setup(self, test_name)
tc2 = src._create_trace_class()
cc2 = src._create_clock_class(frequency=1, offset=bt2.ClockClassOffset(0))
- trace_name1 = 'rouyn'
- trace_name2 = 'noranda'
+ trace_name1 = "rouyn"
+ trace_name2 = "noranda"
- src._add_output_port('out1', (test_name, 1, tc1, cc1, trace_name1))
- src._add_output_port('out2', (test_name, 2, tc2, cc2, trace_name2))
+ src._add_output_port("out1", (test_name, 1, tc1, cc1, trace_name1))
+ src._add_output_port("out2", (test_name, 2, tc2, cc2, trace_name2))
def create_msgs(msg_iter, params):
iter_id, tc, cc, trace_name = params
tc2 = src._create_trace_class()
cc2 = src._create_clock_class(frequency=1, offset=bt2.ClockClassOffset(0))
- stream_name1 = 'port-daniel'
- stream_name2 = 'gascon'
+ stream_name1 = "port-daniel"
+ stream_name2 = "gascon"
- src._add_output_port('out1', (test_name, 1, tc1, cc1, stream_name1))
- src._add_output_port('out2', (test_name, 2, tc2, cc2, stream_name2))
+ src._add_output_port("out1", (test_name, 1, tc1, cc1, stream_name1))
+ src._add_output_port("out2", (test_name, 2, tc2, cc2, stream_name2))
def create_msgs(msg_iter, params):
iter_id, tc, cc, stream_name = params
stream_id1 = 18
stream_id2 = 23
- src._add_output_port('out1', (test_name, 1, tc1, cc1, stream_id1))
- src._add_output_port('out2', (test_name, 2, tc2, cc2, stream_id2))
+ src._add_output_port("out1", (test_name, 1, tc1, cc1, stream_id1))
+ src._add_output_port("out2", (test_name, 2, tc2, cc2, stream_id2))
def create_msgs(msg_iter, params):
iter_id, tc, cc, stream_id = params
stream_name1 = "one"
stream_name2 = None
- src._add_output_port('out1', (test_name, 1, tc1, cc1, stream_name1))
- src._add_output_port('out2', (test_name, 2, tc2, cc2, stream_name2))
+ src._add_output_port("out1", (test_name, 1, tc1, cc1, stream_name1))
+ src._add_output_port("out2", (test_name, 2, tc2, cc2, stream_name2))
def create_msgs(msg_iter, params):
iter_id, tc, cc, stream_no_name = params
stream_class_id1 = 18
stream_class_id2 = 23
- src._add_output_port('out1', (test_name, 1, tc1, cc1, stream_class_id1))
- src._add_output_port('out2', (test_name, 2, tc2, cc2, stream_class_id2))
+ src._add_output_port("out1", (test_name, 1, tc1, cc1, stream_class_id1))
+ src._add_output_port("out2", (test_name, 2, tc2, cc2, stream_class_id2))
def create_msgs(msg_iter, params):
iter_id, tc, cc, stream_class_id = params
tc2 = src._create_trace_class(assigns_automatic_stream_class_id=False)
cc2 = src._create_clock_class(frequency=1, offset=bt2.ClockClassOffset(0))
- stream_class_name1 = 'one'
- stream_class_name2 = 'two'
+ stream_class_name1 = "one"
+ stream_class_name2 = "two"
- src._add_output_port('out1', (test_name, 1, tc1, cc1, stream_class_name1))
- src._add_output_port('out2', (test_name, 2, tc2, cc2, stream_class_name2))
+ src._add_output_port("out1", (test_name, 1, tc1, cc1, stream_class_name1))
+ src._add_output_port("out2", (test_name, 2, tc2, cc2, stream_class_name2))
def create_msgs(msg_iter, params):
iter_id, tc, cc, stream_class_name = params
tc2 = src._create_trace_class(assigns_automatic_stream_class_id=False)
cc2 = src._create_clock_class(frequency=1, offset=bt2.ClockClassOffset(0))
- stream_class_name1 = 'one'
+ stream_class_name1 = "one"
stream_class_name2 = None
- src._add_output_port('out1', (test_name, 1, tc1, cc1, stream_class_name1))
- src._add_output_port('out2', (test_name, 2, tc2, cc2, stream_class_name2))
+ src._add_output_port("out1", (test_name, 1, tc1, cc1, stream_class_name1))
+ src._add_output_port("out2", (test_name, 2, tc2, cc2, stream_class_name2))
def create_msgs(msg_iter, params):
iter_id, tc, cc, stream_class_name = params
timestamp2 = 120
timestamp3 = 4
- src._add_output_port('out1', (test_name, 1, tc, cc, timestamp1))
- src._add_output_port('out2', (test_name, 2, tc, cc, timestamp2))
- src._add_output_port('out3', (test_name, 3, tc, cc, timestamp3))
+ src._add_output_port("out1", (test_name, 1, tc, cc, timestamp1))
+ src._add_output_port("out2", (test_name, 2, tc, cc, timestamp2))
+ src._add_output_port("out3", (test_name, 3, tc, cc, timestamp3))
def create_msgs(msg_iter, params):
iter_id, tc, cc, timestamp = params
tc4 = src._create_trace_class(assigns_automatic_stream_class_id=False)
cc = src._create_clock_class(frequency=1, offset=bt2.ClockClassOffset(0))
- src._add_output_port('out1', (test_name, 1, tc1, cc))
- src._add_output_port('out2', (test_name, 2, tc2, cc))
- src._add_output_port('out3', (test_name, 3, tc3, cc))
- src._add_output_port('out4', (test_name, 4, tc4, cc))
+ src._add_output_port("out1", (test_name, 1, tc1, cc))
+ src._add_output_port("out2", (test_name, 2, tc2, cc))
+ src._add_output_port("out3", (test_name, 3, tc3, cc))
+ src._add_output_port("out4", (test_name, 4, tc4, cc))
def create_msgs(msg_iter, params):
iter_id, tc, cc = params
- trace_hello = tc(name='hello')
- trace_meow = tc(name='meow')
+ trace_hello = tc(name="hello")
+ trace_meow = tc(name="meow")
# Craft list of messages for each iterator so that the last messages of
# each iterator are all sharing the same timestamp.
id=0, default_clock_class=cc, assigns_automatic_stream_id=False
)
sc_0_stream_1 = trace_hello.create_stream(stream_class0, id=1)
- event_class = stream_class0.create_event_class(name='saumon atlantique')
+ event_class = stream_class0.create_event_class(name="saumon atlantique")
msg_iter._msgs = [
msg_iter._create_stream_beginning_message(sc_0_stream_1, 0),
sc_1_stream_1 = trace_meow.create_stream(stream_class1, id=1)
- event_class = stream_class1.create_event_class(name='bar rayƩ')
+ event_class = stream_class1.create_event_class(name="bar rayƩ")
msg_iter._msgs = [
msg_iter._create_stream_beginning_message(sc_1_stream_1, 3),
msg_iter._create_event_message(
tc2 = src._create_trace_class(assigns_automatic_stream_class_id=False)
cc2 = src._create_clock_class(frequency=1, offset=bt2.ClockClassOffset(0))
- event_class_name1 = 'Hull'
- event_class_name2 = 'Gatineau'
+ event_class_name1 = "Hull"
+ event_class_name2 = "Gatineau"
- src._add_output_port('out1', (test_name, 1, tc1, cc1, event_class_name1))
- src._add_output_port('out2', (test_name, 2, tc2, cc2, event_class_name2))
+ src._add_output_port("out1", (test_name, 1, tc1, cc1, event_class_name1))
+ src._add_output_port("out2", (test_name, 2, tc2, cc2, event_class_name2))
def create_msgs(msg_iter, params):
iter_id, tc, cc, event_class_name = params
event_class_id1 = 1
event_class_id2 = 2
- src._add_output_port('out1', (test_name, 1, tc1, cc1, event_class_id1))
- src._add_output_port('out2', (test_name, 2, tc2, cc2, event_class_id2))
+ src._add_output_port("out1", (test_name, 1, tc1, cc1, event_class_id1))
+ src._add_output_port("out2", (test_name, 2, tc2, cc2, event_class_id2))
def create_msgs(msg_iter, params):
iter_id, tc, cc, event_class_id = params
class DiffInactivityMsgCs:
def source_setup(src, test_name):
cc1 = src._create_clock_class(
- frequency=1, name='La Baie', offset=bt2.ClockClassOffset(0)
+ frequency=1, name="La Baie", offset=bt2.ClockClassOffset(0)
)
cc2 = src._create_clock_class(
- frequency=1, name='Chicoutimi', offset=bt2.ClockClassOffset(0)
+ frequency=1, name="Chicoutimi", offset=bt2.ClockClassOffset(0)
)
- src._add_output_port('out1', (test_name, cc1))
- src._add_output_port('out2', (test_name, cc2))
+ src._add_output_port("out1", (test_name, cc1))
+ src._add_output_port("out2", (test_name, cc2))
def create_msgs(msg_iter, params):
- cc, = params
+ (cc,) = params
sb_msg = msg_iter._create_message_iterator_inactivity_message(cc, 0)
msg_iter._msgs = [sb_msg]
TEST_CASES = {
- 'diff_trace_name': DiffTraceName,
- 'diff_event_class_name': DiffEventClassName,
- 'diff_event_class_id': DiffEventClassId,
- 'diff_stream_name': DiffStreamName,
- 'diff_stream_no_name': DiffStreamNoName,
- 'diff_stream_id': DiffStreamId,
- 'diff_stream_class_id': DiffStreamClassId,
- 'diff_stream_class_name': DiffStreamClassName,
- 'diff_stream_class_no_name': DiffStreamClassNoName,
- 'diff_inactivity_msg_cs': DiffInactivityMsgCs,
- 'basic_timestamp_ordering': BasicTimestampOrdering,
- 'multi_iter_ordering': MultiIterOrdering,
+ "diff_trace_name": DiffTraceName,
+ "diff_event_class_name": DiffEventClassName,
+ "diff_event_class_id": DiffEventClassId,
+ "diff_stream_name": DiffStreamName,
+ "diff_stream_no_name": DiffStreamNoName,
+ "diff_stream_id": DiffStreamId,
+ "diff_stream_class_id": DiffStreamClassId,
+ "diff_stream_class_name": DiffStreamClassName,
+ "diff_stream_class_no_name": DiffStreamClassNoName,
+ "diff_inactivity_msg_cs": DiffInactivityMsgCs,
+ "basic_timestamp_ordering": BasicTimestampOrdering,
+ "multi_iter_ordering": MultiIterOrdering,
}
-bt2.register_plugin(__name__, 'test-muxer')
+bt2.register_plugin(__name__, "test-muxer")