Home
last modified time | relevance | path

Searched refs:RpcMethod (Results 1 – 25 of 48) sorted by relevance

12

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_master_service_impl.cc55 ::grpc::internal::RpcMethod::NORMAL_RPC, in Stub()
58 ::grpc::internal::RpcMethod::NORMAL_RPC, in Stub()
61 ::grpc::internal::RpcMethod::NORMAL_RPC, in Stub()
64 ::grpc::internal::RpcMethod::NORMAL_RPC, channel), in Stub()
66 ::grpc::internal::RpcMethod::NORMAL_RPC, channel), in Stub()
68 ::grpc::internal::RpcMethod::NORMAL_RPC, channel), in Stub()
70 ::grpc::internal::RpcMethod::NORMAL_RPC, channel), in Stub()
72 ::grpc::internal::RpcMethod::NORMAL_RPC, channel), in Stub()
74 ::grpc::internal::RpcMethod::NORMAL_RPC, channel), in Stub()
76 ::grpc::internal::RpcMethod::NORMAL_RPC, in Stub()
[all …]
Dgrpc_master_service_impl.h110 const ::grpc::internal::RpcMethod rpcmethod_CreateSession_;
111 const ::grpc::internal::RpcMethod rpcmethod_ExtendSession_;
112 const ::grpc::internal::RpcMethod rpcmethod_PartialRunSetup_;
113 const ::grpc::internal::RpcMethod rpcmethod_RunStep_;
114 const ::grpc::internal::RpcMethod rpcmethod_CloseSession_;
115 const ::grpc::internal::RpcMethod rpcmethod_ListDevices_;
116 const ::grpc::internal::RpcMethod rpcmethod_Reset_;
117 const ::grpc::internal::RpcMethod rpcmethod_MakeCallable_;
118 const ::grpc::internal::RpcMethod rpcmethod_RunCallable_;
119 const ::grpc::internal::RpcMethod rpcmethod_ReleaseCallable_;
Dgrpc_worker_service_impl.cc73 ::grpc::internal::RpcMethod::NORMAL_RPC, nullptr)); in AsyncService()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_service.cc53 ::grpc::internal::RpcMethod::NORMAL_RPC, in Stub()
56 ::grpc::internal::RpcMethod::NORMAL_RPC, channel), in Stub()
58 ::grpc::internal::RpcMethod::NORMAL_RPC, in Stub()
61 ::grpc::internal::RpcMethod::NORMAL_RPC, channel), in Stub()
63 ::grpc::internal::RpcMethod::NORMAL_RPC, channel), in Stub()
65 ::grpc::internal::RpcMethod::NORMAL_RPC, in Stub()
68 ::grpc::internal::RpcMethod::NORMAL_RPC, channel) {} in Stub()
123 ::grpc::internal::RpcMethod::NORMAL_RPC, nullptr)); in AsyncService()
Dgrpc_eager_service.h95 const ::grpc::internal::RpcMethod rpcmethod_CreateContext_;
96 const ::grpc::internal::RpcMethod rpcmethod_Enqueue_;
97 const ::grpc::internal::RpcMethod rpcmethod_WaitQueueDone_;
98 const ::grpc::internal::RpcMethod rpcmethod_KeepAlive_;
99 const ::grpc::internal::RpcMethod rpcmethod_CloseContext_;
100 const ::grpc::internal::RpcMethod rpcmethod_RegisterFunction_;
101 const ::grpc::internal::RpcMethod rpcmethod_SendTensor_;
/external/grpc-grpc/src/cpp/client/
Dgeneric_stub.cc34 internal::RpcMethod(method.c_str(), in CallInternal()
35 internal::RpcMethod::BIDI_STREAMING), in CallInternal()
61 internal::RpcMethod(method.c_str(), internal::RpcMethod::NORMAL_RPC), in PrepareUnaryCall()
71 internal::RpcMethod(method.c_str(), internal::RpcMethod::NORMAL_RPC), in UnaryCall()
/external/grpc-grpc-java/testing-proto/src/test/java/io/grpc/testing/protobuf/
DSimpleServiceTest.java27 import io.grpc.stub.annotations.RpcMethod;
84 return Collections.singleton(RpcMethod.class.getCanonicalName()); in getSupportedAnnotationTypes()
88 MethodDescriptor<SimpleRequest, SimpleResponse> descriptor, RpcMethod annotation) { in verifyRpcMethodAnnotation()
114 Map<String, RpcMethod> methodToAnnotation = new HashMap<String, RpcMethod>(); in process()
116 RpcMethod annotation = enclosedElement.getAnnotation(RpcMethod.class); in process()
/external/grpc-grpc/include/grpcpp/impl/codegen/
Drpc_method.h29 class RpcMethod {
38 RpcMethod(const char* name, RpcType type) in RpcMethod() function
41 RpcMethod(const char* name, RpcType type, in RpcMethod() function
Drpc_service_method.h57 class RpcServiceMethod : public RpcMethod {
60 RpcServiceMethod(const char* name, RpcMethod::RpcType type, in RpcServiceMethod()
62 : RpcMethod(name, type), in RpcServiceMethod()
Dclient_unary_call.h35 class RpcMethod; variable
38 Status BlockingUnaryCall(ChannelInterface* channel, const RpcMethod& method, in BlockingUnaryCall()
49 BlockingUnaryCallImpl(ChannelInterface* channel, const RpcMethod& method, in BlockingUnaryCallImpl()
Dclient_callback.h38 class RpcMethod; variable
43 void CallbackUnaryCall(ChannelInterface* channel, const RpcMethod& method, in CallbackUnaryCall()
54 CallbackUnaryCallImpl(ChannelInterface* channel, const RpcMethod& method, in CallbackUnaryCallImpl()
Dchannel_interface.h41 class RpcMethod; variable
110 friend class ::grpc::internal::RpcMethod;
111 virtual internal::Call CreateCall(const internal::RpcMethod& method,
Dsync_stream.h165 const ::grpc::internal::RpcMethod& method, in Create()
242 const ::grpc::internal::RpcMethod& method, in ClientReader()
283 const ::grpc::internal::RpcMethod& method, in Create()
376 const ::grpc::internal::RpcMethod& method, in ClientWriter()
434 const ::grpc::internal::RpcMethod& method, ClientContext* context) { in Create()
550 const ::grpc::internal::RpcMethod& method, in ClientReaderWriter()
/external/flatbuffers/tests/
Dmonster_test.grpc.fb.cc32 …) , rpcmethod_Store_(MonsterStorage_method_names[0], ::grpc::internal::RpcMethod::NORMAL_RPC, cha… in Stub()
33 …, rpcmethod_Retrieve_(MonsterStorage_method_names[1], ::grpc::internal::RpcMethod::SERVER_STREAMIN… in Stub()
34 …, rpcmethod_GetMaxHitPoint_(MonsterStorage_method_names[2], ::grpc::internal::RpcMethod::CLIENT_ST… in Stub()
35 …, rpcmethod_GetMinMaxHitPoints_(MonsterStorage_method_names[3], ::grpc::internal::RpcMethod::BIDI_… in Stub()
89 ::grpc::internal::RpcMethod::NORMAL_RPC, in Service()
94 ::grpc::internal::RpcMethod::SERVER_STREAMING, in Service()
99 ::grpc::internal::RpcMethod::CLIENT_STREAMING, in Service()
104 ::grpc::internal::RpcMethod::BIDI_STREAMING, in Service()
/external/tensorflow/tensorflow/contrib/verbs/
Dgrpc_verbs_service_impl.cc46 ::grpc::internal::RpcMethod::NORMAL_RPC, in Stub()
60 ::grpc::internal::RpcMethod::NORMAL_RPC, nullptr)); in AsyncService()
Dgrpc_verbs_service_impl.h56 const ::grpc::internal::RpcMethod rpcmethod_GetRemoteAddress_;
/external/grpc-grpc/src/cpp/server/
Dserver_cc.cc148 method->method_type() == internal::RpcMethod::NORMAL_RPC || in SyncRequest()
149 method->method_type() == internal::RpcMethod::SERVER_STREAMING), in SyncRequest()
344 "unknown", internal::RpcMethod::BIDI_STREAMING, in AddUnknownSyncMethod()
482 case internal::RpcMethod::NORMAL_RPC: in PayloadHandlingForMethod()
483 case internal::RpcMethod::SERVER_STREAMING: in PayloadHandlingForMethod()
485 case internal::RpcMethod::CLIENT_STREAMING: in PayloadHandlingForMethod()
486 case internal::RpcMethod::BIDI_STREAMING: in PayloadHandlingForMethod()
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/annotations/
DRpcMethod.java40 public @interface RpcMethod { annotation
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DTestServiceGrpc.java37 @io.grpc.stub.annotations.RpcMethod(
69 @io.grpc.stub.annotations.RpcMethod(
101 @io.grpc.stub.annotations.RpcMethod(
133 @io.grpc.stub.annotations.RpcMethod(
165 @io.grpc.stub.annotations.RpcMethod(
197 @io.grpc.stub.annotations.RpcMethod(
229 @io.grpc.stub.annotations.RpcMethod(
261 @io.grpc.stub.annotations.RpcMethod(
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/channelz/v1/
DChannelzGrpc.java37 @io.grpc.stub.annotations.RpcMethod(
69 @io.grpc.stub.annotations.RpcMethod(
101 @io.grpc.stub.annotations.RpcMethod(
133 @io.grpc.stub.annotations.RpcMethod(
165 @io.grpc.stub.annotations.RpcMethod(
197 @io.grpc.stub.annotations.RpcMethod(
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DBenchmarkServiceGrpc.java33 @io.grpc.stub.annotations.RpcMethod(
65 @io.grpc.stub.annotations.RpcMethod(
97 @io.grpc.stub.annotations.RpcMethod(
129 @io.grpc.stub.annotations.RpcMethod(
161 @io.grpc.stub.annotations.RpcMethod(
DWorkerServiceGrpc.java33 @io.grpc.stub.annotations.RpcMethod(
65 @io.grpc.stub.annotations.RpcMethod(
97 @io.grpc.stub.annotations.RpcMethod(
129 @io.grpc.stub.annotations.RpcMethod(
/external/grpc-grpc/include/grpcpp/
Dchannel.h68 internal::Call CreateCall(const internal::RpcMethod& method,
/external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/
DSimpleServiceGrpc.java36 @io.grpc.stub.annotations.RpcMethod(
68 @io.grpc.stub.annotations.RpcMethod(
100 @io.grpc.stub.annotations.RpcMethod(
132 @io.grpc.stub.annotations.RpcMethod(
/external/grpc-grpc-java/compiler/src/test/golden/
DTestService.java.txt36 @io.grpc.stub.annotations.RpcMethod(
68 @io.grpc.stub.annotations.RpcMethod(
100 @io.grpc.stub.annotations.RpcMethod(
132 @io.grpc.stub.annotations.RpcMethod(
164 @io.grpc.stub.annotations.RpcMethod(
196 @io.grpc.stub.annotations.RpcMethod(

12