projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
lib: create input port msg iterator from self {msg iterator, sink comp.}
[babeltrace.git]
/
tests
/
bindings
/
python
/
bt2
/
test_graph.py
diff --git
a/tests/bindings/python/bt2/test_graph.py
b/tests/bindings/python/bt2/test_graph.py
index f6f5dcaae9eab4a5bc70d06e8f1fcb873d19a1f2..4f6aade1febc787f8544e736beac3edd5cb55647 100644
(file)
--- a/
tests/bindings/python/bt2/test_graph.py
+++ b/
tests/bindings/python/bt2/test_graph.py
@@
-224,7
+224,9
@@
class GraphTestCase(unittest.TestCase):
return next(self._msg_iter)
def _graph_is_configured(self):
return next(self._msg_iter)
def _graph_is_configured(self):
- self._msg_iter = self._input_ports['in'].create_message_iterator()
+ self._msg_iter = self._create_input_port_message_iterator(
+ self._input_ports['in']
+ )
graph = bt2.Graph()
up = graph.add_component(MySource, 'down')
graph = bt2.Graph()
up = graph.add_component(MySource, 'down')
@@
-280,7
+282,9
@@
class GraphTestCase(unittest.TestCase):
comp_self._at += 1
def _graph_is_configured(self):
comp_self._at += 1
def _graph_is_configured(self):
- self._msg_iter = self._input_port.create_message_iterator()
+ self._msg_iter = self._create_input_port_message_iterator(
+ self._input_port
+ )
src = self._graph.add_component(MySource, 'src')
sink = self._graph.add_component(MySink, 'sink')
src = self._graph.add_component(MySource, 'src')
sink = self._graph.add_component(MySink, 'sink')
@@
-329,7
+333,9
@@
class GraphTestCase(unittest.TestCase):
comp_self._at += 1
def _graph_is_configured(self):
comp_self._at += 1
def _graph_is_configured(self):
- self._msg_iter = self._input_port.create_message_iterator()
+ self._msg_iter = self._create_input_port_message_iterator(
+ self._input_port
+ )
src = self._graph.add_component(MySource, 'src')
sink = self._graph.add_component(MySink, 'sink')
src = self._graph.add_component(MySource, 'src')
sink = self._graph.add_component(MySink, 'sink')
@@
-386,7
+392,9
@@
class GraphTestCase(unittest.TestCase):
comp_self._at += 1
def _graph_is_configured(self):
comp_self._at += 1
def _graph_is_configured(self):
- self._msg_iter = self._input_port.create_message_iterator()
+ self._msg_iter = self._create_input_port_message_iterator(
+ self._input_port
+ )
src = self._graph.add_component(MySource, 'src')
sink = self._graph.add_component(MySink, 'sink')
src = self._graph.add_component(MySource, 'src')
sink = self._graph.add_component(MySink, 'sink')
This page took
0.025422 seconds
and
4
git commands to generate.