Changeset 875 for trunk/Monitoring/Watch/watch

Timestamp:

06/11/13 15:05:18 (11 years ago)

Author:

jripsl

Message:

Repository I/O implementation (suite).

File:

• trunk/Monitoring/Watch/watch (modified) (10 diffs)

trunk/Monitoring/Watch/watch

@@ -29 +29 @@
 import smon.types
 
+
 class Mail():
 
@@ -59 +60 @@
 
         @classmethod
+        def cleanup(cls,message):
+                repo_io.cleanup() # truncate/delete everything
+
+        @classmethod
         def set_sim_status_to_error(cls,message):
-                repo_io.update_simulation_status()
+
+                s=repo_io.retrieve_simulation(message.simuid)
+
+                s.status="error"
+
+                repo_io.update_simulation_status(s)
+
+        @classmethod
+        def set_sim_status_to_complete(cls,message):
+
+                s=repo_io.retrieve_simulation(message.simuid)
+
+                s.status="complete"
+
+                repo_io.update_simulation_status(s)
 
         @classmethod
@@ -68 +87 @@
                 #repo_io.delete_simulation(name)
 
-                simulation=smon.types.Simulation(name=message.simuid)
+                simulation=smon.types.Simulation(name=message.simuid,status="running")
 
                 repo_io.create_simulation(simulation)
@@ -80 +99 @@
                 # used for debug
 
-                if "file" in message:
+                if message.file is not None:
                         print "%s %s %s\n"%(message.code,message.jobid,message.file)
                 else:
@@ -107 +126 @@
 class MessageActionsMapping():
 
+        # debug
+        mapping = { "0000":["log", "print_stdout", "crea_sim"],
+                                "0100":["log", "print_stdout", "set_sim_status_to_complete"],
+                                "1000":["log", "print_stdout"],
+                                "1100":["log", "print_stdout"],
+                                "2000":["log", "print_stdout"],
+                                "3000":["log", "print_stdout"],
+                                "8888":["cleanup"],
+                                "9000":["log", "print_stdout"],
+                                "9999":["log", "print_stdout", "set_sim_status_to_error"] }
+
+        # prod
+        """
         mapping = { "0000":["log", "store_msg", "crea_sim"],
+                                "0100":["log", "store_msg", "set_sim_status_to_complete"],
                                 "1000":["log", "store_msg"],
+                                "1100":["log", "store_msg"],
                                 "2000":["log", "store_msg"],
                                 "3000":["log", "store_msg"],
+                                "8888":["cleanup"],
                                 "9000":["log", "store_msg", "mail"],
                                 "9999":["log", "store_msg", "set_sim_status_to_error", "mail"] }
+        """
 
 class Watcher():
@@ -198 +234 @@
                                 print "ERR009 - exception occurs (exception=%s,msg=%s)"%(str(e),base64_decoded_msg)
 
-                                #traceback.print_exc()
-                                #raise
+                                traceback.print_exc()
+                                raise
 
 
@@ -218 +254 @@
                         try:
                                 # message code based action
-                                #Actions.execActions(message)
-                                pass
+                                Actions.execActions(message)
+
                         except Exception,e:
                                 print "ERR019 - exception occurs (exception=%s,msg=%s)"%(str(e),base64_decoded_msg)
@@ -227 +263 @@
                                 raise
 
+
+                        # slow down consumer
+                        #time.sleep(0.5)
 
 
@@ -241 +280 @@
                 print 'You pressed Ctrl+C!'
                 Watcher.channel.stop_consuming()
+                Watcher.stop()
                 sys.exit(0)
 
@@ -248 +288 @@
 
         try:
+
+                Watcher.start()
+
                 Watcher.main()
 
+                Watcher.stop()
+
                 sys.exit(0)
 
         except Exception, e:
 
-                #traceback.print_exc()
+                traceback.print_exc()
 
                 sys.exit(1)