summaryrefslogtreecommitdiff
path: root/gr-wxgui
diff options
context:
space:
mode:
authorJosh Blum2009-10-07 18:47:21 -0700
committerJosh Blum2009-10-07 18:47:21 -0700
commitdfa5e0a5bccb6b3539c1230281b5bec60196f8a2 (patch)
tree23aa5975bd1911765a8be0964229afa124f3d8de /gr-wxgui
parent64a5167c53eeb2d2a657507397b402abe22f67b6 (diff)
downloadgnuradio-dfa5e0a5bccb6b3539c1230281b5bec60196f8a2.tar.gz
gnuradio-dfa5e0a5bccb6b3539c1230281b5bec60196f8a2.tar.bz2
gnuradio-dfa5e0a5bccb6b3539c1230281b5bec60196f8a2.zip
simplify some params
Diffstat (limited to 'gr-wxgui')
-rw-r--r--gr-wxgui/src/python/common.py28
1 files changed, 13 insertions, 15 deletions
diff --git a/gr-wxgui/src/python/common.py b/gr-wxgui/src/python/common.py
index aae4d63cf..9bf3094f2 100644
--- a/gr-wxgui/src/python/common.py
+++ b/gr-wxgui/src/python/common.py
@@ -55,39 +55,37 @@ class wxgui_hb(object):
Initially call the handler to setup the fg.
Bind the handler to the visibility meta event.
"""
- handler = self._conditional_connect_handler_factory(
- source=source, sink=sink, win=self.win, hb=self,
- size=self._hb.input_signature().sizeof_stream_item(0),
- )
+ handler = self._conditional_connect_handler_factory(source=source, sink=sink)
handler(False, init=True) #initially connect
self._bind_to_visible_event(win=self.win, handler=handler)
- @staticmethod
- def _conditional_connect_handler_factory(source, sink, hb, win, size):
+ def _conditional_connect_handler_factory(self, source, sink):
"""
Create a function that will handle the re-connections based on a flag.
The current state of the connection is stored in the namespace.
+ !!!#TODO This entire method could be replaced with a mute block that starves the stream.
"""
nulls = list()
cache = [None]
+ size = self._hb.input_signature().sizeof_stream_item(0)
def callback(visible, init=False):
if visible == cache[0]: return
cache[0] = visible
- if not init: hb.lock()
+ if not init: self.lock()
#print 'visible', visible, source, sink
if visible:
if not init:
- hb.disconnect(source, nulls[0])
- hb.disconnect(nulls[1], nulls[2])
- hb.disconnect(nulls[2], sink)
+ self.disconnect(source, nulls[0])
+ self.disconnect(nulls[1], nulls[2])
+ self.disconnect(nulls[2], sink)
while nulls: nulls.pop()
- hb.connect(source, sink)
+ self.connect(source, sink)
else:
- if not init: hb.disconnect(source, sink)
+ if not init: self.disconnect(source, sink)
nulls.extend([gr.null_sink(size), gr.null_source(size), gr.head(size, 0)])
- hb.connect(source, nulls[0])
- hb.connect(nulls[1], nulls[2], sink)
- if not init: hb.unlock()
+ self.connect(source, nulls[0])
+ self.connect(nulls[1], nulls[2], sink)
+ if not init: self.unlock()
return callback
@staticmethod