X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=tests%2Fbindings%2Fpython%2Fbt2%2Ftest_connection.py;h=7ec6bb01188980c04bc22a0cfa1673b3bd67603a;hb=f5567ea88d172767b34373bc6e402da8bfd85ef8;hp=d25e7178199032d67da9a672f3a44d019e1b625c;hpb=5c61fb9d5be835a0efc87f7764117c4d05e0ae5a;p=babeltrace.git diff --git a/tests/bindings/python/bt2/test_connection.py b/tests/bindings/python/bt2/test_connection.py index d25e7178..7ec6bb01 100644 --- a/tests/bindings/python/bt2/test_connection.py +++ b/tests/bindings/python/bt2/test_connection.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 @@ -28,19 +15,19 @@ class ConnectionTestCase(unittest.TestCase): bt2._UserSourceComponent, message_iterator_class=bt2._UserMessageIterator ): 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_consume(self): raise bt2.Stop graph = bt2.Graph() - src = graph.add_component(MySource, 'src') - sink = graph.add_component(MySink, 'sink') - conn = graph.connect_ports(src.output_ports['out'], sink.input_ports['in']) + src = graph.add_component(MySource, "src") + sink = graph.add_component(MySink, "sink") + conn = graph.connect_ports(src.output_ports["out"], sink.input_ports["in"]) self.assertIs(type(conn), bt2_connection._ConnectionConst) def test_downstream_port(self): @@ -48,20 +35,20 @@ class ConnectionTestCase(unittest.TestCase): bt2._UserSourceComponent, message_iterator_class=bt2._UserMessageIterator ): 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_consume(self): raise bt2.Stop graph = bt2.Graph() - src = graph.add_component(MySource, 'src') - sink = graph.add_component(MySink, 'sink') - conn = graph.connect_ports(src.output_ports['out'], sink.input_ports['in']) - self.assertEqual(conn.downstream_port.addr, sink.input_ports['in'].addr) + src = graph.add_component(MySource, "src") + sink = graph.add_component(MySink, "sink") + conn = graph.connect_ports(src.output_ports["out"], sink.input_ports["in"]) + self.assertEqual(conn.downstream_port.addr, sink.input_ports["in"].addr) self.assertIs(type(conn), bt2_connection._ConnectionConst) self.assertIs(type(conn.downstream_port), bt2_port._InputPortConst) @@ -70,22 +57,22 @@ class ConnectionTestCase(unittest.TestCase): bt2._UserSourceComponent, message_iterator_class=bt2._UserMessageIterator ): 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_consume(self): raise bt2.Stop graph = bt2.Graph() - src = graph.add_component(MySource, 'src') - sink = graph.add_component(MySink, 'sink') - conn = graph.connect_ports(src.output_ports['out'], sink.input_ports['in']) - self.assertEqual(conn.upstream_port.addr, src.output_ports['out'].addr) + src = graph.add_component(MySource, "src") + sink = graph.add_component(MySink, "sink") + conn = graph.connect_ports(src.output_ports["out"], sink.input_ports["in"]) + self.assertEqual(conn.upstream_port.addr, src.output_ports["out"].addr) self.assertIs(type(conn.upstream_port), bt2_port._OutputPortConst) -if __name__ == '__main__': +if __name__ == "__main__": unittest.main()