X-Git-Url: https://git.ralfj.de/saartuer.git/blobdiff_plain/5a866fd8add83733d9e1cde55ecbd23f69661658..a05dfd226f0b41c040a0b7e5cd61be1f22db81a2:/libtuer.py diff --git a/libtuer.py b/libtuer.py index e31ce27..1f8a034 100644 --- a/libtuer.py +++ b/libtuer.py @@ -1,17 +1,15 @@ -import logging, logging.handlers, os, time, queue, threading, subprocess, multiprocessing +import logging, logging.handlers, os, time, queue, threading, subprocess # logging function class Logger: def __init__ (self): - import __main__ as main - self.name = os.path.basename(main.__file__) - self.logger = logging.getLogger(self.name) + self.logger = logging.getLogger("tuerd") self.logger.setLevel(logging.INFO) self.handler = logging.handlers.SysLogHandler(address = '/dev/log', facility = logging.handlers.SysLogHandler.LOG_LOCAL0) self.logger.addHandler(self.handler) def log (self, lvl, what): - thestr = "%s[%d]: %s" % (self.name,os.getpid(),what) + thestr = "%s[%d]: %s" % ("osspd", os.getpid(), what) print (thestr) self.logger.log(lvl, thestr) @@ -31,13 +29,13 @@ logger = Logger() # run a command asynchronously and log the return value if not 0 # prefix must be a string identifying the code position where the call came from def fire_and_forget (cmd, log, prefix): - def _fire_and_forget (cmd, log, prefix): + def _fire_and_forget (): with open("/dev/null", "w") as fnull: retcode = subprocess.call(cmd, stdout=fnull, stderr=fnull) if retcode is not 0: log("%sReturn code %d at command: %s" % (prefix,retcode,str(cmd))) - p = multiprocessing.Process(target=_fire_and_forget, args=(cmd,log,prefix)) - p.start() + t = threading.Thread(target=_fire_and_forget) + t.start() # Threaded callback class class ThreadFunction():