From 3de8521e37c7d27439e7b599a32958920a31d176 Mon Sep 17 00:00:00 2001 From: Tom Smeding Date: Sat, 28 Mar 2020 21:23:54 +0100 Subject: controller: Fix bug (don't exit upon arrival of new worker) --- controller/src/lib.rs | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/controller/src/lib.rs b/controller/src/lib.rs index 60b3639..0918542 100644 --- a/controller/src/lib.rs +++ b/controller/src/lib.rs @@ -404,15 +404,14 @@ fn thread_entry( if let Some(worker) = workers_locked.get_mut(&worker_id) { if worker.loaded_core != current_core_id { - let current_core = current_core.unwrap().clone(); + let current_core = current_core.as_ref().unwrap().clone(); worker_set_new_core( worker, current_core_id, current_core, workers.clone(), collector_sink.clone() ).await; - return; + } else { + free_workers.push_back(worker_id); } - - free_workers.push_back(worker_id); } } } -- cgit v1.2.3