M-Labs
/
artiq
mirror of https://github.com/m-labs/artiq.git
2
0
Fork 2
Code Issues Projects Releases Wiki Activity

applets/simple: support mod buffering

This commit is contained in:
Sebastien Bourdeauducq 2016-01-10 22:12:00 +08:00
parent e2c7578e48
commit 38cdeb0a32
2 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artiq/applets/big_number.py
View File

@ -11,7 +11,7 @@ class NumberWidget(QtWidgets.QLCDNumber):
self.setDigitCount(args.digit_count) self.setDigitCount(args.digit_count)
self.dataset_name = args.dataset self.dataset_name = args.dataset
def data_changed(self, data, mod): def data_changed(self, data, mods):
try: try:
n = float(data[self.dataset_name][1]) n = float(data[self.dataset_name][1])
except (KeyError, ValueError, TypeError): except (KeyError, ValueError, TypeError):

21
artiq/applets/simple.py
View File

@ -8,10 +8,15 @@ from artiq.protocols.pc_rpc import Client
class SimpleApplet: class SimpleApplet:
def __init__(self, main_widget_class, cmd_description=None): def __init__(self, main_widget_class, cmd_description=None,
default_update_delay=0.0):
self.main_widget_class = main_widget_class self.main_widget_class = main_widget_class
self.argparser = argparse.ArgumentParser(description=cmd_description) self.argparser = argparse.ArgumentParser(description=cmd_description)
self.argparser.add_argument("--update-delay", type=float,
default=default_update_delay,
help="time to wait after a mod (buffering other mods) "
"before updating (default: %(default).2f)")
group = self.argparser.add_argument_group("data server") group = self.argparser.add_argument_group("data server")
group.add_argument( group.add_argument(
"--server-notify", default="::1", "--server-notify", default="::1",
@ -71,8 +76,20 @@ class SimpleApplet:
self.data = data self.data = data
return data return data
def flush_mod_buffer(self):
self.main_widget.data_changed(self.data, self.mod_buffer)
del self.mod_buffer
def sub_mod(self, mod): def sub_mod(self, mod):
self.main_widget.data_changed(self.data, mod) if self.args.update_delay:
if hasattr(self, "mod_buffer"):
self.mod_buffer.append(mod)
else:
self.mod_buffer = [mod]
asyncio.get_event_loop().call_later(self.args.update_delay,
self.flush_mod_buffer)
else:
self.main_widget.data_changed(self.data, [mod])
def create_subscriber(self): def create_subscriber(self):
self.subscriber = Subscriber("datasets", self.subscriber = Subscriber("datasets",