| /external/aws-sdk-java-v2/core/auth-crt/src/main/java/software/amazon/awssdk/authcrt/signer/internal/ |
| D | SigningConfigProvider.java | 40 public AwsSigningConfig createCrtSigningConfig(ExecutionAttributes executionAttributes) { in createCrtSigningConfig() argument
41 AwsSigningConfig signingConfig = createDefaultRequestConfig(executionAttributes); in createCrtSigningConfig()
47 public AwsSigningConfig createCrtPresigningConfig(ExecutionAttributes executionAttributes) { in createCrtPresigningConfig() argument
48 AwsSigningConfig signingConfig = createPresigningConfig(executionAttributes); in createCrtPresigningConfig()
54 public AwsSigningConfig createS3CrtSigningConfig(ExecutionAttributes executionAttributes) { in createS3CrtSigningConfig() argument
55 AwsSigningConfig signingConfig = createDefaultRequestConfig(executionAttributes); in createS3CrtSigningConfig()
61 public AwsSigningConfig createS3CrtPresigningConfig(ExecutionAttributes executionAttributes) { in createS3CrtPresigningConfig() argument
62 AwsSigningConfig signingConfig = createPresigningConfig(executionAttributes); in createS3CrtPresigningConfig()
70 public AwsSigningConfig createChunkedSigningConfig(ExecutionAttributes executionAttributes) { in createChunkedSigningConfig() argument
71 AwsSigningConfig signingConfig = createStringToSignConfig(executionAttributes); in createChunkedSigningConfig()
[all …]
|
| D | DefaultAwsCrtV4aSigner.java | 53 …blic SdkHttpFullRequest sign(SdkHttpFullRequest request, ExecutionAttributes executionAttributes) { in sign() argument
54 …if (CredentialUtils.isAnonymous(executionAttributes.getAttribute(AwsSignerExecutionAttribute.AWS_C… in sign()
57 ExecutionAttributes defaultsApplied = applyDefaults(executionAttributes); in sign()
62 …c SdkHttpFullRequest presign(SdkHttpFullRequest request, ExecutionAttributes executionAttributes) { in presign() argument
63 ExecutionAttributes defaultsApplied = applyDefaults(executionAttributes); in presign()
70 private ExecutionAttributes applyDefaults(ExecutionAttributes executionAttributes) { in applyDefaults() argument
71 return applyDefaultRegionScope(executionAttributes); in applyDefaults()
74 private ExecutionAttributes applyDefaultRegionScope(ExecutionAttributes executionAttributes) { in applyDefaultRegionScope() argument
75 … if (executionAttributes.getAttribute(AwsSignerExecutionAttribute.SIGNING_REGION_SCOPE) != null) { in applyDefaultRegionScope()
76 return executionAttributes; in applyDefaultRegionScope()
[all …]
|
| D | DefaultAwsCrtS3V4aSigner.java | 72 …blic SdkHttpFullRequest sign(SdkHttpFullRequest request, ExecutionAttributes executionAttributes) { in sign() argument
73 if (credentialsAreAnonymous(executionAttributes)) { in sign()
76 ExecutionAttributes defaultsApplied = applyDefaults(executionAttributes); in sign()
102 … SignerChecksumParams signerChecksumParamsFromAttributes(ExecutionAttributes executionAttributes) { in signerChecksumParamsFromAttributes() argument
103 …checksumSpecs = HttpChecksumUtils.checksumSpecWithRequestAlgorithm(executionAttributes).orElse(nul… in signerChecksumParamsFromAttributes()
114 …c SdkHttpFullRequest presign(SdkHttpFullRequest request, ExecutionAttributes executionAttributes) { in presign() argument
115 if (credentialsAreAnonymous(executionAttributes)) { in presign()
118 ExecutionAttributes defaultsApplied = applyDefaults(executionAttributes); in presign()
122 private boolean credentialsAreAnonymous(ExecutionAttributes executionAttributes) { in credentialsAreAnonymous() argument
123 …return CredentialUtils.isAnonymous(executionAttributes.getAttribute(AwsSignerExecutionAttribute.AW… in credentialsAreAnonymous()
[all …]
|
| /external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/handlers/ |
| D | EnableChunkedEncodingInterceptorTest.java | 44 ExecutionAttributes executionAttributes = new ExecutionAttributes(); in modifyRequest_EnablesChunckedEncoding_ForPutObectRequest() local
45 assertThat(executionAttributes.getAttribute(ENABLE_CHUNKED_ENCODING)).isNull(); in modifyRequest_EnablesChunckedEncoding_ForPutObectRequest()
47 interceptor.modifyRequest(context(PutObjectRequest.builder().build()), executionAttributes); in modifyRequest_EnablesChunckedEncoding_ForPutObectRequest() local
49 assertThat(executionAttributes.getAttribute(ENABLE_CHUNKED_ENCODING)).isEqualTo(true); in modifyRequest_EnablesChunckedEncoding_ForPutObectRequest()
54 ExecutionAttributes executionAttributes = new ExecutionAttributes(); in modifyRequest_EnablesChunckedEncoding_ForUploadPartRequest() local
55 assertThat(executionAttributes.getAttribute(ENABLE_CHUNKED_ENCODING)).isNull(); in modifyRequest_EnablesChunckedEncoding_ForUploadPartRequest()
57 … interceptor.modifyRequest(context(UploadPartRequest.builder().build()), executionAttributes); in modifyRequest_EnablesChunckedEncoding_ForUploadPartRequest() local
59 assertThat(executionAttributes.getAttribute(ENABLE_CHUNKED_ENCODING)).isEqualTo(true); in modifyRequest_EnablesChunckedEncoding_ForUploadPartRequest()
65 ExecutionAttributes executionAttributes = new ExecutionAttributes(); in modifyRequest_DoesNotEnableChunckedEncoding_ForGetObjectRequest() local
66 assertThat(executionAttributes.getAttribute(ENABLE_CHUNKED_ENCODING)).isNull(); in modifyRequest_DoesNotEnableChunckedEncoding_ForGetObjectRequest()
[all …]
|
| D | S3ExpressChecksumInterceptorTest.java | 51 ExecutionAttributes executionAttributes = createExecutionAttributes(algorithm); in putObjectRequest_withNoChecksumSet_addsCrc32() local
54 … SdkRequest modifiedRequest = interceptor.modifyRequest(modifyRequestContext, executionAttributes); in putObjectRequest_withNoChecksumSet_addsCrc32()
55 …assertThat(executionAttributes.getAttribute(SELECTED_AUTH_SCHEME).authSchemeOption().signerPropert… in putObjectRequest_withNoChecksumSet_addsCrc32()
58 …uest sdkHttpRequest = interceptor.modifyHttpRequest(modifyHttpRequestContext, executionAttributes); in putObjectRequest_withNoChecksumSet_addsCrc32()
66 ExecutionAttributes executionAttributes = createExecutionAttributes(algorithm); in putObjectRequest_withNonCrc32AlgorithmTypeSet_doesNotAddCrc32() local
69 … SdkRequest modifiedRequest = interceptor.modifyRequest(modifyRequestContext, executionAttributes); in putObjectRequest_withNonCrc32AlgorithmTypeSet_doesNotAddCrc32()
70 …assertThat(executionAttributes.getAttribute(SELECTED_AUTH_SCHEME).authSchemeOption().signerPropert… in putObjectRequest_withNonCrc32AlgorithmTypeSet_doesNotAddCrc32()
73 …uest sdkHttpRequest = interceptor.modifyHttpRequest(modifyHttpRequestContext, executionAttributes); in putObjectRequest_withNonCrc32AlgorithmTypeSet_doesNotAddCrc32()
83 ExecutionAttributes executionAttributes = createExecutionAttributes(algorithm); in putObjectRequest_withChecksumSha1ValueSet_doesNotAddCrc32() local
86 … SdkRequest modifiedRequest = interceptor.modifyRequest(modifyRequestContext, executionAttributes); in putObjectRequest_withChecksumSha1ValueSet_doesNotAddCrc32()
[all …]
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/interceptor/ |
| D | ExecutionInterceptorChain.java | 58 …ic void beforeExecution(Context.BeforeExecution context, ExecutionAttributes executionAttributes) { in beforeExecution() argument
59 interceptors.forEach(i -> i.beforeExecution(context, executionAttributes)); in beforeExecution()
62 …rceptorContext modifyRequest(InterceptorContext context, ExecutionAttributes executionAttributes) { in modifyRequest() argument
65 SdkRequest interceptorResult = interceptor.modifyRequest(result, executionAttributes); in modifyRequest()
75 …oid beforeMarshalling(Context.BeforeMarshalling context, ExecutionAttributes executionAttributes) { in beforeMarshalling() argument
76 interceptors.forEach(i -> i.beforeMarshalling(context, executionAttributes)); in beforeMarshalling()
79 … void afterMarshalling(Context.AfterMarshalling context, ExecutionAttributes executionAttributes) { in afterMarshalling() argument
80 interceptors.forEach(i -> i.afterMarshalling(context, executionAttributes)); in afterMarshalling()
84 … ExecutionAttributes executionAttributes) { in modifyHttpRequestAndHttpContent() argument
87 …Body asyncRequestBody = interceptor.modifyAsyncHttpContent(result, executionAttributes).orElse(nul… in modifyHttpRequestAndHttpContent()
[all …]
|
| D | ExecutionInterceptor.java | 136 …lt void beforeExecution(Context.BeforeExecution context, ExecutionAttributes executionAttributes) { in beforeExecution() argument
148 … SdkRequest modifyRequest(Context.ModifyRequest context, ExecutionAttributes executionAttributes) { in modifyRequest() argument
159 …oid beforeMarshalling(Context.BeforeMarshalling context, ExecutionAttributes executionAttributes) { in beforeMarshalling() argument
169 … void afterMarshalling(Context.AfterMarshalling context, ExecutionAttributes executionAttributes) { in afterMarshalling() argument
182 ExecutionAttributes executionAttributes) { in modifyHttpRequest() argument
187 ExecutionAttributes executionAttributes) { in modifyHttpContent() argument
192 ExecutionAttributes executionAttributes) { in modifyAsyncHttpContent() argument
208 …d beforeTransmission(Context.BeforeTransmission context, ExecutionAttributes executionAttributes) { in beforeTransmission() argument
226 …oid afterTransmission(Context.AfterTransmission context, ExecutionAttributes executionAttributes) { in afterTransmission() argument
241 ExecutionAttributes executionAttributes) { in modifyHttpResponse() argument
[all …]
|
| /external/aws-sdk-java-v2/core/protocols/aws-xml-protocol/src/main/java/software/amazon/awssdk/protocols/xml/internal/unmarshall/ |
| D | AwsXmlUnmarshallingContext.java | 31 private final ExecutionAttributes executionAttributes; field in AwsXmlUnmarshallingContext
38 this.executionAttributes = builder.executionAttributes; in AwsXmlUnmarshallingContext()
64 public ExecutionAttributes executionAttributes() { in executionAttributes() method in AwsXmlUnmarshallingContext
65 return executionAttributes; in executionAttributes()
85 .executionAttributes(this.executionAttributes) in toBuilder()
108 if (executionAttributes != null ? ! executionAttributes.equals(that.executionAttributes) : in equals()
109 that.executionAttributes != null) { in equals()
123 result = 31 * result + (executionAttributes != null ? executionAttributes.hashCode() : 0); in hashCode()
132 private ExecutionAttributes executionAttributes; field in AwsXmlUnmarshallingContext.Builder
149 public Builder executionAttributes(ExecutionAttributes executionAttributes) { in executionAttributes() argument
[all …]
|
| /external/aws-sdk-java-v2/core/auth-crt/src/test/java/software/amazon/awssdk/authcrt/signer/internal/ |
| D | SigningConfigProviderTest.java | 46 … ExecutionAttributes executionAttributes = SignerTestUtils.buildBasicExecutionAttributes(testCase); in testBasicHeaderSigningConfiguration() local
48 AwsSigningConfig signingConfig = configProvider.createCrtSigningConfig(executionAttributes); in testBasicHeaderSigningConfiguration()
61 … ExecutionAttributes executionAttributes = SignerTestUtils.buildBasicExecutionAttributes(testCase); in testBasicQuerySigningConfiguration() local
63 … AwsSigningConfig signingConfig = configProvider.createCrtPresigningConfig(executionAttributes); in testBasicQuerySigningConfiguration()
77 … ExecutionAttributes executionAttributes = SignerTestUtils.buildBasicExecutionAttributes(testCase); in testQuerySigningExpirationConfiguration() local
80 …executionAttributes.putAttribute(AwsSignerExecutionAttribute.PRESIGNER_EXPIRATION, expirationTime); in testQuerySigningExpirationConfiguration()
82 … AwsSigningConfig signingConfig = configProvider.createCrtPresigningConfig(executionAttributes); in testQuerySigningExpirationConfiguration()
91 … ExecutionAttributes executionAttributes = SignerTestUtils.buildBasicExecutionAttributes(testCase); in testS3SigningConfiguration() local
92 executionAttributes.putAttribute(S3SignerExecutionAttribute.ENABLE_PAYLOAD_SIGNING, true); in testS3SigningConfiguration()
93 … executionAttributes.putAttribute(AwsSignerExecutionAttribute.SIGNER_DOUBLE_URL_ENCODE, false); in testS3SigningConfiguration()
[all …]
|
| D | DefaultAwsCrtS3V4aSignerTest.java | 89 … ExecutionAttributes executionAttributes = SignerTestUtils.buildBasicExecutionAttributes(testCase); in when_credentials_are_anonymous_return_request() local
90 executionAttributes.putAttribute(AwsSignerExecutionAttribute.AWS_CREDENTIALS, in when_credentials_are_anonymous_return_request()
94 SdkHttpFullRequest signedRequest = s3V4aSigner.sign(request, executionAttributes); in when_credentials_are_anonymous_return_request()
102 … ExecutionAttributes executionAttributes = SignerTestUtils.buildBasicExecutionAttributes(testCase); in no_special_configuration_does_not_sign_payload() local
105 SdkHttpFullRequest signedRequest = s3V4aSigner.sign(request, executionAttributes); in no_special_configuration_does_not_sign_payload()
113 … ExecutionAttributes executionAttributes = SignerTestUtils.buildBasicExecutionAttributes(testCase); in protocol_http_triggers_payload_signing() local
118 … SdkHttpFullRequest signedRequest = s3V4aSigner.sign(requestBuilder.build(), executionAttributes); in protocol_http_triggers_payload_signing()
126 … ExecutionAttributes executionAttributes = SignerTestUtils.buildBasicExecutionAttributes(testCase); in protocol_http_triggers_payload_signing_with_trailer_checksums() local
127 …executionAttributes.putAttribute(SdkInternalExecutionAttribute.HTTP_CHECKSUM, HTTP_CRC32_CHECKSUM); in protocol_http_triggers_payload_signing_with_trailer_checksums()
131 … SdkHttpFullRequest signedRequest = s3V4aSigner.sign(requestBuilder.build(), executionAttributes); in protocol_http_triggers_payload_signing_with_trailer_checksums()
[all …]
|
| /external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/ |
| D | RequestOverrideConfigurationTest.java | 78 … .executionAttributes(ExecutionAttributes.builder().put(testAttribute, expectedValue).build()) in toBuilder_maximal()
220 ExecutionAttributes executionAttributes = new ExecutionAttributes(); in executionAttributes_createsCopy() local
224 executionAttributes.putAttribute(testAttribute, expectedValue); in executionAttributes_createsCopy()
227 .executionAttributes(executionAttributes) in executionAttributes_createsCopy()
230 executionAttributes.putAttribute(testAttribute, "Value2"); in executionAttributes_createsCopy()
232 …assertThat(overrideConfig.executionAttributes().getAttribute(testAttribute)).isEqualTo(expectedVal… in executionAttributes_createsCopy()
237 ExecutionAttributes executionAttributes = new ExecutionAttributes(); in executionAttributes_isImmutable() local
240 executionAttributes.putAttribute(testAttribute, expectedValue); in executionAttributes_isImmutable()
243 .executionAttributes(executionAttributes) in executionAttributes_isImmutable()
246 overrideConfig.executionAttributes().putAttribute(testAttribute, 2); in executionAttributes_isImmutable()
[all …]
|
| /external/aws-sdk-java-v2/test/old-client-version-compatibility-test/src/test/java/ |
| D | InterceptorSignerAttributeTest.java | 75 …ic void beforeExecution(Context.BeforeExecution context, ExecutionAttributes executionAttributes) { in canSetSignerExecutionAttributes_beforeExecution()
76 attributeModifications.accept(executionAttributes); in canSetSignerExecutionAttributes_beforeExecution()
89 … SdkRequest modifyRequest(Context.ModifyRequest context, ExecutionAttributes executionAttributes) { in canSetSignerExecutionAttributes_modifyRequest()
90 attributeModifications.accept(executionAttributes); in canSetSignerExecutionAttributes_modifyRequest()
101 …oid beforeMarshalling(Context.BeforeMarshalling context, ExecutionAttributes executionAttributes) { in canSetSignerExecutionAttributes_beforeMarshalling()
102 attributeModifications.accept(executionAttributes); in canSetSignerExecutionAttributes_beforeMarshalling()
111 … void afterMarshalling(Context.AfterMarshalling context, ExecutionAttributes executionAttributes) { in canSetSignerExecutionAttributes_afterMarshalling()
112 attributeModifications.accept(executionAttributes); in canSetSignerExecutionAttributes_afterMarshalling()
121 …est modifyHttpRequest(Context.ModifyHttpRequest context, ExecutionAttributes executionAttributes) { in canSetSignerExecutionAttributes_modifyHttpRequest()
122 attributeModifications.accept(executionAttributes); in canSetSignerExecutionAttributes_modifyHttpRequest()
[all …]
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/interceptor/ |
| D | HttpChecksumValidationInterceptor.java | 56 … ExecutionAttributes executionAttributes) { in modifyHttpResponseContent() argument
58 …umSpecs resolvedChecksumSpecs = HttpChecksumResolver.getResolvedChecksumSpecs(executionAttributes); in modifyHttpResponseContent()
60 … isFlexibleChecksumValidationForResponse(executionAttributes, resolvedChecksumSpecs, SYNC)) { in modifyHttpResponseContent()
64 updateContextWithChecksumValidationStatus(executionAttributes, algorithmChecksumPair); in modifyHttpResponseContent()
77 … ExecutionAttributes executionAttributes) { in modifyAsyncHttpResponseContent() argument
78 …umSpecs resolvedChecksumSpecs = HttpChecksumResolver.getResolvedChecksumSpecs(executionAttributes); in modifyAsyncHttpResponseContent()
80 … isFlexibleChecksumValidationForResponse(executionAttributes, resolvedChecksumSpecs, ASYNC)) { in modifyAsyncHttpResponseContent()
83 updateContextWithChecksumValidationStatus(executionAttributes, algorithmChecksumPair); in modifyAsyncHttpResponseContent()
93 private void updateContextWithChecksumValidationStatus(ExecutionAttributes executionAttributes, in updateContextWithChecksumValidationStatus() argument
96 … executionAttributes.putAttribute(SdkExecutionAttribute.HTTP_RESPONSE_CHECKSUM_VALIDATION, in updateContextWithChecksumValidationStatus()
[all …]
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/http/ |
| D | ExecutionContext.java | 37 private final ExecutionAttributes executionAttributes; field in ExecutionContext
44 this.executionAttributes = builder.executionAttributes; in ExecutionContext()
67 public ExecutionAttributes executionAttributes() { in executionAttributes() method in ExecutionContext
68 return executionAttributes; in executionAttributes()
87 private ExecutionAttributes executionAttributes; field in ExecutionContext.Builder
98 this.executionAttributes = executionContext.executionAttributes; in Builder()
112 public Builder executionAttributes(ExecutionAttributes executionAttributes) { in executionAttributes() argument
113 this.executionAttributes = executionAttributes; in executionAttributes()
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/retry/ |
| D | RetryPolicyContext.java | 38 private final ExecutionAttributes executionAttributes; field in RetryPolicyContext
46 this.executionAttributes = builder.executionAttributes; in RetryPolicyContext()
79 public ExecutionAttributes executionAttributes() { in executionAttributes() method in RetryPolicyContext
80 return this.executionAttributes; in executionAttributes()
114 private ExecutionAttributes executionAttributes; field in RetryPolicyContext.Builder
125 this.executionAttributes = copy.executionAttributes; in Builder()
145 public Builder executionAttributes(ExecutionAttributes executionAttributes) { in executionAttributes() argument
146 this.executionAttributes = executionAttributes; in executionAttributes()
|
| /external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/util/ |
| D | HttpChecksumResolverTest.java | 41 ExecutionAttributes executionAttributes = getExecutionAttributeWithAllFieldsSet(); in testResolvedChecksumSpecsWithAllTraitsSet() local
42 …umSpecs resolvedChecksumSpecs = HttpChecksumResolver.getResolvedChecksumSpecs(executionAttributes); in testResolvedChecksumSpecsWithAllTraitsSet()
62 ExecutionAttributes executionAttributes = ExecutionAttributes.builder().put( in testResolvedChecksumSpecsWithOnlyHttpChecksumRequired() local
66 …umSpecs resolvedChecksumSpecs = HttpChecksumResolver.getResolvedChecksumSpecs(executionAttributes); in testResolvedChecksumSpecsWithOnlyHttpChecksumRequired()
75 ExecutionAttributes executionAttributes = ExecutionAttributes.builder().put( in testResolvedChecksumSpecsWithDefaults() local
77 …umSpecs resolvedChecksumSpecs = HttpChecksumResolver.getResolvedChecksumSpecs(executionAttributes); in testResolvedChecksumSpecsWithDefaults()
91 ExecutionAttributes executionAttributes = getExecutionAttributeWithAllFieldsSet(); in headerBasedChecksumAlreadyPresent() local
93 HttpChecksumUtils.checksumSpecWithRequestAlgorithm(executionAttributes).orElse(null); in headerBasedChecksumAlreadyPresent()
106 ExecutionAttributes executionAttributes = getExecutionAttributeWithAllFieldsSet(); in headerBasedChecksumWithDifferentHeader() local
108 HttpChecksumUtils.checksumSpecWithRequestAlgorithm(executionAttributes).orElse(null); in headerBasedChecksumWithDifferentHeader()
[all …]
|
| /external/aws-sdk-java-v2/core/aws-core/src/main/java/software/amazon/awssdk/awscore/internal/ |
| D | AwsExecutionContextBuilder.java | 74 ExecutionAttributes executionAttributes = mergeExecutionAttributeOverrides( in invokeInterceptorsAndCreateExecutionContext() local
75 executionParams.executionAttributes(), in invokeInterceptorsAndCreateExecutionContext()
77 originalRequest.overrideConfiguration().map(c -> c.executionAttributes()).orElse(null)); in invokeInterceptorsAndCreateExecutionContext()
79 …executionAttributes.putAttributeIfAbsent(SdkExecutionAttribute.API_CALL_METRIC_COLLECTOR, metricCo… in invokeInterceptorsAndCreateExecutionContext()
81 executionAttributes in invokeInterceptorsAndCreateExecutionContext()
117 …Attribute(RESOLVED_CHECKSUM_SPECS, HttpChecksumResolver.resolveChecksumSpecs(executionAttributes)); in invokeInterceptorsAndCreateExecutionContext()
120 putAuthSchemeResolutionAttributes(executionAttributes, clientConfig, originalRequest); in invokeInterceptorsAndCreateExecutionContext()
130 …interceptorContext = runInitialInterceptors(interceptorContext, executionAttributes, executionInte… in invokeInterceptorsAndCreateExecutionContext()
133 if (loadOldSigner(executionAttributes, originalRequest)) { in invokeInterceptorsAndCreateExecutionContext()
138 authorizationStrategy.addCredentialsToExecutionAttributes(executionAttributes); in invokeInterceptorsAndCreateExecutionContext()
[all …]
|
| /external/aws-sdk-java-v2/services/kms/target/generated-sources/sdk/software/amazon/awssdk/services/kms/endpoints/internal/ |
| D | KmsResolveEndpointInterceptor.java | 51 … SdkRequest modifyRequest(Context.ModifyRequest context, ExecutionAttributes executionAttributes) { in modifyRequest() argument
53 if (AwsEndpointProviderUtils.endpointIsDiscovered(executionAttributes)) { in modifyRequest()
56 KmsEndpointProvider provider = (KmsEndpointProvider) executionAttributes in modifyRequest()
60 … Endpoint endpoint = provider.resolveEndpoint(ruleParams(result, executionAttributes)).join(); in modifyRequest()
62 Optional<MetricCollector> metricCollector = executionAttributes in modifyRequest()
65 if (!AwsEndpointProviderUtils.disableHostPrefixInjection(executionAttributes)) { in modifyRequest()
66 …Optional<String> hostPrefix = hostPrefix(executionAttributes.getAttribute(SdkExecutionAttribute.OP… in modifyRequest()
73 SelectedAuthScheme<?> selectedAuthScheme = executionAttributes in modifyRequest()
77 …executionAttributes.putAttribute(SdkInternalExecutionAttribute.SELECTED_AUTH_SCHEME, selectedAuthS… in modifyRequest()
79 … executionAttributes.putAttribute(SdkInternalExecutionAttribute.RESOLVED_ENDPOINT, endpoint); in modifyRequest()
[all …]
|
| /external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/client/config/ |
| D | ClientOverrideConfigurationTest.java | 198 ExecutionAttributes executionAttributes = new ExecutionAttributes(); in executionAttributes_createsCopy() local
202 executionAttributes.putAttribute(testAttribute, expectedValue); in executionAttributes_createsCopy()
205 .executionAttributes(executionAttributes) in executionAttributes_createsCopy()
208 executionAttributes.putAttribute(testAttribute, "Value2"); in executionAttributes_createsCopy()
209 …assertThat(overrideConfig.executionAttributes().getAttribute(testAttribute)).isEqualTo(expectedVal… in executionAttributes_createsCopy()
214 ExecutionAttributes executionAttributes = new ExecutionAttributes(); in executionAttributes_isImmutable() local
218 executionAttributes.putAttribute(testAttribute, expectedValue); in executionAttributes_isImmutable()
221 .executionAttributes(executionAttributes) in executionAttributes_isImmutable()
225 overrideConfig.executionAttributes().putAttribute(testAttribute, 2); in executionAttributes_isImmutable()
246 …assertThat(overrideConfig.executionAttributes().getAttributes()).isEqualTo(executionAttributeObjec… in executionAttributes_maintainsAllAdded()
[all …]
|
| /external/aws-sdk-java-v2/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/rules/ |
| D | endpoint-resolve-interceptor.java | 41 … SdkRequest modifyRequest(Context.ModifyRequest context, ExecutionAttributes executionAttributes) { in modifyRequest() argument
43 if (AwsEndpointProviderUtils.endpointIsDiscovered(executionAttributes)) { in modifyRequest()
46 QueryEndpointProvider provider = (QueryEndpointProvider) executionAttributes in modifyRequest()
50 … Endpoint endpoint = provider.resolveEndpoint(ruleParams(result, executionAttributes)).join(); in modifyRequest()
52 Optional<MetricCollector> metricCollector = executionAttributes in modifyRequest()
55 if (!AwsEndpointProviderUtils.disableHostPrefixInjection(executionAttributes)) { in modifyRequest()
56 …Optional<String> hostPrefix = hostPrefix(executionAttributes.getAttribute(SdkExecutionAttribute.OP… in modifyRequest()
63 SelectedAuthScheme<?> selectedAuthScheme = executionAttributes in modifyRequest()
67 …executionAttributes.putAttribute(SdkInternalExecutionAttribute.SELECTED_AUTH_SCHEME, selectedAuthS… in modifyRequest()
69 … executionAttributes.putAttribute(SdkInternalExecutionAttribute.RESOLVED_ENDPOINT, endpoint); in modifyRequest()
[all …]
|
| D | endpoint-resolve-interceptor-preSra.java | 53 … SdkRequest modifyRequest(Context.ModifyRequest context, ExecutionAttributes executionAttributes) { in modifyRequest() argument
55 if (AwsEndpointProviderUtils.endpointIsDiscovered(executionAttributes)) { in modifyRequest()
58 QueryEndpointProvider provider = (QueryEndpointProvider) executionAttributes in modifyRequest()
62 … Endpoint endpoint = provider.resolveEndpoint(ruleParams(result, executionAttributes)).join(); in modifyRequest()
64 Optional<MetricCollector> metricCollector = executionAttributes in modifyRequest()
67 if (!AwsEndpointProviderUtils.disableHostPrefixInjection(executionAttributes)) { in modifyRequest()
68 …Optional<String> hostPrefix = hostPrefix(executionAttributes.getAttribute(SdkExecutionAttribute.OP… in modifyRequest()
75 SelectedAuthScheme<?> selectedAuthScheme = executionAttributes in modifyRequest()
79 …executionAttributes.putAttribute(SdkInternalExecutionAttribute.SELECTED_AUTH_SCHEME, selectedAuthS… in modifyRequest()
84 …result = SignerOverrideUtils.overrideSignerIfNotOverridden(result, executionAttributes, signerProv… in modifyRequest()
[all …]
|
| /external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/s3express/ |
| D | S3ExpressAuthSchemeProviderTest.java | 55 ExecutionAttributes executionAttributes = requiredExecutionAttributes(clientContextParams); in s3express_defaultAuthEnabled_returnspressAuthScheme() local
57 new S3AuthSchemeInterceptor().beforeExecution(() -> request, executionAttributes); in s3express_defaultAuthEnabled_returnspressAuthScheme() local
59 …SelectedAuthScheme<?> attribute = executionAttributes.getAttribute(SdkInternalExecutionAttribute.S… in s3express_defaultAuthEnabled_returnspressAuthScheme()
65 ExecutionAttributes executionAttributes = new ExecutionAttributes(); in requiredExecutionAttributes() local
66 …executionAttributes.putAttribute(SdkInternalExecutionAttribute.AUTH_SCHEME_RESOLVER, DefaultS3Auth… in requiredExecutionAttributes()
67 executionAttributes.putAttribute(SdkExecutionAttribute.OPERATION_NAME, "PutObject"); in requiredExecutionAttributes()
68 executionAttributes.putAttribute(AwsExecutionAttribute.AWS_REGION, Region.US_EAST_1); in requiredExecutionAttributes()
69 …executionAttributes.putAttribute(SdkInternalExecutionAttribute.CLIENT_CONTEXT_PARAMS, clientContex… in requiredExecutionAttributes()
70 …executionAttributes.putAttribute(SdkInternalExecutionAttribute.AUTH_SCHEMES, authSchemesWithS3Expr… in requiredExecutionAttributes()
71 executionAttributes.putAttribute(SdkInternalExecutionAttribute.IDENTITY_PROVIDERS, in requiredExecutionAttributes()
[all …]
|
| /external/aws-sdk-java-v2/core/auth-crt/src/test/java/software/amazon/awssdk/authcrt/signer/ |
| D | AwsCrtV4aSignerTest.java | 50 … ExecutionAttributes executionAttributes = SignerTestUtils.buildBasicExecutionAttributes(testCase); in hostHeaderExcludesStandardHttpPort() local
55 SdkHttpFullRequest signed = v4aSigner.sign(request, executionAttributes); in hostHeaderExcludesStandardHttpPort()
63 … ExecutionAttributes executionAttributes = SignerTestUtils.buildBasicExecutionAttributes(testCase); in hostHeaderExcludesStandardHttpsPort() local
68 SdkHttpFullRequest signed = v4aSigner.sign(request, executionAttributes); in hostHeaderExcludesStandardHttpsPort()
76 … ExecutionAttributes executionAttributes = SignerTestUtils.buildBasicExecutionAttributes(testCase); in hostHeaderIncludesNonStandardPorts() local
81 SdkHttpFullRequest signed = v4aSigner.sign(request, executionAttributes); in hostHeaderIncludesNonStandardPorts()
89 … ExecutionAttributes executionAttributes = SignerTestUtils.buildBasicExecutionAttributes(testCase); in testHeaderSigning() local
92 SdkHttpFullRequest signed = v4aSigner.sign(request, executionAttributes); in testHeaderSigning()
98 AwsSigningConfig signingConfig = configProvider.createCrtSigningConfig(executionAttributes); in testHeaderSigning()
108 … ExecutionAttributes executionAttributes = SignerTestUtils.buildBasicExecutionAttributes(testCase); in testQuerySigning() local
[all …]
|
| /external/aws-sdk-java-v2/core/auth/src/main/java/software/amazon/awssdk/auth/signer/internal/util/ |
| D | SignerMethodResolver.java | 51 …atic SigningMethod resolveSigningMethodUsed(Signer signer, ExecutionAttributes executionAttributes, in resolveSigningMethodUsed() argument
56 if (isProtocolBasedStreamingSigningAuth(signer, executionAttributes)) { in resolveSigningMethodUsed()
58 } else if (isProtocolBasedUnsigned(signer, executionAttributes)) { in resolveSigningMethodUsed()
69 …olean isProtocolBasedStreamingSigningAuth(Signer signer, ExecutionAttributes executionAttributes) { in isProtocolBasedStreamingSigningAuth() argument
70 return (executionAttributes.getOptionalAttribute(ENABLE_PAYLOAD_SIGNING).orElse(false) && in isProtocolBasedStreamingSigningAuth()
71 executionAttributes.getOptionalAttribute(ENABLE_CHUNKED_ENCODING).orElse(false)) || in isProtocolBasedStreamingSigningAuth()
73 && executionAttributes.getOptionalAttribute(ENABLE_CHUNKED_ENCODING).orElse(false); in isProtocolBasedStreamingSigningAuth()
86 …te static boolean isProtocolBasedUnsigned(Signer signer, ExecutionAttributes executionAttributes) { in isProtocolBasedUnsigned() argument
89 executionAttributes.getOptionalAttribute(ENABLE_PAYLOAD_SIGNING).orElse(false); in isProtocolBasedUnsigned()
|
| /external/aws-sdk-java-v2/core/aws-core/src/test/java/software/amazon/awssdk/awscore/util/ |
| D | SignerOverrideUtilsTest.java | 40 ExecutionAttributes executionAttributes = stubs.right(); in overrideSignerIfNotOverridden() local
42 …esult = SignerOverrideUtils.overrideSignerIfNotOverridden(request, executionAttributes, BarSigner:… in overrideSignerIfNotOverridden()
53 ExecutionAttributes executionAttributes = stubs.right(); in overrideSignerIfNotOverridden2() local
55 …esult = SignerOverrideUtils.overrideSignerIfNotOverridden(request, executionAttributes, BarSigner:… in overrideSignerIfNotOverridden2()
75 ExecutionAttributes executionAttributes = stubs.right(); in overrideSignerOriginalConfigPreserved() local
78 …esult = SignerOverrideUtils.overrideSignerIfNotOverridden(request, executionAttributes, () -> over… in overrideSignerOriginalConfigPreserved()
98 ExecutionAttributes executionAttributes = new ExecutionAttributes(); in stubInitialSigner() local
100 executionAttributes.putAttribute(SdkExecutionAttribute.SIGNER_OVERRIDDEN, true); in stubInitialSigner()
102 return Pair.of(request, executionAttributes); in stubInitialSigner()
107 …blic SdkHttpFullRequest sign(SdkHttpFullRequest request, ExecutionAttributes executionAttributes) { in sign() argument
[all …]
|