diff options
| author | Sascha Roloff <sascha.roloff@huawei.com> | 2024-02-23 14:58:49 +0100 |
|---|---|---|
| committer | Sascha Roloff <sascha.roloff@huawei.com> | 2024-02-26 17:16:21 +0100 |
| commit | 702187ec4158b7e6a21e7fb6b0d2f6ef8137dcc9 (patch) | |
| tree | 4130db57070a6914d88faf19800779526fdb73b1 /src/buildtool/execution_api/execution_service/cas_server.cpp | |
| parent | d83c997ad5a866f4fbb38d4a81e7edf70a491db2 (diff) | |
| download | justbuild-702187ec4158b7e6a21e7fb6b0d2f6ef8137dcc9.tar.gz | |
Unify error logging in just execute BatchUpdateBlobs
Diffstat (limited to 'src/buildtool/execution_api/execution_service/cas_server.cpp')
| -rw-r--r-- | src/buildtool/execution_api/execution_service/cas_server.cpp | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/src/buildtool/execution_api/execution_service/cas_server.cpp b/src/buildtool/execution_api/execution_service/cas_server.cpp index 4fd78323..1e56eb53 100644 --- a/src/buildtool/execution_api/execution_service/cas_server.cpp +++ b/src/buildtool/execution_api/execution_service/cas_server.cpp @@ -123,8 +123,10 @@ auto CASServiceImpl::BatchUpdateBlobs( // before storing the actual tree object. if (auto err = CASUtils::EnsureTreeInvariant(x.data(), hash, *storage_)) { + auto str = fmt::format("BatchUpdateBlobs: {}", *err); + logger_.Emit(LogLevel::Error, str); return ::grpc::Status{grpc::StatusCode::FAILED_PRECONDITION, - *err}; + str}; } auto const& dgst = storage_->CAS().StoreTree(x.data()); if (!dgst) { @@ -134,7 +136,9 @@ auto CASServiceImpl::BatchUpdateBlobs( return ::grpc::Status{grpc::StatusCode::INTERNAL, str}; } if (auto err = CheckDigestConsistency(x.digest(), *dgst)) { - return ::grpc::Status{grpc::StatusCode::INVALID_ARGUMENT, *err}; + auto str = fmt::format("BatchUpdateBlobs: {}", *err); + logger_.Emit(LogLevel::Error, str); + return ::grpc::Status{grpc::StatusCode::INVALID_ARGUMENT, str}; } } else { @@ -146,7 +150,9 @@ auto CASServiceImpl::BatchUpdateBlobs( return ::grpc::Status{grpc::StatusCode::INTERNAL, str}; } if (auto err = CheckDigestConsistency(x.digest(), *dgst)) { - return ::grpc::Status{grpc::StatusCode::INVALID_ARGUMENT, *err}; + auto str = fmt::format("BatchUpdateBlobs: {}", *err); + logger_.Emit(LogLevel::Error, str); + return ::grpc::Status{grpc::StatusCode::INVALID_ARGUMENT, str}; } } } |