yukari/flandre
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

opt

Browse Source
This commit is contained in:
flandre 2025-04-16 18:01:26 +08:00
parent 11692de405
commit 442b6a672d
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
flandre/nodes/Muxer.py
View File

@ -29,6 +29,7 @@ class Muxer(Node):
self.req_driver_socket: zmq.Socket = None self.req_driver_socket: zmq.Socket = None
self.playback_rf_msg: RfFrameMsg | None = None self.playback_rf_msg: RfFrameMsg | None = None
self.device_enabled = False self.device_enabled = False
self.driver_data_raw = b''
def custom_setup(self): def custom_setup(self):
self.rep_socket: zmq.Socket = self.c.ctx.socket(zmq.REP) self.rep_socket: zmq.Socket = self.c.ctx.socket(zmq.REP)
@ -55,13 +56,13 @@ class Muxer(Node):
logger.warning('Device not enabled') logger.warning('Device not enabled')
return return
self.req_driver_socket.send(b'') self.req_driver_socket.send(b'')
driver_data_raw = self.req_driver_socket.recv() self.driver_data_raw = self.req_driver_socket.recv()
if driver_data_raw == b'': if self.driver_data_raw == b'':
# todo fixit driver no empty # todo fixit driver no empty
self.rep_socket.send(BeamformerMsg(b'nop').encode_msg()) self.rep_socket.send(BeamformerMsg(b'nop').encode_msg())
return return
_, _, sequence_id, encoder = struct.unpack_from('=iiii', driver_data_raw) _, _, sequence_id, encoder = struct.unpack_from('=iiii', self.driver_data_raw)
driver_data_body = driver_data_raw[4 + 8 + 4:] driver_data_body = self.driver_data_raw[4 + 8 + 4:]
data_msg = RfFrameMsg(0, RfFrameMemory( data_msg = RfFrameMsg(0, RfFrameMemory(
RfFrameMeta( RfFrameMeta(
encoder=encoder, encoder=encoder,