hero123457/uhd
1
0
Fork 0
mirror of https://github.com/EttusResearch/uhd.git synced 2026-10-25 17:36:10 +00:00
Code Issues Projects Releases Wiki Activity

python: skip output buffer flushing when wait_for_buffer_complete is False

Browse Source
This commit is contained in:
Max Köhler 2026-03-13 13:18:09 +01:00 committed by Martin Braun
parent be13c71d6a
commit 06ad932994
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
host/python/uhd/usrp/dram_utils.py
View File

@ -726,12 +726,16 @@ class DramReceiver:
tmp_stream_cmd = stream_cmd
for idx, rcp in enumerate(self.radio_chan_pairs):
stream_cmd = tmp_stream_cmd
# Flush data on output buffer
flush_timeout = time.monotonic() + 0.25
while time.monotonic() < flush_timeout:
if self.replay_blocks[0].get_record_fullness(ports[idx]) == 0:
break
self.replay_blocks[0].record_restart(ports[idx])
# Flush data on output buffer only if wait_for_buffer_complete is
# set. The record and record_restart calls below both reset the FPGA
# record engine. When the record engine state is known the flush
# loop can be skipped for speedup.
if wait_for_buffer_complete:
flush_timeout = time.monotonic() + 0.25
while time.monotonic() < flush_timeout:
if self.replay_blocks[0].get_record_fullness(ports[idx]) == 0:
break
self.replay_blocks[0].record_restart(ports[idx])
mem_region = mem_regions[ports[idx]]
mem_size = min(stream_cmd.num_samps * self.bytes_per_sample, mem_region[1])
self.replay_blocks[0].record(mem_region[0], mem_size, ports[idx])