From bd66d45945dc186a0d08db7d9845ef657d549577 Mon Sep 17 00:00:00 2001 From: Alberto Sartori Date: Mon, 23 Jan 2023 18:31:14 +0100 Subject: execution-service: add new subcommand execute This subcommand starts a single node remote execution service honoring the just native remote protocol. If the flag --compatible is provided, the execution service will honor the original remote build execution protocol. New command line args supported by this subcommand: -p,--port INT: Execution service will listen to this port. If unset, the service will listen to the first available one. --info-file TEXT: Write the used port, interface, and pid to this file in JSON format. If the file exists, it will be overwritten. -i,--interface TEXT: Interface to use. If unset, the loopback device is used. --pid-file TEXT Write pid to this file in plain txt. If the file exists, it will be overwritten. --tls-server-cert TEXT: Path to the TLS server certificate. --tls-server-key TEXT: Path to the TLS server key. Co-authored by: Klaus Aehlig --- .../execution_api/execution_service/ac_server.cpp | 54 ++++++++++++++++++++++ 1 file changed, 54 insertions(+) create mode 100644 src/buildtool/execution_api/execution_service/ac_server.cpp (limited to 'src/buildtool/execution_api/execution_service/ac_server.cpp') diff --git a/src/buildtool/execution_api/execution_service/ac_server.cpp b/src/buildtool/execution_api/execution_service/ac_server.cpp new file mode 100644 index 00000000..1b5b9470 --- /dev/null +++ b/src/buildtool/execution_api/execution_service/ac_server.cpp @@ -0,0 +1,54 @@ +// Copyright 2023 Huawei Cloud Computing Technology Co., Ltd. +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +#include "src/buildtool/execution_api/execution_service/ac_server.hpp" + +#include "fmt/format.h" +#include "src/buildtool/execution_api/local/garbage_collector.hpp" + +auto ActionCacheServiceImpl::GetActionResult( + ::grpc::ServerContext* /*context*/, + const ::build::bazel::remote::execution::v2::GetActionResultRequest* + request, + ::build::bazel::remote::execution::v2::ActionResult* response) + -> ::grpc::Status { + logger_.Emit(LogLevel::Trace, + "GetActionResult: {}", + request->action_digest().hash()); + auto lock = GarbageCollector::SharedLock(); + if (!lock) { + auto str = fmt::format("Could not acquire SharedLock"); + logger_.Emit(LogLevel::Error, str); + return grpc::Status{grpc::StatusCode::INTERNAL, str}; + } + auto x = ac_.CachedResult(request->action_digest()); + if (!x) { + return grpc::Status{ + grpc::StatusCode::NOT_FOUND, + fmt::format("{} missing from AC", request->action_digest().hash())}; + } + *response = *x; + return ::grpc::Status::OK; +} + +auto ActionCacheServiceImpl::UpdateActionResult( + ::grpc::ServerContext* /*context*/, + const ::build::bazel::remote::execution::v2::UpdateActionResultRequest* + /*request*/, + ::build::bazel::remote::execution::v2::ActionResult* /*response*/) + -> ::grpc::Status { + auto const* str = "UpdateActionResult not implemented"; + logger_.Emit(LogLevel::Error, str); + return ::grpc::Status{grpc::StatusCode::UNIMPLEMENTED, str}; +} -- cgit v1.2.3