summaryrefslogtreecommitdiff
path: root/grc/python/FlowGraph.py
diff options
context:
space:
mode:
authorJohnathan Corgan <johnathan@corganlabs.com>2012-12-07 10:06:29 -0800
committerJohnathan Corgan <johnathan@corganlabs.com>2012-12-07 10:07:52 -0800
commitddb6ada4dbd0fa8db97ba6f2f4d2d8cb4149c8f1 (patch)
tree5faf735022d164b5f222a2d1b6e11b0b901f8a28 /grc/python/FlowGraph.py
parent583ba9b96ce3c3e52173cd847a0c00ff10c1cf85 (diff)
parent52ca5e2765b7a4532d26502b5b76b7c85c5019d7 (diff)
Merge branch 'master' into next
Conflicts: gnuradio-core/src/lib/runtime/gr_basic_block.h
Diffstat (limited to 'grc/python/FlowGraph.py')
-rw-r--r--grc/python/FlowGraph.py10
1 files changed, 10 insertions, 0 deletions
diff --git a/grc/python/FlowGraph.py b/grc/python/FlowGraph.py
index b68d497e58..055488b314 100644
--- a/grc/python/FlowGraph.py
+++ b/grc/python/FlowGraph.py
@@ -66,6 +66,8 @@ class FlowGraph(_FlowGraph, _GUIFlowGraph):
'in': self.get_pad_sources(),
'out': self.get_pad_sinks(),
}[direction]
+ # we only want stream ports
+ sorted_pads = filter(lambda b: b.get_param('type').get_evaluated() != 'message', sorted_pads);
#load io signature
return [{
'label': str(pad.get_param('label').get_evaluated()),
@@ -95,6 +97,14 @@ class FlowGraph(_FlowGraph, _GUIFlowGraph):
pads = filter(lambda b: b.get_key() == 'pad_sink', self.get_enabled_blocks())
return sorted(pads, lambda x, y: cmp(x.get_id(), y.get_id()))
+ def get_msg_pad_sources(self):
+ ps = self.get_pad_sources();
+ return filter(lambda b: b.get_param('type').get_evaluated() == 'message', ps);
+
+ def get_msg_pad_sinks(self):
+ ps = self.get_pad_sinks();
+ return filter(lambda b: b.get_param('type').get_evaluated() == 'message', ps);
+
def get_imports(self):
"""
Get a set of all import statments in this flow graph namespace.