joachim/openwebrx-clone
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

lock on dsp to avoid race conditions

Browse Source
This commit is contained in:
Jakob Ketterl 2021-04-27 16:58:23 +02:00
parent 0c7b0d2eaa
commit 118335b2b6
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
owrx/connection.py
View File

@ -140,6 +140,7 @@ class OpenWebRxReceiverClient(OpenWebRxClient, SdrSourceEventClient):
super().__init__(conn) super().__init__(conn)
self.dsp = None self.dsp = None
self.dspLock = threading.Lock()
self.sdr = None self.sdr = None
self.configSubs = [] self.configSubs = []
self.bookmarkSub = None self.bookmarkSub = None
@ -351,15 +352,17 @@ class OpenWebRxReceiverClient(OpenWebRxClient, SdrSourceEventClient):
super().close() super().close()
def stopDsp(self): def stopDsp(self):
if self.dsp is not None: with self.dspLock:
self.dsp.stop() if self.dsp is not None:
self.dsp = None self.dsp.stop()
self.dsp = None
if self.sdr is not None: if self.sdr is not None:
self.sdr.removeSpectrumClient(self) self.sdr.removeSpectrumClient(self)
def getDsp(self): def getDsp(self):
if self.dsp is None and self.sdr is not None: with self.dspLock:
self.dsp = DspManager(self, self.sdr) if self.dsp is None and self.sdr is not None:
self.dsp = DspManager(self, self.sdr)
return self.dsp return self.dsp
def write_spectrum_data(self, data): def write_spectrum_data(self, data):