light9 Changeset - ce1c73235ee2

Changeset - ce1c73235ee2

Parent rev.

Child rev.

[Not reviewed]

default

0 3 0

drewp@bigasterisk.com - 20 months ago 2023-05-30 05:32:50
drewp@bigasterisk.com

minor

3 files changed with 3 insertions and 3 deletions:

light9/collector/collector_client_asyncio.py

light9/collector/service.py

light9/effect/sequencer/service.py

0 comments (0 inline, 0 general)

light9/collector/collector_client_asyncio.py

➞

Show inline comments

@@ @@ -32,7 +32,7 @@ class _Sender: @@
     async def send(self, client: str, session: str, settings: DeviceSettings):
         msg = toCollectorJson(client, session, settings).encode('utf8')
         # log.info(f'send {len(msg)}')
+        # log.info(f'zmq send {len(msg)}')
         await self.socket.send_multipart([b'setAttr', msg])

light9/collector/service.py

➞

Show inline comments

@@ @@ -84,6 +84,7 @@ async def zmqListener(collector): @@
             [topic, msg] = await sock.recv_multipart()
             if topic != b'setAttr':
                 raise ValueError(topic)
             # log.info(f'zmq recv {len(msg)}')
             client, clientSession, settings, sendTime = parseJsonMessage(collector.graph, msg)
             collector.setAttrs(client, clientSession, settings, sendTime)
     except:

light9/effect/sequencer/service.py

➞

Show inline comments

@@ @@ -19,7 +19,6 @@ from light9 import networking @@
 from light9.collector.collector_client_asyncio import sendToCollector
 from light9.effect.sequencer.eval_faders import FaderEval
 from light9.effect.sequencer.sequencer import Sequencer, StateUpdate
 from light9.metrics import metrics
 from light9.run_local import log
 RATE = 20
@@ @@ -62,7 +61,7 @@ def main(): @@
         ds = faders.computeOutput()
         await sendToCollector('effectSequencer', session='0', settings=ds)
     faders_loop = loop_forever(update, metric_prefix='faders', sleep_period=1 / RATE)
+    faders_loop = loop_forever(func=update, metric_prefix='faders', sleep_period=1 / RATE)
     app = Starlette(
         debug=True,

0 comments (0 inline, 0 general)