Home
last modified time | relevance | path

Searched defs:serverCall (Results 1 – 15 of 15) sorted by relevance

/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/
DRbacFilterTest.java99 ServerCall<Void,Void> serverCall = mock(ServerCall.class); in ipPortParser() local
126 ServerCall<Void,Void> serverCall = mock(ServerCall.class); in portRangeParser() local
149 ServerCall<Void,Void> serverCall = mock(ServerCall.class); in pathParser() local
176 ServerCall<Void,Void> serverCall = mock(ServerCall.class); in authenticatedParser() local
195 ServerCall<Void,Void> serverCall = mock(ServerCall.class); in headerParser() local
232 ServerCall<Void,Void> serverCall = mock(ServerCall.class); in compositeRules() local
DXdsServerWrapperTest.java915 ServerCall<Void, Void> serverCall = mock(ServerCall.class); in interceptor_success() local
948 ServerCall<Void, Void> serverCall = mock(ServerCall.class); in interceptor_virtualHostNotMatch() local
988 ServerCall<Void, Void> serverCall = mock(ServerCall.class); in interceptor_routeNotMatch() local
1033 ServerCall<Void, Void> serverCall = mock(ServerCall.class); in interceptor_invalidRouteAction() local
1073 ServerCall<Void, Void> serverCall = mock(ServerCall.class); in interceptor_failingRouterConfig() local
1156 ServerCall<Void, Void> serverCall = mock(ServerCall.class); in buildInterceptor_inline() local
1234 ServerCall<Void, Void> serverCall = mock(ServerCall.class); in buildInterceptor_rds() local
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/grpcproxy/
DGrpcProxy.java68 ServerCall<ReqT, RespT> serverCall, Metadata headers) { in startCall()
82 public CallProxy(ServerCall<ReqT, RespT> serverCall, ClientCall<ReqT, RespT> clientCall) { in CallProxy()
132 private final ServerCall<?, RespT> serverCall; field in GrpcProxy.CallProxy.ResponseProxy
136 public ResponseProxy(ServerCall<?, RespT> serverCall) { in ResponseProxy()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DRetryTest.java285 ServerCall<String, Integer> serverCall = serverCalls.poll(5, SECONDS); in retryUntilBufferLimitExceeded() local
326 ServerCall<String, Integer> serverCall = serverCalls.poll(5, SECONDS); in statsRecorded() local
398 ServerCall<String, Integer> serverCall = serverCalls.poll(5, SECONDS); in statsRecorde_callCancelledBeforeCommit() local
456 ServerCall<String, Integer> serverCall = serverCalls.poll(5, SECONDS); in serverCancelledAndClientDeadlineExceeded() local
532 ServerCall<String, Integer> serverCall = serverCalls.poll(5, SECONDS); in transparentRetryStatsRecorded() local
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DServerCallsTest.java83 private final ServerCallRecorder serverCall = new ServerCallRecorder(UNARY_METHOD); field in ServerCallsTest
456 ServerCallRecorder serverCall = new ServerCallRecorder(UNARY_METHOD); in clientSendsOne_errorMissingRequest_unary() local
474 ServerCallRecorder serverCall = new ServerCallRecorder(SERVER_STREAMING_METHOD); in clientSendsOne_errorMissingRequest_serverStreaming() local
493 ServerCallRecorder serverCall = new ServerCallRecorder(UNARY_METHOD); in clientSendsOne_errorTooManyRequests_unary() local
514 ServerCallRecorder serverCall = new ServerCallRecorder(SERVER_STREAMING_METHOD); in clientSendsOne_errorTooManyRequests_serverStreaming() local
/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
DHealthCheckingLoadBalancerFactoryTest.java301 ServerSideCall serverCall = healthImpl.calls.peek(); in typicalWorkflow() local
342 ServerSideCall serverCall = healthImpls[i].calls.peek(); in typicalWorkflow() local
669 ServerSideCall serverCall = healthImpl.calls.poll(); in serviceConfigDisablesHealthCheckWhenRpcActive() local
813 ServerSideCall serverCall = healthImpl.calls.poll(); in serviceConfigChangesServiceNameWhenRpcActive() local
873 ServerSideCall serverCall = healthImpl.calls.poll(); in serviceConfigChangesServiceNameWhenRetryPending() local
DBinaryLogProviderTest.java226 final AtomicReference<ServerCall<String, Integer>> serverCall = in wrapMethodDefinition_handler() local
288 ServerCall<ReqT, RespT> serverCall = new NoopServerCall<ReqT, RespT>() { in startServerCallHelper() local
/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/orca/
DOrcaOobUtilTest.java281 ServerSideCall serverCall = orcaServiceImp.calls.peek(); in singlePolicyTypicalWorkflow() local
300 ServerSideCall serverCall = orcaServiceImps[i].calls.peek(); in singlePolicyTypicalWorkflow() local
368 ServerSideCall serverCall = orcaServiceImp.calls.peek(); in twoLevelPoliciesTypicalWorkflow() local
387 ServerSideCall serverCall = orcaServiceImps[i].calls.peek(); in twoLevelPoliciesTypicalWorkflow() local
417 ServerSideCall serverCall = orcaServiceImp.calls.poll(); in orcReportingDisabledWhenServiceNotImplemented() local
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServerCallImplTest.java238 ServerCallImpl<Long, Long> serverCall = new ServerCallImpl<>( in sendMessage_serverSendsOne_closeOnSecondCall() local
273 ServerCallImpl<Long, Long> serverCall = new ServerCallImpl<>( in sendMessage_serverSendsOne_closeOnSecondCall_appRunToCompletion() local
311 ServerCallImpl<Long, Long> serverCall = new ServerCallImpl<>( in serverSendsOne_okFailsOnMissingResponse() local
/external/grpc-grpc-java/api/src/test/java/io/grpc/
DForwardingServerCallTest.java40 @Mock private ServerCall<Integer, Integer> serverCall; field in ForwardingServerCallTest
DServerInterceptorsTest.java496 ServerCall<String, String> serverCall = new NoopServerCall<>(); in distinctMarshallerForRequestAndResponse() local
/external/grpc-grpc-java/examples/example-jwt-auth/src/main/java/io/grpc/examples/jwtauth/
DJwtServerInterceptor.java43 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> serverCall, in interceptCall()
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DTransmitStatusRuntimeExceptionInterceptor.java59 final ServerCall<ReqT, RespT> serverCall = new SerializingServerCall<>(call); in interceptCall() local
/external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/internal/rbac/engine/
DGrpcAuthorizationEngine.java66 public AuthDecision evaluate(Metadata metadata, ServerCall<?,?> serverCall) { in evaluate()
282 private final ServerCall<?,?> serverCall; field in GrpcAuthorizationEngine.EvaluateArgs
287 private EvaluateArgs(Metadata metadata, ServerCall<?,?> serverCall) { in EvaluateArgs()
/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/internal/rbac/engine/
DGrpcAuthorizationEngineTest.java86 private ServerCall<Void,Void> serverCall; field in GrpcAuthorizationEngineTest