| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | ServerInterceptorsTest.java | 83 Mockito.when(handler.startCall( in setUp()
128 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers)); in multipleInvocationsOfHandler()
130 verify(handler).startCall(call, headers); in multipleInvocationsOfHandler()
134 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers)); in multipleInvocationsOfHandler()
137 verify(handler, times(2)).startCall(call, headers); in multipleInvocationsOfHandler()
153 getMethod(intercepted, "basic/flow").getServerCallHandler().startCall(call, headers); in correctHandlerCalled()
154 verify(handler).startCall(call, headers); in correctHandlerCalled()
158 getMethod(intercepted, "basic/flow2").getServerCallHandler().startCall(call, headers); in correctHandlerCalled()
159 verify(handler2).startCall(call, headers); in correctHandlerCalled()
173 assertSame(listener, next.startCall(call, headers)); in callNextTwice()
[all …]
|
| D | ContextsTest.java | 89 public ServerCall.Listener<Object> startCall( in interceptCall_basic()
114 public ServerCall.Listener<Object> startCall( in interceptCall_restoresIfNextThrows()
152 public ServerCall.Listener<Object> startCall( in interceptCall_restoresIfListenerThrows()
|
| D | ServerServiceDefinitionTest.java | 157 public ServerCall.Listener<ReqT> startCall(ServerCall<ReqT, RespT> call, Metadata headers) { in startCall() method in ServerServiceDefinitionTest.NoopServerCallHandler
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | UtilServerInterceptorsTest.java | 53 public ServerCall.Listener<Void> startCall(
114 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers).onMessage(null); in statusRuntimeExceptionTransmitter()
115 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers).onCancel(); in statusRuntimeExceptionTransmitter()
116 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers).onComplete(); in statusRuntimeExceptionTransmitter()
117 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers).onHalfClose(); in statusRuntimeExceptionTransmitter()
118 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers).onReady(); in statusRuntimeExceptionTransmitter()
149 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers); in statusRuntimeExceptionTransmitterIgnoresClosedCalls()
167 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers); in statusRuntimeExceptionTransmitterIgnoresClosedCalls()
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ServerCallsTest.java | 117 callHandler.startCall(serverCall, new Metadata()); in runtimeStreamObserverIsServerCallStreamObserver()
151 callHandler.startCall(serverCall, new Metadata()); in cannotSetOnCancelHandlerAfterServiceInvocation()
179 callHandler.startCall(serverCall, new Metadata()); in cannotSetOnReadyHandlerAfterServiceInvocation()
207 callHandler.startCall(serverCall, new Metadata()); in cannotDisableAutoFlowControlAfterServiceInvocation()
231 callHandler.startCall(serverCall, new Metadata()); in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
252 callHandler.startCall(serverCall, new Metadata()); in disablingInboundAutoFlowControlForUnaryHasNoEffect()
277 callHandler.startCall(serverCall, new Metadata()); in onReadyHandlerCalledForUnaryRequest()
305 ServerCall.Listener<Integer> listener = callHandler.startCall(serverCall, new Metadata()); in clientSendsOne_errorMissingRequest_unary()
323 ServerCall.Listener<Integer> listener = callHandler.startCall(serverCall, new Metadata()); in clientSendsOne_errorMissingRequest_serverStreaming()
342 ServerCall.Listener<Integer> listener = callHandler.startCall(serverCall, new Metadata()); in clientSendsOne_errorTooManyRequests_unary()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | ServerInterceptors.java | 226 public ServerCall.Listener<ReqT> startCall( in startCall() method in ServerInterceptors.InterceptCallHandler
249 public ServerCall.Listener<WReqT> startCall( in wrapHandler()
273 .startCall(unwrappedCall, headers); in wrapHandler()
|
| D | ServerCallHandler.java | 41 ServerCall.Listener<RequestT> startCall( in startCall() method
|
| D | Contexts.java | 52 next.startCall(call, headers), in interceptCall()
|
| /external/dagger2/java/dagger/grpc/server/ |
| D | ProxyServerCallHandler.java | 80 public Listener<InputStream> startCall( in startCall() method in ProxyServerCallHandler
87 .startCall(new ServerCallAdapter(call, delegateMethod.getMethodDescriptor()), headers); in startCall()
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | BinaryLogProviderTest.java | 215 public Listener<String> startCall( in wrapMethodDefinition_methodDescriptor()
235 public ServerCall.Listener<String> startCall( in wrapMethodDefinition_handler()
301 return methodDef.getServerCallHandler().startCall(serverCall, new Metadata()); in startServerCallHelper()
368 final ServerCall.Listener<ReqT> oListener = next.startCall(wCall, headers);
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/ |
| D | HeaderServerInterceptor.java | 45 return next.startCall(new SimpleForwardingServerCall<ReqT, RespT>(call) { in interceptCall()
|
| /external/dagger2/javatests/dagger/grpc/functional/server/ |
| D | CountingInterceptor.java | 49 return next.startCall(call, headers); in interceptCall()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ServerImplTest.java | 477 public ServerCall.Listener<String> startCall( in basicExchangeHelper()
656 return next.startCall(call, headers); in interceptors()
672 return next.startCall(call, headers); in interceptors()
680 public ServerCall.Listener<String> startCall( in interceptors()
735 public ServerCall.Listener<String> startCall( in exceptionInStartCallPropagatesToStream()
857 public ServerCall.Listener<String> startCall( in testCallContextIsBoundInListenerCallbacks()
962 public ServerCall.Listener<String> startCall( in testClientClose_setup()
1086 verify(callHandler).startCall(Matchers.<ServerCall<String, Integer>>anyObject(), in handlerRegistryPriorities()
1249 return next.startCall(call, headers); in binaryLogInstalled()
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceImpl.java | 515 return next.startCall(new SimpleForwardingServerCall<ReqT, RespT>(call) {
543 return next.startCall(new SimpleForwardingServerCall<ReqT, RespT>(call) {
570 return next.startCall(new SimpleForwardingServerCall<ReqT, RespT>(call) {
|
| /external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/ |
| D | AbstractBenchmark.java | 267 public ServerCall.Listener<ByteBuf> startCall( in setup()
298 public ServerCall.Listener<ByteBuf> startCall( in setup()
331 public ServerCall.Listener<ByteBuf> startCall( in setup()
|
| D | HandlerRegistryBenchmark.java | 83 public Listener<Void> startCall(ServerCall<Void, Void> call, in setup()
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | ServerCalls.java | 115 public ServerCall.Listener<ReqT> startCall(ServerCall<ReqT, RespT> call, Metadata headers) { in startCall() method in ServerCalls.UnaryServerCallHandler
218 public ServerCall.Listener<ReqT> startCall(ServerCall<ReqT, RespT> call, Metadata headers) { in startCall() method in ServerCalls.StreamingServerCallHandler
|
| D | ClientCalls.java | 280 startCall(call, responseListener, streamingResponse); in asyncUnaryRequestCall()
296 startCall( in asyncStreamingRequestCall()
304 private static <ReqT, RespT> void startCall( in startCall() method in ClientCalls
|
| /external/lzma/C/ |
| D | MtDec.h | 70 int startCall; member
|
| /external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/header/ |
| D | HeaderClientInterceptorTest.java | 71 return next.startCall(call, headers);
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
| D | TestUtils.java | 61 return next.startCall(call, requestHeaders); in recordRequestHeadersInterceptor()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ServerImpl.java | 480 listener = startCall(stream, methodName, method, headers, context, statsTraceCtx); in streamCreated()
528 private <ReqT, RespT> ServerStreamListener startCall(ServerStream stream, String fullMethodName, in startCall() method in ServerImpl.ServerTransportListenerImpl
563 methodDef.getServerCallHandler().startCall(call, headers); in startWrappedCall()
|
| /external/webrtc/examples/androidapp/src/org/appspot/apprtc/ |
| D | CallActivity.java | 383 startCall(); in onCreate()
420 startCall(); in onActivityResult()
570 private void startCall() {
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | TransmitStatusRuntimeExceptionInterceptor.java | 60 ServerCall.Listener<ReqT> listener = next.startCall(serverCall, headers); in interceptCall()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadServer.java | 200 public ServerCall.Listener<ByteBuf> startCall( in startCall() method in GenericServiceCallHandler
|