Home
last modified time | relevance | path

Searched refs:GenericStub (Results 1 – 18 of 18) sorted by relevance

/external/grpc-grpc/include/grpcpp/generic/
Dgeneric_stub.h38 class GenericStub final {
40 explicit GenericStub(std::shared_ptr<ChannelInterface> channel) in GenericStub() function
73 explicit experimental_type(GenericStub* stub) : stub_(stub) {} in experimental_type()
80 GenericStub* stub_;
/external/grpc-grpc/src/cpp/client/
Dgeneric_stub.cc42 std::unique_ptr<GenericClientAsyncReaderWriter> GenericStub::Call( in Call()
49 std::unique_ptr<GenericClientAsyncReaderWriter> GenericStub::PrepareCall( in PrepareCall()
55 std::unique_ptr<GenericClientAsyncResponseReader> GenericStub::PrepareUnaryCall( in PrepareUnaryCall()
65 void GenericStub::experimental_type::UnaryCall( in UnaryCall()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_rpc_factory.cc142 ::grpc::GenericStub* GrpcRPCFactory::GetOrCreateStubForAddress( in GetOrCreateStubForAddress()
150 auto* created = new ::grpc::GenericStub(channel); in GetOrCreateStubForAddress()
194 ::grpc::GenericStub* singleton_stub = nullptr; in StartCall()
199 singleton_stub](int64 ix) -> ::grpc::GenericStub* { in StartCall()
Dgrpc_state.h42 RPCState(::grpc::GenericStub* stub, ::grpc::CompletionQueue* cq,
51 RPCState(::grpc::GenericStub* stub, ::grpc::CompletionQueue* cq, in RPCState()
166 ::grpc::GenericStub* stub_;
Dgrpc_rpc_factory.h63 ::grpc::GenericStub* GetOrCreateStubForAddress(const string& address);
71 typedef std::unique_ptr<::grpc::GenericStub> StubPtr;
Dgrpc_remote_worker.cc283 ::grpc::GenericStub stub_;
/external/grpc-grpc/test/cpp/qps/
Dclient_async.cc769 grpc::GenericStub* stub, const ByteBuffer& req, in ClientRpcContextGenericStreamingImpl()
772 grpc::GenericStub*, grpc::ClientContext*, in ClientRpcContextGenericStreamingImpl()
855 grpc::GenericStub* stub_;
874 grpc::GenericStub*, grpc::ClientContext*, const grpc::string&,
897 static std::unique_ptr<grpc::GenericStub> GenericStubCreator( in GenericStubCreator()
899 return std::unique_ptr<grpc::GenericStub>(new grpc::GenericStub(ch)); in GenericStubCreator()
903 : public AsyncClient<grpc::GenericStub, ByteBuffer> {
906 : AsyncClient<grpc::GenericStub, ByteBuffer>(config, SetupCtx, in GenericAsyncStreamingClient()
916 grpc::GenericStub* stub, grpc::ClientContext* ctx, in PrepareReq()
921 static ClientRpcContext* SetupCtx(grpc::GenericStub* stub, in SetupCtx()
/external/grpc-grpc/examples/cpp/helloworld/cocoapods/HelloWorldCpp/
DViewController.mm36 std::unique_ptr<grpc::GenericStub> generic_stub_;
45 generic_stub_.reset(new grpc::GenericStub(channel));
/external/grpc-grpc/test/cpp/end2end/
Dclient_callback_end2end_test.cc60 generic_stub_.reset(new GenericStub(channel_)); in ResetStub()
152 std::unique_ptr<grpc::GenericStub> generic_stub_;
Dfilter_end2end_test.cc151 generic_stub_.reset(new GenericStub(channel)); in ResetStub()
226 std::unique_ptr<grpc::GenericStub> generic_stub_;
Dgeneric_end2end_test.cc94 generic_stub_.reset(new GenericStub(channel)); in ResetStub()
182 std::unique_ptr<grpc::GenericStub> generic_stub_;
/external/grpc-grpc/src/python/grpcio_tests/tests/qps/
Dbenchmark_client.py32 class GenericStub(object): class
70 self._stub = GenericStub(channel)
/external/grpc-grpc/test/cpp/util/
Dcli_call.h87 std::unique_ptr<grpc::GenericStub> stub_;
Dcli_call.cc55 : stub_(new grpc::GenericStub(channel)) { in CliCall()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_client.cc57 ::grpc::GenericStub stub_;
/external/grpc-grpc/test/cpp/cocoapods/generic/
Dgeneric.mm96 std::unique_ptr<GenericStub> generic_stub_;
159 generic_stub_.reset(new GenericStub(channel));
/external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/face/
Dface.py691 class GenericStub(six.with_metaclass(abc.ABCMeta)): class
/external/grpc-grpc/src/python/grpcio/grpc/beta/
D_client_adaptations.py426 class _GenericStub(face.GenericStub):