Changeset ae9ad6 for src/Fragmentation/Automation/SpecificFragmentController_ReceiveResultContainer_impl.hpp

Timestamp:

Aug 11, 2025, 5:45:37 PM (2 months ago)

Author:

Frederik Heber <frederik.heber@…>

Branches:

Candidate_v1.7.0, stable

Children:

9cdab3

Parents:

ab2e834

git-author:

Frederik Heber <frederik.heber@…> (07/16/25 20:16:30)

git-committer:

Frederik Heber <frederik.heber@…> (08/11/25 17:45:37)

Message:

Removes check in FragmentationAutomation's ReceiveResults.

• we can no longer check for the number of workers and stop when they are 0. Hence, this check is removed entirely and we simply keep on waiting.

File:

• src/Fragmentation/Automation/SpecificFragmentController_ReceiveResultContainer_impl.hpp (modified) (1 diff)

src/Fragmentation/Automation/SpecificFragmentController_ReceiveResultContainer_impl.hpp

@@ -73 +73 @@
       LOG(1, "INFO: #" << JobStatus.first << " are waiting in the queue and #" << NoReceivedResults << " of " << NoExpectedResults << " jobs are calculated so far.");
     }
-
-    // if not all jobs are done yet, check number of present workers
-    if (NoReceivedResults != NoExpectedResults) {
-      callback.checkEnrolledWorkers(callback.host, callback.port);
-      callback.RunService("Checking on number of workers");
-      if (callback.getExitflag() != 0)
-        break;
-      const std::vector<size_t>& NumberWorkers = callback.getNumberOfWorkers();
-      const int TotalNumberWorkers = std::accumulate(
-          NumberWorkers.begin(), NumberWorkers.end(), 0);
-      if (TotalNumberWorkers == 0) {
-        ELOG(0, "Not all jobs are finished, but no workers are present working on it?!");
-        callback.setExitflag(ExitflagContainer::ErrorFlag);
-        break;
-      } else {
-        LOG(4, "There are " << NumberWorkers << " workers enrolled.");
-      }
-    }
-}
+  }
 }