Apache/jclouds
1
0
Fork 0
mirror of https://github.com/apache/jclouds.git synced 2025-02-07 18:49:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add test for aborting a single part MPU

Browse Source 
Also tighten up checks to ensure there is no litter, mostly for
transient and filesystem blobstores.
This commit is contained in:
Andrew Gaul 2019-02-06 17:11:57 -08:00
parent d14276d9a5
commit 222fb84f5c
1 changed files with 27 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
blobstore/src/test/java/org/jclouds/blobstore/integration/internal/BaseBlobIntegrationTest.java
View File

@ -1290,6 +1290,33 @@ public class BaseBlobIntegrationTest extends BaseBlobStoreIntegrationTest {
blobStore.abortMultipartUpload(mpu); blobStore.abortMultipartUpload(mpu);
assertThat(blobStore.list(container)).isEmpty();
blob = blobStore.getBlob(container, name);
assertThat(blob).isNull();
} finally {
returnContainer(container);
}
}
@Test(groups = { "integration", "live" })
public void testMultipartUploadOnePartAbort() throws Exception {
BlobStore blobStore = view.getBlobStore();
String container = getContainerName();
try {
String name = "blob-name";
Blob blob = blobStore.blobBuilder(name).build();
MultipartUpload mpu = blobStore.initiateMultipartUpload(container, blob.getMetadata(), new PutOptions());
ByteSource byteSource = TestUtils.randomByteSource().slice(0, 1);
Payload payload = Payloads.newByteSourcePayload(byteSource);
payload.getContentMetadata().setContentLength(byteSource.size());
MultipartPart part = blobStore.uploadMultipartPart(mpu, 1, payload);
blobStore.abortMultipartUpload(mpu);
assertThat(blobStore.list(container)).isEmpty();
blob = blobStore.getBlob(container, name); blob = blobStore.getBlob(container, name);
assertThat(blob).isNull(); assertThat(blob).isNull();
} finally { } finally {