| /aosp_15_r20/external/cronet/net/spdy/ |
| H A D | spdy_stream_unittest.cc | 198 StreamDelegateSendImmediate delegate(stream, kPostBodyStringPiece); in TEST_F() local
201 spdy::Http2HeaderBlock headers( in TEST_F() local
249 StreamDelegateSendImmediate delegate(stream, kPostBodyStringPiece); in TEST_F() local
252 spdy::Http2HeaderBlock headers( in TEST_F() local
323 StreamDelegateWithTrailers delegate(stream, kPostBodyStringPiece); in TEST_F() local
326 spdy::Http2HeaderBlock headers( in TEST_F() local
379 StreamDelegateSendImmediate delegate(stream, kPostBodyStringPiece); in TEST_F() local
382 spdy::Http2HeaderBlock headers( in TEST_F() local
446 StreamDelegateWithBody delegate(stream, body_data); in TEST_F() local
449 spdy::Http2HeaderBlock headers( in TEST_F() local
[all …]
|
| H A D | spdy_session_unittest.cc | 552 spdy::Http2HeaderBlock headers( in TEST_F() local
681 spdy::Http2HeaderBlock headers( in TEST_F() local
749 spdy::Http2HeaderBlock headers( in TEST_F() local
829 test::StreamDelegateDoNothing delegate(spdy_stream); in TEST_F() local
832 spdy::Http2HeaderBlock headers( in TEST_F() local
903 spdy::Http2HeaderBlock headers( in TEST_F() local
956 test::StreamDelegateDoNothing delegate(spdy_stream); in TEST_F() local
959 spdy::Http2HeaderBlock headers( in TEST_F() local
1016 test::StreamDelegateDoNothing delegate(spdy_stream); in TEST_F() local
1019 spdy::Http2HeaderBlock headers( in TEST_F() local
[all …]
|
| H A D | spdy_session_pool_unittest.cc | 209 void OnEarlyHintsReceived(const spdy::Http2HeaderBlock& headers) override {} in OnEarlyHintsReceived()
274 SessionOpeningDelegate delegate(spdy_session_pool_, test_key); in TEST_F() local
449 SessionOpeningDelegate delegate(spdy_session_pool_, test_key); in TEST_F() local
1140 spdy::Http2HeaderBlock headers( in TEST_P() local
1268 spdy::Http2HeaderBlock headers( in TEST_F() local
1364 test::StreamDelegateDoNothing delegate(spdy_stream); in TEST_F() local
1367 spdy::Http2HeaderBlock headers(spdy_util.ConstructGetHeaderBlock(url.spec())); in TEST_F() local
1423 test::StreamDelegateDoNothing delegate(spdy_stream); in TEST_F() local
1426 spdy::Http2HeaderBlock headers(spdy_util.ConstructGetHeaderBlock(url.spec())); in TEST_F() local
1523 test::StreamDelegateDoNothing delegate(spdy_stream); in TEST_F() local
[all …]
|
| H A D | bidirectional_stream_spdy_impl.cc | 46 BidirectionalStreamImpl::Delegate* delegate, in Start()
199 const spdy::Http2HeaderBlock& headers) { in OnEarlyHintsReceived()
288 spdy::Http2HeaderBlock headers; in SendRequestHeadersHelper() local
323 BidirectionalStreamImpl::Delegate* delegate = delegate_; in NotifyError() local
|
| /aosp_15_r20/external/cronet/net/test/embedded_test_server/ |
| H A D | http_response.cc | 34 RawHttpResponse::RawHttpResponse(const std::string& headers, in RawHttpResponse()
41 base::WeakPtr<HttpResponseDelegate> delegate) { in SendResponse()
65 base::StringPairs headers = BuildHeaders(); in ToResponseString() local
84 base::StringPairs headers; in BuildHeaders() local
95 base::WeakPtr<HttpResponseDelegate> delegate) { in SendResponse()
106 base::WeakPtr<HttpResponseDelegate> delegate) { in SendResponse()
114 void HungResponse::SendResponse(base::WeakPtr<HttpResponseDelegate> delegate) {} in SendResponse()
117 base::StringPairs headers) in HungAfterHeadersHttpResponse()
122 base::WeakPtr<HttpResponseDelegate> delegate) { in SendResponse()
|
| H A D | default_handlers.cc | 87 RequestQuery headers = ParseQuery(request_url); in HandleEchoHeader() local
326 RequestQuery headers = ParseQuery(url); in ExtractHeadersFromQuery() local
353 auto headers = ExtractHeadersFromQuery(request_url); in HandleSetHeader() local
397 auto headers = ExtractHeadersFromQuery(request_url); in HandleSetHeaderWithFile() local
806 void SendResponse(base::WeakPtr<HttpResponseDelegate> delegate) override { in SendResponse()
818 void SendExabyte(base::WeakPtr<HttpResponseDelegate> delegate) { in SendExabyte()
824 void PostSendExabyteTask(base::WeakPtr<HttpResponseDelegate> delegate) { in PostSendExabyteTask()
898 void SendResponse(base::WeakPtr<HttpResponseDelegate> delegate) override { in SendResponse()
910 base::StringPairs headers = {{"Content-Type", "text/plain"}, in SendHeaders() local
|
| /aosp_15_r20/external/dagger2/java/dagger/grpc/server/ |
| H A D | ProxyServerCallHandler.java | 49 ServerServiceDefinition getServiceDefinition(Metadata headers); in getServiceDefinition()
82 Metadata headers) { in startCall()
92 private ServerMethodDefinition<RequestT, ResponseT> getMethodDefinition(Metadata headers) { in getMethodDefinition()
119 private final Listener<RequestT> delegate; field in ProxyServerCallHandler.ServerCallListenerAdapter
121 public ServerCallListenerAdapter(Listener<RequestT> delegate) { in ServerCallListenerAdapter()
152 private final ServerCall<InputStream, InputStream> delegate; field in ProxyServerCallHandler.ServerCallAdapter
155 ServerCallAdapter(ServerCall<InputStream, InputStream> delegate, in ServerCallAdapter() argument
172 public void sendHeaders(Metadata headers) { in sendHeaders()
|
| /aosp_15_r20/external/grpc-grpc-java/api/src/main/java/io/grpc/ |
| H A D | CompositeCallCredentials.java | 46 private final MetadataApplier delegate; field in CompositeCallCredentials.WrappingMetadataApplier
50 RequestInfo requestInfo, Executor appExecutor, MetadataApplier delegate, Context context) { in WrappingMetadataApplier()
58 public void apply(Metadata headers) { in apply()
76 private final MetadataApplier delegate; field in CompositeCallCredentials.CombiningMetadataApplier
79 public CombiningMetadataApplier(MetadataApplier delegate, Metadata firstHeaders) { in CombiningMetadataApplier()
85 public void apply(Metadata headers) { in apply()
|
| H A D | ForwardingClientCall.java | 28 protected abstract ClientCall<ReqT, RespT> delegate(); in delegate() method in ForwardingClientCall
31 public void start(Listener<RespT> responseListener, Metadata headers) { in start()
46 private final ClientCall<ReqT, RespT> delegate; field in ForwardingClientCall.SimpleForwardingClientCall
48 protected SimpleForwardingClientCall(ClientCall<ReqT, RespT> delegate) { in SimpleForwardingClientCall()
53 protected ClientCall<ReqT, RespT> delegate() { in delegate() method in ForwardingClientCall.SimpleForwardingClientCall
|
| /aosp_15_r20/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| H A D | TokenAttachingTracerFactory.java | 37 private final ClientStreamTracer.Factory delegate; field in TokenAttachingTracerFactory
39 TokenAttachingTracerFactory(@Nullable ClientStreamTracer.Factory delegate) { in TokenAttachingTracerFactory()
45 ClientStreamTracer.StreamInfo info, Metadata headers) { in newClientStreamTracer()
52 protected ClientStreamTracer delegate() { in newClientStreamTracer() method in TokenAttachingTracerFactory.TokenPropagationTracer
57 public void streamCreated(Attributes transportAttrs, Metadata headers) { in newClientStreamTracer()
|
| /aosp_15_r20/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| H A D | CompressionTest.java | 263 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) { in interceptCall()
289 protected ClientCompressor(ClientCall<ReqT, RespT> delegate) { in ClientCompressor()
294 public void start(io.grpc.ClientCall.Listener<RespT> responseListener, Metadata headers) { in start()
301 private ClientHeadersCapture(Listener<RespT> delegate) { in ClientHeadersCapture()
306 public void onHeaders(Metadata headers) { in onHeaders()
|
| /aosp_15_r20/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| H A D | TokenAttachingTracerFactoryTest.java | 38 Metadata headers; field in TokenAttachingTracerFactoryTest.FakeClientStreamTracer
41 public void streamCreated(Attributes transportAttrs, Metadata headers) { in streamCreated()
49 private final ClientStreamTracer.Factory delegate = mock( field in TokenAttachingTracerFactoryTest
66 Metadata headers = new Metadata(); in hasToken() local
85 Metadata headers = new Metadata(); in noToken() local
104 Metadata headers = new Metadata(); in nullDelegate() local
109 headers); in nullDelegate() local
|
| /aosp_15_r20/external/cronet/net/url_request/ |
| H A D | url_request_http_job_unittest.cc | 237 TestDelegate delegate; in TEST_F() local
283 TestDelegate delegate; in TEST_F() local
333 TestDelegate delegate; in TEST_F() local
374 URLRequest::Delegate* delegate) { in CreateFirstPartyRequest()
410 TestDelegate delegate; in TEST_F() local
435 TestDelegate delegate; in TEST_F() local
462 TestDelegate delegate; in TEST_F() local
494 TestDelegate delegate; in TEST_F() local
520 TestDelegate delegate; in TEST_F() local
549 TestDelegate delegate; in TEST_F() local
[all …]
|
| H A D | url_request_unittest.cc | 519 const HttpRequestHeaders& headers, in OnBeforeStartTransaction()
701 URLRequest::Delegate* delegate) { in CreateFirstPartyRequest()
1488 HttpRequestHeaders headers = WebSocketCommonTestHeaders(); in TEST_F() local
1751 TestDelegate delegate; in TEST_F() local
1770 TestDelegate delegate; in TEST_F() local
1806 TestDelegate delegate; in TEST_F() local
1837 TestDelegate delegate; in TEST_F() local
3883 HttpRequestHeaders headers; in TEST_F() local
3901 HttpRequestHeaders headers; in TEST_F() local
3980 HttpRequestHeaders headers; in HTTPRedirectMethodTest() local
[all …]
|
| /aosp_15_r20/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| H A D | CallCredentialsApplyingTransportFactory.java | 43 private final ClientTransportFactory delegate; field in CallCredentialsApplyingTransportFactory
48 ClientTransportFactory delegate, CallCredentials channelCallCredentials, in CallCredentialsApplyingTransportFactory()
78 private final ConnectionClientTransport delegate; field in CallCredentialsApplyingTransportFactory.CallCredentialsApplyingTransport
96 CallCredentialsApplyingTransport(ConnectionClientTransport delegate, String authority) { in CallCredentialsApplyingTransport()
102 protected ConnectionClientTransport delegate() { in delegate() method in CallCredentialsApplyingTransportFactory.CallCredentialsApplyingTransport
109 final MethodDescriptor<?, ?> method, Metadata headers, final CallOptions callOptions, in newStream()
|
| /aosp_15_r20/external/grpc-grpc-java/binder/src/androidTest/java/io/grpc/binder/ |
| H A D | BinderChannelSmokeTest.java | 328 private final StreamObserver<V> delegate; field in BinderChannelSmokeTest.ForwardingStreamObserver
330 ForwardingStreamObserver(StreamObserver<V> delegate) { in ForwardingStreamObserver()
353 Metadata headers, ServerCallHandler<ReqT, RespT> next) { in interceptCall()
360 super.sendHeaders(headers); in interceptCall() argument
|
| /aosp_15_r20/external/cronet/net/http/ |
| H A D | bidirectional_stream.cc | 40 base::Value::Dict NetLogHeadersParams(const spdy::Http2HeaderBlock* headers, in NetLogHeadersParams()
49 const HttpRequestHeaders* headers, in NetLogParams()
70 Delegate* delegate) in BidirectionalStream()
81 Delegate* delegate, in BidirectionalStream()
|
| H A D | http_stream_factory.cc | 87 const HttpResponseHeaders* headers, in ProcessAlternativeServices()
124 HttpStreamRequest::Delegate* delegate, in RequestStream()
140 HttpStreamRequest::Delegate* delegate, in RequestWebSocketHandshakeStream()
158 HttpStreamRequest::Delegate* delegate, in RequestBidirectionalStreamImpl()
175 HttpStreamRequest::Delegate* delegate, in RequestStreamInternal()
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/http/ |
| H A D | metadata_decoder_test.cc | 18 std::string EncodeHeaders(spdy::Http2HeaderBlock& headers) { in EncodeHeaders()
19 quic::NoopDecoderStreamErrorDelegate delegate; in EncodeHeaders() local
40 spdy::Http2HeaderBlock headers; in TEST_F() local
66 spdy::Http2HeaderBlock headers; in TEST_F() local
|
| H A D | quic_spdy_stream_test.cc | 381 std::vector<std::pair<absl::string_view, absl::string_view>> headers) { in EncodeQpackHeaders()
465 QuicHeaderList ProcessHeaders(bool fin, const Http2HeaderBlock& headers) { in ProcessHeaders()
483 std::vector<std::pair<absl::string_view, absl::string_view>> headers) { in HeadersFrame()
489 std::string HeadersFrame(const Http2HeaderBlock& headers) { in HeadersFrame()
555 QuicHeaderList headers; in TEST_P() local
573 std::string headers = in TEST_P() local
609 std::string headers = in TEST_P() local
621 QuicHeaderList headers; in TEST_P() local
697 QuicHeaderList headers = ProcessHeaders(false, headers_); in TEST_P() local
717 QuicHeaderList headers = ProcessHeaders(false, headers_); in TEST_P() local
[all …]
|
| /aosp_15_r20/external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/orca/ |
| H A D | OrcaPerRequestUtil.java | 169 ClientStreamTracer.Factory delegate, OrcaPerRequestReportListener listener); in newOrcaClientStreamTracerFactory()
207 private final ClientStreamTracer.Factory delegate; field in OrcaPerRequestUtil.OrcaReportingTracerFactory
211 ClientStreamTracer.Factory delegate, OrcaPerRequestReportListener listener) { in OrcaReportingTracerFactory()
217 public ClientStreamTracer newClientStreamTracer(StreamInfo info, Metadata headers) { in newClientStreamTracer()
|
| /aosp_15_r20/external/grpc-grpc-java/rls/src/test/java/io/grpc/rls/ |
| H A D | RlsLoadBalancerTest.java | 176 Metadata headers = new Metadata(); in lb_serverStatusCodeConversion() local
206 Metadata headers = new Metadata(); in lb_working_withDefaultTarget_rlsResponding() local
266 Metadata headers = new Metadata(); in lb_working_withDefaultTarget_noRlsResponse() local
332 Metadata headers = new Metadata(); in lb_working_withoutDefaultTarget() local
401 Metadata headers = new Metadata(); in lb_nameResolutionFailed() local
525 protected ManagedChannelBuilder<?> delegate() { in createResolvingOobChannelBuilder() method in RlsLoadBalancerTest.FakeHelper.CleaningChannelBuilder
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/http/async/ |
| H A D | FilterTransformingAsyncHttpResponseHandler.java | 31 private final TransformingAsyncResponseHandler<ResultT> delegate; field in FilterTransformingAsyncHttpResponseHandler
33 …public FilterTransformingAsyncHttpResponseHandler(TransformingAsyncResponseHandler<ResultT> delega… in FilterTransformingAsyncHttpResponseHandler()
43 public void onHeaders(SdkHttpResponse headers) { in onHeaders()
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/protocols/aws-xml-protocol/src/test/java/software/amazon/awssdk/protocols/xml/internal/unmarshall/ |
| H A D | AwsXmlResponseHandlerTest.java | 40 HttpResponseHandler<FakeResponse> delegate = Mockito.mock(HttpResponseHandler.class); in handleResponse_awsResponse_shouldAddResponseMetadata() local
55 HttpResponseHandler<SdkPojo> delegate = Mockito.mock(HttpResponseHandler.class); in handleResponse_nonAwsResponse_shouldReturnDirectly() local
125 public Map<String, List<String>> headers() { in headers() method in AwsXmlResponseHandlerTest.TestSdkHttpFullResponse
|
| /aosp_15_r20/external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/ |
| H A D | FaultFilter.java | 197 Metadata headers = args.getHeaders(); in buildClientInterceptor() local
241 protected ClientCall<ReqT, RespT> delegate() { in buildClientInterceptor() method in FaultFilter.FaultInjectionInterceptor.DeadlineInsightForwardingCall
246 public void start(Listener<RespT> listener, Metadata headers) { in buildClientInterceptor()
300 private Long determineFaultDelayNanos(FaultDelay faultDelay, Metadata headers) { in determineFaultDelayNanos()
328 private Status determineFaultAbortStatus(FaultAbort faultAbort, Metadata headers) { in determineFaultAbortStatus()
449 public void start(final ClientCall.Listener<RespT> listener, Metadata headers) { in start()
|