Home
last modified time | relevance | path

Searched refs:AsyncService (Results 1 – 25 of 34) sorted by relevance

12

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_worker_service_impl.cc69 WorkerService::AsyncService::AsyncService() { in AsyncService() function in tensorflow::grpc::WorkerService::AsyncService
78 WorkerService::AsyncService::~AsyncService() {} in ~AsyncService()
Dgrpc_worker_service_impl.h103 class AsyncService : public ::grpc::Service {
105 AsyncService();
106 virtual ~AsyncService();
Dgrpc_master_service_impl.cc149 MasterService::AsyncService::AsyncService() { in AsyncService() function in tensorflow::grpc::MasterService::AsyncService
160 MasterService::AsyncService::~AsyncService() {} in ~AsyncService()
Dgrpc_master_service.cc95 Call<GrpcMasterService, grpc::MasterService::AsyncService, \
98 &grpc::MasterService::AsyncService::Request##method, \
138 grpc::MasterService::AsyncService master_service_;
146 using MasterCall = Call<GrpcMasterService, grpc::MasterService::AsyncService,
Dgrpc_worker_service.cc78 Call<GrpcWorkerServiceThread, grpc::WorkerService::AsyncService, \
103 grpc::WorkerService::AsyncService* worker_service) in GrpcWorkerServiceThread()
184 Call<GrpcWorkerServiceThread, grpc::WorkerService::AsyncService,
352 Call<GrpcWorkerServiceThread, grpc::WorkerService::AsyncService, in EnqueueRecvTensorRequestRaw()
367 grpc::WorkerService::AsyncService* const worker_service_;
421 grpc::WorkerService::AsyncService worker_service_;
Dgrpc_master_service_impl.h125 class AsyncService : public ::grpc::Service {
127 AsyncService();
128 virtual ~AsyncService();
/external/tensorflow/tensorflow/contrib/verbs/
Dgrpc_verbs_service_impl.cc56 VerbsService::AsyncService::AsyncService() { in AsyncService() function in tensorflow::grpc::VerbsService::AsyncService
65 VerbsService::AsyncService::~AsyncService() {} in ~AsyncService()
Dgrpc_verbs_service_impl.h62 class AsyncService : public ::grpc::Service {
64 AsyncService();
65 virtual ~AsyncService();
Dgrpc_verbs_service.h40 using WorkerCall = Call<GrpcVerbsService, grpc::VerbsService::AsyncService,
48 grpc::VerbsService::AsyncService verbs_service_;
Dgrpc_verbs_service.cc71 Call<GrpcVerbsService, grpc::VerbsService::AsyncService, \
74 &grpc::VerbsService::AsyncService::Request##method, \
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_service_impl.h35 using EagerCall = Call<GrpcEagerServiceImpl, grpc::EagerService::AsyncService,
53 tensorflow::eager::grpc::EagerService::AsyncService, method##Request, \
56 &grpc::EagerService::AsyncService::Request##method, \
74 tensorflow::eager::grpc::EagerService::AsyncService service_;
Dgrpc_eager_service.cc119 EagerService::AsyncService::AsyncService() { in AsyncService() function in tensorflow::eager::grpc::EagerService::AsyncService
128 EagerService::AsyncService::~AsyncService() {} in ~AsyncService()
Dgrpc_eager_service_impl.cc39 tensorflow::eager::grpc::EagerService::AsyncService, method##Request, \ in HandleRPCsLoop()
42 &grpc::EagerService::AsyncService::Request##method, \ in HandleRPCsLoop()
Dgrpc_eager_service.h107 class AsyncService : public ::grpc::Service {
109 AsyncService();
110 virtual ~AsyncService();
/external/guice/extensions/service/test/com/google/inject/service/
DSingleServiceIntegrationTest.java22 AsyncService service = in testAsyncServiceLifecycle()
23 new AsyncService(executor) { in testAsyncServiceLifecycle()
63 AsyncService service = in testAsyncServiceBlockingLifecycle()
64 new AsyncService(executor) { in testAsyncServiceBlockingLifecycle()
/external/grpc-grpc/examples/cpp/helloworld/
Dgreeter_async_server.cc75 CallData(Greeter::AsyncService* service, ServerCompletionQueue* cq) in CallData()
118 Greeter::AsyncService* service_;
158 Greeter::AsyncService service_;
/external/guice/extensions/service/src/com/google/inject/service/
DAsyncService.java31 public abstract class AsyncService implements Service { class
42 public AsyncService(ExecutorService executor) { in AsyncService() method in AsyncService
/external/grpc-grpc/test/cpp/qps/
Dserver_async.cc536 BenchmarkService::AsyncService* service) { in RegisterBenchmarkService()
573 BenchmarkService::AsyncService, in CreateAsyncServer()
576 &BenchmarkService::AsyncService::RequestUnaryCall, in CreateAsyncServer()
577 &BenchmarkService::AsyncService::RequestStreamingCall, in CreateAsyncServer()
578 &BenchmarkService::AsyncService::RequestStreamingFromClient, in CreateAsyncServer()
579 &BenchmarkService::AsyncService::RequestStreamingFromServer, in CreateAsyncServer()
580 &BenchmarkService::AsyncService::RequestStreamingBothWays, in CreateAsyncServer()
/external/grpc-grpc/test/cpp/end2end/
Dnonblocking_test.cc102 service_.reset(new grpc::testing::EchoTestService::AsyncService()); in BuildAndStartServer()
168 std::unique_ptr<grpc::testing::EchoTestService::AsyncService> service_;
Dthread_stress_test.cc253 ::grpc::testing::EchoTestService::AsyncService service_;
301 CommonStressTestInsecure<grpc::testing::EchoTestService::AsyncService>>,
303 grpc::testing::EchoTestService::AsyncService, false>>>
Draw_end2end_test.cc170 typedef grpc::testing::EchoTestService::AsyncService SType; in TEST_F()
353 grpc::testing::EchoTestService::AsyncService> in TEST_F()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dfullstack_streaming_pump.h42 EchoTestService::AsyncService service; in BM_PumpStreamClientToServer()
111 EchoTestService::AsyncService service; in BM_PumpStreamServerToClient()
Dfullstack_streaming_ping_pong.h52 EchoTestService::AsyncService service; in BM_StreamingPingPong()
145 EchoTestService::AsyncService service; in BM_StreamingPingPongMsgs()
249 EchoTestService::AsyncService service; in BM_StreamingPingPongWithCoalescingApi()
/external/grpc-grpc/test/cpp/server/
Dserver_request_call_test.cc48 testing::EchoTestService::AsyncService service; in TEST()
/external/grpc-grpc/src/cpp/server/load_reporter/
Dload_reporter_async_service_impl.h39 : public grpc::lb::v1::LoadReporter::AsyncService {

12