summaryrefslogtreecommitdiff
path: root/src/buildtool/execution_api/remote/bazel/bazel_api.cpp
diff options
context:
space:
mode:
authorMaksim Denisov <denisov.maksim@huawei.com>2025-01-23 14:41:26 +0100
committerMaksim Denisov <denisov.maksim@huawei.com>2025-02-07 14:58:04 +0100
commit1dda220300b704dfbe28dad9586246571c49c503 (patch)
tree5dab68bc60d88805300ff243ce29e4b454e6f34c /src/buildtool/execution_api/remote/bazel/bazel_api.cpp
parentd5a957afddb68c216184dff0e90e16c083be1134 (diff)
downloadjustbuild-1dda220300b704dfbe28dad9586246571c49c503.tar.gz
BazelNetworkReader: Use ArtifactDigest in IncrementalReader
...and while there, pass digests needed to be read by pointer to IncrementalReader to avoid an extra copy.
Diffstat (limited to 'src/buildtool/execution_api/remote/bazel/bazel_api.cpp')
-rw-r--r--src/buildtool/execution_api/remote/bazel/bazel_api.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/buildtool/execution_api/remote/bazel/bazel_api.cpp b/src/buildtool/execution_api/remote/bazel/bazel_api.cpp
index 0bfacf3f..bee70424 100644
--- a/src/buildtool/execution_api/remote/bazel/bazel_api.cpp
+++ b/src/buildtool/execution_api/remote/bazel/bazel_api.cpp
@@ -64,7 +64,7 @@ namespace {
auto reader = network->CreateReader();
std::size_t count{};
std::unordered_set<ArtifactBlob> container{};
- for (auto blobs : reader.ReadIncrementally(digests)) {
+ for (auto blobs : reader.ReadIncrementally(&digests)) {
if (count + blobs.size() > size) {
Logger::Log(LogLevel::Warning,
"received more blobs than requested.");
@@ -248,7 +248,7 @@ auto BazelApi::CreateAction(
auto size = file_digests.size();
auto reader = network_->CreateReader();
std::size_t count{};
- for (auto blobs : reader.ReadIncrementally(file_digests)) {
+ for (auto blobs : reader.ReadIncrementally(&file_digests)) {
if (count + blobs.size() > size) {
Logger::Log(LogLevel::Warning,
"received more blobs than requested.");
@@ -556,7 +556,7 @@ auto BazelApi::CreateAction(
gsl::not_null<std::vector<std::string>*> const& targets) {
auto reader = network->CreateReader();
targets->reserve(digests.size());
- for (auto blobs : reader.ReadIncrementally(digests)) {
+ for (auto blobs : reader.ReadIncrementally(&digests)) {
for (auto const& blob : blobs) {
targets->emplace_back(*blob.data);
}