21
21
22
22
import java .time .Duration ;
23
23
import java .util .stream .Stream ;
24
+ import org .junit .jupiter .api .AfterAll ;
24
25
import org .junit .jupiter .api .Assumptions ;
25
26
import org .junit .jupiter .api .Test ;
26
27
import org .junit .jupiter .params .ParameterizedTest ;
27
28
import org .junit .jupiter .params .provider .Arguments ;
28
29
import org .junit .jupiter .params .provider .MethodSource ;
30
+ import software .amazon .awssdk .crt .CrtResource ;
29
31
import software .amazon .awssdk .crt .io .SocketOptions ;
30
32
import software .amazon .awssdk .crt .io .TlsCipherPreference ;
31
33
import software .amazon .awssdk .http .crt .TcpKeepAliveConfiguration ;
32
34
33
35
class AwsCrtConfigurationUtilsTest {
34
36
37
+ @ AfterAll
38
+ public static void tearDown () {
39
+ CrtResource .waitForNoResources ();
40
+ }
41
+
35
42
@ ParameterizedTest
36
43
@ MethodSource ("cipherPreferences" )
37
44
void resolveCipherPreference_pqNotSupported_shouldFallbackToSystemDefault (Boolean preferPqTls ,
@@ -57,13 +64,16 @@ private static Stream<Arguments> cipherPreferences() {
57
64
@ ParameterizedTest
58
65
@ MethodSource ("tcpKeepAliveConfiguration" )
59
66
void tcpKeepAliveConfiguration (TcpKeepAliveConfiguration tcpKeepAliveConfiguration , Duration connectionTimeout , SocketOptions expected ) {
60
- assertThat (AwsCrtConfigurationUtils .buildSocketOptions (tcpKeepAliveConfiguration , connectionTimeout ))
61
- .satisfies (socketOptions -> {
62
- assertThat (socketOptions .connectTimeoutMs ).isEqualTo (expected .connectTimeoutMs );
63
- assertThat (socketOptions .keepAlive ).isEqualTo (expected .keepAlive );
64
- assertThat (socketOptions .keepAliveIntervalSecs ).isEqualTo (expected .keepAliveIntervalSecs );
65
- assertThat (socketOptions .keepAliveTimeoutSecs ).isEqualTo (expected .keepAliveTimeoutSecs );
66
- });
67
+ try (SocketOptions socketOptions = AwsCrtConfigurationUtils .buildSocketOptions (tcpKeepAliveConfiguration ,
68
+ connectionTimeout )) {
69
+ assertThat (socketOptions )
70
+ .satisfies (options -> {
71
+ assertThat (options .connectTimeoutMs ).isEqualTo (expected .connectTimeoutMs );
72
+ assertThat (options .keepAlive ).isEqualTo (expected .keepAlive );
73
+ assertThat (options .keepAliveIntervalSecs ).isEqualTo (expected .keepAliveIntervalSecs );
74
+ assertThat (options .keepAliveTimeoutSecs ).isEqualTo (expected .keepAliveTimeoutSecs );
75
+ });
76
+ }
67
77
}
68
78
69
79
private static Stream <Arguments > tcpKeepAliveConfiguration () {
0 commit comments