X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=tests%2Fbindings%2Fpython%2Fbt2%2Ftest_trace_collection_message_iterator.py;h=7181a1e55eea979875827fc8d10c6adc52451ce6;hb=5f2a1585bf407f3f3aa7e63d9041b75390cf8563;hp=3abbe358b5a579441139928192b4bd3e6cad26a8;hpb=c87f23fa2be424d0e97c4ca677c738a847813acf;p=babeltrace.git diff --git a/tests/bindings/python/bt2/test_trace_collection_message_iterator.py b/tests/bindings/python/bt2/test_trace_collection_message_iterator.py index 3abbe358..7181a1e5 100644 --- a/tests/bindings/python/bt2/test_trace_collection_message_iterator.py +++ b/tests/bindings/python/bt2/test_trace_collection_message_iterator.py @@ -296,15 +296,35 @@ class TraceCollectionMessageIteratorTestCase(unittest.TestCase): hist = _count_msgs_by_type(msgs) self.assertEqual(hist[bt2._EventMessage], 3) - def test_iter_intersection_no_inputs_param(self): + def test_iter_intersection_params(self): + # Check that all params used to create the source component are passed + # to the `babeltrace.trace-infos` query. specs = [ bt2.ComponentSpec.from_named_plugin_and_component_class( - 'text', 'dmesg', {'read-from-stdin': True} + 'ctf', + 'fs', + { + 'inputs': [_3EVENTS_INTERSECT_TRACE_PATH], + 'clock-class-offset-s': 1000, + }, ) ] - with self.assertRaises(ValueError): - bt2.TraceCollectionMessageIterator(specs, stream_intersection_mode=True) + msg_iter = bt2.TraceCollectionMessageIterator( + specs, stream_intersection_mode=True + ) + + event_msgs = [x for x in msg_iter if type(x) is bt2._EventMessage] + self.assertEqual(len(event_msgs), 3) + self.assertEqual( + event_msgs[0].default_clock_snapshot.ns_from_origin, 13516309000000071 + ) + self.assertEqual( + event_msgs[1].default_clock_snapshot.ns_from_origin, 13516309000000072 + ) + self.assertEqual( + event_msgs[2].default_clock_snapshot.ns_from_origin, 13516309000000082 + ) def test_iter_no_intersection_two_traces(self): spec = bt2.ComponentSpec.from_named_plugin_and_component_class(