Clients now exit when all batches are solved

build/includes/summa_actor/client.hpp

@@ -50,8 +50,12 @@ class Client_Container {
          */
         void addClient(caf::actor client_actor, std::string hostname);
 
-        
         int getClientID(caf::actor);
 
+        Client removeClient_fromBack();
+
         std::string getHostname_ByClientID(int client_id);
+
+        bool isEmpty();
+
 };
\ No newline at end of file

build/source/actors/summa_actor/client.cpp

@@ -48,3 +48,13 @@ int Client_Container::getClientID(caf::actor client_actor) {
 std::string Client_Container::getHostname_ByClientID(int client_id) {
     return this->client_list[client_id].getHostname();
 }
+
+bool Client_Container::isEmpty() {
+    return this->client_list.empty();
+}
+
+Client Client_Container::removeClient_fromBack() {
+    Client client = this->client_list.back();
+    this->client_list.pop_back();
+    return client;
+}

build/source/actors/summa_actor/summa_server.cpp

@@ -67,11 +67,30 @@ behavior summa_server(stateful_actor<summa_server_state>* self, Distributed_Sett
 
             std::optional<Batch> new_batch = self->state.batch_container->assignBatch(
                 self->state.client_container->getHostname_ByClientID(client_id), client_actor);
+            
             if (new_batch.has_value()) {
+                
                 self->send(client_actor, new_batch.value());
+            
             } else {
-                aout(self) << "no more batches left to assign\n";
-                aout(self) << "we are not done yet. Clients could Fail\n";
+                
+                if (self->state.batch_container->getBatchesRemaining() > 0) {
+                    
+                    aout(self) << "no more batches left to assign\n";
+                    aout(self) << "we are not done yet. Clients could Fail\n";
+
+                } else {
+                    aout(self) << "Telling Clients To Exit\n"; 
+                    while(!self->state.client_container->isEmpty()) {
+                        Client client = self->state.client_container->removeClient_fromBack();
+
+                        caf::actor client_actor =  client.getActor();
+                        self->send(client_actor, time_to_exit_v);
+                    }
+
+                    aout(self) << "SERVER EXITING!!\n";
+                    self->quit();
+                }
             }
         }
     };