[jclouds] branch master updated: Store transient Blob data with ByteArrayPayload

[ga...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

gaul pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/jclouds.git


The following commit(s) were added to refs/heads/master by this push:
     new 8de7b696 Store transient Blob data with ByteArrayPayload
8de7b696 is described below

commit 8de7b696e13f7131b3ea4a77b10f5cfd139dd712
Author: Andrew Gaul <ga...@apache.org>
AuthorDate: Sun Jul 12 04:53:37 2020 +0900

    Store transient Blob data with ByteArrayPayload
    
    This avoids a race condition due to sharing the same Closer instance
    and unbounded growth of its Closeable Deque.  References
    gaul/s3proxy#303.
---
 .../src/main/java/org/jclouds/blobstore/TransientStorageStrategy.java  | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/blobstore/src/main/java/org/jclouds/blobstore/TransientStorageStrategy.java b/blobstore/src/main/java/org/jclouds/blobstore/TransientStorageStrategy.java
index 3053aa4..66e1583 100644
--- a/blobstore/src/main/java/org/jclouds/blobstore/TransientStorageStrategy.java
+++ b/blobstore/src/main/java/org/jclouds/blobstore/TransientStorageStrategy.java
@@ -55,7 +55,6 @@ import com.google.common.collect.Multimaps;
 import com.google.common.hash.HashCode;
 import com.google.common.hash.Hashing;
 import com.google.common.hash.HashingInputStream;
-import com.google.common.io.ByteSource;
 import com.google.common.io.ByteStreams;
 import com.google.common.net.HttpHeaders;
 
@@ -239,7 +238,7 @@ public class TransientStorageStrategy implements LocalStorageStrategy {
       checkNotNull(in, "blob");
       checkNotNull(input, "input");
       checkNotNull(contentMd5, "contentMd5");
-      Payload payload = Payloads.newByteSourcePayload(ByteSource.wrap(input));
+      Payload payload = Payloads.newByteArrayPayload(input);
       MutableContentMetadata oldMd = in.getPayload().getContentMetadata();
       HttpUtils.copy(oldMd, payload.getContentMetadata());
       payload.getContentMetadata().setContentMD5(contentMd5);