|
|
@@ -114,9 +114,10 @@ class SurveillanceRadar:
|
|
|
self.rx_stream.issue_stream_cmd(stream_cmd)
|
|
|
metadata = uhd.types.RXMetadata()
|
|
|
|
|
|
- buff = np.zeros((self.samps_per_packet,), dtype=np.complex64)
|
|
|
+
|
|
|
while not self.stop_event.is_set():
|
|
|
try:
|
|
|
+ buff = np.zeros((self.samps_per_packet,), dtype=np.complex64)
|
|
|
num_rx = self.rx_stream.recv(buff, metadata,timeout=10)
|
|
|
# time.sleep(0.5)
|
|
|
if metadata.error_code != uhd.types.RXMetadataErrorCode.none:
|
|
|
@@ -128,7 +129,8 @@ class SurveillanceRadar:
|
|
|
#如果队列已满，则去对头元素
|
|
|
if self.rx_buffer.full():
|
|
|
self.rx_buffer.get()
|
|
|
- self.rx_buffer.put(buff.copy()[:num_rx])
|
|
|
+ self.rx_buffer.put(buff.copy()[:num_rx], block=False)
|
|
|
+ del buff
|
|
|
except Exception as e:
|
|
|
# stream_cmd = uhd.types.StreamCMD(uhd.types.StreamMode.stop_cont)
|
|
|
# self.usrp.issue_stream_cmd(stream_cmd)
|
