2025-05-10 19:30:36 +08:00
|
|
|
import zmq
|
|
|
|
|
|
2025-05-11 17:35:37 +08:00
|
|
|
from flandre import C
|
2025-05-10 19:30:36 +08:00
|
|
|
from flandre.utils.RfFrame import b2t
|
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
|
|
context = zmq.Context()
|
|
|
|
|
device_socket = context.socket(zmq.PULL)
|
|
|
|
|
device_socket.connect(C.live_push_socket)
|
|
|
|
|
last_ts = 0
|
|
|
|
|
while True:
|
|
|
|
|
buffer = device_socket.recv()
|
|
|
|
|
ts, sequence_id, encoder, s = b2t(buffer)
|
|
|
|
|
if last_ts == ts:
|
|
|
|
|
print(ts)
|
|
|
|
|
last_ts = ts
|
