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

JCLOUDS-1125: Upload two parts in list MPU test 

This allows B2 to call complete multipart upload.
This commit is contained in:
Andrew Gaul 2016-06-13 17:00:50 -07:00
parent 0bd2959410
commit 52de3b5766
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1297,15 +1297,22 @@ public class BaseBlobIntegrationTest extends BaseBlobStoreIntegrationTest {
// some providers like Azure cannot list an MPU until the first blob is uploaded // some providers like Azure cannot list an MPU until the first blob is uploaded
assertThat(uploads.size()).isBetween(0, 1); assertThat(uploads.size()).isBetween(0, 1);
ByteSource byteSource = TestUtils.randomByteSource().slice(0, 1); // B2 requires at least two parts to call complete
Payload payload = Payloads.newByteSourcePayload(byteSource); ByteSource byteSource = TestUtils.randomByteSource().slice(0, blobStore.getMinimumMultipartPartSize() + 1);
payload.getContentMetadata().setContentLength(byteSource.size()); ByteSource byteSource1 = byteSource.slice(0, blobStore.getMinimumMultipartPartSize());
MultipartPart part = blobStore.uploadMultipartPart(mpu, 1, payload); ByteSource byteSource2 = byteSource.slice(blobStore.getMinimumMultipartPartSize(), 1);
Payload payload1 = Payloads.newByteSourcePayload(byteSource1);
Payload payload2 = Payloads.newByteSourcePayload(byteSource2);
payload1.getContentMetadata().setContentLength(byteSource1.size());
payload2.getContentMetadata().setContentLength(byteSource2.size());
MultipartPart part1 = blobStore.uploadMultipartPart(mpu, 1, payload1);
MultipartPart part2 = blobStore.uploadMultipartPart(mpu, 2, payload2);
uploads = blobStore.listMultipartUploads(container); uploads = blobStore.listMultipartUploads(container);
assertThat(uploads).hasSize(1); assertThat(uploads).hasSize(1);
blobStore.completeMultipartUpload(mpu, ImmutableList.of(part)); blobStore.completeMultipartUpload(mpu, ImmutableList.of(part1, part2));
mpu = null;
uploads = blobStore.listMultipartUploads(container); uploads = blobStore.listMultipartUploads(container);
assertThat(uploads).isEmpty(); assertThat(uploads).isEmpty();