From dfcd8d353ff8e8920d9ad8e1e56f79f5a54b73ea Mon Sep 17 00:00:00 2001 From: Alberto Sartori Date: Wed, 15 Feb 2023 16:17:11 +0100 Subject: just-execute: report un-tagged hashes --- .../execution_api/execution_service/cas_server.cpp | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) (limited to 'src/buildtool/execution_api/execution_service/cas_server.cpp') diff --git a/src/buildtool/execution_api/execution_service/cas_server.cpp b/src/buildtool/execution_api/execution_service/cas_server.cpp index 025a6757..3afde937 100644 --- a/src/buildtool/execution_api/execution_service/cas_server.cpp +++ b/src/buildtool/execution_api/execution_service/cas_server.cpp @@ -32,7 +32,9 @@ auto CASServiceImpl::FindMissingBlobs( } for (auto const& x : request->blob_digests()) { auto const& hash = x.hash(); - logger_.Emit(LogLevel::Trace, "FindMissingBlobs: {}", hash); + logger_.Emit(LogLevel::Trace, + "FindMissingBlobs: {}", + NativeSupport::Unprefix(hash)); if (NativeSupport::IsTree(hash)) { if (!storage_.TreePath(x)) { auto* d = response->add_missing_blob_digests(); @@ -61,20 +63,24 @@ auto CASServiceImpl::BatchUpdateBlobs( } for (auto const& x : request->requests()) { auto const& hash = x.digest().hash(); - logger_.Emit(LogLevel::Trace, "BatchUpdateBlobs: {}", hash); + logger_.Emit(LogLevel::Trace, + "BatchUpdateBlobs: {}", + NativeSupport::Unprefix(hash)); auto* r = response->add_responses(); r->mutable_digest()->CopyFrom(x.digest()); if (NativeSupport::IsTree(hash)) { if (!storage_.StoreTree(x.data())) { - auto const& str = fmt::format( - "BatchUpdateBlobs: could not upload tree {}", hash); + auto const& str = + fmt::format("BatchUpdateBlobs: could not upload tree {}", + NativeSupport::Unprefix(hash)); logger_.Emit(LogLevel::Error, str); return ::grpc::Status{grpc::StatusCode::INTERNAL, str}; } } else if (!storage_.StoreBlob(x.data(), false)) { auto const& str = - fmt::format("BatchUpdateBlobs: could not upload blob {}", hash); + fmt::format("BatchUpdateBlobs: could not upload blob {}", + NativeSupport::Unprefix(hash)); logger_.Emit(LogLevel::Error, str); return ::grpc::Status{grpc::StatusCode::INTERNAL, str}; } -- cgit v1.2.3