aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/tools
diff options
context:
space:
mode:
authorGravatar tomlu <tomlu@google.com>2018-08-03 11:34:23 -0700
committerGravatar Copybara-Service <copybara-piper@google.com>2018-08-03 11:36:05 -0700
commite18be0b36ddd5aff3befdb6bd231752c30a1023a (patch)
treef7c9eaaa85d072b34b230362d9243d97b36ff23f /src/tools
parent880508ccf8bab7aa9d238210f8b2ee21d52600f9 (diff)
Pass digest to Chunker construction when available.
* Refactor Chunker constructor to a builder to reduce constructor overload. * Pass digest into this where we have it * Redo ensureInputsPresent to not lose the missing digests during processing so we can pass them to the Chunker constructor. RELNOTES: None PiperOrigin-RevId: 207297915
Diffstat (limited to 'src/tools')
-rw-r--r--src/tools/remote/src/main/java/com/google/devtools/build/remote/worker/ByteStreamServer.java5
1 files changed, 4 insertions, 1 deletions
diff --git a/src/tools/remote/src/main/java/com/google/devtools/build/remote/worker/ByteStreamServer.java b/src/tools/remote/src/main/java/com/google/devtools/build/remote/worker/ByteStreamServer.java
index 066d93cf7c..08c4163621 100644
--- a/src/tools/remote/src/main/java/com/google/devtools/build/remote/worker/ByteStreamServer.java
+++ b/src/tools/remote/src/main/java/com/google/devtools/build/remote/worker/ByteStreamServer.java
@@ -81,7 +81,10 @@ final class ByteStreamServer extends ByteStreamImplBase {
try {
// This still relies on the blob size to be small enough to fit in memory.
// TODO(olaola): refactor to fix this if the need arises.
- Chunker c = new Chunker(getFromFuture(cache.downloadBlob(digest)), digestUtil);
+ Chunker c =
+ Chunker.builder(digestUtil)
+ .setInput(digest, getFromFuture(cache.downloadBlob(digest)))
+ .build();
while (c.hasNext()) {
responseObserver.onNext(
ReadResponse.newBuilder().setData(c.next().getData()).build());