| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/http/ |
| D | HttpHeader.java | 17 public class HttpHeader { class
25 private HttpHeader() {} in HttpHeader() method in HttpHeader
32 public HttpHeader(String name, String value){ in HttpHeader() method in HttpHeader
42 public HttpHeader(byte[] name, byte[] value){ in HttpHeader() method in HttpHeader
95 … public static List<HttpHeader> loadHeadersListFromMarshalledHeadersBlob(ByteBuffer headersBlob) { in loadHeadersListFromMarshalledHeadersBlob()
96 List<HttpHeader> headers = new ArrayList<>(16); in loadHeadersListFromMarshalledHeadersBlob()
110 headers.add(new HttpHeader(nameBuf, valueBuf)); in loadHeadersListFromMarshalledHeadersBlob()
127 public static byte[] marshalHeadersForJni(List<HttpHeader> headers) { in marshalHeadersForJni()
130 for (HttpHeader header : headers) { in marshalHeadersForJni()
137 for (HttpHeader header : headers) { in marshalHeadersForJni()
[all …]
|
| D | HttpRequestBase.java | 15 protected List<HttpHeader> headers;
27 protected HttpRequestBase(HttpHeader[] headers, HttpRequestBodyStream bodyStream) { in HttpRequestBase()
33 this.headers = new ArrayList<HttpHeader>(Arrays.asList(headers)); in HttpRequestBase()
56 for (HttpHeader header : headers) { in marshalForJni()
69 for (HttpHeader header : headers) { in marshalForJni()
85 public List<HttpHeader> getHeaders() { in getHeaders()
89 public HttpHeader[] getHeadersAsArray() { in getHeadersAsArray()
90 return headers.toArray(new HttpHeader[] {}); in getHeadersAsArray()
93 public void addHeader(final HttpHeader header) { in addHeader()
98 headers.add(new HttpHeader(headerName, headerValue)); in addHeader()
[all …]
|
| D | HttpRequest.java | 24 this(method, encodedPath, new HttpHeader[] {}, null); in HttpRequest()
35 …public HttpRequest(String method, String encodedPath, HttpHeader[] headers, HttpRequestBodyStream … in HttpRequest()
72 this.headers = HttpHeader.loadHeadersListFromMarshalledHeadersBlob(marshalledRequest); in HttpRequest()
|
| D | Http2Request.java | 18 this(new HttpHeader[] {}, null); in Http2Request()
29 public Http2Request(HttpHeader[] headers, HttpRequestBodyStream bodyStream) { in Http2Request()
|
| /external/aws-sdk-java-v2/http-clients/aws-crt-client/src/main/java/software/amazon/awssdk/http/crt/internal/request/ |
| D | CrtRequestAdapter.java | 23 import software.amazon.awssdk.crt.http.HttpHeader;
51 …HttpHeader[] crtHeaderArray = asArray(createAsyncHttpHeaderList(sdkRequest.getUri(), sdkExecuteReq… in toAsyncCrtRequest()
75 …HttpHeader[] crtHeaderArray = asArray(createHttpHeaderList(sdkRequest.getUri(), sdkExecuteRequest)… in toCrtRequest()
88 private static HttpHeader[] asArray(List<HttpHeader> crtHeaderList) { in asArray()
89 return crtHeaderList.toArray(new HttpHeader[0]); in asArray()
92 …private static List<HttpHeader> createAsyncHttpHeaderList(URI uri, AsyncExecuteRequest sdkExecuteR… in createAsyncHttpHeaderList()
95 List<HttpHeader> crtHeaderList = new ArrayList<>(sdkRequest.numHeaders() + 3); in createAsyncHttpHeaderList()
99 crtHeaderList.add(new HttpHeader(Header.HOST, uri.getHost())); in createAsyncHttpHeaderList()
104 crtHeaderList.add(new HttpHeader(Header.CONNECTION, Header.KEEP_ALIVE_VALUE)); in createAsyncHttpHeaderList()
110 … crtHeaderList.add(new HttpHeader(Header.CONTENT_LENGTH, Long.toString(contentLength.get()))); in createAsyncHttpHeaderList()
[all …]
|
| /external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/ |
| D | SigningTest.java | 35 import software.amazon.awssdk.crt.http.HttpHeader;
81 HttpHeader[] requestHeaders = in createSimpleRequest()
82 new HttpHeader[]{ in createSimpleRequest()
83 new HttpHeader("Host", uri.getHost()), in createSimpleRequest()
84 … new HttpHeader("Content-Length", Integer.toString(body.getBytes(StandardCharsets.UTF_8).length)) in createSimpleRequest()
93 HttpHeader[] requestHeaders = in createSigv4TestSuiteRequest()
94 new HttpHeader[]{ in createSigv4TestSuiteRequest()
95 new HttpHeader("Host", "example.amazonaws.com") in createSigv4TestSuiteRequest()
106 HttpHeader[] requestHeaders = new HttpHeader[]{ in createUnsignableRequest()
107 new HttpHeader("Authorization", "bad") in createUnsignableRequest()
[all …]
|
| D | HttpRequestResponseTest.java | 16 import software.amazon.awssdk.crt.http.HttpHeader;
34 HttpHeader[] requestHeaders = null; in testRequest()
37 requestHeaders = new HttpHeader[] { new HttpHeader("Host", uri.getHost()), in testRequest()
38 … new HttpHeader("Content-Length", Integer.toString(requestBody.getBytes(UTF8).length)) }; in testRequest()
40 requestHeaders = new HttpHeader[] { new HttpHeader("Host", uri.getHost()), in testRequest()
41 new HttpHeader("Transfer-Encoding", "chunked") }; in testRequest()
95 for (HttpHeader h : response.headers) { in testRequest()
255 HttpHeader[] requestHeaders = new HttpHeader[] { new HttpHeader("Host", uri.getHost()) }; in testHttpRequestUnActivated()
267 HttpHeader[] nextHeaders) { in testHttpRequestUnActivated()
|
| D | Http2RequestResponseTest.java | 14 import software.amazon.awssdk.crt.http.HttpHeader;
39 HttpHeader[] requestHeaders = null; in getHttp2Request()
41 …requestHeaders = new HttpHeader[] { new HttpHeader(":method", method), new HttpHeader(":path", pat… in getHttp2Request()
42 … new HttpHeader(":scheme", uri.getScheme()), new HttpHeader(":authority", uri.getHost()), in getHttp2Request()
43 … new HttpHeader("content-length", Integer.toString(requestBody.getBytes(UTF8).length)), }; in getHttp2Request()
99 for (HttpHeader h : response.headers) { in testHttp2Request()
190 HttpHeader[] nextHeaders) { in testHttp2ResetStream()
|
| D | S3ClientTest.java | 321 HttpHeader[] headers = { new HttpHeader("Host", ENDPOINT) }; in testS3Get()
368 HttpHeader[] headers = { new HttpHeader("Host", ENDPOINT) }; in testS3GetErrorHeadersAreReported()
403 HttpHeader[] headers = { new HttpHeader("Host", ENDPOINT) }; in testS3GetAfterClientIsClose()
442 HttpHeader[] headers = { new HttpHeader("Host", ENDPOINT) }; in testS3CallbackExceptionIsProperlyPropagated()
487 HttpHeader[] headers = { new HttpHeader("Host", ENDPOINT + ":443") }; in testS3GetWithEndpoint()
552 HttpHeader[] headers = { new HttpHeader("Host", ENDPOINT) }; in testS3GetWithBackpressure()
634 HttpHeader[] headers = { new HttpHeader("Host", ENDPOINT) }; in testS3GetWithBackpressureIncrementViaOnResponseBody()
679 HttpHeader[] headers = { new HttpHeader("Host", ENDPOINT) }; in testS3OverrideRequestCredentials()
730 HttpHeader[] headers = { new HttpHeader("Host", ENDPOINT) }; in testS3GetWithSignConfigShouldSignHeader()
790 HttpHeader[] headers = { in testS3PutHelper()
[all …]
|
| D | Elasticurl.java | 30 import software.amazon.awssdk.crt.http.HttpHeader;
159 HttpHeader[] headers = new HttpHeader[] {}; in buildHttpRequest()
165 request.addHeader(new HttpHeader(":method", method)); in buildHttpRequest()
166 request.addHeader(new HttpHeader(":scheme", uri.getScheme())); in buildHttpRequest()
167 request.addHeader(new HttpHeader(":authority", uri.getAuthority())); in buildHttpRequest()
168 request.addHeader(new HttpHeader(":path", pathAndQuery)); in buildHttpRequest()
170 request.addHeader(new HttpHeader("Host", uri.getHost())); in buildHttpRequest()
174 request.addHeader(new HttpHeader("accept", "*/*")); in buildHttpRequest()
175 …request.addHeader(new HttpHeader("user-agent", "elasticurl 1.0, Powered by the AWS Common Runtime.… in buildHttpRequest()
182 request.addHeader(new HttpHeader(pair[0].trim(), pair[1].trim())); in buildHttpRequest()
[all …]
|
| D | Http2ClientLocalHostTest.java | 30 import software.amazon.awssdk.crt.http.HttpHeader;
119 HttpHeader[] requestHeaders = new HttpHeader[] { in createHttp2Request()
120 new HttpHeader(":method", method), in createHttp2Request()
121 new HttpHeader(":path", uri.getPath()), in createHttp2Request()
122 new HttpHeader(":scheme", uri.getScheme()), in createHttp2Request()
123 new HttpHeader(":authority", uri.getHost()), in createHttp2Request()
152 HttpHeader[] nextHeaders) { in testParallelRequestsStress()
211 HttpHeader[] nextHeaders) { in testParallelRequestsStressWithBody()
278 HttpHeader[] nextHeaders) { in testRequestsUploadStress()
323 HttpHeader[] nextHeaders) { in testRequestsDownloadStress()
|
| D | Http2StreamManagerTest.java | 69 HttpHeader[] requestHeaders = new HttpHeader[] { in createHttp2Request()
70 new HttpHeader(":method", method), in createHttp2Request()
71 new HttpHeader(":path", path), in createHttp2Request()
72 new HttpHeader(":scheme", uri.getScheme()), in createHttp2Request()
73 new HttpHeader(":authority", uri.getHost()), in createHttp2Request()
74 … new HttpHeader("content-length", Integer.toString(requestBody.getBytes(UTF8).length)) in createHttp2Request()
103 HttpHeader[] nextHeaders) { in testParallelStreams()
|
| /external/aws-sdk-java-v2/core/http-auth-aws/src/main/java/software/amazon/awssdk/http/auth/aws/crt/internal/util/ |
| D | CrtHttpRequestConverter.java | 26 import software.amazon.awssdk.crt.http.HttpHeader;
50 HttpHeader[] crtHeaderArray = createHttpHeaderArray(request); in toRequest()
67 for (HttpHeader header : crtRequest.getHeaders()) { in toRequest()
115 private static HttpHeader[] createHttpHeaderArray(SdkHttpRequest request) { in createHttpHeaderArray()
116 List<HttpHeader> crtHeaderList = new ArrayList<>(request.numHeaders() + 2); in createHttpHeaderArray()
120 crtHeaderList.add(new HttpHeader(HOST, request.host())); in createHttpHeaderArray()
126 HttpHeader h = new HttpHeader(name, val); in createHttpHeaderArray()
131 return crtHeaderList.toArray(new HttpHeader[0]); in createHttpHeaderArray()
|
| /external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/internal/crt/ |
| D | S3CrtResponseHandlerAdapterTest.java | 40 import software.amazon.awssdk.crt.http.HttpHeader;
71 HttpHeader[] httpHeaders = new HttpHeader[2]; in successfulResponse_shouldCompleteFutureSuccessfully()
72 httpHeaders[0] = new HttpHeader("foo", "1"); in successfulResponse_shouldCompleteFutureSuccessfully()
73 httpHeaders[1] = new HttpHeader("bar", "2"); in successfulResponse_shouldCompleteFutureSuccessfully()
96 HttpHeader[] httpHeaders = new HttpHeader[2]; in nullByteBuffer_shouldCompleteFutureExceptionally()
97 httpHeaders[0] = new HttpHeader("foo", "1"); in nullByteBuffer_shouldCompleteFutureExceptionally()
98 httpHeaders[1] = new HttpHeader("bar", "2"); in nullByteBuffer_shouldCompleteFutureExceptionally()
115 responseHandlerAdapter.onResponseHeaders(statusCode, new HttpHeader[0]); in errorResponse_shouldCompleteFutureSuccessfully()
|
| /external/aws-sdk-java-v2/http-clients/aws-crt-client/src/test/java/software/amazon/awssdk/http/crt/internal/ |
| D | BaseHttpStreamResponseHandlerTest.java | 41 import software.amazon.awssdk.crt.http.HttpHeader;
73 HttpHeader[] httpHeaders = getHttpHeaders(); in serverError_shouldShutdownConnection()
88 HttpHeader[] httpHeaders = getHttpHeaders(); in nonServerError_shouldNotShutdownConnection()
103 HttpHeader[] httpHeaders = getHttpHeaders(); in failedToGetResponse_shouldShutdownConnection()
116 HttpHeader[] httpHeaders = getHttpHeaders(); in streamClosed_shouldNotIncreaseStreamWindow()
137 HttpHeader[] httpHeaders = getHttpHeaders(); in publisherWritesFutureFails_shouldShutdownConnection()
168 HttpHeader[] httpHeaders = getHttpHeaders(); in publisherWritesFutureCompletesAfterConnectionClosed_shouldNotInvokeIncrementWindow()
194 HttpHeader[] httpHeaders = getHttpHeaders(); in publisherWritesFutureCompletesWhenConnectionClosed_shouldNotInvokeIncrementWindow()
225 static HttpHeader[] getHttpHeaders() { in getHttpHeaders()
226 HttpHeader[] httpHeaders = new HttpHeader[1]; in getHttpHeaders()
[all …]
|
| D | InputStreamAdaptingHttpStreamResponseHandlerTest.java | 45 import software.amazon.awssdk.crt.http.HttpHeader;
71 HttpHeader[] httpHeaders = getHttpHeaders(); in abortStream_shouldShutDownConnection()
93 HttpHeader[] httpHeaders = getHttpHeaders(); in closeStream_shouldShutdownConnection()
115 HttpHeader[] httpHeaders = getHttpHeaders(); in cancelFuture_shouldCloseConnection()
|
| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/s3/ |
| D | S3FinishedResponseContext.java | 7 import software.amazon.awssdk.crt.http.HttpHeader;
17 private final HttpHeader[] errorHeaders;
27 …umAlgorithm, final boolean didValidateChecksum, Throwable cause, final HttpHeader[] errorHeaders) { in S3FinishedResponseContext()
82 public HttpHeader[] getErrorHeaders() { in getErrorHeaders()
|
| D | S3MetaRequestResponseHandlerNativeAdapter.java | 7 import software.amazon.awssdk.crt.http.HttpHeader;
23 …HttpHeader[] errorHeaders = headersBlob == null ? null : HttpHeader.loadHeadersFromMarshalledHeade… in onFinished()
29 …responseHandler.onResponseHeaders(statusCode, HttpHeader.loadHeadersFromMarshalledHeadersBlob(head… in onResponseHeaders()
|
| D | S3MetaRequestResponseHandler.java | 8 import software.amazon.awssdk.crt.http.HttpHeader;
23 default void onResponseHeaders(final int statusCode, final HttpHeader[] headers) { in onResponseHeaders()
|
| /external/aws-sdk-java-v2/core/auth-crt/src/main/java/software/amazon/awssdk/authcrt/signer/internal/ |
| D | CrtHttpRequestConverter.java | 32 import software.amazon.awssdk.crt.http.HttpHeader;
56 HttpHeader[] crtHeaderArray = createHttpHeaderArray(inputRequest); in requestToCrt()
71 for (HttpHeader header : signedCrtRequest.getHeaders()) { in crtRequestToHttp()
128 private HttpHeader[] createHttpHeaderArray(SdkHttpFullRequest request) { in createHttpHeaderArray()
129 List<HttpHeader> crtHeaderList = new ArrayList<>(request.numHeaders() + 2); in createHttpHeaderArray()
133 crtHeaderList.add(new HttpHeader(HOST_HEADER, request.host())); in createHttpHeaderArray()
139 HttpHeader h = new HttpHeader(name, val); in createHttpHeaderArray()
144 return crtHeaderList.toArray(new HttpHeader[0]); in createHttpHeaderArray()
|
| /external/aws-sdk-java-v2/test/s3-benchmarks/src/main/java/software/amazon/awssdk/s3benchmarks/ |
| D | CrtS3ClientDownloadBenchmark.java | 22 import software.amazon.awssdk.crt.http.HttpHeader;
43 HttpHeader[] headers = {new HttpHeader("Host", endpoint)}; in sendOneRequest()
|
| D | CrtS3ClientUploadBenchmark.java | 25 import software.amazon.awssdk.crt.http.HttpHeader;
52 HttpHeader[] headers = {new HttpHeader("Host", endpoint)}; in sendOneRequest()
|
| /external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/crt/ |
| D | S3CrtResponseHandlerAdapter.java | 26 import software.amazon.awssdk.crt.http.HttpHeader;
64 public void onResponseHeaders(int statusCode, HttpHeader[] headers) { in onResponseHeaders()
136 HttpHeader[] headers = context.getErrorHeaders(); in handleError()
198 … int statusCode, HttpHeader[] headers) { in populateSdkHttpResponse()
200 for (HttpHeader h : headers) { in populateSdkHttpResponse()
|
| D | S3CrtAsyncHttpClient.java | 41 import software.amazon.awssdk.crt.http.HttpHeader;
250 HttpHeader[] crtHeaderArray = createHttpHeaderList(asyncRequest).toArray(new HttpHeader[0]); in toCrtRequest()
289 private static List<HttpHeader> createHttpHeaderList(AsyncExecuteRequest asyncRequest) { in createHttpHeaderList()
291 List<HttpHeader> crtHeaderList = new ArrayList<>(); in createHttpHeaderList()
296 crtHeaderList.add(new HttpHeader(Header.HOST, hostHeader)); in createHttpHeaderList()
302 … crtHeaderList.add(new HttpHeader(Header.CONTENT_LENGTH, Long.toString(contentLength.get()))); in createHttpHeaderList()
306 sdkRequest.forEachHeader((key, value) -> value.stream().map(val -> new HttpHeader(key, val)) in createHttpHeaderList()
|
| /external/aws-sdk-java-v2/http-clients/aws-crt-client/src/main/java/software/amazon/awssdk/http/crt/internal/response/ |
| D | ResponseHandlerHelper.java | 20 import software.amazon.awssdk.crt.http.HttpHeader;
48 …ponseHeaders(HttpStream stream, int responseStatusCode, int headerType, HttpHeader[] nextHeaders) { in onResponseHeaders()
50 for (HttpHeader h : nextHeaders) { in onResponseHeaders()
|