summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/buildtool/execution_api/execution_service/cas_server.cpp12
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};
}
}
}