commit 8de7b696e13f7131b3ea4a77b10f5cfd139dd712
author Andrew Gaul <gaul@apache.org> Sun Jul 12 04:53:37 2020 +0900
committer Andrew Gaul <gaul@apache.org> Sun Jul 12 05:13:48 2020 +0900
tree 954d58369fd11952704046482787053fd9f85e94
parent 9e4c7a16daeb97f9b51b9077e40d12ce5343840f

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.

blobstore/src/main/java/org/jclouds/blobstore/TransientStorageStrategy.java

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.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 @@
       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);