| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service_impl.h | 35 using EagerCall = Call<GrpcEagerServiceImpl, grpc::EagerService::AsyncService,
40 grpc::EagerService::AsyncService,
61 Call<GrpcEagerServiceImpl, grpc::EagerService::AsyncService, \
64 &grpc::EagerService::AsyncService::Request##method, \
81 Call<GrpcEagerServiceImpl, grpc::EagerService::AsyncService, EnqueueRequest, in EnqueueHandler()
84 &grpc::EagerService::AsyncService::RequestEnqueue, in EnqueueHandler()
102 Call<GrpcEagerServiceImpl, grpc::EagerService::AsyncService, in RunComponentFunctionHandler()
106 &grpc::EagerService::AsyncService::RequestRunComponentFunction, in RunComponentFunctionHandler()
161 grpc::EagerService::AsyncService service_;
|
| D | grpc_eager_service_impl.cc | 45 Call<GrpcEagerServiceImpl, grpc::EagerService::AsyncService, \ in HandleRPCsLoop()
48 &grpc::EagerService::AsyncService::Request##method, \ in HandleRPCsLoop()
62 grpc::EagerService::AsyncService, in HandleRPCsLoop()
65 &grpc::EagerService::AsyncService::RequestStreamingEnqueue, in HandleRPCsLoop()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_worker_service_impl.cc | 71 WorkerService::AsyncService::AsyncService() { in AsyncService() function in tensorflow::grpc::WorkerService::AsyncService
80 WorkerService::AsyncService::~AsyncService() {} in ~AsyncService()
|
| D | grpc_worker_service_impl.h | 104 class AsyncService : public ::grpc::Service {
106 AsyncService();
107 virtual ~AsyncService();
|
| D | grpc_master_service_impl.cc | 149 MasterService::AsyncService::AsyncService() { in AsyncService() function in tensorflow::grpc::MasterService::AsyncService
160 MasterService::AsyncService::~AsyncService() {} in ~AsyncService()
|
| D | grpc_master_service.cc | 95 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,
|
| D | grpc_worker_service.cc | 78 Call<GrpcWorkerServiceThread, grpc::WorkerService::AsyncService, \
103 grpc::WorkerService::AsyncService* worker_service) in GrpcWorkerServiceThread()
185 Call<GrpcWorkerServiceThread, grpc::WorkerService::AsyncService,
345 Call<GrpcWorkerServiceThread, grpc::WorkerService::AsyncService, in EnqueueRecvTensorRequestRaw()
360 grpc::WorkerService::AsyncService* const worker_service_;
409 grpc::WorkerService::AsyncService worker_service_;
|
| D | grpc_master_service_impl.h | 127 class AsyncService : public ::grpc::Service {
129 AsyncService();
130 virtual ~AsyncService();
|
| /external/tensorflow/tensorflow/core/tpu/kernels/ |
| D | tpu_compilation_cache_service.h | 37 using AsyncService = ServiceType::AsyncService; variable
50 using GetTpuProgramCall = Call<TpuCompilationCacheService, AsyncService,
66 AsyncService service_;
|
| /external/guice/extensions/service/test/com/google/inject/service/ |
| D | SingleServiceIntegrationTest.java | 22 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/ |
| D | greeter_async_server.cc | 75 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/ |
| D | AsyncService.java | 31 public abstract class AsyncService implements Service { class
42 public AsyncService(ExecutorService executor) { in AsyncService() method in AsyncService
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | server_async.cc | 536 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/ |
| D | nonblocking_test.cc | 102 service_.reset(new grpc::testing::EchoTestService::AsyncService()); in BuildAndStartServer()
168 std::unique_ptr<grpc::testing::EchoTestService::AsyncService> service_;
|
| D | thread_stress_test.cc | 253 ::grpc::testing::EchoTestService::AsyncService service_;
301 CommonStressTestInsecure<grpc::testing::EchoTestService::AsyncService>>,
303 grpc::testing::EchoTestService::AsyncService, false>>>
|
| D | raw_end2end_test.cc | 170 typedef grpc::testing::EchoTestService::AsyncService SType; in TEST_F()
353 grpc::testing::EchoTestService::AsyncService> in TEST_F()
|
| D | hybrid_end2end_test.cc | 750 duplicate::EchoTestService::AsyncService dup_service; in TEST_F()
758 HandleEcho<duplicate::EchoTestService::AsyncService>, &dup_service, in TEST_F()
822 duplicate::EchoTestService::AsyncService dup_service; in TEST_F()
830 HandleEcho<duplicate::EchoTestService::AsyncService>, &dup_service, in TEST_F()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | fullstack_streaming_pump.h | 42 EchoTestService::AsyncService service; in BM_PumpStreamClientToServer()
111 EchoTestService::AsyncService service; in BM_PumpStreamServerToClient()
|
| D | fullstack_streaming_ping_pong.h | 52 EchoTestService::AsyncService service; in BM_StreamingPingPong()
145 EchoTestService::AsyncService service; in BM_StreamingPingPongMsgs()
249 EchoTestService::AsyncService service; in BM_StreamingPingPongWithCoalescingApi()
|
| D | fullstack_unary_ping_pong.h | 42 EchoTestService::AsyncService service; in BM_UnaryPingPong()
|
| D | bm_fullstack_trickle.cc | 260 EchoTestService::AsyncService service; in BM_PumpStreamServerToClient_Trickle()
354 EchoTestService::AsyncService service; in BM_PumpUnbalancedUnary_Trickle()
|
| /external/grpc-grpc/test/cpp/server/ |
| D | server_request_call_test.cc | 48 testing::EchoTestService::AsyncService service; in TEST()
|
| /external/grpc-grpc/src/cpp/server/load_reporter/ |
| D | load_reporter_async_service_impl.h | 39 : public grpc::lb::v1::LoadReporter::AsyncService {
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/load_reporter/ |
| D | load_reporter_async_service_impl.h | 40 : public grpc::lb::v1::LoadReporter::AsyncService {
|
| /external/grpc-grpc/test/cpp/performance/ |
| D | writes_per_rpc_test.cc | 170 EchoTestService::AsyncService service; in UnaryPingPong()
|