| /external/grpc-grpc-java/core/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
48 Collections.unmodifiableMap(new HashMap<String, ServerMethodDefinition<?, ?>>(methods)); in ServerServiceDefinition()
61 public Collection<ServerMethodDefinition<?, ?>> getMethods() { in getMethods()
71 public ServerMethodDefinition<?, ?> getMethod(String methodName) { in getMethod()
81 private final Map<String, ServerMethodDefinition<?, ?>> methods =
82 new HashMap<String, ServerMethodDefinition<?, ?>>();
102 return addMethod(ServerMethodDefinition.create( in addMethod()
108 public <ReqT, RespT> Builder addMethod(ServerMethodDefinition<ReqT, RespT> def) { in addMethod()
129 for (ServerMethodDefinition<?, ?> serverMethod : methods.values()) { in build()
[all …]
|
| 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<ReqT, RespT>(method, handler); in create()
63 public ServerMethodDefinition<ReqT, RespT> withServerCallHandler( in withServerCallHandler()
65 return new ServerMethodDefinition<ReqT, RespT>(method, handler); in withServerCallHandler()
|
| D | ServerInterceptors.java | 113 for (ServerMethodDefinition<?, ?> method : serviceDef.getMethods()) { in intercept()
177 List<ServerMethodDefinition<?, ?>> wrappedMethods = in useMarshalledMessages()
178 new ArrayList<ServerMethodDefinition<?, ?>>(); in useMarshalledMessages()
182 for (final ServerMethodDefinition<?, ?> definition : serviceDef.getMethods()) { in useMarshalledMessages()
194 for (ServerMethodDefinition<?, ?> definition : wrappedMethods) { in useMarshalledMessages()
201 ServerServiceDefinition.Builder serviceDefBuilder, ServerMethodDefinition<ReqT, RespT> method, in wrapAndAddMethod()
233 static <OReqT, ORespT, WReqT, WRespT> ServerMethodDefinition<WReqT, WRespT> wrapMethod( in wrapMethod()
234 final ServerMethodDefinition<OReqT, ORespT> definition, in wrapMethod()
240 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 | 30 ServerMethodDefinition<WrapReqT, WrapRespT> wrapMethod( in wrapMethod()
31 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()
69 new HashMap<String, ServerMethodDefinition<?, ?>>(); in build()
71 for (ServerMethodDefinition<?, ?> method : service.getMethods()) { in build()
|
| D | ServerImpl.java | 48 import io.grpc.ServerMethodDefinition;
464 ServerMethodDefinition<?, ?> method = registry.lookupMethod(methodName); in streamCreated()
529 ServerMethodDefinition<ReqT, RespT> methodDef, Metadata headers, in startCall()
541 ServerMethodDefinition<ReqT, RespT> interceptedDef = methodDef.withServerCallHandler(handler); in startCall()
542 ServerMethodDefinition<?, ?> wMethodDef = binlog == null in startCall()
549 ServerMethodDefinition<WReqT, WRespT> methodDef, in startWrappedCall()
|
| D | AbstractServerImplBuilder.java | 36 import io.grpc.ServerMethodDefinition;
70 public ServerMethodDefinition<?, ?> lookupMethod(
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | ServerServiceDefinitionTest.java | 50 private ServerMethodDefinition<String, Integer> methodDef1
51 = ServerMethodDefinition.create(method1, methodHandler1);
52 private ServerMethodDefinition<String, Integer> methodDef2
53 = ServerMethodDefinition.create(method2, methodHandler2);
75 for (ServerMethodDefinition<?, ?> serverMethod : ssd.getMethods()) { in addMethod_twoArg()
137 HashSet<ServerMethodDefinition<?, ?>> goldenMethodDefs in builderWithServiceName()
138 = new HashSet<ServerMethodDefinition<?, ?>>(); in builderWithServiceName()
141 assertEquals(goldenMethodDefs, new HashSet<ServerMethodDefinition<?, ?>>(ssd.getMethods())); in builderWithServiceName()
150 assertEquals(Collections.<ServerMethodDefinition<?, ?>>emptySet(), in builderWithServiceName_noMethods()
151 new HashSet<ServerMethodDefinition<?, ?>>(ssd.getMethods())); in builderWithServiceName_noMethods()
|
| D | ServerInterceptorsTest.java | 399 ServerMethodDefinition<InputStream, InputStream> serverMethod = in typedMarshalledMessages()
400 (ServerMethodDefinition<InputStream, InputStream>) intercepted2.getMethod("basic/wrapped"); in typedMarshalledMessages()
413 private static ServerMethodDefinition<String, Integer> getSoleMethod( in getSoleMethod()
418 return (ServerMethodDefinition<String, Integer>) getOnlyElement(serviceDef.getMethods()); in getSoleMethod()
422 private static ServerMethodDefinition<String, Integer> getMethod( in getMethod()
424 return (ServerMethodDefinition<String, Integer>) serviceDef.getMethod(name); in getMethod()
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/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;
70 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/services/ |
| D | BinaryLogProviderTest.java | 42 import io.grpc.ServerMethodDefinition;
210 ServerMethodDefinition<String, Integer> methodDef = in wrapMethodDefinition_methodDescriptor()
211 ServerMethodDefinition.create( in wrapMethodDefinition_methodDescriptor()
220 ServerMethodDefinition<?, ?> wMethodDef = binlogProvider.wrapMethodDefinition(methodDef); in wrapMethodDefinition_methodDescriptor()
230 ServerMethodDefinition<String, Integer> methodDef = in wrapMethodDefinition_handler()
231 ServerMethodDefinition.create( in wrapMethodDefinition_handler()
246 ServerMethodDefinition<?, ?> wDef = binlogProvider.wrapMethodDefinition(methodDef); in wrapMethodDefinition_handler()
288 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/core/src/test/java/io/grpc/internal/ |
| D | ServerImplTest.java | 70 import io.grpc.ServerMethodDefinition;
168 public ServerMethodDefinition<?, ?> lookupMethod(
1260 public <ReqT, RespT> ServerMethodDefinition<?, ?> wrapMethodDefinition( in binaryLogInstalled()
1261 ServerMethodDefinition<ReqT, RespT> oMethodDef) { in binaryLogInstalled()
1262 return ServerMethodDefinition.create( in binaryLogInstalled()
|
| D | ManagedChannelImplTest.java | 88 import io.grpc.ServerMethodDefinition;
2572 public <ReqT, RespT> ServerMethodDefinition<?, ?> wrapMethodDefinition( in binaryLogInstalled()
2573 ServerMethodDefinition<ReqT, RespT> oMethodDef) { in binaryLogInstalled()
|