From a5221f5f8e51c639c958dfca5fa9799b572d1803 Mon Sep 17 00:00:00 2001 From: Rita Zhang Date: Tue, 1 Dec 2015 16:30:20 -0800 Subject: [PATCH] Upload two parts in testBigMultipartUpload --- src/test/java/org/gaul/s3proxy/S3AwsSdkTest.java | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) diff --git a/src/test/java/org/gaul/s3proxy/S3AwsSdkTest.java b/src/test/java/org/gaul/s3proxy/S3AwsSdkTest.java index 96d88f4..5166bce 100644 --- a/src/test/java/org/gaul/s3proxy/S3AwsSdkTest.java +++ b/src/test/java/org/gaul/s3proxy/S3AwsSdkTest.java @@ -220,6 +220,7 @@ public final class S3AwsSdkTest { String key = "multipart-upload"; int size = 10_000_000; + int partSize = 5 * 1024 * 1024; ByteSource byteSource = TestUtils.randomByteSource().slice(0, size); InitiateMultipartUploadRequest initRequest = @@ -232,13 +233,25 @@ public final class S3AwsSdkTest { .withBucketName(containerName).withKey(key) .withUploadId(uploadId).withPartNumber(1) .withInputStream(byteSource.openStream()) - .withPartSize(size); + .withPartSize(partSize); UploadPartResult uploadPartResult = client.uploadPart(uploadRequest); PartETag partETag = uploadPartResult.getPartETag(); + + UploadPartRequest uploadRequest2 = new UploadPartRequest() + .withBucketName(containerName).withKey(key) + .withUploadId(uploadId).withPartNumber(2) + .withInputStream(byteSource + .slice(partSize, size - partSize).openStream()) + .withPartSize(size - partSize); + + UploadPartResult uploadPartResult2 = client.uploadPart(uploadRequest2); + PartETag partETag2 = uploadPartResult2.getPartETag(); + // must be mutable since AWK SDK sorts parts List partETagList = new ArrayList(); partETagList.add(partETag); + partETagList.add(partETag2); CompleteMultipartUploadRequest completeRequest = new CompleteMultipartUploadRequest(