From f9c6bad768c5c4f04c81bd7401b14b13db598b70 Mon Sep 17 00:00:00 2001 From: LSmyrnaios Date: Mon, 29 May 2023 12:42:54 +0300 Subject: [PATCH] Do not send shutDownRequests to workers which have already shutdown. --- .../urls_controller/controllers/ShutdownController.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/main/java/eu/openaire/urls_controller/controllers/ShutdownController.java b/src/main/java/eu/openaire/urls_controller/controllers/ShutdownController.java index eabd31e..f71d0db 100644 --- a/src/main/java/eu/openaire/urls_controller/controllers/ShutdownController.java +++ b/src/main/java/eu/openaire/urls_controller/controllers/ShutdownController.java @@ -41,8 +41,10 @@ public class ShutdownController { else { shouldShutdownService = true; // Send "shutdownWorker" requests to all Workers. - for ( String workerId : UrlsController.workersInfoMap.keySet() ) - shutdownService.postShutdownOrCancelRequestToWorker(workerId, UrlsController.workersInfoMap.get(workerId).getWorkerIP(), false); + for ( String workerId : UrlsController.workersInfoMap.keySet() ) { + if ( ! UrlsController.workersInfoMap.get(workerId).getHasShutdown() ) + shutdownService.postShutdownOrCancelRequestToWorker(workerId, UrlsController.workersInfoMap.get(workerId).getWorkerIP(), false); + } // That's it for now. The workers may take some hours to finish their work (including delivering the full-text files). // A scheduler monitors the shutdown of the workers. Once all worker have shutdown, the Controller shuts down as well.