X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=logger.py;h=569d2e0b61b8266d45fb6f24cefa3cbb2c2afc4e;hb=48a73b18fd7daed13c645c1adeddb57b560e7a2d;hp=767a04e6f8a3b930cfe70c868c1156ef925898b4;hpb=b266b22c0fce1a4c9d8c2f1bcfbbe876601fee55;p=nodemanager.git diff --git a/logger.py b/logger.py index 767a04e..569d2e0 100644 --- a/logger.py +++ b/logger.py @@ -34,7 +34,7 @@ def log(msg, level=LOG_NODE): if level > LOG_LEVEL: return try: - fd = os.open(LOG_FILE, os.O_WRONLY | os.O_CREAT | os.O_APPEND, 0600) + fd = os.open(LOG_FILE, os.O_WRONLY | os.O_CREAT | os.O_APPEND, 0o600) if not msg.endswith('\n'): msg += '\n' os.write(fd, '%s: %s' % (time.asctime(time.gmtime()), msg)) @@ -69,24 +69,24 @@ def log_trace(msg="", name=None): # for some reason the various modules are still triggered even when the # data from PLC cannot be reached # we show this message instead of the exception stack instead in this case -def log_missing_data(msg,key): - log("%s: could not find the %s key in data (PLC connection down?) - IGNORED"%(msg,key)) +def log_missing_data(msg, key): + log("%s: could not find the %s key in data (PLC connection down?) - IGNORED"%(msg, key)) -def log_data_in_file(data, file, message="",level=LOG_NODE): +def log_data_in_file(data, file, message="", level=LOG_NODE): if level > LOG_LEVEL: return import pprint, time try: - f=open(file,'w') - now=time.strftime("Last update: %Y.%m.%d at %H:%M:%S %Z", time.localtime()) - f.write(now+'\n') - if message: f.write('Message:'+message+'\n') - pp=pprint.PrettyPrinter(stream=f,indent=2) - pp.pprint(data) - f.close() - verbose("logger:.log_data_in_file Owerwrote %s"%file) + with open(file, 'w') as f: + now=time.strftime("Last update: %Y.%m.%d at %H:%M:%S %Z", time.localtime()) + f.write(now+'\n') + if message: f.write('Message:'+message+'\n') + pp=pprint.PrettyPrinter(stream=f, indent=2) + pp.pprint(data) + f.close() + verbose("logger:.log_data_in_file Owerwrote %s"%file) except: - log_exc('logger.log_data_in_file failed - file=%s - message=%r'%(file,message)) + log_exc('logger.log_data_in_file failed - file=%s - message=%r'%(file, message)) def log_slivers(data): log_data_in_file(data, LOG_SLIVERS, "raw GetSlivers") @@ -102,7 +102,7 @@ class Buffer: self.buffer = '' self.message = message - def add(self,c): + def add(self, c): self.buffer += c if c=='\n': self.flush() @@ -144,13 +144,13 @@ def log_call(command, timeout=default_timeout_minutes*60, poll=1): break # child has failed else: - log("log_call:end command (%s) returned with code %d" %(message,returncode)) + log("log_call:end command (%s) returned with code %d" %(message, returncode)) break # no : still within timeout ? if time.time() >= trigger: buffer.flush() child.terminate() - log("log_call:end terminating command (%s) - exceeded timeout %d s"%(message,timeout)) + log("log_call:end terminating command (%s) - exceeded timeout %d s"%(message, timeout)) break except: log_exc("failed to run command %s" % message)