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

fix local buffer bug

Browse Source
This commit is contained in:
Junzi Sun 2019-08-26 16:38:36 +02:00
parent cfcd21b692
commit b062bdf998
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pyModeS/streamer/source.py
View File

@ -6,6 +6,9 @@ from pyModeS.extra.rtlreader import RtlReader
class NetSource(TcpClient): class NetSource(TcpClient):
def __init__(self, host, port, rawtype): def __init__(self, host, port, rawtype):
super(NetSource, self).__init__(host, port, rawtype) super(NetSource, self).__init__(host, port, rawtype)
self.reset_local_buffer()
def reset_local_buffer(self):
self.local_buffer_adsb_msg = [] self.local_buffer_adsb_msg = []
self.local_buffer_adsb_ts = [] self.local_buffer_adsb_ts = []
self.local_buffer_commb_msg = [] self.local_buffer_commb_msg = []
@ -41,11 +44,15 @@ class NetSource(TcpClient):
"commb_msg": self.local_buffer_commb_msg, "commb_msg": self.local_buffer_commb_msg,
} }
) )
self.reset_local_buffer()
class RtlSdrSource(RtlReader): class RtlSdrSource(RtlReader):
def __init__(self): def __init__(self):
super(RtlSdrSource, self).__init__() super(RtlSdrSource, self).__init__()
self.reset_local_buffer()
def reset_local_buffer(self):
self.local_buffer_adsb_msg = [] self.local_buffer_adsb_msg = []
self.local_buffer_adsb_ts = [] self.local_buffer_adsb_ts = []
self.local_buffer_commb_msg = [] self.local_buffer_commb_msg = []
@ -81,3 +88,4 @@ class RtlSdrSource(RtlReader):
"commb_msg": self.local_buffer_commb_msg, "commb_msg": self.local_buffer_commb_msg,
} }
) )
self.reset_local_buffer()