beremiz

Added logging based on collecting Kernel logs

2013-04-04, Edouard Tisserant
fc1bc441cf71
Parents b14b6f9008dc
Children edb49073227ec317b1aaf920
Added logging based on collecting Kernel logs
1 files changed, 42 insertions(+), 0 deletions(-)
  • +42 -0
    etherlab/runtime_etherlab.py
    • --- a/etherlab/runtime_etherlab.py Thu Apr 04 14:32:02 2013 +0900
    +++ b/etherlab/runtime_etherlab.py Thu Apr 04 17:50:43 2013 +0900
    @@ -1,5 +1,6 @@
    import subprocess,sys,ctypes
    from threading import Thread
    +import ctypes,time,re
    SDOAnswered = PLCBinary.SDOAnswered
    SDOAnswered.restype = None
    @@ -48,3 +49,44 @@
    def GetResult():
    global Result
    return Result
    +
    +KMSGPollThread=None
    +StopKMSGThread=False
    +def KMSGPollThreadProc():
    + """
    + Logs Kernel messages starting with EtherCAT
    + Uses GLibc wrapper to Linux syscall "klogctl"
    + Last 4 KB are polled, and lines compared to last
    + captured line to detect new lines
    + """
    + global StopKMSGThread
    + libc=ctypes.CDLL("libc.so.6")
    + klog = libc.klogctl
    + klog.argtypes = [ctypes.c_int, ctypes.c_char_p, ctypes.c_int]
    + klog.restype = ctypes.c_int
    + s=ctypes.create_string_buffer(4*1024)
    + last = None
    + while not StopKMSGThread:
    + l = klog(3,s,len(s)-1)
    + log = s.value[:l-1]
    + if last :
    + log = log.rpartition(last)[2]
    + if log :
    + last = log.rpartition('\n')[2]
    + for msg in re.findall(r'<\d>\[\s*\d*\.\d*\]\s*(EtherCAT\s*.*)$',
    + log, re.MULTILINE):
    + PLCObject.LogMessage(msg)
    + time.sleep(0.5)
    +
    +def _runtime_etherlab_init():
    + global KMSGPollThread, StopKMSGThread
    + StopKMSGThread = False
    + KMSGPollThread = Thread(target = KMSGPollThreadProc)
    + KMSGPollThread.start()
    +
    +def _runtime_etherlab_cleanup():
    + global KMSGPollThread, StopKMSGThread
    + StopKMSGThread = True
    + KMSGPollThread = None
    +
    +