Skip to content

Commit 9df97c6

Browse files
authored
Bump up CRT version, clean up resources in tests, fix credential adapter TODO (#2594)
1 parent c61d14b commit 9df97c6

File tree

3 files changed

+18
-23
lines changed

3 files changed

+18
-23
lines changed

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@
112112
<rxjava.version>2.2.21</rxjava.version>
113113
<commons-codec.verion>1.10</commons-codec.verion>
114114
<jmh.version>1.29</jmh.version>
115-
<awscrt.version>0.13.2</awscrt.version>
115+
<awscrt.version>0.13.5</awscrt.version>
116116

117117
<!--Test dependencies -->
118118
<junit.version>4.13.1</junit.version>

services-custom/s3-transfer-manager/src/it/java/software/amazon/awssdk/transfer/s3/CrtExceptionTransformationIntegrationTest.java

Lines changed: 16 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616
package software.amazon.awssdk.transfer.s3;
1717

1818
import org.junit.AfterClass;
19-
import org.junit.Before;
2019
import org.junit.BeforeClass;
2120
import org.junit.Test;
2221
import software.amazon.awssdk.services.s3.model.GetObjectRequest;
@@ -41,33 +40,30 @@ public class CrtExceptionTransformationIntegrationTest extends S3IntegrationTest
4140

4241
private static final int OBJ_SIZE = 8 * 1024;
4342
private static RandomTempFile testFile;
44-
private S3TransferManager transferManager;
45-
private S3CrtAsyncClient s3Crt;
43+
private static S3TransferManager transferManager;
44+
private static S3CrtAsyncClient s3Crt;
4645

4746
@BeforeClass
48-
public static void setupFixture() {
47+
public static void setupFixture() throws IOException {
4948
createBucket(BUCKET);
49+
testFile = new RandomTempFile(BUCKET, OBJ_SIZE);
50+
s3Crt = S3CrtAsyncClient.builder()
51+
.credentialsProvider(CREDENTIALS_PROVIDER_CHAIN)
52+
.region(S3IntegrationTestBase.DEFAULT_REGION)
53+
.build();
54+
transferManager =
55+
S3TransferManager.builder()
56+
.s3ClientConfiguration(b -> b.credentialsProvider(CREDENTIALS_PROVIDER_CHAIN)
57+
.region(S3IntegrationTestBase.DEFAULT_REGION))
58+
.build();
5059
}
5160

5261
@AfterClass
5362
public static void tearDownFixture() {
5463
deleteBucketAndAllContents(BUCKET);
55-
}
56-
57-
@Before
58-
public void methodSetup() throws IOException {
59-
testFile = new RandomTempFile(BUCKET, OBJ_SIZE);
60-
s3Crt = S3CrtAsyncClient.builder()
61-
.credentialsProvider(CREDENTIALS_PROVIDER_CHAIN)
62-
.region(S3IntegrationTestBase.DEFAULT_REGION)
63-
.build();
64-
transferManager =
65-
S3TransferManager.builder()
66-
.s3ClientConfiguration(b -> b.credentialsProvider(CREDENTIALS_PROVIDER_CHAIN)
67-
.region(S3IntegrationTestBase.DEFAULT_REGION)
68-
.targetThroughputInGbps(20.0)
69-
.minimumPartSizeInBytes(1000L))
70-
.build();
64+
s3Crt.close();
65+
transferManager.close();
66+
testFile.delete();
7167
}
7268

7369
@Test

services-custom/s3-transfer-manager/src/main/java/software/amazon/awssdk/transfer/s3/internal/CrtCredentialsProviderAdapter.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,8 +42,7 @@ public CrtCredentialsProviderAdapter(AwsCredentialsProvider credentialsProvider)
4242
byte[] accessKey = sdkCredentials.accessKeyId().getBytes(StandardCharsets.UTF_8);
4343
byte[] secreteKey = sdkCredentials.secretAccessKey().getBytes(StandardCharsets.UTF_8);
4444

45-
// TODO: confirm with CRT if set empty means null. Currently setting null causes the crash
46-
byte[] sessionTokens = new byte[0];
45+
byte[] sessionTokens = null;
4746
if (sdkCredentials instanceof AwsSessionCredentials) {
4847
sessionTokens =
4948
((AwsSessionCredentials) sdkCredentials).sessionToken().getBytes(StandardCharsets.UTF_8);

0 commit comments

Comments
 (0)