Skip to content
Merged
Show file tree
Hide file tree
Changes from 18 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion crt/s2n
Submodule s2n updated from f5e5e8 to a71ea1
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,17 @@ public enum ChecksumAlgorithm {

SHA256(4),

CRC64NVME(5);
CRC64NVME(5),

SHA512(6),

XXHASH64(7),

XXHASH3(8),

XXHASH128(9),

MD5(10);
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

why we have md5 here, but not in c-s3?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

convenience for java team. they just cast their enum directly. c-s3 currently does not support it.


ChecksumAlgorithm(int nativeValue) {
this.nativeValue = nativeValue;
Expand All @@ -49,6 +59,11 @@ private static Map<Integer, ChecksumAlgorithm> buildEnumMapping() {
enumMapping.put(SHA1.getNativeValue(), SHA1);
enumMapping.put(SHA256.getNativeValue(), SHA256);
enumMapping.put(CRC64NVME.getNativeValue(), CRC64NVME);
enumMapping.put(SHA512.getNativeValue(), SHA512);
enumMapping.put(XXHASH64.getNativeValue(), XXHASH64);
enumMapping.put(XXHASH3.getNativeValue(), XXHASH3);
enumMapping.put(XXHASH128.getNativeValue(), XXHASH128);
enumMapping.put(MD5.getNativeValue(), MD5);
return enumMapping;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -114,7 +114,7 @@ public boolean getValidateChecksum() {
* The list of algorithms for user to pick up when validate the checksum. Client
* will pick up the algorithm from the list with the priority based on
* performance, and the algorithm sent by server. The priority based on
* performance is [CRC64NVME, CRC32C, CRC32, SHA1, SHA256].
* performance is [XXHASH128, XXHASH3,CRC64NVME, CRC32C, CRC32, XXHASH64, SHA512, SHA1, SHA256].
Comment thread
DmitriyMusatkin marked this conversation as resolved.
Outdated
*
* If the response checksum was validated by client, the result will indicate
* which algorithm was picked.
Expand Down
6 changes: 6 additions & 0 deletions src/main/java/software/amazon/awssdk/crt/s3/S3Client.java
Original file line number Diff line number Diff line change
Expand Up @@ -168,6 +168,12 @@ public S3MetaRequest makeMetaRequest(S3MetaRequestOptions options) {
throw new IllegalArgumentException("S3Client.makeMetaRequest has invalid options; Operation name must be set for MetaRequestType.DEFAULT.");
}

if (options.getChecksumConfig() != null && options.getChecksumAlgorithm() == ChecksumAlgorithm.MD5) {
Log.log(Log.LogLevel.Error, Log.LogSubject.S3Client,
"S3Client.makeMetaRequest has invalid options; MD5 not supported as checksum algorithm.");
throw new IllegalArgumentException("S3Client.makeMetaRequest has invalid options; MD5 not supported as checksum algorithm.");
}

S3MetaRequest metaRequest = new S3MetaRequest();
S3MetaRequestResponseHandlerNativeAdapter responseHandlerNativeAdapter = new S3MetaRequestResponseHandlerNativeAdapter(
options.getResponseHandler());
Expand Down
55 changes: 54 additions & 1 deletion src/test/java/software/amazon/awssdk/crt/test/S3ClientTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -307,6 +307,39 @@ public void testS3ClientCreateDestroyHttpProxyEnvironmentVariableSetting() {
}
}

@Test
public void testS3ClientCreateMD5MetaRequest() {
skipIfAndroid();
skipIfNetworkUnavailable();

S3ClientOptions clientOptions = new S3ClientOptions().withRegion(REGION)
.withComputeContentMd5(true)
.withMemoryLimitInBytes(5L * 1024 * 1024 * 1024);
try (S3Client client = createS3Client(clientOptions)) {
S3MetaRequestResponseHandler responseHandler = new S3MetaRequestResponseHandler() {
@Override
public int onResponseBody(ByteBuffer bodyBytesIn, long objectRangeStart, long objectRangeEnd) {
return 0;
}

@Override
public void onFinished(S3FinishedResponseContext context) {
}
};

HttpHeader[] headers = { new HttpHeader("Host", ENDPOINT) };
HttpRequest httpRequest = new HttpRequest("GET", PRE_EXIST_1MB_PATH, headers, null);

S3MetaRequestOptions metaRequestOptions = new S3MetaRequestOptions()
.withMetaRequestType(MetaRequestType.GET_OBJECT)
.withChecksumAlgorithm(ChecksumAlgorithm.MD5)
.withHttpRequest(httpRequest)
.withResponseHandler(responseHandler);

Assert.assertThrows(IllegalArgumentException.class, () -> { client.makeMetaRequest(metaRequestOptions); });
}
}

@Test
public void testS3Get() {
skipIfAndroid();
Expand Down Expand Up @@ -1360,9 +1393,13 @@ public void onFinished(S3FinishedResponseContext context) {
}
};
ArrayList<ChecksumAlgorithm> algorList = new ArrayList<ChecksumAlgorithm>();
algorList.add(ChecksumAlgorithm.XXHASH128);
algorList.add(ChecksumAlgorithm.XXHASH3);
algorList.add(ChecksumAlgorithm.CRC64NVME);
algorList.add(ChecksumAlgorithm.CRC32C);
algorList.add(ChecksumAlgorithm.CRC32);
algorList.add(ChecksumAlgorithm.XXHASH64);
algorList.add(ChecksumAlgorithm.SHA512);
algorList.add(ChecksumAlgorithm.SHA1);
algorList.add(ChecksumAlgorithm.SHA256);
ChecksumConfig validateChecksumConfig = new ChecksumConfig().withValidateChecksum(true)
Expand All @@ -1381,13 +1418,29 @@ public void onFinished(S3FinishedResponseContext context) {
}

@Test
public void testS3PutTrailerChecksums() throws Exception {
public void testS3PutTrailerChecksumsCRC64() throws Exception {
skipIfAndroid();
skipIfNetworkUnavailable();
Assume.assumeTrue(hasAwsCredentials());
testS3RoundTripWithChecksumHelper(ChecksumAlgorithm.CRC64NVME, ChecksumLocation.TRAILER, false, false);
}

@Test
public void testS3PutTrailerChecksumsSHA512() throws Exception {
skipIfAndroid();
skipIfNetworkUnavailable();
Assume.assumeTrue(hasAwsCredentials());
testS3RoundTripWithChecksumHelper(ChecksumAlgorithm.SHA512, ChecksumLocation.TRAILER, false, false);
}

@Test
public void testS3PutTrailerChecksumsXXHASH3_64() throws Exception {
skipIfAndroid();
skipIfNetworkUnavailable();
Assume.assumeTrue(hasAwsCredentials());
testS3RoundTripWithChecksumHelper(ChecksumAlgorithm.XXHASH3, ChecksumLocation.TRAILER, false, false);
}

@Test
public void testS3PutHeaderChecksums() throws Exception {
skipIfAndroid();
Expand Down
Loading