/external/grpc-grpc-java/core/src/main/java/io/grpc/ |
D | MethodDescriptor.java | 43 private final String fullMethodName; field in MethodDescriptor 211 MethodType type, String fullMethodName, in create() argument 215 type, fullMethodName, requestMarshaller, responseMarshaller, null, false, false, false); in create() 220 String fullMethodName, in MethodDescriptor() argument 229 this.fullMethodName = Preconditions.checkNotNull(fullMethodName, "fullMethodName"); in MethodDescriptor() 255 return fullMethodName; in getFullMethodName() 388 public static String extractFullServiceName(String fullMethodName) { in extractFullServiceName() argument 389 int index = checkNotNull(fullMethodName, "fullMethodName").lastIndexOf('/'); in extractFullServiceName() 393 return fullMethodName.substring(0, index); in extractFullServiceName() 441 .setFullMethodName(fullMethodName) in toBuilder() [all …]
|
D | ServerStreamTracer.java | 70 String fullMethodName, Metadata headers); in newServerStreamTracer() argument
|
/external/grpc-grpc-java/examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/ |
D | SafeMethodCachingInterceptor.java | 43 private final String fullMethodName; field in SafeMethodCachingInterceptor.Key 46 public Key(String fullMethodName, MessageLite request) { in Key() argument 47 this.fullMethodName = fullMethodName; in Key() 55 return Objects.equals(this.fullMethodName, other.fullMethodName) in equals() 63 return Objects.hash(fullMethodName, request); in hashCode() 171 final String fullMethodName = method.getFullMethodName(); 268 requestKey = new Key(fullMethodName, (MessageLite) message);
|
/external/dagger2/javatests/dagger/grpc/functional/server/ |
D | VerifyInterceptor.java | 48 final String fullMethodName = in apply() local 53 int calls = coffeeServer.methodCount(fullMethodName); in apply() 55 assertWithMessage("Calls to %s", fullMethodName) in apply() 56 .that(coffeeServer.methodCount(fullMethodName)) in apply()
|
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
D | BinaryLogProviderImpl.java | 69 public ServerInterceptor getServerInterceptor(String fullMethodName) { in getServerInterceptor() argument 70 BinlogHelper helperForMethod = factory.getLog(fullMethodName); in getServerInterceptor() 80 String fullMethodName, CallOptions callOptions) { in getClientInterceptor() argument 81 BinlogHelper helperForMethod = factory.getLog(fullMethodName); in getClientInterceptor()
|
D | BinaryLogProvider.java | 93 protected abstract ServerInterceptor getServerInterceptor(String fullMethodName); in getServerInterceptor() argument 104 String fullMethodName, CallOptions callOptions); in getClientInterceptor() argument
|
D | BinlogHelper.java | 603 BinlogHelper getLog(String fullMethodName); 701 public BinlogHelper getLog(String fullMethodName) { 702 if (blacklistedMethods.contains(fullMethodName)) { 705 BinlogHelper methodLog = perMethodLogs.get(fullMethodName); 710 MethodDescriptor.extractFullServiceName(fullMethodName));
|
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
D | CensusTracingModule.java | 302 ServerTracer(String fullMethodName, @Nullable SpanContext remoteSpan) { in ServerTracer() argument 303 checkNotNull(fullMethodName, "fullMethodName"); in ServerTracer() 307 generateTraceSpanName(true, fullMethodName), in ServerTracer() 366 public ServerStreamTracer newServerStreamTracer(String fullMethodName, Metadata headers) { in newServerStreamTracer() argument 371 return new ServerTracer(fullMethodName, remoteSpan); in newServerStreamTracer() 415 static String generateTraceSpanName(boolean isServer, String fullMethodName) { 417 return prefix + "." + fullMethodName.replace('/', '.');
|
D | CensusStatsModule.java | 135 TagContext parentCtx, String fullMethodName, in newClientCallTracer() argument 138 this, parentCtx, fullMethodName, recordStartedRpcs, recordFinishedRpcs); in newClientCallTracer() 323 String fullMethodName, in ClientCallTracer() argument 330 .put(RpcMeasureConstants.RPC_METHOD, TagValue.create(fullMethodName)).build(); in ClientCallTracer() 630 public ServerStreamTracer newServerStreamTracer(String fullMethodName, Metadata headers) { in newServerStreamTracer() argument 638 .put(RpcMeasureConstants.RPC_METHOD, TagValue.create(fullMethodName)) in newServerStreamTracer()
|
D | StatsTraceContext.java | 67 List<ServerStreamTracer.Factory> factories, String fullMethodName, Metadata headers) { in newServerContext() argument 73 tracers[i] = factories.get(i).newServerStreamTracer(fullMethodName, headers); in newServerContext()
|
D | ServiceConfigInterceptor.java | 111 String fullMethodName = MethodDescriptor.generateFullMethodName(serviceName, methodName); in handleUpdate() local 113 !newServiceMethodConfigs.containsKey(fullMethodName), in handleUpdate() 115 fullMethodName); in handleUpdate() 116 newServiceMethodConfigs.put(fullMethodName, info); in handleUpdate()
|
D | ServerImpl.java | 528 private <ReqT, RespT> ServerStreamListener startCall(ServerStream stream, String fullMethodName, in startCall() argument 544 return startWrappedCall(fullMethodName, wMethodDef, stream, headers, context); in startCall() 548 String fullMethodName, in startWrappedCall() argument 566 "startCall() returned a null listener for method " + fullMethodName); in startWrappedCall()
|
/external/pigweed/pw_rpc/java/main/dev/pigweed/pw_rpc/ |
D | Client.java | 121 public MethodClient method(int channelId, String fullMethodName) { 123 int index = fullMethodName.lastIndexOf(delimiter); 126 channelId, fullMethodName.substring(0, index), fullMethodName.substring(index + 1)); 129 throw new IllegalArgumentException("Invalid method name '" + fullMethodName
|
/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ClassType/ |
D | AbstractNewInstanceTestCase.java | 109 final String fullMethodName = methodName + methodSignature; in checkNewInstanceTag() local 111 assertTrue("Failed to find constructor " + fullMethodName, constructorId != -1); in checkNewInstanceTag() 112 logWriter.println(fullMethodName + " method ID: " + constructorId); in checkNewInstanceTag() 119 .println("Sending ClassType.NewInstance command for constructor " + fullMethodName); in checkNewInstanceTag()
|
/external/dagger2/java/dagger/grpc/server/ |
D | ProxyServerCallHandler.java | 93 String fullMethodName = delegateMethodDescriptor.getFullMethodName(); in getMethodDefinition() local 96 if (methodDefinition.getMethodDescriptor().getFullMethodName().equals(fullMethodName)) { in getMethodDefinition() 100 throw new IllegalStateException("Could not find " + fullMethodName); in getMethodDefinition()
|
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/ |
D | HandlerRegistryBenchmark.java | 99 for (String fullMethodName : fullMethodNames) { in lookupMethod() 100 bh.consume(registry.lookupMethod(fullMethodName)); in lookupMethod()
|
/external/nullaway/nullaway/src/main/java/com/uber/nullaway/ |
D | ErrorBuilder.java | 282 final String fullMethodName = config.getCastToNonNullMethod(); in addCastToNonNullFix() local 283 assert fullMethodName != null; in addCastToNonNullFix() 285 final String[] parts = fullMethodName.split("\\."); in addCastToNonNullFix() 291 .addStaticImport(fullMethodName) // ensure castToNonNull static import in addCastToNonNullFix()
|
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/annotations/ |
D | RpcMethod.java | 46 String fullMethodName(); in fullMethodName() method
|
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/ |
D | TestServiceGrpc.java | 38 fullMethodName = SERVICE_NAME + '/' + "EmptyCall", 70 fullMethodName = SERVICE_NAME + '/' + "UnaryCall", 102 fullMethodName = SERVICE_NAME + '/' + "CacheableUnaryCall", 134 fullMethodName = SERVICE_NAME + '/' + "StreamingOutputCall", 166 fullMethodName = SERVICE_NAME + '/' + "StreamingInputCall", 198 fullMethodName = SERVICE_NAME + '/' + "FullDuplexCall", 230 fullMethodName = SERVICE_NAME + '/' + "HalfDuplexCall", 262 fullMethodName = SERVICE_NAME + '/' + "UnimplementedCall",
|
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/channelz/v1/ |
D | ChannelzGrpc.java | 38 fullMethodName = SERVICE_NAME + '/' + "GetTopChannels", 70 fullMethodName = SERVICE_NAME + '/' + "GetServers", 102 fullMethodName = SERVICE_NAME + '/' + "GetServerSockets", 134 fullMethodName = SERVICE_NAME + '/' + "GetChannel", 166 fullMethodName = SERVICE_NAME + '/' + "GetSubchannel", 198 fullMethodName = SERVICE_NAME + '/' + "GetSocket",
|
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/ |
D | BenchmarkServiceGrpc.java | 34 fullMethodName = SERVICE_NAME + '/' + "UnaryCall", 66 fullMethodName = SERVICE_NAME + '/' + "StreamingCall", 98 fullMethodName = SERVICE_NAME + '/' + "StreamingFromClient", 130 fullMethodName = SERVICE_NAME + '/' + "StreamingFromServer", 162 fullMethodName = SERVICE_NAME + '/' + "StreamingBothWays",
|
D | WorkerServiceGrpc.java | 34 fullMethodName = SERVICE_NAME + '/' + "RunServer", 66 fullMethodName = SERVICE_NAME + '/' + "RunClient", 98 fullMethodName = SERVICE_NAME + '/' + "CoreCount", 130 fullMethodName = SERVICE_NAME + '/' + "QuitWorker",
|
/external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/ |
D | SimpleServiceGrpc.java | 37 fullMethodName = SERVICE_NAME + '/' + "UnaryRpc", 69 fullMethodName = SERVICE_NAME + '/' + "ClientStreamingRpc", 101 fullMethodName = SERVICE_NAME + '/' + "ServerStreamingRpc", 133 fullMethodName = SERVICE_NAME + '/' + "BidiStreamingRpc",
|
/external/testng/src/main/java/org/testng/internal/ |
D | XmlMethodSelector.java | 128 String fullMethodName = methodClass.getName() in includeMethodFromIncludeExclude() local 132 String[] fullyQualifiedMethodName = new String[] { fullMethodName }; in includeMethodFromIncludeExclude()
|
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
D | AbstractServerImplBuilderTest.java | 40 public ServerStreamTracer newServerStreamTracer(String fullMethodName, Metadata headers) {
|