| /external/opencensus-java/contrib/spring/src/main/java/io/opencensus/contrib/spring/instrument/web/client/ |
| D | TracingAsyncClientHttpRequestInterceptor.java | 33 import org.springframework.http.HttpRequest;
47 final HttpClientHandler<HttpRequest, ClientHttpResponse, HttpRequest> handler;
49 private static final Setter<HttpRequest> setter =
50 new Setter<HttpRequest>() {
52 public void put(HttpRequest carrier, String key, String value) {
70 @Nullable HttpExtractor<HttpRequest, ClientHttpResponse> extractor) { in create() argument
76 @Nullable HttpExtractor<HttpRequest, ClientHttpResponse> extractor) { in TracingAsyncClientHttpRequestInterceptor() argument
85 extractor = (HttpExtractor<HttpRequest, ClientHttpResponse>) new HttpClientExtractor(); in TracingAsyncClientHttpRequestInterceptor()
89 new HttpClientHandler<HttpRequest, ClientHttpResponse, HttpRequest>( in TracingAsyncClientHttpRequestInterceptor()
99 HttpRequest request, in intercept()
[all …]
|
| /external/tensorflow/tensorflow/core/platform/cloud/ |
| D | gcs_file_system_test.cc | 64 std::vector<HttpRequest*> requests( in TEST()
79 std::unique_ptr<HttpRequest::Factory>( in TEST()
110 std::vector<HttpRequest*> requests({ in TEST()
126 std::unique_ptr<HttpRequest::Factory>( in TEST()
157 std::vector<HttpRequest*> requests({ in TEST()
174 std::unique_ptr<HttpRequest::Factory>( in TEST()
206 std::vector<HttpRequest*> requests( in TEST()
221 std::unique_ptr<HttpRequest::Factory>( in TEST()
254 std::vector<HttpRequest*> requests({new FakeHttpRequest( in TEST()
262 std::unique_ptr<HttpRequest::Factory>( in TEST()
[all …]
|
| D | http_request.h | 43 class HttpRequest {
48 virtual HttpRequest* Create() = 0;
83 virtual void RecordRequest(const HttpRequest* request, const string& uri,
87 virtual void RecordResponse(const HttpRequest* request, const string& uri,
91 HttpRequest() {} in HttpRequest() function
92 virtual ~HttpRequest() {} in ~HttpRequest()
187 TF_DISALLOW_COPY_AND_ASSIGN(HttpRequest);
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/http/ |
| D | httpcli.cc | 65 void (*g_test_only_on_handshake_done_intercept)(HttpRequest* req);
69 OrphanablePtr<HttpRequest> HttpRequest::Get( in Get()
89 return MakeOrphanable<HttpRequest>( in Get()
95 OrphanablePtr<HttpRequest> HttpRequest::Post( in Post()
113 return MakeOrphanable<HttpRequest>( in Post()
119 OrphanablePtr<HttpRequest> HttpRequest::Put( in Put()
137 return MakeOrphanable<HttpRequest>( in Put()
143 void HttpRequest::SetOverride(grpc_httpcli_get_override get, in SetOverride()
151 void HttpRequest::TestOnlySetOnHandshakeDoneIntercept( in TestOnlySetOnHandshakeDoneIntercept()
152 void (*intercept)(HttpRequest* req)) { in TestOnlySetOnHandshakeDoneIntercept()
[all …]
|
| D | httpcli.h | 83 class HttpRequest : public InternallyRefCounted<HttpRequest> {
103 static OrphanablePtr<HttpRequest> Get(
129 static OrphanablePtr<HttpRequest> Post(
155 static OrphanablePtr<HttpRequest> Put(
162 HttpRequest(URI uri, const grpc_slice& request_text,
169 ~HttpRequest() override;
180 void (*intercept)(HttpRequest* req));
197 HttpRequest* req = static_cast<HttpRequest*>(user_data); in OnRead()
205 RefCountedPtr<HttpRequest> req(static_cast<HttpRequest*>(user_data)); in ContinueOnReadAfterScheduleOnExecCtx()
216 HttpRequest* req = static_cast<HttpRequest*>(arg); in DoneWrite()
|
| /external/grpc-grpc/src/core/lib/http/ |
| D | httpcli.cc | 63 void (*g_test_only_on_handshake_done_intercept)(HttpRequest* req);
67 OrphanablePtr<HttpRequest> HttpRequest::Get( in Get()
87 return MakeOrphanable<HttpRequest>( in Get()
93 OrphanablePtr<HttpRequest> HttpRequest::Post( in Post()
111 return MakeOrphanable<HttpRequest>( in Post()
117 OrphanablePtr<HttpRequest> HttpRequest::Put( in Put()
135 return MakeOrphanable<HttpRequest>( in Put()
141 void HttpRequest::SetOverride(grpc_httpcli_get_override get, in SetOverride()
149 void HttpRequest::TestOnlySetOnHandshakeDoneIntercept( in TestOnlySetOnHandshakeDoneIntercept()
150 void (*intercept)(HttpRequest* req)) { in TestOnlySetOnHandshakeDoneIntercept()
[all …]
|
| D | httpcli.h | 83 class HttpRequest : public InternallyRefCounted<HttpRequest> {
103 GRPC_MUST_USE_RESULT static OrphanablePtr<HttpRequest> Get(
128 GRPC_MUST_USE_RESULT static OrphanablePtr<HttpRequest> Post(
153 GRPC_MUST_USE_RESULT static OrphanablePtr<HttpRequest> Put(
159 HttpRequest(URI uri, const grpc_slice& request_text,
166 ~HttpRequest() override;
177 void (*intercept)(HttpRequest* req));
194 HttpRequest* req = static_cast<HttpRequest*>(user_data); in OnRead()
202 RefCountedPtr<HttpRequest> req(static_cast<HttpRequest*>(user_data)); in ContinueOnReadAfterScheduleOnExecCtx()
213 HttpRequest* req = static_cast<HttpRequest*>(arg); in DoneWrite()
|
| /external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/ |
| D | SigningTest.java | 36 import software.amazon.awssdk.crt.http.HttpRequest;
77 …private HttpRequest createSimpleRequest(String endpoint, String method, String path, String body) … in createSimpleRequest()
87 return new HttpRequest(method, path, requestHeaders, makeBodyStreamFromString(body)); in createSimpleRequest()
91 private HttpRequest createSigv4TestSuiteRequest() throws Exception { in createSigv4TestSuiteRequest()
101 return new HttpRequest(method, path, requestHeaders, null); in createSigv4TestSuiteRequest()
104 private HttpRequest createUnsignableRequest(String method, String path) throws Exception { in createUnsignableRequest()
110 return new HttpRequest(method, path, requestHeaders, null); in createUnsignableRequest()
113 private HttpRequest createBadBodyStreamRequest(String method, String path) throws Exception { in createBadBodyStreamRequest()
131 return new HttpRequest(method, path, requestHeaders, badBodyStream); in createBadBodyStreamRequest()
134 private HttpHeader findHeader(HttpRequest request, String name) { in findHeader()
[all …]
|
| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt/ |
| D | WebsocketHandshakeTransformArgs.java | 9 import software.amazon.awssdk.crt.http.HttpRequest;
24 private HttpRequest httpRequest;
25 private CompletableFuture<HttpRequest> future;
32 …public WebsocketHandshakeTransformArgs(MqttClientConnection mqttConnection, HttpRequest httpReques… in WebsocketHandshakeTransformArgs()
33 CompletableFuture<HttpRequest> future) { in WebsocketHandshakeTransformArgs()
55 public HttpRequest getHttpRequest() { in getHttpRequest()
64 public void complete(HttpRequest signedRequest) { in complete()
|
| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt5/ |
| D | Mqtt5WebsocketHandshakeTransformArgs.java | 9 import software.amazon.awssdk.crt.http.HttpRequest;
24 private HttpRequest httpRequest;
25 private CompletableFuture<HttpRequest> future;
32 public Mqtt5WebsocketHandshakeTransformArgs(Mqtt5Client mqttClient, HttpRequest httpRequest, in Mqtt5WebsocketHandshakeTransformArgs()
33 CompletableFuture<HttpRequest> future) { in Mqtt5WebsocketHandshakeTransformArgs()
55 public HttpRequest getHttpRequest() { in getHttpRequest()
64 public void complete(HttpRequest signedRequest) { in complete()
|
| /external/federated-compute/fcp/client/http/ |
| D | in_memory_request_response_test.cc | 98 absl::StatusOr<std::unique_ptr<HttpRequest>> request = in TEST()
100 HttpRequest::Method::kGet, {}, "", in TEST()
106 absl::StatusOr<std::unique_ptr<HttpRequest>> request = in TEST()
108 "https://valid.com", HttpRequest::Method::kGet, {}, in TEST()
118 absl::StatusOr<std::unique_ptr<HttpRequest>> request = in TEST()
120 "https://valid.com", HttpRequest::Method::kPost, in TEST()
128 absl::StatusOr<std::unique_ptr<HttpRequest>> request = in TEST()
129 InMemoryHttpRequest::Create(expected_uri, HttpRequest::Method::kGet, {}, in TEST()
133 EXPECT_EQ((*request)->method(), HttpRequest::Method::kGet); in TEST()
142 absl::StatusOr<std::unique_ptr<HttpRequest>> request = in TEST()
[all …]
|
| D | http_client.h | 41 class HttpRequest; // forward declaration variable
146 std::unique_ptr<HttpRequest> request) = 0;
184 class HttpRequest {
201 virtual ~HttpRequest() = default;
367 virtual absl::Status OnResponseStarted(const HttpRequest& request,
392 virtual void OnResponseError(const HttpRequest& request,
406 virtual absl::Status OnResponseBody(const HttpRequest& request,
425 virtual void OnResponseBodyError(const HttpRequest& request,
435 virtual void OnResponseCompleted(const HttpRequest& request,
|
| D | protocol_request_helper.h | 68 absl::StatusOr<std::unique_ptr<HttpRequest>> CreateProtocolRequest(
70 HttpRequest::Method method, std::string request_body,
77 absl::StatusOr<std::unique_ptr<HttpRequest>> CreateGetOperationRequest(
84 absl::StatusOr<std::unique_ptr<HttpRequest>> CreateCancelOperationRequest(
88 absl::StatusOr<std::unique_ptr<HttpRequest>> CreateHttpRequest(
90 HttpRequest::Method method, std::string request_body,
112 std::unique_ptr<HttpRequest> request, InterruptibleRunner& runner);
119 std::vector<std::unique_ptr<HttpRequest>> requests,
|
| D | protocol_request_helper_test.cc | 124 HttpRequest::Method::kPost, "request_body", in TEST()
134 "/v1/request", QueryParams(), HttpRequest::Method::kPost, expected_body, in TEST()
139 EXPECT_EQ((*request)->method(), HttpRequest::Method::kPost); in TEST()
157 "/v1/request", QueryParams(), HttpRequest::Method::kPost, expected_body, in TEST()
162 EXPECT_EQ((*request)->method(), HttpRequest::Method::kPost); in TEST()
183 EXPECT_EQ((*request)->method(), HttpRequest::Method::kGet); in TEST()
197 EXPECT_EQ((*request)->method(), HttpRequest::Method::kGet); in TEST()
265 "https://initial.uri/suffix1", HttpRequest::Method::kPost, in TEST_F()
276 "/suffix1", QueryParams(), HttpRequest::Method::kPost, "body1", in TEST_F()
304 "https://second.uri/suffix2", HttpRequest::Method::kGet, in TEST_F()
[all …]
|
| D | protocol_request_helper.cc | 191 absl::StatusOr<std::unique_ptr<HttpRequest>>
194 HttpRequest::Method method, in CreateProtocolRequest()
202 absl::StatusOr<std::unique_ptr<HttpRequest>>
207 return CreateHttpRequest(uri_path_suffix, {}, HttpRequest::Method::kGet, "", in CreateGetOperationRequest()
212 absl::StatusOr<std::unique_ptr<HttpRequest>>
217 return CreateHttpRequest(uri_path_suffix, {}, HttpRequest::Method::kGet, "", in CreateCancelOperationRequest()
222 absl::StatusOr<std::unique_ptr<HttpRequest>>
225 HttpRequest::Method method, in CreateHttpRequest()
279 std::unique_ptr<HttpRequest> request, InterruptibleRunner& runner) { in PerformProtocolRequest()
280 std::vector<std::unique_ptr<HttpRequest>> requests; in PerformProtocolRequest()
[all …]
|
| D | http_federated_protocol_test.cc | 544 request_uri, HttpRequest::Method::kPost, _, in RunSuccessfulEligibilityEvalCheckin()
592 request_uri, HttpRequest::Method::kPost, _, in RunSuccessfulCheckin()
603 plan_uri, HttpRequest::Method::kGet, _, ""))) in RunSuccessfulCheckin()
629 std::string(expected_request_uri), HttpRequest::Method::kPost, _, in ExpectSuccessfulReportEligibilityEvalTaskResultRequest()
643 HttpRequest::Method::kPost, _, in ExpectSuccessfulReportTaskResultRequest()
661 HttpRequest::Method::kPost, _, in ExpectSuccessfulStartAggregationDataUploadRequest()
671 HttpRequest::Method::kGet, _, in ExpectSuccessfulStartAggregationDataUploadRequest()
689 std::string(byte_stream_upload_uri), HttpRequest::Method::kPost, _, in ExpectSuccessfulByteStreamUploadRequest()
701 HttpRequest::Method::kPost, _, in ExpectSuccessfulSubmitAggregationResultRequest()
712 HttpRequest::Method::kPost, _, _))) in ExpectSuccessfulAbortAggregationRequest()
[all …]
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/nrs/ |
| D | DelegateHttpRequest.java | 19 import io.netty.handler.codec.http.HttpRequest;
32 class DelegateHttpRequest extends DelegateHttpMessage implements HttpRequest {
34 protected final HttpRequest request;
36 DelegateHttpRequest(HttpRequest request) { in DelegateHttpRequest()
42 public HttpRequest setMethod(HttpMethod method) { in setMethod()
48 public HttpRequest setUri(String uri) { in setUri()
76 public HttpRequest setProtocolVersion(HttpVersion version) { in setProtocolVersion()
|
| /external/federated-compute/fcp/client/http/curl/ |
| D | curl_http_client_test.cc | 40 const std::string& request_uri, HttpRequest::Method method, in SetUpOnResponseStarted()
45 const HttpRequest& request, in SetUpOnResponseStarted()
61 HttpRequest::Method method, int response_code, in SetUpOnResponseBody()
67 .WillOnce(::testing::Invoke([=](const HttpRequest& request, in SetUpOnResponseBody()
85 HttpRequest::Method method, int response_code, in SetUpOnResponseBody()
93 [=, &total_bytes_downloaded](const HttpRequest& request, in SetUpOnResponseBody()
113 const std::string& request_uri, HttpRequest::Method method, in SetUpOnResponseCompleted()
118 const HttpRequest& request, in SetUpOnResponseCompleted()
138 HttpRequest::Method::kGet, /*response_code*/ 200, in SetUpGetRequestCallback()
141 SetUpOnResponseBody(request_callback, request_uri, HttpRequest::Method::kGet, in SetUpGetRequestCallback()
[all …]
|
| /external/cronet/stable/net/test/embedded_test_server/ |
| D | http_request.h | 42 struct HttpRequest { struct
55 HttpRequest(); argument
56 HttpRequest(const HttpRequest& other);
57 ~HttpRequest();
124 std::unique_ptr<HttpRequest> GetRequest();
144 std::unique_ptr<HttpRequest> http_request_;
|
| D | http_request.cc | 39 HttpRequest::HttpRequest() = default;
41 HttpRequest::HttpRequest(const HttpRequest& other) = default;
43 HttpRequest::~HttpRequest() = default;
45 GURL HttpRequest::GetURL() const { in GetURL()
52 : http_request_(std::make_unique<HttpRequest>()) {} in HttpRequestParser()
238 std::unique_ptr<HttpRequest> HttpRequestParser::GetRequest() { in GetRequest()
240 std::unique_ptr<HttpRequest> result = std::move(http_request_); in GetRequest()
244 http_request_ = std::make_unique<HttpRequest>(); in GetRequest()
|
| /external/cronet/tot/net/test/embedded_test_server/ |
| D | http_request.h | 42 struct HttpRequest { struct
55 HttpRequest(); argument
56 HttpRequest(const HttpRequest& other);
57 ~HttpRequest();
124 std::unique_ptr<HttpRequest> GetRequest();
144 std::unique_ptr<HttpRequest> http_request_;
|
| D | http_request.cc | 39 HttpRequest::HttpRequest() = default;
41 HttpRequest::HttpRequest(const HttpRequest& other) = default;
43 HttpRequest::~HttpRequest() = default;
45 GURL HttpRequest::GetURL() const { in GetURL()
52 : http_request_(std::make_unique<HttpRequest>()) {} in HttpRequestParser()
238 std::unique_ptr<HttpRequest> HttpRequestParser::GetRequest() { in GetRequest()
240 std::unique_ptr<HttpRequest> result = std::move(http_request_); in GetRequest()
244 http_request_ = std::make_unique<HttpRequest>(); in GetRequest()
|
| /external/federated-compute/fcp/client/http/testing/ |
| D | test_helpers.h | 71 const HttpRequest::Method method;
79 std::unique_ptr<HttpRequest> request) override;
124 const ::testing::Matcher<HttpRequest::Method>& method_matcher,
134 (const HttpRequest& request, const HttpResponse& response),
138 (const HttpRequest& request, const absl::Status& error),
142 (const HttpRequest& request, const HttpResponse& response,
147 (const HttpRequest& request, const HttpResponse& response,
152 (const HttpRequest& request, const HttpResponse& response),
|
| /external/opencensus-java/examples/src/main/java/io/opencensus/examples/http/jetty/client/ |
| D | HelloWorldClient.java | 32 import org.eclipse.jetty.client.HttpRequest;
90 HttpRequest request = in main()
91 (HttpRequest) in main()
95 HttpRequest asyncRequest = in main()
96 (HttpRequest) in main()
100 HttpRequest postRequest = in main()
101 (HttpRequest) in main()
|
| /external/opencensus-java/contrib/http_util/ |
| D | README.md | 51 // public class HttpRequest {
60 // use the HttpRequest itself as Carrier.
61 TextFormat.Setter<HttpRequest> myTextFormatSetter =
62 new TextFormat.Setter<HttpRequest>() {
64 public void put(HttpRequest carrier, String key, String value) {
68 TextFormat.Getter<HttpRequest> myTextFormatGetter =
69 new TextFormat.Getter<HttpRequest>() {
71 public String get(HttpRequest carrier, String key) {
75 HttpExtractor<HttpRequest, HttpResponse> extractor =
76 new HttpExtractor<HttpRequest, HttpResponse>() {
[all …]
|