diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/buildtool/execution_api/remote/bazel/bytestream_client.hpp | 19 |
1 files changed, 15 insertions, 4 deletions
diff --git a/src/buildtool/execution_api/remote/bazel/bytestream_client.hpp b/src/buildtool/execution_api/remote/bazel/bytestream_client.hpp index dd1aa773..79ed20ca 100644 --- a/src/buildtool/execution_api/remote/bazel/bytestream_client.hpp +++ b/src/buildtool/execution_api/remote/bazel/bytestream_client.hpp @@ -47,7 +47,10 @@ class ByteStreamClient { if (not finished_) { auto status = reader_->Finish(); if (not status.ok()) { - LogStatus(logger_, LogLevel::Debug, status); + logger_->Emit(LogLevel::Error, + "{}: {}", + static_cast<int>(status.error_code()), + status.error_message()); return std::nullopt; } finished_ = true; @@ -150,10 +153,18 @@ class ByteStreamClient { LogStatus(&logger_, LogLevel::Error, status); return false; } - - return gsl::narrow<std::size_t>(response.committed_size()) == - data.size(); + if (gsl::narrow<std::size_t>(response.committed_size()) != + data.size()) { + logger_.Emit( + LogLevel::Error, + "Commited size {} is different from the original one {}.", + response.committed_size(), + data.size()); + return false; + } + return true; } catch (...) { + logger_.Emit(LogLevel::Error, "Caught exception in Write"); return false; } } |