diff options
author | Maksim Denisov <denisov.maksim@huawei.com> | 2025-01-23 14:41:26 +0100 |
---|---|---|
committer | Maksim Denisov <denisov.maksim@huawei.com> | 2025-02-07 14:58:04 +0100 |
commit | 1dda220300b704dfbe28dad9586246571c49c503 (patch) | |
tree | 5dab68bc60d88805300ff243ce29e4b454e6f34c /src/buildtool/execution_api/remote/bazel/bazel_api.cpp | |
parent | d5a957afddb68c216184dff0e90e16c083be1134 (diff) | |
download | justbuild-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.cpp | 6 |
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); } |