diff options
author | tomlu <tomlu@google.com> | 2018-08-03 11:34:23 -0700 |
---|---|---|
committer | Copybara-Service <copybara-piper@google.com> | 2018-08-03 11:36:05 -0700 |
commit | e18be0b36ddd5aff3befdb6bd231752c30a1023a (patch) | |
tree | f7c9eaaa85d072b34b230362d9243d97b36ff23f /src/tools | |
parent | 880508ccf8bab7aa9d238210f8b2ee21d52600f9 (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.java | 5 |
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()); |