updates: go_idle et affichage final fin process

Etienne Pallier
1 parent 5a76fb80
Showing 5 changed files with 43 additions and 5 deletions Show diff stats
README.md
pyros.py
src/agent/Agent.py
src/agent/AgentA.py
src/agent/AgentB.py
@@ -71,7 +71,7 @@ Date: 19/03/2019
  
 Author: E. Pallier
  
-VERSION: 0.20.22
+VERSION: 0.20.23
  
 Comment:
 	pyros.py peut lancer plusieurs agents (A et B) en même temps (+ flush_commands + test)
@@ -382,7 +382,8 @@ def start(agent:str, configfile:str):
                 cmd = f" Agent{agent_name[5:]}.py {configfile}"
  
             #if not test_mode(): execProcessFromVenv(cmd)
-            if not test_mode(): current_processes.append( (execProcessFromVenvAsync(cmd), agent_name) )
+            #if not test_mode(): current_processes.append( (execProcessFromVenvAsync(cmd), agent_name, 0) )
+            if not test_mode(): current_processes.append( [execProcessFromVenvAsync(cmd), agent_name, -1] )
             # self._change_dir("..")
             os.chdir(current_dir)
  
@@ -390,9 +391,12 @@ def start(agent:str, configfile:str):
     # self._change_dir('..')
     #os.chdir("..")
     # Wait for end of each process execution
-    for (p,agent) in current_processes:
+    #for (p,agent) in current_processes:
+    for process in current_processes:
+        p,agent,_ = process
         print(f"************ Waiting for end of execution of agent {agent} ************")
         p.wait()
+        process[2] = p.returncode
         print(f"************ END of execution of agent {agent} ************")
         if p.returncode == 0:
             printFullTerm(Colors.GREEN, f"Process {agent} executed successfully")
@@ -401,8 +405,22 @@ def start(agent:str, configfile:str):
             printFullTerm(Colors.WARNING, f"Process {agent} execution failed")
             # self.addError(self.current_command, command)
  
+    print()
+    print()
+    print("Synthesis of the results:")
+    for process in current_processes:
+        p,agent,returncode = process
+        print(process)
+        if returncode == 0:
+            printFullTerm(Colors.GREEN, f"Process {agent} executed successfully")
+            # self.addExecuted(self.current_command, command)
+        else:
+            printFullTerm(Colors.WARNING, f"Process {agent} execution failed")
+            # self.addError(self.current_command, command)
+        
     #print("************ end of START() ************")
     # Only according to the last process status:
+    #return True if p.returncode==0 else False
     return True if p.returncode==0 else False
  
  
@@ -295,7 +295,8 @@ class Agent:
         self.SIMULATOR_COMMANDS = iter(self.SIMULATOR_COMMANDS_LIST)
         self.RUN_IN_THREAD = RUN_IN_THREAD
         self.set_status(self.STATUS_LAUNCH)
-        self.set_mode(self.MODE_IDLE)
+        self.set_idle()
+        #self.set_mode(self.MODE_IDLE)
         if not config_filename:
             config_filename = self.DEFAULT_CONFIG_FILE_NAME
  
@@ -317,7 +318,8 @@ class Agent:
  
         self.set_mode_from_config(name)
         # TODO: remove
-        self.set_idle()
+        #self.set_idle()
+        self.set_active()
  
         # Create 1st survey if none
         #tmp = AgentSurvey.objects.filter(name=self.name)
@@ -463,6 +465,9 @@ class Agent:
         at each iteration
         """
         self.set_status(self.STATUS_ROUTINE_PROCESS)
+        if not self.is_active():
+            self.print("I am IDLE, so I bypass the routine_process (do not send any new command)")
+            return
  
         if self.cmdts is None:
             self.cmdts = self.simulator_get_next_command_to_send()
@@ -32,10 +32,15 @@ class AgentA(Agent):
  
         "go_active",
  
+        # Because of this command, the receiver agent
+        # will no more send any new command
         "go_idle",
+
         # Not executed because receiver agent is now "idle"
         #"specific0",
  
+        # Because of this command, the receiver agent
+        # will now be able to send new commands
         "go_active",
  
         # Executed because receiver agent is now "active"
@@ -27,8 +27,18 @@ class AgentB(Agent):
     SIMULATOR_COMMANDS_DEST = "AgentA"
     # Scenario to be executed
     SIMULATOR_COMMANDS_LIST = [
+        "flush_commands",
         "go_active",
+
+        # Because of this command, the receiver agent
+        # will no more send any new command
+        "go_idle",
+        "go_idle",
         "go_idle",
+
+        # Because of this command, the receiver agent
+        # will now be able to send new commands
+        "go_active",
     ]
     """
         "go_active",