FGFS-4.1/pyModeS
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix exception buffer bug

Browse Source
This commit is contained in:
Junzi Sun 2020-08-17 00:53:49 +02:00
parent 2bdd638cef
commit 0ced97e3eb
2 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pyModeS/extra/rtlreader.py
View File

@ -31,6 +31,8 @@ class RtlReader(object):
self.stop_flag = False self.stop_flag = False
self.noise_floor = 1e6 self.noise_floor = 1e6
self.exception_queue = None
def _calc_noise(self): def _calc_noise(self):
"""Calculate noise floor""" """Calculate noise floor"""
window = smaples_per_microsec * 100 window = smaples_per_microsec * 100
@ -162,6 +164,7 @@ class RtlReader(object):
def run(self, raw_pipe_in=None, stop_flag=None, exception_queue=None): def run(self, raw_pipe_in=None, stop_flag=None, exception_queue=None):
self.raw_pipe_in = raw_pipe_in self.raw_pipe_in = raw_pipe_in
self.exception_queue = exception_queue
self.stop_flag = stop_flag self.stop_flag = stop_flag
try: try:
@ -173,8 +176,8 @@ class RtlReader(object):
except Exception as e: except Exception as e:
tb = traceback.format_exc() tb = traceback.format_exc()
if exception_queue is not None: if self.exception_queue is not None:
exception_queue.put(tb) self.exception_queue.put(tb)
raise e raise e

6
pyModeS/extra/tcpclient.py
View File

@ -28,6 +28,8 @@ class TcpClient(object):
self.raw_pipe_in = None self.raw_pipe_in = None
self.stop_flag = False self.stop_flag = False
self.exception_queue = None
def connect(self): def connect(self):
self.socket = zmq.Context().socket(zmq.STREAM) self.socket = zmq.Context().socket(zmq.STREAM)
self.socket.setsockopt(zmq.LINGER, 0) self.socket.setsockopt(zmq.LINGER, 0)
@ -255,6 +257,7 @@ class TcpClient(object):
def run(self, raw_pipe_in=None, stop_flag=None, exception_queue=None): def run(self, raw_pipe_in=None, stop_flag=None, exception_queue=None):
self.raw_pipe_in = raw_pipe_in self.raw_pipe_in = raw_pipe_in
self.exception_queue = exception_queue
self.stop_flag = stop_flag self.stop_flag = stop_flag
self.connect() self.connect()
@ -286,7 +289,8 @@ class TcpClient(object):
continue continue
except Exception as e: except Exception as e:
tb = traceback.format_exc() tb = traceback.format_exc()
exception_queue.put(tb) if self.exception_queue is not None:
self.exception_queue.put(tb)
raise e raise e