Ignore closed communicators in queue

trikko · Apr 30, 2024 · 8159f4e · 8159f4e
1 parent 2da125d
commit 8159f4e
Showing 1 changed file with 11 additions and 5 deletions.
diff --git a/source/serverino/daemon.d b/source/serverino/daemon.d
@@ -696,16 +696,22 @@ package:
             {
                auto communicator = Communicator.popFromWaitingList();
 
-               communicator.setWorker(availableWorkers.front);
-               availableWorkers.popFront;
+               if(communicator.requestToProcess !is null)
+               {
+                  communicator.setWorker(availableWorkers.front);
+                  availableWorkers.popFront;
+               }
             }
             else if(!deadWorkers.empty)
             {
                auto communicator = Communicator.popFromWaitingList();
 
-               deadWorkers.front.reinit(true);
-               communicator.setWorker(deadWorkers.front);
-               deadWorkers.popFront;
+               if(communicator.requestToProcess !is null)
+               {
+                  deadWorkers.front.reinit(true);
+                  communicator.setWorker(deadWorkers.front);
+                  deadWorkers.popFront;
+               }
             }
             else break; // All workers are busy. We'll try again later.
          }