| /external/grpc-grpc-java/api/src/main/java/io/grpc/ |
| D | ServerServiceDefinition.java | 42 private final Map<String, ServerMethodDefinition<?, ?>> methods;
45 ServiceDescriptor serviceDescriptor, Map<String, ServerMethodDefinition<?, ?>> methods) { in ServerServiceDefinition() argument
60 public Collection<ServerMethodDefinition<?, ?>> getMethods() { in getMethods()
70 public ServerMethodDefinition<?, ?> getMethod(String methodName) { in getMethod()
80 private final Map<String, ServerMethodDefinition<?, ?>> methods = new HashMap<>();
100 return addMethod(ServerMethodDefinition.create( in addMethod()
106 public <ReqT, RespT> Builder addMethod(ServerMethodDefinition<ReqT, RespT> def) { in addMethod()
127 for (ServerMethodDefinition<?, ?> serverMethod : methods.values()) { in build()
132 Map<String, ServerMethodDefinition<?, ?>> tmpMethods = new HashMap<>(methods); in build()
134 ServerMethodDefinition<?, ?> removed = tmpMethods.remove( in build()
|
| D | ServerMethodDefinition.java | 24 public final class ServerMethodDefinition<ReqT, RespT> { class
28 private ServerMethodDefinition(MethodDescriptor<ReqT, RespT> method, in ServerMethodDefinition() method in ServerMethodDefinition
41 public static <ReqT, RespT> ServerMethodDefinition<ReqT, RespT> create( in create()
44 return new ServerMethodDefinition<>(method, handler); in create()
63 public ServerMethodDefinition<ReqT, RespT> withServerCallHandler( in withServerCallHandler()
65 return new ServerMethodDefinition<>(method, handler); in withServerCallHandler()
|
| D | ServerInterceptors.java | 113 for (ServerMethodDefinition<?, ?> method : serviceDef.getMethods()) { in intercept()
212 List<ServerMethodDefinition<?, ?>> wrappedMethods = in useMarshalledMessages()
217 for (final ServerMethodDefinition<?, ?> definition : serviceDef.getMethods()) { in useMarshalledMessages()
234 for (ServerMethodDefinition<?, ?> definition : wrappedMethods) { in useMarshalledMessages()
241 ServerServiceDefinition.Builder serviceDefBuilder, ServerMethodDefinition<ReqT, RespT> method, in wrapAndAddMethod()
273 static <OReqT, ORespT, WReqT, WRespT> ServerMethodDefinition<WReqT, WRespT> wrapMethod( in wrapMethod()
274 final ServerMethodDefinition<OReqT, ORespT> definition, in wrapMethod()
280 return ServerMethodDefinition.create(wrappedMethod, wrappedHandler); in wrapMethod()
|
| D | BinaryLog.java | 28 public abstract <ReqT, RespT> ServerMethodDefinition<?, ?> wrapMethodDefinition( in wrapMethodDefinition()
29 ServerMethodDefinition<ReqT, RespT> oMethodDef); in wrapMethodDefinition()
|
| D | HandlerRegistry.java | 48 public abstract ServerMethodDefinition<?, ?> lookupMethod( in lookupMethod()
58 public final ServerMethodDefinition<?, ?> lookupMethod(String methodName) { in lookupMethod()
|
| D | InternalServerInterceptors.java | 25 ServerMethodDefinition<WrapReqT, WrapRespT> wrapMethod( in wrapMethod()
26 final ServerMethodDefinition<OrigReqT, OrigRespT> definition, in wrapMethod()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | InternalHandlerRegistry.java | 20 import io.grpc.ServerMethodDefinition;
33 private final Map<String, ServerMethodDefinition<?, ?>> methods;
36 List<ServerServiceDefinition> services, Map<String, ServerMethodDefinition<?, ?>> methods) { in InternalHandlerRegistry() argument
51 public ServerMethodDefinition<?, ?> lookupMethod(String methodName, @Nullable String authority) { in lookupMethod()
68 Map<String, ServerMethodDefinition<?, ?>> map = in build()
71 for (ServerMethodDefinition<?, ?> method : service.getMethods()) { in build()
|
| D | ServerImpl.java | 54 import io.grpc.ServerMethodDefinition;
534 ServerMethodDefinition<?, ?> wrapMethod; in streamCreatedInternal()
537 ServerMethodDefinition<?, ?> method = registry.lookupMethod(methodName); in streamCreatedInternal()
568 final ServerMethodDefinition<ReqT, RespT> methodDef, in streamCreatedInternal()
667 private <ReqT, RespT> ServerMethodDefinition<?,?> wrapMethod(ServerStream stream, in wrapMethod()
668 ServerMethodDefinition<ReqT, RespT> methodDef, StatsTraceContext statsTraceCtx) { in wrapMethod()
679 ServerMethodDefinition<ReqT, RespT> interceptedDef = methodDef.withServerCallHandler(handler); in wrapMethod()
680 ServerMethodDefinition<?, ?> wMethodDef = binlog == null in wrapMethod()
|
| D | ServerImplBuilder.java | 38 import io.grpc.ServerMethodDefinition;
332 public ServerMethodDefinition<?, ?> lookupMethod( in lookupMethod()
|
| /external/dagger2/java/dagger/grpc/server/ |
| D | ProxyServerCallHandler.java | 25 import io.grpc.ServerMethodDefinition;
60 public static <RequestT, ResponseT> ServerMethodDefinition<InputStream, InputStream> proxyMethod( in proxyMethod()
63 return ServerMethodDefinition.create( in proxyMethod()
83 ServerMethodDefinition<RequestT, ResponseT> delegateMethod = getMethodDefinition(headers); in startCall()
92 private ServerMethodDefinition<RequestT, ResponseT> getMethodDefinition(Metadata headers) { in getMethodDefinition()
94 for (ServerMethodDefinition<?, ?> methodDefinition : in getMethodDefinition()
97 return (ServerMethodDefinition<RequestT, ResponseT>) methodDefinition; in getMethodDefinition()
|
| /external/grpc-grpc-java/api/src/test/java/io/grpc/ |
| D | ServerServiceDefinitionTest.java | 51 private ServerMethodDefinition<String, Integer> methodDef1
52 = ServerMethodDefinition.create(method1, methodHandler1);
53 private ServerMethodDefinition<String, Integer> methodDef2
54 = ServerMethodDefinition.create(method2, methodHandler2);
77 for (ServerMethodDefinition<?, ?> serverMethod : ssd.getMethods()) { in addMethod_twoArg()
139 HashSet<ServerMethodDefinition<?, ?>> goldenMethodDefs in builderWithServiceName()
152 assertEquals(Collections.<ServerMethodDefinition<?, ?>>emptySet(), in builderWithServiceName_noMethods()
|
| D | ServerInterceptorsTest.java | 415 ServerMethodDefinition<InputStream, InputStream> serverMethod = in typedMarshalledMessages()
416 (ServerMethodDefinition<InputStream, InputStream>) intercepted2.getMethod("basic/wrapped"); in typedMarshalledMessages()
494 ServerMethodDefinition<String, String> serverMethod = in distinctMarshallerForRequestAndResponse()
495 (ServerMethodDefinition<String, String>) intercepted.getMethod("basic/wrapped"); in distinctMarshallerForRequestAndResponse()
503 private static ServerMethodDefinition<String, Integer> getSoleMethod( in getSoleMethod()
508 return (ServerMethodDefinition<String, Integer>) getOnlyElement(serviceDef.getMethods()); in getSoleMethod()
512 private static ServerMethodDefinition<String, Integer> getMethod( in getMethod()
514 return (ServerMethodDefinition<String, Integer>) serviceDef.getMethod(name); in getMethod()
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/protobuf/services/ |
| D | BinaryLogProvider.java | 35 import io.grpc.ServerMethodDefinition;
68 public final <ReqT, RespT> ServerMethodDefinition<?, ?> wrapMethodDefinition( in wrapMethodDefinition()
69 ServerMethodDefinition<ReqT, RespT> oMethodDef) { in wrapMethodDefinition()
77 ServerMethodDefinition<byte[], byte[]> binDef = in wrapMethodDefinition()
82 return ServerMethodDefinition.create(binMethod, binlogHandler); in wrapMethodDefinition()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | MutableHandlerRegistryTest.java | 31 import io.grpc.ServerMethodDefinition;
71 private ServerMethodDefinition flowMethodDefinition;
112 ServerMethodDefinition<?, ?> method = registry.lookupMethod("basic/flow"); in simpleLookup()
133 ServerMethodDefinition<?, ?> method = registry.lookupMethod("basic/flow"); in simpleLookupWithBindable()
173 ServerMethodDefinition<?, ?> anotherMethodDefinition = in replaceAndLookup()
178 ServerMethodDefinition<?, ?> method = registry.lookupMethod("basic/another"); in replaceAndLookup()
|
| D | UtilServerInterceptorsTest.java | 27 import io.grpc.ServerMethodDefinition;
66 private static ServerMethodDefinition<Void, Void> getSoleMethod( in getSoleMethod()
71 return (ServerMethodDefinition<Void, Void>) getOnlyElement(serviceDef.getMethods()); in getSoleMethod()
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/ |
| D | BinaryLogProviderTest.java | 41 import io.grpc.ServerMethodDefinition;
208 ServerMethodDefinition<String, Integer> methodDef = in wrapMethodDefinition_methodDescriptor()
209 ServerMethodDefinition.create( in wrapMethodDefinition_methodDescriptor()
218 ServerMethodDefinition<?, ?> wMethodDef = binlogProvider.wrapMethodDefinition(methodDef); in wrapMethodDefinition_methodDescriptor()
228 ServerMethodDefinition<String, Integer> methodDef = in wrapMethodDefinition_handler()
229 ServerMethodDefinition.create( in wrapMethodDefinition_handler()
244 ServerMethodDefinition<?, ?> wDef = binlogProvider.wrapMethodDefinition(methodDef); in wrapMethodDefinition_handler()
286 final ServerMethodDefinition<ReqT, RespT> methodDef, in startServerCallHelper()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | MutableHandlerRegistry.java | 23 import io.grpc.ServerMethodDefinition;
90 public ServerMethodDefinition<?, ?> lookupMethod(String methodName, @Nullable String authority) { in lookupMethod()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/grpcproxy/ |
| D | GrpcProxy.java | 33 import io.grpc.ServerMethodDefinition;
199 public ServerMethodDefinition<?,?> lookupMethod(String methodName, String authority) { in lookupMethod()
205 return ServerMethodDefinition.create(methodDescriptor, handler); in lookupMethod()
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | RetryTest.java | 44 import io.grpc.ServerMethodDefinition;
151 private final ServerMethodDefinition<String, Integer> methodDefinition =
152 ServerMethodDefinition.create(
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ServerImplTest.java | 71 import io.grpc.ServerMethodDefinition;
176 public ServerMethodDefinition<?, ?> lookupMethod(
1479 public <ReqT, RespT> ServerMethodDefinition<?, ?> wrapMethodDefinition( in binaryLogInstalled()
1480 ServerMethodDefinition<ReqT, RespT> oMethodDef) { in binaryLogInstalled()
1481 return ServerMethodDefinition.create( in binaryLogInstalled()
|
| D | ManagedChannelImplTest.java | 109 import io.grpc.ServerMethodDefinition;
3434 public <ReqT, RespT> ServerMethodDefinition<?, ?> wrapMethodDefinition( in binaryLogInstalled()
3435 ServerMethodDefinition<ReqT, RespT> oMethodDef) { in binaryLogInstalled()
|