From 55ba09ec97d2449b39d7fcc38c346969168d899b Mon Sep 17 00:00:00 2001 From: Alberto Sartori Date: Mon, 27 Feb 2023 10:27:52 +0100 Subject: 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. --- .../execution_api/execution_service/server_implementation.cpp | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'src/buildtool/execution_api/execution_service/server_implementation.cpp') 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 creds; if (Auth::GetAuthMethod() == AuthMethod::kTLS) { -- cgit v1.2.3