Changeset 365a44

Timestamp:

Sep 17, 2014, 10:33:09 PM (11 years ago)

Author:

Frederik Heber <heber@…>

Children:

019b96

Parents:

c4c20a

git-author:

Frederik Heber <heber@…> (05/22/14 16:18:35)

git-committer:

Frederik Heber <heber@…> (09/17/14 22:33:09)

Message:

Added loop to SystemCommandJob to attempt execution three times.

Location:

src/Jobs/JobMarket

Files:

• SystemCommandJob.cpp (modified) (4 diffs)
• SystemCommandJob.hpp (modified) (1 diff)

src/Jobs/JobMarket/SystemCommandJob.cpp

@@ -64 +64 @@
 #include "CodePatterns/Log.hpp"
 #include "CodePatterns/toString.hpp"
+
+// static entities
+const unsigned int SystemCommandJob::MAX_ATTEMPTS = 3;
 
 /** Constructor for class SystemCommandJob.
@@ -140 +143 @@
   Chronos::getInstance().startTiming(WorkName);
   FragmentResult::ptr s;
-  {
+  int exitflag = 255;
+  for(unsigned int counter = 0;
+      (counter < MAX_ATTEMPTS) && (exitflag != 0);
+      ++counter) {
     // open process
     std::string command_args = command+std::string(" ")+tmpTemplate;
@@ -153 +159 @@
     }
 
-    int exitflag;
     // read stdout from process
     const int fd = fileno(stdoutstream);
@@ -171 +176 @@
 
     if (exitflag != 0)
-      ELOG(1, "Job " << getId() << " failed on executing: " << command_args);
-    s->exitflag = exitflag;
-  }
+      ELOG(1, "Job " << getId() << " on attempt #" << counter+1
+          << " failed on executing: " << command_args);
+  }
+  s->exitflag = exitflag;
   Chronos::getInstance().endTiming(WorkName);
 

src/Jobs/JobMarket/SystemCommandJob.hpp

@@ -78 +78 @@
 
 private:
+  //!> number of maximum attempts to run fragment job
+  static const unsigned int MAX_ATTEMPTS;
+
+private:
   friend class boost::serialization::access;
   // serialization