diff --git a/flandre/launcher.py b/flandre/launcher.py
index f0efc61..c15f2eb 100644
--- a/flandre/launcher.py
+++ b/flandre/launcher.py
@@ -238,6 +238,17 @@ def device_upload(name, file: TextIOWrapper):
     dd.set_name_and_file_only(name, file.read())
 
 
+
+@device.command('recvm')
+def device_recvmonitor():
+    ctx = zmq.Context()
+    pull = ctx.socket(zmq.PULL)
+    pull.connect(C.live_push_socket)
+    while True:
+        b = pull.recv()
+        seq, encoder, host_ts, device_ts_low, device_ts_high, buffer = b2t(b)
+        print(seq, encoder, host_ts, device_ts_low, device_ts_high)
+
 @device.command('recvplot')
 def device_recvplot():
     ctx = zmq.Context()
diff --git a/flandre/utils/RfFrame.py b/flandre/utils/RfFrame.py
index e928a1b..ab7045d 100644
--- a/flandre/utils/RfFrame.py
+++ b/flandre/utils/RfFrame.py
@@ -41,6 +41,17 @@ class RfFrameMemory(RfFrame):
 
 
 def b2t(b: bytes):
-    _, sequence_id, ts, encoder = struct.unpack_from('=IQQi', b)
-    buffer = b[4 + 8 + 8 + 4:]
-    return ts, sequence_id, encoder, buffer
+    # _, seq, encoder, host_ts, driver_ts = struct.unpack_from('<iQiQQ', b)
+    # _, seq, encoder, host_ts, driver_ts = struct.unpack_from('=QQiQi', b)
+    # driver_ts, host_ts, encoder, seq = struct.unpack_from('QQiQ', b)
+    # buffer = b[4 + 8 + 8 + 8 + 4:]
+    # return seq, encoder, host_ts, driver_ts, buffer
+
+    magic, seq, encoder, host_ts, device_ts_low, device_ts_high = struct.unpack_from('iQiQII', b)
+    # bb = b[4 + 8 + 4 + 8:4 + 8 + 4 + 8 + 4]
+    # device_ts_low = struct.unpack('<I', bb)
+    # device_ts_low = b[4 + 8 + 4 + 8:4 + 8 + 4 + 8 + 4]
+    # print(bin(device_ts_low[0]),bin(device_ts_low[1]),bin(device_ts_low[2]),bin(device_ts_low[3]))
+    buffer = b[4 + 8 + 8 + 8 + 4:]
+
+    return seq, encoder, host_ts, device_ts_low, device_ts_high, buffer