aha-worker parses now also the messages and put them in a log file

aha/aha-worker.py

@@ -9,15 +9,29 @@
 #for the aha tak to take the decisions
 #The aha framework can be launched then in screen
 #
+
+
 import dircache,os.path,time,sys,ConfigParser,getopt
+from ahalib import *
 
 class PeriodTaks():
+    #Define message types
+    FROM_KERNEL  = 1
+    TO_KERNEL    = 2
 
-    def __init__(self,outqueue,inqueue, timeout,sleeptime):
+    def __init__(self,outqueue,inqueue, timeout,sleeptime, logfile):
         self.outqueue= outqueue
         self.inqueue = inqueue
         self.timeout = timeout
         self.sleeptime = sleeptime
+        self.logfile = logfile
+        #Log file descriptor
+        self.lfd = open(logfile,'a')
+        self.aha = AHAActions(inqueue,outqueue)
+
+    #Make close action externally available
+    def closeLogFile(self):
+        self.lfd.close()
 
     def remove_old_msg(self,queue):
         #Get current date if the files are older than the timeout remove them
@@ -29,9 +43,13 @@ class PeriodTaks():
             t1 = int(s[os.path.stat.ST_CTIME])
             delta = t0 - t1
             if (delta > self.timeout):
-                #Old file was found remove it
+                #Old file was found record it
-                os.unlink(af)
+                if queue == self.outqueue:
-
+                    self.record_message(af,t1,PeriodTaks.FROM_KERNEL)
+                if queue == self.inqueue:
+                    self.record_message(af,t1,PeriodTaks.TO_KERNEL)
+                #Remove it
+                self.aha.silent_clean(af)
 
     def clean_input_queue(self):
         try:
@@ -46,6 +64,22 @@ class PeriodTaks():
         except OSError,e:
             sys.stderr.write(str(e))
 
+    #Parse the file an put the information in a log file for later processing
+    #One log file is handier than for each message a file
+    #Take timestamps when the kernel created the file
+    def record_message(self,filename, ctime,type):
+        try:
+            if type == PeriodTaks.FROM_KERNEL:
+                msg = self.aha.load_file(filename)
+                logEntry = self.aha.serializeKernelMessage(msg,ctime)
+                self.lfd.write(logEntry)
+
+            if type == PeriodTaks.TO_KERNEL:
+                msg = self.aha.get_kernel_reply(filename)
+                logEntry=self.aha.serializeAhaReply(msg,ctime)
+                self.lfd.write(logEntry)
+        except IOError,e:
+            sys.stderr.write('Failed to record message: %s\n'%filename)
 
 def usage(exitcode):
     print """
@@ -68,7 +102,7 @@ LICENSE
 
 configfile = None
 isHelp = 0
-
+p = None
 try:
     opts,args = getopt.getopt(sys.argv[1:],"hc:",["help","config="])
     for o,a in opts:
@@ -76,6 +110,9 @@ try:
             usage(0)
         if o in ('--config','-c'):
             configfile = a
+    if configfile == None:
+        sys.stderr.write('A configuration file needs to be specified\n')
+        sys.exit(1)
     #Load config file and get opts
     c=ConfigParser.ConfigParser()
     c.read(configfile)
@@ -83,20 +120,24 @@ try:
     sleeptime = int(c.get('worker','sleeptime'))
     inqueue = c.get('common','inqueue')
     outqueue= c.get('common','outqueue')
-    p = PeriodTaks(outqueue, inqueue, timeout,sleeptime)
+    logfile = c.get('worker','logfile')
+    p = PeriodTaks(outqueue, inqueue, timeout,sleeptime,logfile)
     print "Start working ..."
     while True:
         p.clean_input_queue()
         p.clean_output_queue()
         time.sleep(sleeptime)
+        print "Resume ..."
 
     sys.exit(0)
 except getopt.GetoptError,e:
     usage(1)
-except TypeError,e:
+except ConfigParser.NoOptionError,e:
-    sys.stderr.write('Configuration file error\n')
+    sys.stderr.write('Configuration error. (%s)\n'%(str(e)))
-except KeyboardInterrupt,e:
-    sys.exit(0)
-    sys.stderr.write(str(e))
     sys.exit(1)
-
+except KeyboardInterrupt,e:
+    if p !=None:
+        p.closeLogFile()
+    sys.exit(0)
+#Should not be reached
+sys.exit(0)