X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=tests%2Fbindings%2Fpython%2Fbt2%2Ftest_message_iterator.py;h=71f636394f799fd0647f9a5eba48037bbd74bf7f;hb=f5567ea88d172767b34373bc6e402da8bfd85ef8;hp=d03cdb302757b4b0b698bc94b5ce9755921b6daf;hpb=2e1b56154a3032b52687751ed2e5c1a8a5134f7c;p=babeltrace.git diff --git a/tests/bindings/python/bt2/test_message_iterator.py b/tests/bindings/python/bt2/test_message_iterator.py index d03cdb30..71f63639 100644 --- a/tests/bindings/python/bt2/test_message_iterator.py +++ b/tests/bindings/python/bt2/test_message_iterator.py @@ -1,20 +1,7 @@ +# SPDX-License-Identifier: GPL-2.0-only # # Copyright (C) 2019 EfficiOS Inc. # -# This program is free software; you can redistribute it and/or -# modify it under the terms of the GNU General Public License -# as published by the Free Software Foundation; only version 2 -# of the License. -# -# This program is distributed in the hope that it will be useful, -# but WITHOUT ANY WARRANTY; without even the implied warranty of -# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -# GNU General Public License for more details. -# -# You should have received a copy of the GNU General Public License -# along with this program; if not, write to the Free Software -# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. -# import unittest import bt2 @@ -29,29 +16,27 @@ class SimpleSink(bt2._UserSinkComponent): # it. def __init__(self, config, params, obj): - self._add_input_port('in') + self._add_input_port("in") def _user_consume(self): next(self._msg_iter) def _user_graph_is_configured(self): - self._msg_iter = self._create_input_port_message_iterator( - self._input_ports['in'] - ) + self._msg_iter = self._create_message_iterator(self._input_ports["in"]) def _create_graph(src_comp_cls, sink_comp_cls, flt_comp_cls=None): graph = bt2.Graph() - src_comp = graph.add_component(src_comp_cls, 'src') - sink_comp = graph.add_component(sink_comp_cls, 'sink') + src_comp = graph.add_component(src_comp_cls, "src") + sink_comp = graph.add_component(sink_comp_cls, "sink") if flt_comp_cls is not None: - flt_comp = graph.add_component(flt_comp_cls, 'flt') - graph.connect_ports(src_comp.output_ports['out'], flt_comp.input_ports['in']) - graph.connect_ports(flt_comp.output_ports['out'], sink_comp.input_ports['in']) + flt_comp = graph.add_component(flt_comp_cls, "flt") + graph.connect_ports(src_comp.output_ports["out"], flt_comp.input_ports["in"]) + graph.connect_ports(flt_comp.output_ports["out"], sink_comp.input_ports["in"]) else: - graph.connect_ports(src_comp.output_ports['out'], sink_comp.input_ports['in']) + graph.connect_ports(src_comp.output_ports["out"], sink_comp.input_ports["in"]) return graph @@ -71,7 +56,7 @@ class UserMessageIteratorTestCase(unittest.TestCase): class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter): def __init__(self, config, params, obj): nonlocal the_output_port_from_source - the_output_port_from_source = self._add_output_port('out', 'user data') + the_output_port_from_source = self._add_output_port("out", "user data") initialized = False graph = _create_graph(MySource, SimpleSink) @@ -80,7 +65,7 @@ class UserMessageIteratorTestCase(unittest.TestCase): self.assertEqual( the_output_port_from_source.addr, the_output_port_from_iter.addr ) - self.assertEqual(the_output_port_from_iter.user_data, 'user data') + self.assertEqual(the_output_port_from_iter.user_data, "user data") def test_create_from_message_iterator(self): class MySourceIter(bt2._UserMessageIterator): @@ -90,14 +75,14 @@ class UserMessageIteratorTestCase(unittest.TestCase): class MySource(bt2._UserSourceComponent, message_iterator_class=MySourceIter): def __init__(self, config, params, obj): - self._add_output_port('out') + self._add_output_port("out") class MyFilterIter(bt2._UserMessageIterator): def __init__(self, config, self_port_output): nonlocal flt_iter_initialized flt_iter_initialized = True - self._up_iter = self._create_input_port_message_iterator( - self._component._input_ports['in'] + self._up_iter = self._create_message_iterator( + self._component._input_ports["in"] ) def __next__(self): @@ -105,8 +90,8 @@ class UserMessageIteratorTestCase(unittest.TestCase): class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyFilterIter): def __init__(self, config, params, obj): - self._add_input_port('in') - self._add_output_port('out') + self._add_input_port("in") + self._add_output_port("out") src_iter_initialized = False flt_iter_initialized = False @@ -115,31 +100,90 @@ class UserMessageIteratorTestCase(unittest.TestCase): self.assertTrue(src_iter_initialized) self.assertTrue(flt_iter_initialized) + # Test that creating a message iterator from a sink component on a + # non-connected inport port raises. + def test_create_from_sink_component_unconnected_port_raises(self): + class MySink(bt2._UserSinkComponent): + def __init__(comp_self, config, params, obj): + comp_self._input_port = comp_self._add_input_port("in") + + def _user_graph_is_configured(comp_self): + with self.assertRaisesRegex(ValueError, "input port is not connected"): + comp_self._create_message_iterator(comp_self._input_port) + + nonlocal seen + seen = True + + def _user_consume(self): + raise bt2.Stop + + seen = False + graph = bt2.Graph() + graph.add_component(MySink, "snk") + graph.run() + self.assertTrue(seen) + + # Test that creating a message iterator from a message iteartor on a + # non-connected inport port raises. + def test_create_from_message_iterator_unconnected_port_raises(self): + class MyFilterIter(bt2._UserMessageIterator): + def __init__(iter_self, config, port): + input_port = iter_self._component._input_ports["in"] + + with self.assertRaisesRegex(ValueError, "input port is not connected"): + iter_self._create_message_iterator(input_port) + + nonlocal seen + seen = True + + class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyFilterIter): + def __init__(comp_self, config, params, obj): + comp_self._add_input_port("in") + comp_self._add_output_port("out") + + class MySink(bt2._UserSinkComponent): + def __init__(comp_self, config, params, obj): + comp_self._input_port = comp_self._add_input_port("in") + + def _user_graph_is_configured(comp_self): + comp_self._input_iter = comp_self._create_message_iterator( + comp_self._input_port + ) + + def _user_consume(self): + raise bt2.Stop + + seen = False + graph = bt2.Graph() + flt = graph.add_component(MyFilter, "flt") + snk = graph.add_component(MySink, "snk") + graph.connect_ports(flt.output_ports["out"], snk.input_ports["in"]) + graph.run() + self.assertTrue(seen) + def test_create_user_error(self): # This tests both error handling by - # _UserSinkComponent._create_input_port_message_iterator - # and _UserMessageIterator._create_input_port_message_iterator, as they + # _UserSinkComponent._create_message_iterator + # and _UserMessageIterator._create_message_iterator, as they # are both used in the graph. class MySourceIter(bt2._UserMessageIterator): def __init__(self, config, self_port_output): - raise ValueError('Very bad error') + raise ValueError("Very bad error") class MySource(bt2._UserSourceComponent, message_iterator_class=MySourceIter): def __init__(self, config, params, obj): - self._add_output_port('out') + self._add_output_port("out") class MyFilterIter(bt2._UserMessageIterator): def __init__(self, config, self_port_output): # This is expected to raise because of the error in # MySourceIter.__init__. - self._create_input_port_message_iterator( - self._component._input_ports['in'] - ) + self._create_message_iterator(self._component._input_ports["in"]) class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyFilterIter): def __init__(self, config, params, obj): - self._add_input_port('in') - self._add_output_port('out') + self._add_input_port("in") + self._add_output_port("out") graph = _create_graph(MySource, SimpleSink, MyFilter) @@ -150,9 +194,9 @@ class UserMessageIteratorTestCase(unittest.TestCase): cause = exc[0] self.assertIsInstance(cause, bt2._MessageIteratorErrorCause) - self.assertEqual(cause.component_name, 'src') - self.assertEqual(cause.component_output_port_name, 'out') - self.assertIn('ValueError: Very bad error', cause.message) + self.assertEqual(cause.component_name, "src") + self.assertEqual(cause.component_output_port_name, "out") + self.assertIn("ValueError: Very bad error", cause.message) def test_finalize(self): class MyIter(bt2._UserMessageIterator): @@ -162,7 +206,7 @@ class UserMessageIteratorTestCase(unittest.TestCase): class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter): def __init__(self, config, params, obj): - self._add_output_port('out') + self._add_output_port("out") finalized = False graph = _create_graph(MySource, SimpleSink) @@ -178,7 +222,7 @@ class UserMessageIteratorTestCase(unittest.TestCase): class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter): def __init__(self, config, params, obj): - self._add_output_port('out') + self._add_output_port("out") config_type = None graph = _create_graph(MySource, SimpleSink) @@ -193,16 +237,14 @@ class UserMessageIteratorTestCase(unittest.TestCase): class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter): def __init__(self, config, params, obj): - self._add_output_port('out') + self._add_output_port("out") class MySink(bt2._UserSinkComponent): def __init__(self, config, params, obj): - self._add_input_port('in') + self._add_input_port("in") def _user_graph_is_configured(self): - self._msg_iter = self._create_input_port_message_iterator( - self._input_ports['in'] - ) + self._msg_iter = self._create_message_iterator(self._input_ports["in"]) def _user_consume(self): nonlocal can_seek_forward @@ -226,7 +268,7 @@ class UserMessageIteratorTestCase(unittest.TestCase): class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter): def __init__(self, config, params, obj): - self._add_output_port('out') + self._add_output_port("out") graph = _create_graph(MySource, SimpleSink) with self.assertRaises(bt2._Error) as ctx: @@ -243,7 +285,7 @@ class UserMessageIteratorTestCase(unittest.TestCase): class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter): def __init__(self, config, params, obj): - self._add_output_port('out') + self._add_output_port("out") self._salut = 23 salut = None @@ -263,7 +305,7 @@ class UserMessageIteratorTestCase(unittest.TestCase): class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter): def __init__(self, config, params, obj): - self._add_output_port('out') + self._add_output_port("out") called = False graph = _create_graph(MySource, SimpleSink) @@ -278,7 +320,7 @@ class UserMessageIteratorTestCase(unittest.TestCase): class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter): def __init__(self, config, params, obj): - self._add_output_port('out') + self._add_output_port("out") addr = None graph = _create_graph(MySource, SimpleSink) @@ -314,11 +356,11 @@ class UserMessageIteratorTestCase(unittest.TestCase): tc = self._create_trace_class() sc = tc.create_stream_class(supports_packets=True) ec = sc.create_event_class() - self._add_output_port('out', (tc, sc, ec)) + self._add_output_port("out", (tc, sc, ec)) graph = bt2.Graph() - src = graph.add_component(MySource, 'src') - it = TestOutputPortMessageIterator(graph, src.output_ports['out']) + src = graph.add_component(MySource, "src") + it = TestOutputPortMessageIterator(graph, src.output_ports["out"]) # Skip beginning messages. msg = next(it) @@ -343,14 +385,12 @@ class UserMessageIteratorTestCase(unittest.TestCase): class MySource(bt2._UserSourceComponent, message_iterator_class=MyIter): def __init__(self, config, params, obj): - self._add_output_port('out') + self._add_output_port("out") class MyFilterIter(bt2._UserMessageIterator): def __init__(self, port): input_port = port.user_data - self._upstream_iter = self._create_input_port_message_iterator( - input_port - ) + self._upstream_iter = self._create_message_iterator(input_port) def __next__(self): return next(self._upstream_iter) @@ -363,12 +403,12 @@ class UserMessageIteratorTestCase(unittest.TestCase): class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyFilterIter): def __init__(self, config, params, obj): - input_port = self._add_input_port('in') - self._add_output_port('out', input_port) + input_port = self._add_input_port("in") + self._add_output_port("out", input_port) graph = bt2.Graph() - src = graph.add_component(MySource, 'src') - it = TestOutputPortMessageIterator(graph, src.output_ports['out']) + src = graph.add_component(MySource, "src") + it = TestOutputPortMessageIterator(graph, src.output_ports["out"]) # Three times the initial ref count of `None` iterations should # be enough to catch the bug even if there are small differences @@ -379,6 +419,61 @@ class UserMessageIteratorTestCase(unittest.TestCase): with self.assertRaises(bt2.TryAgain): next(it) + def test_error_in_iterator_with_cycle_after_having_created_upstream_iterator(self): + # Test a failure that triggered an abort in libbabeltrace2, in this situation: + # + # - The filter iterator creates an upstream iterator. + # - The filter iterator creates a reference cycle, including itself. + # - An exception is raised, causing the filter iterator's + # initialization method to fail. + class MySourceIter(bt2._UserMessageIterator): + pass + + class MySource(bt2._UserSourceComponent, message_iterator_class=MySourceIter): + def __init__(self, config, params, obj): + self._add_output_port("out") + + class MyFilterIter(bt2._UserMessageIterator): + def __init__(self, config, port): + # First, create an upstream iterator. + self._upstream_iter = self._create_message_iterator( + self._component._input_ports["in"] + ) + + # Then, voluntarily make a reference cycle that will keep this + # Python object alive, which will keep the upstream iterator + # Babeltrace object alive. + self._self = self + + # Finally, raise an exception to make __init__ fail. + raise ValueError("woops") + + class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyFilterIter): + def __init__(self, config, params, obj): + self._in = self._add_input_port("in") + self._out = self._add_output_port("out") + + class MySink(bt2._UserSinkComponent): + def __init__(self, config, params, obj): + self._input_port = self._add_input_port("in") + + def _user_graph_is_configured(self): + self._upstream_iter = self._create_message_iterator(self._input_port) + + def _user_consume(self): + # We should not reach this. + assert False + + g = bt2.Graph() + src = g.add_component(MySource, "src") + flt = g.add_component(MyFilter, "flt") + snk = g.add_component(MySink, "snk") + g.connect_ports(src.output_ports["out"], flt.input_ports["in"]) + g.connect_ports(flt.output_ports["out"], snk.input_ports["in"]) + + with self.assertRaisesRegex(bt2._Error, "ValueError: woops"): + g.run() + def _setup_seek_test( sink_cls, @@ -432,12 +527,12 @@ def _setup_seek_test( sc = tc.create_stream_class(supports_packets=True) ec = sc.create_event_class() - self._add_output_port('out', (tc, sc, ec)) + self._add_output_port("out", (tc, sc, ec)) class MyFilterIter(bt2._UserMessageIterator): def __init__(self, config, port): - self._upstream_iter = self._create_input_port_message_iterator( - self._component._input_ports['in'] + self._upstream_iter = self._create_message_iterator( + self._component._input_ports["in"] ) config.can_seek_forward = self._upstream_iter.can_seek_forward @@ -458,8 +553,8 @@ def _setup_seek_test( class MyFilter(bt2._UserFilterComponent, message_iterator_class=MyFilterIter): def __init__(self, config, params, obj): - self._add_input_port('in') - self._add_output_port('out') + self._add_input_port("in") + self._add_output_port("out") return _create_graph(MySource, sink_cls, flt_comp_cls=MyFilter) @@ -475,12 +570,10 @@ class UserMessageIteratorSeekBeginningTestCase(unittest.TestCase): def test_can_seek_beginning(self): class MySink(bt2._UserSinkComponent): def __init__(self, config, params, obj): - self._add_input_port('in') + self._add_input_port("in") def _user_graph_is_configured(self): - self._msg_iter = self._create_input_port_message_iterator( - self._input_ports['in'] - ) + self._msg_iter = self._create_message_iterator(self._input_ports["in"]) def _user_consume(self): nonlocal can_seek_beginning @@ -511,12 +604,10 @@ class UserMessageIteratorSeekBeginningTestCase(unittest.TestCase): # a _user_seek_beginning method. class MySink(bt2._UserSinkComponent): def __init__(self, config, params, obj): - self._add_input_port('in') + self._add_input_port("in") def _user_graph_is_configured(self): - self._msg_iter = self._create_input_port_message_iterator( - self._input_ports['in'] - ) + self._msg_iter = self._create_message_iterator(self._input_ports["in"]) def _user_consume(self): nonlocal can_seek_beginning @@ -535,12 +626,10 @@ class UserMessageIteratorSeekBeginningTestCase(unittest.TestCase): # a _user_seek_beginning method. class MySink(bt2._UserSinkComponent): def __init__(self, config, params, obj): - self._add_input_port('in') + self._add_input_port("in") def _user_graph_is_configured(self): - self._msg_iter = self._create_input_port_message_iterator( - self._input_ports['in'] - ) + self._msg_iter = self._create_message_iterator(self._input_ports["in"]) def _user_consume(self): nonlocal can_seek_beginning @@ -554,19 +643,17 @@ class UserMessageIteratorSeekBeginningTestCase(unittest.TestCase): def test_can_seek_beginning_user_error(self): class MySink(bt2._UserSinkComponent): def __init__(self, config, params, obj): - self._add_input_port('in') + self._add_input_port("in") def _user_graph_is_configured(self): - self._msg_iter = self._create_input_port_message_iterator( - self._input_ports['in'] - ) + self._msg_iter = self._create_message_iterator(self._input_ports["in"]) def _user_consume(self): # This is expected to raise. self._msg_iter.can_seek_beginning() def _user_can_seek_beginning(self): - raise ValueError('moustiquaire') + raise ValueError("moustiquaire") graph = _setup_seek_test( MySink, @@ -578,24 +665,22 @@ class UserMessageIteratorSeekBeginningTestCase(unittest.TestCase): graph.run_once() cause = ctx.exception[0] - self.assertIn('ValueError: moustiquaire', cause.message) + self.assertIn("ValueError: moustiquaire", cause.message) def test_can_seek_beginning_wrong_return_value(self): class MySink(bt2._UserSinkComponent): def __init__(self, config, params, obj): - self._add_input_port('in') + self._add_input_port("in") def _user_graph_is_configured(self): - self._msg_iter = self._create_input_port_message_iterator( - self._input_ports['in'] - ) + self._msg_iter = self._create_message_iterator(self._input_ports["in"]) def _user_consume(self): # This is expected to raise. self._msg_iter.can_seek_beginning() def _user_can_seek_beginning(self): - return 'Amqui' + return "Amqui" graph = _setup_seek_test( MySink, @@ -612,12 +697,10 @@ class UserMessageIteratorSeekBeginningTestCase(unittest.TestCase): def test_seek_beginning(self): class MySink(bt2._UserSinkComponent): def __init__(self, config, params, obj): - self._add_input_port('in') + self._add_input_port("in") def _user_graph_is_configured(self): - self._msg_iter = self._create_input_port_message_iterator( - self._input_ports['in'] - ) + self._msg_iter = self._create_message_iterator(self._input_ports["in"]) def _user_consume(self): nonlocal do_seek_beginning @@ -656,18 +739,16 @@ class UserMessageIteratorSeekBeginningTestCase(unittest.TestCase): def test_seek_beginning_user_error(self): class MySink(bt2._UserSinkComponent): def __init__(self, config, params, obj): - self._add_input_port('in') + self._add_input_port("in") def _user_graph_is_configured(self): - self._msg_iter = self._create_input_port_message_iterator( - self._input_ports['in'] - ) + self._msg_iter = self._create_message_iterator(self._input_ports["in"]) def _user_consume(self): self._msg_iter.seek_beginning() def _user_seek_beginning(self): - raise ValueError('ouch') + raise ValueError("ouch") graph = _setup_seek_test(MySink, user_seek_beginning=_user_seek_beginning) @@ -719,7 +800,7 @@ class UserMessageIteratorSeekNsFromOriginTestCase(unittest.TestCase): ) def test_can_seek_ns_from_origin_returns_false_can_seek_beginning_forward_seekable( - self + self, ): # Test the case where: # @@ -738,7 +819,7 @@ class UserMessageIteratorSeekNsFromOriginTestCase(unittest.TestCase): ) def test_can_seek_ns_from_origin_returns_false_can_seek_beginning_not_forward_seekable( - self + self, ): # Test the case where: # @@ -757,7 +838,7 @@ class UserMessageIteratorSeekNsFromOriginTestCase(unittest.TestCase): ) def test_can_seek_ns_from_origin_returns_false_cant_seek_beginning_forward_seekable( - self + self, ): # Test the case where: # @@ -776,7 +857,7 @@ class UserMessageIteratorSeekNsFromOriginTestCase(unittest.TestCase): ) def test_can_seek_ns_from_origin_returns_false_cant_seek_beginning_not_forward_seekable( - self + self, ): # Test the case where: # @@ -814,7 +895,7 @@ class UserMessageIteratorSeekNsFromOriginTestCase(unittest.TestCase): ) def test_no_can_seek_ns_from_origin_no_seek_ns_from_origin_can_seek_beginning_forward_seekable( - self + self, ): # Test the case where: # @@ -833,7 +914,7 @@ class UserMessageIteratorSeekNsFromOriginTestCase(unittest.TestCase): ) def test_no_can_seek_ns_from_origin_no_seek_ns_from_origin_can_seek_beginning_not_forward_seekable( - self + self, ): # Test the case where: # @@ -852,7 +933,7 @@ class UserMessageIteratorSeekNsFromOriginTestCase(unittest.TestCase): ) def test_no_can_seek_ns_from_origin_no_seek_ns_from_origin_cant_seek_beginning_forward_seekable( - self + self, ): # Test the case where: # @@ -871,7 +952,7 @@ class UserMessageIteratorSeekNsFromOriginTestCase(unittest.TestCase): ) def test_no_can_seek_ns_from_origin_no_seek_ns_from_origin_cant_seek_beginning_not_forward_seekable( - self + self, ): # Test the case where: # @@ -899,12 +980,10 @@ class UserMessageIteratorSeekNsFromOriginTestCase(unittest.TestCase): ): class MySink(bt2._UserSinkComponent): def __init__(self, config, params, obj): - self._add_input_port('in') + self._add_input_port("in") def _user_graph_is_configured(self): - self._msg_iter = self._create_input_port_message_iterator( - self._input_ports['in'] - ) + self._msg_iter = self._create_message_iterator(self._input_ports["in"]) def _user_consume(self): nonlocal can_seek_ns_from_origin @@ -958,19 +1037,17 @@ class UserMessageIteratorSeekNsFromOriginTestCase(unittest.TestCase): def test_can_seek_ns_from_origin_user_error(self): class MySink(bt2._UserSinkComponent): def __init__(self, config, params, obj): - self._add_input_port('in') + self._add_input_port("in") def _user_graph_is_configured(self): - self._msg_iter = self._create_input_port_message_iterator( - self._input_ports['in'] - ) + self._msg_iter = self._create_message_iterator(self._input_ports["in"]) def _user_consume(self): # This is expected to raise. self._msg_iter.can_seek_ns_from_origin(2) def _user_can_seek_ns_from_origin(self, ns_from_origin): - raise ValueError('Joutel') + raise ValueError("Joutel") graph = _setup_seek_test( MySink, @@ -982,24 +1059,22 @@ class UserMessageIteratorSeekNsFromOriginTestCase(unittest.TestCase): graph.run_once() cause = ctx.exception[0] - self.assertIn('ValueError: Joutel', cause.message) + self.assertIn("ValueError: Joutel", cause.message) def test_can_seek_ns_from_origin_wrong_return_value(self): class MySink(bt2._UserSinkComponent): def __init__(self, config, params, obj): - self._add_input_port('in') + self._add_input_port("in") def _user_graph_is_configured(self): - self._msg_iter = self._create_input_port_message_iterator( - self._input_ports['in'] - ) + self._msg_iter = self._create_message_iterator(self._input_ports["in"]) def _user_consume(self): # This is expected to raise. self._msg_iter.can_seek_ns_from_origin(2) def _user_can_seek_ns_from_origin(self, ns_from_origin): - return 'Nitchequon' + return "Nitchequon" graph = _setup_seek_test( MySink, @@ -1016,12 +1091,10 @@ class UserMessageIteratorSeekNsFromOriginTestCase(unittest.TestCase): def test_seek_ns_from_origin(self): class MySink(bt2._UserSinkComponent): def __init__(self, config, params, obj): - self._add_input_port('in') + self._add_input_port("in") def _user_graph_is_configured(self): - self._msg_iter = self._create_input_port_message_iterator( - self._input_ports['in'] - ) + self._msg_iter = self._create_message_iterator(self._input_ports["in"]) def _user_consume(self): self._msg_iter.seek_ns_from_origin(17) @@ -1039,5 +1112,5 @@ class UserMessageIteratorSeekNsFromOriginTestCase(unittest.TestCase): self.assertEqual(actual_ns_from_origin, 17) -if __name__ == '__main__': +if __name__ == "__main__": unittest.main()