Apache
/
jclouds
mirror of https://github.com/apache/jclouds.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #723 from andrewgaul/filesystem-transient-input-supplier 

Ensure we close streams via InputSupplier methods
This commit is contained in:
Adrian Cole 2012-07-17 15:23:47 -07:00
parent 880388d035 bd5bf0dad2
commit 007eba6d7c
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apis/filesystem/src/main/java/org/jclouds/filesystem/FilesystemAsyncBlobStore.java
View File

@ -539,7 +539,7 @@ public class FilesystemAsyncBlobStore extends BaseAsyncBlobStore {
if (options.getRanges() != null && options.getRanges().size() > 0) { if (options.getRanges() != null && options.getRanges().size() > 0) {
byte[] data; byte[] data;
try { try {
data = toByteArray(blob.getPayload().getInput()); data = toByteArray(blob.getPayload());
} catch (IOException e) { } catch (IOException e) {
return immediateFailedFuture(new RuntimeException(e)); return immediateFailedFuture(new RuntimeException(e));
} }

2
blobstore/src/main/java/org/jclouds/blobstore/TransientAsyncBlobStore.java
View File

@ -580,7 +580,7 @@ public class TransientAsyncBlobStore extends BaseAsyncBlobStore {
if (options.getRanges() != null && options.getRanges().size() > 0) { if (options.getRanges() != null && options.getRanges().size() > 0) {
byte[] data; byte[] data;
try { try {
data = toByteArray(blob.getPayload().getInput()); data = toByteArray(blob.getPayload());
} catch (IOException e) { } catch (IOException e) {
return immediateFailedFuture(new RuntimeException(e)); return immediateFailedFuture(new RuntimeException(e));
} }