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

correctly close iqtee / iqtee2 pipes

Browse Source
This commit is contained in:
Jakob Ketterl
2020-07-18 20:00:49 +02:00
parent e53f1f60eb
commit 174e9afa7b
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
csdr/csdr.py
View File

@@ -95,10 +95,9 @@ class Pipe(object):
self.file = open(self.path, self.direction, encoding=self.encoding) self.file = open(self.path, self.direction, encoding=self.encoding)
def close(self): def close(self):
if self.file is None:
return
try: try:
self.file.close() if self.file is not None:
self.file.close()
os.unlink(self.path) os.unlink(self.path)
except FileNotFoundError: except FileNotFoundError:
# it seems like we keep calling this twice. no idea why, but we don't need the resulting error. # it seems like we keep calling this twice. no idea why, but we don't need the resulting error.
@@ -685,6 +684,9 @@ class dsp(object):
def try_create_pipes(self, pipe_names, command_base): def try_create_pipes(self, pipe_names, command_base):
for pipe_name, pipe_type in pipe_names.items(): for pipe_name, pipe_type in pipe_names.items():
if self.has_pipe(pipe_name):
logger.warning("{pipe_name} is still in use", pipe_name=pipe_name)
self.pipes[pipe_name].close()
if "{" + pipe_name + "}" in command_base: if "{" + pipe_name + "}" in command_base:
p = self.pipe_base_path + pipe_name p = self.pipe_base_path + pipe_name
encoding = None encoding = None