X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=tests%2Fdata%2Fplugins%2Fflt.utils.muxer%2Fbt_plugin_muxer_test.py;fp=tests%2Fdata%2Fplugins%2Fflt.utils.muxer%2Fbt_plugin_muxer_test.py;h=8ac1f1b7456300c7820b0f838b81384d0547a72b;hp=bc447b4343cee236e2666b68b2fb372bac948733;hb=f5567ea88d172767b34373bc6e402da8bfd85ef8;hpb=419d8c49bd978a59b8a0619d83cb6ba26b18f970 diff --git a/tests/data/plugins/flt.utils.muxer/bt_plugin_muxer_test.py b/tests/data/plugins/flt.utils.muxer/bt_plugin_muxer_test.py index bc447b43..8ac1f1b7 100644 --- a/tests/data/plugins/flt.utils.muxer/bt_plugin_muxer_test.py +++ b/tests/data/plugins/flt.utils.muxer/bt_plugin_muxer_test.py @@ -25,7 +25,7 @@ class TheSourceOfConfusion( bt2._UserSourceComponent, message_iterator_class=TheIteratorOfConfusion ): def __init__(self, config, params, obj): - test_name = str(params['test-name']) + test_name = str(params["test-name"]) TEST_CASES[test_name].source_setup(self, test_name) @@ -37,11 +37,11 @@ class DiffTraceName: 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 @@ -64,11 +64,11 @@ class DiffStreamName: 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 @@ -94,8 +94,8 @@ class DiffStreamId: 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 @@ -121,8 +121,8 @@ class DiffStreamNoName: 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 @@ -148,8 +148,8 @@ class DiffStreamClassId: 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 @@ -174,11 +174,11 @@ class DiffStreamClassName: 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 @@ -204,11 +204,11 @@ class DiffStreamClassNoName: 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 @@ -236,9 +236,9 @@ class BasicTimestampOrdering: 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 @@ -260,15 +260,15 @@ class MultiIterOrdering: 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. @@ -280,7 +280,7 @@ class MultiIterOrdering: 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), @@ -331,7 +331,7 @@ class MultiIterOrdering: 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( @@ -348,11 +348,11 @@ class DiffEventClassName: 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 @@ -387,8 +387,8 @@ class DiffEventClassId: 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 @@ -416,14 +416,14 @@ class DiffEventClassId: 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 @@ -432,18 +432,18 @@ class DiffInactivityMsgCs: 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")