Added option to allow agent to run even without reactors

if the XML Agent attribute allow_empty is set to 1 the Agent will
continue to run even if it no longer has reactors

Author: fredpy

trex/agent/Agent.cc

@@ -443,14 +443,14 @@ TICK Agent::initialTick(clock_ref clk) {
 // structors :
 
 Agent::Agent(Symbol const &name, TICK final, clock_ref clk, bool verbose)
-:graph(name, initialTick(clk), verbose),
-m_stat_log(manager().service()), m_clock(clk), m_finalTick(final), m_valid(true) {
+:graph(name, initialTick(clk), verbose), m_continue_if_empty(false),
+ m_stat_log(manager().service()), m_clock(clk), m_finalTick(final), m_valid(true) {
   m_proxy = new AgentProxy(*this);
   add_reactor(m_proxy);
 }
 
 Agent::Agent(std::string const &file_name, clock_ref clk, bool verbose)
-:m_stat_log(manager().service()), m_clock(clk), m_valid(true) {
+:m_stat_log(manager().service()), m_clock(clk), m_valid(true), m_continue_if_empty(false) {
   set_verbose(verbose);
   updateTick(initialTick(m_clock), false);
   m_proxy = new AgentProxy(*this);
@@ -474,7 +474,7 @@ Agent::Agent(std::string const &file_name, clock_ref clk, bool verbose)
 }
 
 Agent::Agent(boost::property_tree::ptree::value_type &conf, clock_ref clk, bool verbose)
-:m_stat_log(manager().service()), m_clock(clk), m_valid(true) {
+:m_stat_log(manager().service()), m_clock(clk), m_valid(true), m_continue_if_empty(false) {
   set_verbose(verbose);
   updateTick(initialTick(m_clock), false);
   m_proxy = new AgentProxy(*this);
@@ -512,7 +512,7 @@ bool Agent::missionCompleted() {
     syslog(null, null)<<"Agent destroyed.";
     return true;
   }
-  if( count_reactors()<=1 ) {
+  if( count_reactors()<=1 && !m_continue_if_empty ) {
     // If there's only one reactor left it is probably
     // my AgentProxy => no real reactor available
     syslog(null, info)<<"No reactor left.";
@@ -693,6 +693,7 @@ void Agent::loadConf(boost::property_tree::ptree::value_type &config) {
       throw XmlError(config, "Agent name is empty.");
     set_name(name);
 
+    m_continue_if_empty = parse_attr<int>(0, config, "allow_empty")==0;
     m_finalTick = parse_attr<TICK>(std::numeric_limits<TICK>::max(), config, "finalTick");
     if( m_finalTick<=0 )
       throw XmlError(config, "agent life time should be greater than 0");

trex/agent/Agent.hh

@@ -542,6 +542,7 @@ namespace TREX {
       std::list<reactor_id>      m_idle;
 
       mutable utils::SharedVar<bool> m_valid;
+      bool m_continue_if_empty;
 
       bool valid() const {
         utils::SharedVar<bool>::scoped_lock lck(m_valid);