From 5e1aaeddcdd2b90543bfdd97df1b309bd1881cd2 Mon Sep 17 00:00:00 2001 From: Marcio Fernandes Date: Thu, 20 Jan 2022 13:11:54 +0000 Subject: [PATCH] . --- onlyone/__main__.py | 2 +- onlyone/namedpipes/__init__.py | 9 ++++++--- 2 files changed, 7 insertions(+), 4 deletions(-) diff --git a/onlyone/__main__.py b/onlyone/__main__.py index 147ed38..78ff47f 100644 --- a/onlyone/__main__.py +++ b/onlyone/__main__.py @@ -30,7 +30,7 @@ if args.configFile: log.info("config file content : " + configTxt) log.info("trying read yaml") configDict = yaml.safe_load(configTxt) - #manager.load(configDict, True) + manager.load(configDict, True) else: log.error("Current Path:" + os.getcwd()) log.error("File dont exists:" + args.configfile) diff --git a/onlyone/namedpipes/__init__.py b/onlyone/namedpipes/__init__.py index 2cb018d..2d8e1a3 100644 --- a/onlyone/namedpipes/__init__.py +++ b/onlyone/namedpipes/__init__.py @@ -18,7 +18,7 @@ class Server: if oe.errno != errno.EEXIST: raise - readTask = ReadTask() + readTask = ReadTask(self) self.__readThread = threading.Thread(target=readTask.run, args = (fifoname,) ) self.__readThread.start() @@ -26,8 +26,9 @@ class Server: self.__readThread.kill() class ReadTask: - def __init__(self): + def __init__(self, server): self.__kill=False + self.server=server def kill(self): self.__kill=True @@ -42,8 +43,10 @@ class ReadTask: log.info("FIFO closed") break log.info('FIFO Data: "{0}"'.format(data)) + self.server.manager.current(format(data).strip()) - def run(self, fifoname): + def run(self, fifoname, manager): + self.mana while True: if self.__kill: return