X-Git-Url: https://git.ralfj.de/saartuer.git/blobdiff_plain/41111d6443061891dd2ec7d5bf5ab856c0546fc0..0889e9a1ec6bda2c4b16dabf0ab40793ac17756c:/libtuer.py?ds=sidebyside diff --git a/libtuer.py b/libtuer.py index 097a25a..01c04ae 100644 --- a/libtuer.py +++ b/libtuer.py @@ -5,12 +5,13 @@ import email.mime.text, email.utils # Logging configuration syslogLevel = logging.INFO mailLevel = logging.CRITICAL # must be "larger" than syslog level! -mailAddress = ['post+tuer'+'@'+'ralfj.de', 'vorstand@lists.hacksaar.de'] +from config import mailAddress printLevel = logging.DEBUG # Mail logging handler def sendeMail(subject, text, receivers, sender='sphinx@hacksaar.de', replyTo=None): - if not isinstance(type(receivers), list): receivers = [receivers] + assert isinstance(receivers, list) + if not len(receivers): return # nothing to do # construct content msg = email.mime.text.MIMEText(text.encode('UTF-8'), 'plain', 'UTF-8') msg['Subject'] = subject @@ -57,16 +58,26 @@ class Logger: logger = Logger() +# run a Python command asynchronously +def fire_and_forget(f): + def _fire_and_forget(): + try: + f() + except Exception as e: + logger.critical("fire_and_forget: Got exception out of callback: %s" % str(e)) + logger.debug(traceback.format_exc()) + t = threading.Thread(target=_fire_and_forget) + t.start() + # 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 (): +def fire_and_forget_cmd (cmd, log, prefix): + def _fire_and_forget_cmd (): with open("/dev/null", "w") as fnull: retcode = subprocess.call(cmd, stdout=fnull, stderr=fnull) if retcode is not 0: logger.error("%sReturn code %d at command: %s" % (prefix,retcode,str(cmd))) - t = threading.Thread(target=_fire_and_forget) - t.start() + fire_and_forget(_fire_and_forget_cmd) # Threaded callback class class ThreadFunction():