Searched refs:GenericStub (Results 1 – 18 of 18) sorted by relevance
/external/grpc-grpc/include/grpcpp/generic/ |
D | generic_stub.h | 38 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/ |
D | generic_stub.cc | 42 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/ |
D | grpc_rpc_factory.cc | 142 ::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()
|
D | grpc_state.h | 42 RPCState(::grpc::GenericStub* stub, ::grpc::CompletionQueue* cq, 51 RPCState(::grpc::GenericStub* stub, ::grpc::CompletionQueue* cq, in RPCState() 166 ::grpc::GenericStub* stub_;
|
D | grpc_rpc_factory.h | 63 ::grpc::GenericStub* GetOrCreateStubForAddress(const string& address); 71 typedef std::unique_ptr<::grpc::GenericStub> StubPtr;
|
D | grpc_remote_worker.cc | 283 ::grpc::GenericStub stub_;
|
/external/grpc-grpc/test/cpp/qps/ |
D | client_async.cc | 769 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/ |
D | ViewController.mm | 36 std::unique_ptr<grpc::GenericStub> generic_stub_; 45 generic_stub_.reset(new grpc::GenericStub(channel));
|
/external/grpc-grpc/test/cpp/end2end/ |
D | client_callback_end2end_test.cc | 60 generic_stub_.reset(new GenericStub(channel_)); in ResetStub() 152 std::unique_ptr<grpc::GenericStub> generic_stub_;
|
D | filter_end2end_test.cc | 151 generic_stub_.reset(new GenericStub(channel)); in ResetStub() 226 std::unique_ptr<grpc::GenericStub> generic_stub_;
|
D | generic_end2end_test.cc | 94 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/ |
D | benchmark_client.py | 32 class GenericStub(object): class 70 self._stub = GenericStub(channel)
|
/external/grpc-grpc/test/cpp/util/ |
D | cli_call.h | 87 std::unique_ptr<grpc::GenericStub> stub_;
|
D | cli_call.cc | 55 : stub_(new grpc::GenericStub(channel)) { in CliCall()
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
D | grpc_eager_client.cc | 57 ::grpc::GenericStub stub_;
|
/external/grpc-grpc/test/cpp/cocoapods/generic/ |
D | generic.mm | 96 std::unique_ptr<GenericStub> generic_stub_; 159 generic_stub_.reset(new GenericStub(channel));
|
/external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/face/ |
D | face.py | 691 class GenericStub(six.with_metaclass(abc.ABCMeta)): class
|
/external/grpc-grpc/src/python/grpcio/grpc/beta/ |
D | _client_adaptations.py | 426 class _GenericStub(face.GenericStub):
|