Send response (#117)

faasm · Jun 17, 2021 · cd8a532 · cd8a532
1 parent fe6d33a
commit cd8a532
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/src/scheduler/FunctionCallClient.cpp b/src/scheduler/FunctionCallClient.cpp
@@ -102,6 +102,9 @@ void FunctionCallClient::sendFlush()
         call.set_returnhost(faabric::util::getSystemConfig().endpointHost);
 
         SEND_MESSAGE(faabric::scheduler::FunctionCalls::Flush, call);
+
+        // Await the response
+        awaitResponse(FUNCTION_CALL_PORT + REPLY_PORT_OFFSET);
     }
 }
 

diff --git a/src/scheduler/FunctionCallServer.cpp b/src/scheduler/FunctionCallServer.cpp
@@ -54,6 +54,9 @@ void FunctionCallServer::recvFlush(faabric::transport::Message& body)
 
     // Clear the scheduler
     scheduler.flushLocally();
+
+    faabric::EmptyResponse response;
+    SEND_SERVER_RESPONSE(response, msg.returnhost(), FUNCTION_CALL_PORT)
 }
 
 void FunctionCallServer::recvExecuteFunctions(faabric::transport::Message& body)