From d018e1cf1a6ee45dd86f6675e9f27ddfd620f333 Mon Sep 17 00:00:00 2001
From: flandre <remilia@flandre.net>
Date: Tue, 13 May 2025 22:04:30 +0800
Subject: [PATCH] add recvplotdiff

---
 flandre/launcher.py | 37 ++++++++++++++++++++++++++++++-------
 1 file changed, 30 insertions(+), 7 deletions(-)

diff --git a/flandre/launcher.py b/flandre/launcher.py
index ba58c14..1cb9c63 100644
--- a/flandre/launcher.py
+++ b/flandre/launcher.py
@@ -233,12 +233,35 @@ def device_recvplot():
             last_ts = ts
             first = False
             continue
-        print((ts - last_ts)/10**6,flush=True)
+        print((ts - last_ts) / 10 ** 6, flush=True)
         last_ts = ts
 
+
+@device.command('recvplotdiff')
+def device_recvplotdiff():
+    ctx = zmq.Context()
+    pull = ctx.socket(zmq.PULL)
+    pull.connect(C.live_push_socket)
+    last_ts = 0
+    max_interval = 0
+    first = True
+    while True:
+        b = pull.recv()
+
+        ts, sequence_id, encoder, buffer = b2t(b)
+        if first:
+            last_ts = ts
+            first = False
+            continue
+        max_interval = max(max_interval, ts - last_ts)
+        print(max_interval / 10 ** 6, flush=True)
+        last_ts = ts
+
+
 def b2b(b):
     return hashlib.blake2b(b, digest_size=4).hexdigest()
 
+
 @device.command('recvzero')
 def device_recvzero():
     ctx = zmq.Context()
@@ -251,12 +274,12 @@ def device_recvzero():
     while True:
         b = pull.recv()
         ts, sequence_id, encoder, buffer = b2t(b)
-        if ts==last_ts:
-            print('tszero', sequence_id, encoder, (ts - last_ts)/10**6,flush=True)
-            print(b2b(b),b2b(last_b))
-        if sequence_id==last_sequence_id:
-            print('szero', sequence_id, encoder,flush=True)
-            print(b2b(b),b2b(last_b))
+        if ts == last_ts:
+            print('tszero', sequence_id, encoder, (ts - last_ts) / 10 ** 6, flush=True)
+            print(b2b(b), b2b(last_b))
+        if sequence_id == last_sequence_id:
+            print('szero', sequence_id, encoder, flush=True)
+            print(b2b(b), b2b(last_b))
         last_ts = ts
         last_sequence_id = sequence_id
         last_b = b