Add extra logging for HRU actor and remove unnecessary logging in Job actor

build/source/actors/hru_actor/hru_actor.cpp

 #include "hru_actor.hpp"
 
+bool hru_extra_logging = false;
+
 namespace caf {
 
 behavior hru_actor(stateful_actor<hru_state>* self, int refGRU, int indxGRU,
@@ -110,8 +112,9 @@ behavior hru_actor(stateful_actor<hru_state>* self, int refGRU, int indxGRU,
     },
 
     [=](update_timeZoneOffset, int iFile) {
-        aout(self) << "Recieved New iFile-" << iFile 
-                    << " to update timeZoneOffset \n";
+        if (hru_extra_logging)
+            aout(self) << "Recieved New iFile-" << iFile 
+                       << " to update timeZoneOffset \n";
         int err;
         self->state.iFile = iFile;
         setTimeZoneOffset(&iFile, self->state.hru_data, &err);
@@ -119,8 +122,9 @@ behavior hru_actor(stateful_actor<hru_state>* self, int refGRU, int indxGRU,
 
     // BMI - Functions
     [=](update_hru, int timestep, int forcingstep) {
-      aout(self) << "Computing Time Step: " << timestep 
-                 << " Forcing Step: " << forcingstep << "\n";
+      if (hru_extra_logging)
+        aout(self) << "Computing Time Step: " << timestep 
+                   << " Forcing Step: " << forcingstep << "\n";
       self->state.output_structure_step_index = 1;
       self->state.timestep = timestep;
       self->state.forcingStep = forcingstep;

build/source/actors/job_actor/job_actor.cpp

@@ -139,7 +139,7 @@ behavior job_actor(stateful_actor<job_state>* self,
     },
 
     [=](update_hru){
-      aout(self) << "Job_Actor: Updating HRUs\n";
+      // aout(self) << "Job_Actor: Updating HRUs\n";
       for(auto gru : self->state.gru_container.gru_list) {
         self->send(gru->getGRUActor(), update_hru_v, 
                     self->state.timestep, self->state.forcingStep);
@@ -150,7 +150,8 @@ behavior job_actor(stateful_actor<job_state>* self,
       self->state.num_gru_done_timestep++;
       
       if (self->state.num_gru_done_timestep >= self->state.num_gru) {
-        aout(self) << "Job_Actor: Done Update\n";
+        aout(self) << "Job_Actor: Done Update for timestep:" 
+                   << self->state.timestep << "\n";
         // write the output
         int steps_to_write = 1;
         int start_gru = 1;
@@ -166,9 +167,8 @@ behavior job_actor(stateful_actor<job_state>* self,
               self->send_exit(self->state.file_access_actor, 
                               exit_reason::user_shutdown);
               self->quit();
-            } else {
-              aout(self) << "Job_Actor: Done Writing Output\n";
-            }
+            } 
+            // else {  aout(self) << "Job_Actor: Done Writing Output\n"; }
           });
 
         self->state.timestep++;