Home
last modified time | relevance | path

Searched refs:sdkHttpRequest (Results 1 – 19 of 19) sorted by relevance

/aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/
H A DConfiguredS3SdkHttpRequest.java29 private final SdkHttpRequest sdkHttpRequest; field in ConfiguredS3SdkHttpRequest
34 this.sdkHttpRequest = Validate.notNull(builder.sdkHttpRequest, "sdkHttpRequest"); in ConfiguredS3SdkHttpRequest()
43 public SdkHttpRequest sdkHttpRequest() { in sdkHttpRequest() method in ConfiguredS3SdkHttpRequest
44 return sdkHttpRequest; in sdkHttpRequest()
57 return builder().sdkHttpRequest(sdkHttpRequest) in toBuilder()
73 if (!sdkHttpRequest.equals(that.sdkHttpRequest)) { in equals()
86 int result = sdkHttpRequest.hashCode(); in hashCode()
94 private SdkHttpRequest sdkHttpRequest; field in ConfiguredS3SdkHttpRequest.Builder
100 public Builder sdkHttpRequest(SdkHttpRequest sdkHttpRequest) { in sdkHttpRequest() argument
101 this.sdkHttpRequest = sdkHttpRequest; in sdkHttpRequest()
/aosp_15_r20/external/aws-sdk-java-v2/core/protocols/protocol-core/src/test/java/software/amazon/awssdk/protocols/core/
H A DProtocolUtilsTest.java33 SdkHttpFullRequest.Builder sdkHttpRequest = ProtocolUtils.createSdkHttpRequest( in createSdkHttpRequest_SetsHttpMethodAndEndpointCorrectly() local
37 assertThat(sdkHttpRequest.protocol()).isEqualTo("http"); in createSdkHttpRequest_SetsHttpMethodAndEndpointCorrectly()
38 assertThat(sdkHttpRequest.host()).isEqualTo("localhost"); in createSdkHttpRequest_SetsHttpMethodAndEndpointCorrectly()
39 assertThat(sdkHttpRequest.port()).isEqualTo(8080); in createSdkHttpRequest_SetsHttpMethodAndEndpointCorrectly()
40 assertThat(sdkHttpRequest.method()).isEqualTo(SdkHttpMethod.DELETE); in createSdkHttpRequest_SetsHttpMethodAndEndpointCorrectly()
45 SdkHttpFullRequest.Builder sdkHttpRequest = ProtocolUtils.createSdkHttpRequest( in createSdkHttpRequest_EndpointWithPathSetCorrectly() local
49 assertThat(sdkHttpRequest.encodedPath()).isEqualTo("/foo/bar"); in createSdkHttpRequest_EndpointWithPathSetCorrectly()
54 SdkHttpFullRequest.Builder sdkHttpRequest = ProtocolUtils.createSdkHttpRequest( in createSdkHttpRequest_RequestUriAppendedToEndpointPath() local
59 assertThat(sdkHttpRequest.encodedPath()).isEqualTo("/foo/bar/baz"); in createSdkHttpRequest_RequestUriAppendedToEndpointPath()
64 SdkHttpFullRequest.Builder sdkHttpRequest = ProtocolUtils.createSdkHttpRequest( in createSdkHttpRequest_NoTrailingSlashInEndpointPath_RequestUriAppendedToEndpointPath() local
[all …]
/aosp_15_r20/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/documenttype/
H A DDocumentTypeTest.java182 SdkHttpRequest sdkHttpRequest = getSyncRequest(); in explicitDocumentOnlyStringPayload() local
183 …assertThat(sdkHttpRequest.firstMatchingHeader("accept").get()).contains(AcceptHeader.IMAGE_JPEG.to… in explicitDocumentOnlyStringPayload()
199 SdkHttpRequest sdkHttpRequest = getSyncRequest(); in explicitDocumentOnlyListPayload() local
200 …assertThat(sdkHttpRequest.firstMatchingHeader("accept").get()).contains(AcceptHeader.IMAGE_JPEG.to… in explicitDocumentOnlyListPayload()
213 SdkHttpRequest sdkHttpRequest = getSyncRequest(); in explicitDocumentOnlyNullDocumentPayload() local
214 …assertThat(sdkHttpRequest.firstMatchingHeader("accept").get()).contains(AcceptHeader.IMAGE_JPEG.to… in explicitDocumentOnlyNullDocumentPayload()
227 SdkHttpRequest sdkHttpRequest = getSyncRequest(); in explicitDocumentOnlyNullPayload() local
228 …assertThat(sdkHttpRequest.firstMatchingHeader("accept").get()).contains(AcceptHeader.IMAGE_JPEG.to… in explicitDocumentOnlyNullPayload()
240 SdkHttpRequest sdkHttpRequest = getSyncRequest(); in explicitDocumentOnlyEmptyPayload() local
241 …assertThat(sdkHttpRequest.firstMatchingHeader("accept").get()).contains(AcceptHeader.IMAGE_JPEG.to… in explicitDocumentOnlyEmptyPayload()
[all …]
/aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/handlers/
H A DS3ExpressChecksumInterceptorTest.java58 …SdkHttpRequest sdkHttpRequest = interceptor.modifyHttpRequest(modifyHttpRequestContext, executionA… in putObjectRequest_withNoChecksumSet_addsCrc32() local
59 … assertThat(sdkHttpRequest.firstMatchingHeader("x-amz-sdk-checksum-algorithm")).contains("CRC32"); in putObjectRequest_withNoChecksumSet_addsCrc32()
73 …SdkHttpRequest sdkHttpRequest = interceptor.modifyHttpRequest(modifyHttpRequestContext, executionA… in putObjectRequest_withNonCrc32AlgorithmTypeSet_doesNotAddCrc32() local
74 assertThat(sdkHttpRequest.firstMatchingHeader("x-amz-sdk-checksum-algorithm")).isEmpty(); in putObjectRequest_withNonCrc32AlgorithmTypeSet_doesNotAddCrc32()
90 …SdkHttpRequest sdkHttpRequest = interceptor.modifyHttpRequest(modifyHttpRequestContext, executionA… in putObjectRequest_withChecksumSha1ValueSet_doesNotAddCrc32() local
91 assertThat(sdkHttpRequest.firstMatchingHeader("x-amz-sdk-checksum-algorithm")).isEmpty(); in putObjectRequest_withChecksumSha1ValueSet_doesNotAddCrc32()
107 …SdkHttpRequest sdkHttpRequest = interceptor.modifyHttpRequest(modifyHttpRequestContext, executionA… in putObjectRequest_withChecksumSha256ValueSet_doesNotAddCrc32() local
108 assertThat(sdkHttpRequest.firstMatchingHeader("x-amz-sdk-checksum-algorithm")).isEmpty(); in putObjectRequest_withChecksumSha256ValueSet_doesNotAddCrc32()
124 …SdkHttpRequest sdkHttpRequest = interceptor.modifyHttpRequest(modifyHttpRequestContext, executionA… in putObjectRequest_withChecksumCrc32ValueSet_doesNotAddCrc32() local
125 assertThat(sdkHttpRequest.firstMatchingHeader("x-amz-sdk-checksum-algorithm")).isEmpty(); in putObjectRequest_withChecksumCrc32ValueSet_doesNotAddCrc32()
[all …]
H A DEnableTrailingChecksumInterceptorTest.java69 …SdkHttpRequest sdkHttpRequest = interceptor.modifyHttpRequest(modifyHttpRequestContext, executionA… in testGetObjectModifyRequest() local
72 …validateGetObjectValues(sdkHttpRequest, getObjectRequest, useS3Express, disableChecksumValidation,… in testGetObjectModifyRequest()
75 …private void validateGetObjectValues(SdkHttpRequest sdkHttpRequest, GetObjectRequest getObjectRequ… in validateGetObjectValues() argument
82 assertThat(sdkHttpRequest.headers().get(ENABLE_CHECKSUM_REQUEST_HEADER)).isNull(); in validateGetObjectValues()
85 assertThat(sdkHttpRequest.headers().get(ENABLE_CHECKSUM_REQUEST_HEADER)).isNull(); in validateGetObjectValues()
92 assertThat(sdkHttpRequest.headers().get(ENABLE_CHECKSUM_REQUEST_HEADER)).isNull(); in validateGetObjectValues()
97 … assertThat(sdkHttpRequest.headers().get(ENABLE_CHECKSUM_REQUEST_HEADER)).isNull(); in validateGetObjectValues()
101 …assertThat(sdkHttpRequest.headers().get(ENABLE_CHECKSUM_REQUEST_HEADER)).containsOnly(ENABLE_MD5_C… in validateGetObjectValues()
126 …SdkHttpRequest sdkHttpRequest = interceptor.modifyHttpRequest(modifyHttpRequestContext, executionA… in modifyRequest_nonGetObjectRequest_shouldNotModify() local
128 assertThat(sdkHttpRequest.headers().get(ENABLE_CHECKSUM_REQUEST_HEADER)).isNull(); in modifyRequest_nonGetObjectRequest_shouldNotModify()
H A DAsyncChecksumValidationInterceptorTest.java146 SdkHttpRequest sdkHttpRequest = SdkHttpFullRequest.builder() in afterUnmarshalling_putObjectRequest_shouldValidateChecksum() local
152 …InterceptorTestUtils.afterUnmarshallingContext(putObjectRequest, sdkHttpRequest, response, sdkHttp… in afterUnmarshalling_putObjectRequest_shouldValidateChecksum()
167 SdkHttpRequest sdkHttpRequest = SdkHttpFullRequest.builder() in afterUnmarshalling_putObjectRequest_shouldValidateChecksum_throwExceptionIfInvalid() local
175 .httpRequest(sdkHttpRequest) in afterUnmarshalling_putObjectRequest_shouldValidateChecksum_throwExceptionIfInvalid()
197 SdkHttpRequest sdkHttpRequest = SdkHttpFullRequest.builder() in afterUnmarshalling_putObjectRequest_with_SSE_shouldNotValidateChecksum() local
205 …InterceptorTestUtils.afterUnmarshallingContext(putObjectRequest, sdkHttpRequest, response, sdkHttp… in afterUnmarshalling_putObjectRequest_with_SSE_shouldNotValidateChecksum()
H A DSyncChecksumValidationInterceptorTest.java178 SdkHttpRequest sdkHttpRequest = SdkHttpFullRequest.builder() in afterUnmarshalling_putObjectRequest_shouldValidateChecksum() local
184 …InterceptorTestUtils.afterUnmarshallingContext(putObjectRequest, sdkHttpRequest, response, sdkHttp… in afterUnmarshalling_putObjectRequest_shouldValidateChecksum()
199 SdkHttpRequest sdkHttpRequest = SdkHttpFullRequest.builder() in afterUnmarshalling_putObjectRequest_shouldValidateChecksum_throwExceptionIfInvalid() local
208 .httpRequest(sdkHttpRequest) in afterUnmarshalling_putObjectRequest_shouldValidateChecksum_throwExceptionIfInvalid()
230 SdkHttpRequest sdkHttpRequest = SdkHttpFullRequest.builder() in afterUnmarshalling_putObjectRequest_with_SSE_shouldNotValidateChecksum() local
238 …InterceptorTestUtils.afterUnmarshallingContext(putObjectRequest, sdkHttpRequest, response, sdkHttp… in afterUnmarshalling_putObjectRequest_with_SSE_shouldNotValidateChecksum()
/aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/util/
H A DHttpChecksumUtils.java66 public static boolean isStreamingUnsignedPayload(SdkHttpRequest sdkHttpRequest, in isStreamingUnsignedPayload() argument
71 String protocol = sdkHttpRequest.protocol(); in isStreamingUnsignedPayload()
150 …public static boolean isHttpChecksumPresent(SdkHttpRequest sdkHttpRequest, ChecksumSpecs checksumS… in isHttpChecksumPresent() argument
153 return sdkHttpRequest.firstMatchingHeader(checksumSpec.headerName()).isPresent() || in isHttpChecksumPresent()
154 isTrailerChecksumPresent(sdkHttpRequest, checksumSpec); in isHttpChecksumPresent()
166 …private static boolean isTrailerChecksumPresent(SdkHttpRequest sdkHttpRequest, ChecksumSpecs check… in isTrailerChecksumPresent() argument
167 Optional<String> trailerBasedChecksum = sdkHttpRequest.firstMatchingHeader(X_AMZ_TRAILER); in isTrailerChecksumPresent()
180 public static boolean isTrailerBasedFlexibleChecksumComputed(SdkHttpRequest sdkHttpRequest, in isTrailerBasedFlexibleChecksumComputed() argument
186 !HttpChecksumUtils.isHttpChecksumPresent(sdkHttpRequest, checksumSpecs) && in isTrailerBasedFlexibleChecksumComputed()
187 HttpChecksumUtils.isStreamingUnsignedPayload(sdkHttpRequest, executionAttributes, in isTrailerBasedFlexibleChecksumComputed()
/aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/functionaltests/
H A DS3ExpressCreateSessionTest.java315 SdkHttpRequest sdkHttpRequest = context.httpRequest(); in modifyHttpRequest() local
316 String host = sdkHttpRequest.host(); in modifyHttpRequest()
319 return sdkHttpRequest.toBuilder().host("localhost") in modifyHttpRequest()
320 … .encodedPath(SdkHttpUtils.appendUri(bucket, sdkHttpRequest.encodedPath())) in modifyHttpRequest()
330 SdkHttpRequest sdkHttpRequest = context.httpRequest(); in beforeTransmission() local
331 this.headers = sdkHttpRequest.headers(); in beforeTransmission()
332 System.out.printf("%s %s%n", sdkHttpRequest.method(), sdkHttpRequest.encodedPath()); in beforeTransmission()
H A DS3ExpressTest.java417 SdkHttpRequest sdkHttpRequest = context.httpRequest(); in modifyHttpRequest() local
418 String host = sdkHttpRequest.host(); in modifyHttpRequest()
421 return sdkHttpRequest.toBuilder().host("localhost") in modifyHttpRequest()
422 … .encodedPath(SdkHttpUtils.appendUri(bucket, sdkHttpRequest.encodedPath())) in modifyHttpRequest()
432 SdkHttpRequest sdkHttpRequest = context.httpRequest(); in beforeTransmission() local
433 this.headers = sdkHttpRequest.headers(); in beforeTransmission()
434 System.out.printf("%s %s%n", sdkHttpRequest.method(), sdkHttpRequest.encodedPath()); in beforeTransmission()
/aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/utils/
H A DInterceptorTestUtils.java47 public static SdkHttpRequest sdkHttpRequest(URI customUri) { in sdkHttpRequest() method in InterceptorTestUtils
109 …ext.ModifyHttpRequest modifyHttpRequestContext(SdkRequest request, SdkHttpRequest sdkHttpRequest) {
116 return sdkHttpRequest;
180 …halling afterUnmarshallingContext(SdkRequest request, SdkHttpRequest sdkHttpRequest, SdkResponse r…
204 return sdkHttpRequest;
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/url-connection-client/src/main/java/software/amazon/awssdk/http/urlconnection/
H A DUrlConnectionHttpClient.java153 SdkHttpRequest sdkHttpRequest = request.httpRequest(); in createAndConfigureConnection() local
154 HttpURLConnection connection = connectionFactory.createConnection(sdkHttpRequest.getUri()); in createAndConfigureConnection()
155 setHeaders(connection, sdkHttpRequest); in createAndConfigureConnection()
158 if (sdkHttpRequest.matchingHeaders("Transfer-Encoding").contains("chunked")) { in createAndConfigureConnection()
162 if (!sdkHttpRequest.firstMatchingHeader(ACCEPT).isPresent()) { in createAndConfigureConnection()
168 invokeSafely(() -> connection.setRequestMethod(sdkHttpRequest.method().name())); in createAndConfigureConnection()
177 sdkHttpRequest.firstMatchingHeader(CONTENT_LENGTH).map(Long::parseLong) in createAndConfigureConnection()
/aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/handlers/
H A DS3ExpressChecksumInterceptor.java114 SdkHttpRequest sdkHttpRequest = context.httpRequest(); in modifyHttpRequest() local
119 …Optional<String> headerValue = getFirstNestedValue(sdkHttpRequest.headers(), "x-amz-sdk-checksum-a… in modifyHttpRequest()
121 …return sdkHttpRequest.toBuilder().appendHeader("x-amz-sdk-checksum-algorithm", Algorithm.CRC32.nam… in modifyHttpRequest()
124 return sdkHttpRequest; in modifyHttpRequest()
/aosp_15_r20/external/aws-sdk-java-v2/http-client-spi/src/test/java/software/amazon/awssdk/http/
H A DSdkHttpRequestResponseTest.java418 …final SdkHttpRequest sdkHttpRequest = SdkHttpRequest.builder().method(SdkHttpMethod.POST).uri(uri)… in testSdkHttpRequestBuilderNoQueryParams() local
419 assertThat(sdkHttpRequest.getUri().getQuery()).isNullOrEmpty(); in testSdkHttpRequestBuilderNoQueryParams()
425 final SdkHttpRequest sdkHttpRequest = in testSdkHttpRequestBuilderUriWithQueryParams() local
427 …assertThat(sdkHttpRequest.getUri().getQuery()).contains("reqParam=1234", "oParam=3456&reqParam=567… in testSdkHttpRequestBuilderUriWithQueryParams()
433 final SdkHttpRequest sdkHttpRequest = in testSdkHttpRequestBuilderUriWithQueryParamsIgnoreOtherQueryParams() local
435 …assertThat(sdkHttpRequest.getUri().getQuery()).contains("reqParam=1234", "oParam=3456&reqParam=567… in testSdkHttpRequestBuilderUriWithQueryParamsIgnoreOtherQueryParams()
/aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/s3express/
H A DS3ExpressCacheFunctionalTest.java312 SdkHttpRequest sdkHttpRequest = context.httpRequest(); in modifyHttpRequest() local
313 String host = sdkHttpRequest.host(); in modifyHttpRequest()
316 return sdkHttpRequest.toBuilder().host("localhost") in modifyHttpRequest()
317 … .encodedPath(SdkHttpUtils.appendUri(bucket, sdkHttpRequest.encodedPath())) in modifyHttpRequest()
/aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/multipart/
H A DMultipartClientChecksumTest.java135 SdkHttpRequest sdkHttpRequest = context.httpRequest(); in beforeTransmission() local
136 headers = sdkHttpRequest.headers(); in beforeTransmission()
/aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/it/java/software/amazon/awssdk/services/s3/multipart/
H A DS3ClientMultiPartCopyIntegrationTest.java221 SdkHttpRequest sdkHttpRequest = context.httpRequest(); in beforeTransmission() local
222 Map<String, List<String>> headers = sdkHttpRequest.headers(); in beforeTransmission()
H A DS3MultipartClientPutObjectIntegrationTest.java243 SdkHttpRequest sdkHttpRequest = context.httpRequest(); in beforeTransmission() local
244 headers = sdkHttpRequest.headers(); in beforeTransmission()
/aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/http/pipeline/stages/
H A DMakeAsyncHttpRequestStageTest.java126 SdkHttpFullRequest sdkHttpRequest = SdkHttpFullRequest.builder() in testExecute_contextContainsMetricCollector_addsChildToExecuteRequest() local
148 …etableFuture<SdkHttpFullRequest> requestFuture = CompletableFuture.completedFuture(sdkHttpRequest); in testExecute_contextContainsMetricCollector_addsChildToExecuteRequest()