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

fix frame bug

Browse Source
This commit is contained in:
scarlet 2025-05-26 23:16:52 -07:00
parent 2cd7c4ee35
commit 2d31f2acb4
6 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
flandre/__init__.py
View File

@ -60,7 +60,7 @@ class SoftwareConfig:
video_height: int = 1080 video_height: int = 1080
video_width: int = 960 video_width: int = 960
live_ip: str = 'vmaosmax' live_ip: str = 'scarlet'
live_push_port: int = 5555 live_push_port: int = 5555
live_rep_port: int = 5556 live_rep_port: int = 5556
device_py_rep_port: int = 5558 device_py_rep_port: int = 5558

6
flandre/launcher.py
View File

@ -240,6 +240,12 @@ def device_end_capture():
def device_upload(name, file: TextIOWrapper): def device_upload(name, file: TextIOWrapper):
dd.set_name_and_file_only(name, file.read()) dd.set_name_and_file_only(name, file.read())
@device.command('recv_single')
def device_recvmonitor():
r = dd.get_data()
seq, encoder, host_ts, device_ts_low, device_ts_high, buffer = b2t(r)
print(seq, encoder, host_ts, device_ts_low, device_ts_high)
print((buffer.__len__()//2)/256)
@device.command('recvm') @device.command('recvm')
def device_recvmonitor(): def device_recvmonitor():

3
flandre/nodes/Beamformer.py
View File

@ -113,6 +113,9 @@ class Beamformer(Node):
continue continue
mat = RfMat.from_rf_frame(rf_frame_msg.rf_frame, 'gpu') mat = RfMat.from_rf_frame(rf_frame_msg.rf_frame, 'gpu')
# logger.info(mat.frame_meta.blake2b) # logger.info(mat.frame_meta.blake2b)
if mat is None:
logger.warning(f"{rf_frame_msg.rf_frame.seq_meta.prod()} , {rf_frame_msg.rf_frame.__bytes__().__len__() // 2}")
continue
last_blake2b = mat.frame_meta.blake2b last_blake2b = mat.frame_meta.blake2b
if mat is None: if mat is None:

3
flandre/nodes/Muxer.py
View File

@ -80,7 +80,8 @@ class Muxer(Node):
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('=IQi', self.driver_data_raw) # _, sequence_id, encoder = struct.unpack_from('=IQi', self.driver_data_raw)
ts, sequence_id, encoder, driver_data_body = b2t(self.driver_data_raw) # ts, sequence_id, encoder, driver_data_body = b2t(self.driver_data_raw)
sequence_id, encoder, host_ts, device_ts_low, device_ts_high, driver_data_body = b2t(self.driver_data_raw)
data_msg = RfFrameMsg(0, RfFrameMemory( data_msg = RfFrameMsg(0, RfFrameMemory(
RfFrameMeta( RfFrameMeta(
encoder=encoder, encoder=encoder,

2
flandre/pyqt/Image.py
View File

@ -1,4 +1,4 @@
# Form implementation generated from reading ui file '/home/lambda/source/scarlet/flandre/flandre/pyqt/Image.ui' # Form implementation generated from reading ui file 'C:\Users\lambda\source\scarlet\flandre\flandre\pyqt\Image.ui'
# #
# Created by: PyQt6 UI code generator 6.8.0 # Created by: PyQt6 UI code generator 6.8.0
# #

2
flandre/utils/RfFrame.py
View File

@ -52,6 +52,6 @@ def b2t(b: bytes):
# device_ts_low = struct.unpack('<I', bb) # device_ts_low = struct.unpack('<I', bb)
# device_ts_low = b[4 + 8 + 4 + 8:4 + 8 + 4 + 8 + 4] # 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])) # 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 + 4 + 8 + 4 + 4:] buffer = b[4 + 8 + 4 + 8 + 4 + 4+4+4:]
return seq, encoder, host_ts, device_ts_low, device_ts_high, buffer return seq, encoder, host_ts, device_ts_low, device_ts_high, buffer