-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)
# 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():