execution service: implement WaitExecution and google::longrunning::Operations::GetOperation

For each action that is executed, an entry is added to a shared thread
safe cache. Once the number of operations stored exceeds twice 2^n,
where n is given by the option --log-operations-threshold, at most 2^n
operations will be removed, in a FIFO scheme.

1 files changed, 4 insertions, 1 deletions

diff --git a/src/buildtool/execution_api/execution_service/server_implementation.cpp b/src/buildtool/execution_api/execution_service/server_implementation.cpp
index 73850686..bba2e4cf 100644
--- a/src/buildtool/execution_api/execution_service/server_implementation.cpp
+++ b/src/buildtool/execution_api/execution_service/server_implementation.cpp
@@ -29,6 +29,7 @@
 #include "src/buildtool/execution_api/execution_service/capabilities_server.hpp"
 #include "src/buildtool/execution_api/execution_service/cas_server.hpp"
 #include "src/buildtool/execution_api/execution_service/execution_server.hpp"
+#include "src/buildtool/execution_api/execution_service/operations_server.hpp"
 #include "src/buildtool/execution_api/remote/config.hpp"
 #include "src/buildtool/logging/logger.hpp"
 
@@ -53,6 +54,7 @@ auto ServerImpl::Run() -> bool {
     CASServiceImpl cas{};
     BytestreamServiceImpl b{};
     CapabilitiesServiceImpl cap{};
+    OperarationsServiceImpl op{};
 
     grpc::ServerBuilder builder;
 
@@ -60,7 +62,8 @@ auto ServerImpl::Run() -> bool {
         .RegisterService(&ac)
         .RegisterService(&cas)
         .RegisterService(&b)
-        .RegisterService(&cap);
+        .RegisterService(&cap)
+        .RegisterService(&op);
 
     std::shared_ptr<grpc::ServerCredentials> creds;
     if (Auth::GetAuthMethod() == AuthMethod::kTLS) {