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

Close streams in filesystem tests 

Windows cannot delete open files and this may have caused test
failures.  References #912.
This commit is contained in:
Andrew Gaul 2012-05-03 06:43:01 -07:00
parent 19390ea87d
commit 0903d8522a
1 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
apis/filesystem/src/test/java/org/jclouds/filesystem/FilesystemAsyncBlobStoreTest.java
View File

@ -64,6 +64,7 @@ import org.testng.annotations.BeforeMethod;
import org.testng.annotations.DataProvider; import org.testng.annotations.DataProvider;
import org.testng.annotations.Test; import org.testng.annotations.Test;
import com.google.common.io.Closeables;
import com.google.inject.CreationException; import com.google.inject.CreationException;
/** /**
@ -730,23 +731,39 @@ public class FilesystemAsyncBlobStoreTest {
*/ */
final String containerName = "containerWithRanges"; final String containerName = "containerWithRanges";
String payload = "abcdefgh"; String payload = "abcdefgh";
InputStream is;
Blob blob = blobStore.blobBuilder("test").payload(new StringPayload(payload)).build(); Blob blob = blobStore.blobBuilder("test").payload(new StringPayload(payload)).build();
blobStore.putBlob(containerName, blob); blobStore.putBlob(containerName, blob);
GetOptions getOptionsRangeStartAt = new GetOptions(); GetOptions getOptionsRangeStartAt = new GetOptions();
getOptionsRangeStartAt.startAt(1); getOptionsRangeStartAt.startAt(1);
Blob blobRangeStartAt = blobStore.getBlob(containerName, blob.getMetadata().getName(), getOptionsRangeStartAt); Blob blobRangeStartAt = blobStore.getBlob(containerName, blob.getMetadata().getName(), getOptionsRangeStartAt);
Assert.assertEquals("bcdefgh", IOUtils.toString(blobRangeStartAt.getPayload().getInput())); is = blobRangeStartAt.getPayload().getInput();
try {
Assert.assertEquals("bcdefgh", IOUtils.toString(is));
} finally {
Closeables.closeQuietly(is);
}
GetOptions getOptionsRangeTail = new GetOptions(); GetOptions getOptionsRangeTail = new GetOptions();
getOptionsRangeTail.tail(3); getOptionsRangeTail.tail(3);
Blob blobRangeTail = blobStore.getBlob(containerName, blob.getMetadata().getName(), getOptionsRangeTail); Blob blobRangeTail = blobStore.getBlob(containerName, blob.getMetadata().getName(), getOptionsRangeTail);
Assert.assertEquals("fgh", IOUtils.toString(blobRangeTail.getPayload().getInput())); is = blobRangeTail.getPayload().getInput();
try {
Assert.assertEquals("fgh", IOUtils.toString(is));
} finally {
Closeables.closeQuietly(is);
}
GetOptions getOptionsFragment = new GetOptions(); GetOptions getOptionsFragment = new GetOptions();
getOptionsFragment.range(4, 6); getOptionsFragment.range(4, 6);
Blob blobFragment = blobStore.getBlob(containerName, blob.getMetadata().getName(), getOptionsFragment); Blob blobFragment = blobStore.getBlob(containerName, blob.getMetadata().getName(), getOptionsFragment);
Assert.assertEquals("efg", IOUtils.toString(blobFragment.getPayload().getInput())); is = blobFragment.getPayload().getInput();
try {
Assert.assertEquals("efg", IOUtils.toString(is));
} finally {
Closeables.closeQuietly(is);
}
} }
/** Test that BlobRequestSigner creates expected URIs. */ /** Test that BlobRequestSigner creates expected URIs. */