Changeset c53ae2

Timestamp:

Feb 2, 2023, 1:31:56 PM (3 years ago)

Author:

Frederik Heber <frederik.heber@…>

Branches:

Candidate_v1.7.0, stable

Children:

75a0cb

Parents:

d91a8f

Message:

FIX: WorkerListener tried to get result from new-joined worker.

• bracket error caused the 'break' to be missed when a newly joined worker was already known. This caused a receive result handle to be started where the actual empty result was handled gracefully.

File:

• ThirdParty/JobMarket/src/JobMarket/FragmentScheduler_WorkerListener.cpp (modified) (3 diffs)

ThirdParty/JobMarket/src/JobMarket/FragmentScheduler_WorkerListener.cpp

@@ -117 +117 @@
             boost::bind(&FragmentScheduler::WorkerListener_t::handle_enrolled, this,
             boost::asio::placeholders::error, conn, data));
+          // mark as idle if a rejoining worker
+          unmarkBusyWorkerFunction(data->address);
+          LOG(1, "INFO: There are " << pool.getNoTotalWorkers() << " workers in the queue, "
+              << pool.getNoIdleWorkers() << " of which are idle.");
         } else {
           // insert as its new worker
@@ -124 +128 @@
             boost::bind(&FragmentScheduler::WorkerListener_t::handle_enrolled, this,
             boost::asio::placeholders::error, conn, data));
+        }
         break;
       }
@@ -166 +171 @@
         ELOG(1, "WorkerListener_t::handle_ReadChoice() - called with no valid choice.");
         break;
-      }
     }
     // restore NoOperation choice such that choice is not read twice