diff --git a/src/main/java/org/gaul/s3proxy/NullBlobStore.java b/src/main/java/org/gaul/s3proxy/NullBlobStore.java index 904235dd..d0f5b661 100644 --- a/src/main/java/org/gaul/s3proxy/NullBlobStore.java +++ b/src/main/java/org/gaul/s3proxy/NullBlobStore.java @@ -28,7 +28,6 @@ import com.google.common.collect.ImmutableSet; import com.google.common.hash.HashCode; import com.google.common.io.ByteSource; -import com.google.common.io.ByteStreams; import com.google.common.primitives.Longs; import org.jclouds.blobstore.BlobStore; @@ -81,7 +80,7 @@ public Blob getBlob(String container, String name, GetOptions options) { byte[] array; try (InputStream is = blob.getPayload().openStream()) { - array = ByteStreams.toByteArray(is); + array = is.readAllBytes(); } catch (IOException ioe) { throw new RuntimeException(ioe); } diff --git a/src/main/java/org/gaul/s3proxy/S3ProxyHandler.java b/src/main/java/org/gaul/s3proxy/S3ProxyHandler.java index 6d2de45d..f9bcb262 100644 --- a/src/main/java/org/gaul/s3proxy/S3ProxyHandler.java +++ b/src/main/java/org/gaul/s3proxy/S3ProxyHandler.java @@ -577,8 +577,8 @@ public final void doHandle(HttpServletRequest baseRequest, } else { // buffer the entire stream to calculate digest // why input stream read contentlength of header? - payload = ByteStreams.toByteArray(ByteStreams.limit( - is, v4MaxNonChunkedRequestSize + 1)); + payload = ByteStreams.limit(is, v4MaxNonChunkedRequestSize + 1) + .readAllBytes(); if (payload.length == v4MaxNonChunkedRequestSize + 1) { throw new S3Exception( S3ErrorCode.MAX_MESSAGE_LENGTH_EXCEEDED);