Home
last modified time | relevance | path

Searched refs:ServerCall (Results 1 – 25 of 41) sorted by relevance

12

/external/grpc-grpc-java/core/src/test/java/io/grpc/
DServerInterceptorsTest.java33 import io.grpc.ServerCall.Listener;
62 private ServerCall.Listener<String> listener;
66 private ServerCall<String, Integer> call = new NoopServerCall<String, Integer>();
84 Mockito.<ServerCall<String, Integer>>any(), Mockito.<Metadata>any())) in setUp()
168 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in callNextTwice()
169 ServerCall<ReqT, RespT> call, in callNextTwice()
190 public ServerCall.Listener<String> startCall( in ordered()
191 ServerCall<String, Integer> call, in ordered()
199 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in ordered()
200 ServerCall<ReqT, RespT> call, in ordered()
[all …]
DContextsTest.java51 private ServerCall<Object, Object> call = new NoopServerCall<Object, Object>();
59 final ServerCall.Listener<Object> listener = new ServerCall.Listener<Object>() { in interceptCall_basic()
86 ServerCall.Listener<Object> wrapped = interceptCall(uniqueContext, call, headers, in interceptCall_basic()
89 public ServerCall.Listener<Object> startCall( in interceptCall_basic()
90 ServerCall<Object, Object> call, Metadata headers) { in interceptCall_basic()
114 public ServerCall.Listener<Object> startCall( in interceptCall_restoresIfNextThrows()
115 ServerCall<Object, Object> call, Metadata headers) { in interceptCall_restoresIfNextThrows()
128 final ServerCall.Listener<Object> listener = new ServerCall.Listener<Object>() { in interceptCall_restoresIfListenerThrows()
149 ServerCall.Listener<Object> wrapped = interceptCall(uniqueContext, call, headers, in interceptCall_restoresIfListenerThrows()
152 public ServerCall.Listener<Object> startCall( in interceptCall_restoresIfListenerThrows()
[all …]
DForwardingServerCallListenerTest.java37 @Mock private ServerCall.Listener<Integer> serverCallListener;
49 ServerCall.Listener.class, serverCallListener, forwarder, Collections.<Method>emptyList()); in allMethodsForwarded()
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DServerCalls.java26 import io.grpc.ServerCall;
115 public ServerCall.Listener<ReqT> startCall(ServerCall<ReqT, RespT> call, Metadata headers) { in startCall()
128 private final class UnaryServerCallListener extends ServerCall.Listener<ReqT> {
129 private final ServerCall<ReqT, RespT> call;
137 ServerCall<ReqT, RespT> call) { in UnaryServerCallListener()
218 public ServerCall.Listener<ReqT> startCall(ServerCall<ReqT, RespT> call, Metadata headers) { in startCall()
229 private final class StreamingServerCallListener extends ServerCall.Listener<ReqT> {
233 private final ServerCall<ReqT, RespT> call;
240 ServerCall<ReqT, RespT> call) { in StreamingServerCallListener()
305 final ServerCall<ReqT, RespT> call;
[all …]
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DBinaryLogProviderTest.java38 import io.grpc.ServerCall;
39 import io.grpc.ServerCall.Listener;
216 ServerCall<String, Integer> call, Metadata headers) { in wrapMethodDefinition_methodDescriptor()
228 final AtomicReference<ServerCall<String, Integer>> serverCall = in wrapMethodDefinition_handler()
229 new AtomicReference<ServerCall<String, Integer>>(); in wrapMethodDefinition_handler()
235 public ServerCall.Listener<String> startCall( in wrapMethodDefinition_handler()
236 ServerCall<String, Integer> call, Metadata headers) { in wrapMethodDefinition_handler()
238 return new ServerCall.Listener<String>() { in wrapMethodDefinition_handler()
248 ServerCall.Listener<?> wListener = startServerCallHelper(wDef, serializedResp); in wrapMethodDefinition_handler()
283 private static void onServerMessageHelper(ServerCall.Listener listener, Object request) { in onServerMessageHelper()
[all …]
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DUtilServerInterceptorsTest.java24 import io.grpc.ServerCall;
45 private static class VoidCallListener extends ServerCall.Listener<Void> {
46 public void onCall(ServerCall<Void, Void> call, Metadata headers) { } in onCall()
53 public ServerCall.Listener<Void> startCall(
54 ServerCall<Void, Void> call, Metadata headers) {
148 ServerCall.Listener<Void> callDoubleSreListener = in statusRuntimeExceptionTransmitterIgnoresClosedCalls()
156 public void onCall(ServerCall<Void, Void> call, Metadata headers) { in statusRuntimeExceptionTransmitterIgnoresClosedCalls()
166 ServerCall.Listener<Void> callClosedListener = in statusRuntimeExceptionTransmitterIgnoresClosedCalls()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DForwardingServerCallListener.java29 protected abstract ServerCall.Listener<ReqT> delegate(); in delegate()
43 private final ServerCall.Listener<ReqT> delegate;
45 protected SimpleForwardingServerCallListener(ServerCall.Listener<ReqT> delegate) { in SimpleForwardingServerCallListener()
50 protected ServerCall.Listener<ReqT> delegate() { in delegate()
DForwardingServerCall.java28 protected abstract ServerCall<ReqT, RespT> delegate(); in delegate()
42 private final ServerCall<ReqT, RespT> delegate;
44 protected SimpleForwardingServerCall(ServerCall<ReqT, RespT> delegate) { in SimpleForwardingServerCall()
49 protected ServerCall<ReqT, RespT> delegate() { in delegate()
DServerInterceptors.java226 public ServerCall.Listener<ReqT> startCall( in startCall()
227 ServerCall<ReqT, RespT> call, in startCall()
249 public ServerCall.Listener<WReqT> startCall( in wrapHandler()
250 final ServerCall<WReqT, WRespT> call, in wrapHandler()
252 final ServerCall<OReqT, ORespT> unwrappedCall = in wrapHandler()
255 protected ServerCall<WReqT, WRespT> delegate() { in wrapHandler()
272 final ServerCall.Listener<OReqT> originalListener = originalHandler in wrapHandler()
277 protected ServerCall.Listener<OReqT> delegate() { in wrapHandler()
DContexts.java44 public static <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in interceptCall()
46 ServerCall<ReqT, RespT> call, in interceptCall()
67 public ContextualizedServerCallListener(ServerCall.Listener<ReqT> delegate, Context context) { in ContextualizedServerCallListener()
DServerCallHandler.java41 ServerCall.Listener<RequestT> startCall( in startCall()
42 ServerCall<RequestT, ResponseT> call, in startCall()
DServerInterceptor.java50 <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in interceptCall()
51 ServerCall<ReqT, RespT> call, in interceptCall()
DPartialForwardingServerCallListener.java27 extends ServerCall.Listener<ReqT> {
31 protected abstract ServerCall.Listener<?> delegate(); in delegate()
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DTransmitStatusRuntimeExceptionInterceptor.java26 import io.grpc.ServerCall;
57 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in interceptCall()
58 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) { in interceptCall()
59 final ServerCall<ReqT, RespT> serverCall = new SerializingServerCall<ReqT, RespT>(call); in interceptCall()
60 ServerCall.Listener<ReqT> listener = next.startCall(serverCall, headers); in interceptCall()
128 SerializingServerCall(ServerCall<ReqT, RespT> delegate) {
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServerImplTest.java66 import io.grpc.ServerCall;
67 import io.grpc.ServerCall.Listener;
191 private ServerCall.Listener<String> callListener;
468 final AtomicReference<ServerCall<String, Integer>> callReference in basicExchangeHelper()
469 = new AtomicReference<ServerCall<String, Integer>>(); in basicExchangeHelper()
477 public ServerCall.Listener<String> startCall( in basicExchangeHelper()
478 ServerCall<String, Integer> call, in basicExchangeHelper()
507 ServerCall<String, Integer> call = callReference.get(); in basicExchangeHelper()
648 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in interceptors()
649 ServerCall<ReqT, RespT> call, in interceptors()
[all …]
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DServerCallsTest.java31 import io.grpc.ServerCall;
116 ServerCall.Listener<Integer> callListener = in runtimeStreamObserverIsServerCallStreamObserver()
150 ServerCall.Listener<Integer> callListener = in cannotSetOnCancelHandlerAfterServiceInvocation()
178 ServerCall.Listener<Integer> callListener = in cannotSetOnReadyHandlerAfterServiceInvocation()
206 ServerCall.Listener<Integer> callListener = in cannotDisableAutoFlowControlAfterServiceInvocation()
230 ServerCall.Listener<Integer> callListener = in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
276 ServerCall.Listener<Integer> callListener = 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/testing/src/main/java/io/grpc/internal/
DNoopServerCall.java21 import io.grpc.ServerCall;
29 public class NoopServerCall<ReqT, RespT> extends ServerCall<ReqT, RespT> {
36 public static class NoopServerCallListener<T> extends ServerCall.Listener<T> {
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/
DAbstractBenchmark.java26 import io.grpc.ServerCall;
267 public ServerCall.Listener<ByteBuf> startCall( in setup()
268 final ServerCall<ByteBuf, ByteBuf> call, in setup()
272 return new ServerCall.Listener<ByteBuf>() { in setup()
298 public ServerCall.Listener<ByteBuf> startCall( in setup()
299 final ServerCall<ByteBuf, ByteBuf> call, in setup()
303 return new ServerCall.Listener<ByteBuf>() { in setup()
331 public ServerCall.Listener<ByteBuf> startCall( in setup()
332 final ServerCall<ByteBuf, ByteBuf> call, in setup()
336 return new ServerCall.Listener<ByteBuf>() { in setup()
DHandlerRegistryBenchmark.java21 import io.grpc.ServerCall;
22 import io.grpc.ServerCall.Listener;
83 public Listener<Void> startCall(ServerCall<Void, Void> call, in setup()
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/header/
DHeaderClientInterceptorTest.java28 import io.grpc.ServerCall;
29 import io.grpc.ServerCall.Listener;
70 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) {
98 Matchers.<ServerCall<HelloRequest, HelloReply>>any(), in clientHeaderDeliveredToServer()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/
DHeaderServerInterceptor.java22 import io.grpc.ServerCall;
40 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in interceptCall()
41 ServerCall<ReqT, RespT> call, in interceptCall()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DServerCallImpl.java37 import io.grpc.ServerCall;
43 final class ServerCallImpl<ReqT, RespT> extends ServerCall<ReqT, RespT> {
192 ServerStreamListener newServerStreamListener(ServerCall.Listener<ReqT> listener) { in newServerStreamListener()
229 private final ServerCall.Listener<ReqT> listener;
233 ServerCallImpl<ReqT, ?> call, ServerCall.Listener<ReqT> listener, in ServerStreamListenerImpl()
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestServiceImpl.java24 import io.grpc.ServerCall;
511 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
512 ServerCall<ReqT, RespT> call,
539 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
540 ServerCall<ReqT, RespT> call,
566 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
567 ServerCall<ReqT, RespT> call,
/external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/
DTestUtils.java21 import io.grpc.ServerCall;
56 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in recordRequestHeadersInterceptor()
57 ServerCall<ReqT, RespT> call, in recordRequestHeadersInterceptor()
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
DLoadServer.java28 import io.grpc.ServerCall;
200 public ServerCall.Listener<ByteBuf> startCall( in startCall()
201 final ServerCall<ByteBuf, ByteBuf> call, Metadata headers) { in startCall()
204 return new ServerCall.Listener<ByteBuf>() { in startCall()

12