From 5bc69b6fa43838f4bc52b4718e2056bd26f89b5d Mon Sep 17 00:00:00 2001 From: Jakob Ketterl Date: Thu, 13 Aug 2020 23:51:11 +0200 Subject: [PATCH] use id of pipe to avoid file system collisions --- csdr/csdr.py | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/csdr/csdr.py b/csdr/csdr.py index d8dd6ed..1b16320 100644 --- a/csdr/csdr.py +++ b/csdr/csdr.py @@ -87,15 +87,11 @@ class Pipe(object): def __init__(self, path, direction, encoding=None): self.doOpen = True - self.path = path + self.path = "{base}_{myid}".format(base=path, myid=id(self)) self.direction = direction self.encoding = encoding self.file = None - try: - os.unlink(path) - except Exception: - pass - os.mkfifo(path) + os.mkfifo(self.path) def open(self): self.file = open(self.path, self.direction, encoding=self.encoding) @@ -247,7 +243,7 @@ class dsp(object): def set_temporary_directory(self, what): self.temporary_directory = what - self.pipe_base_path = "{tmp_dir}/openwebrx_pipe_{myid}_".format(tmp_dir=self.temporary_directory, myid=id(self)) + self.pipe_base_path = "{tmp_dir}/openwebrx_pipe_".format(tmp_dir=self.temporary_directory) def chain(self, which): chain = ["nc -v 127.0.0.1 {nc_port}"]