bt2: pass all params to `babeltrace.trace-info` query when computing stream intersection

[babeltrace.git] / tests / bindings / python / bt2 / test_trace_collection_message_iterator.py

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 3abbe358b5a579441139928192b4bd3e6cad26a8..065b46e9af534b3987fbc8e18cc13c447bd8a84b 100644 (file)
--- 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-info` 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(