| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/ |
| D | graph_data_server.h | 96 template <class ServiceImpl, class AsyncService, class RequestMessage, class ResponseMessage>
100 using EnqueueFunction = void (AsyncService::*)(grpc::ServerContext *, RequestMessage *,
105 CallData(ServiceImpl *service_impl, AsyncService *async_service, grpc::ServerCompletionQueue *cq, in CallData()
117 …static Status EnqueueRequest(ServiceImpl *service_impl, AsyncService *async_service, grpc::ServerC… in EnqueueRequest()
119 auto call = new CallData<ServiceImpl, AsyncService, RequestMessage, ResponseMessage>( in EnqueueRequest()
151 AsyncService *async_service_;
164 …CallData<gnn::GraphDataServiceImpl, GnnGraphData::AsyncService, request_msg, response_msg>::Enqueu…
165 …service_impl, async_service, cq, &GnnGraphData::AsyncService::Request##method, …
204 GnnGraphData::AsyncService svc_;
|
| /third_party/grpc/examples/cpp/helloworld/ |
| D | greeter_async_server.cc | 79 CallData(Greeter::AsyncService* service, ServerCompletionQueue* cq) in CallData()
122 Greeter::AsyncService* service_;
162 Greeter::AsyncService service_;
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/ |
| D | cache_grpc_server.h | 53 Status operator()(CacheServerGreeter::AsyncService *svc, grpc::ServerCompletionQueue *cq);
91 CacheServerGreeter::AsyncService svc_;
|
| D | cache_grpc_server.cc | 128 Status CacheServerRequest::operator()(CacheServerGreeter::AsyncService *svc, grpc::ServerCompletion… in operator ()()
|
| /third_party/grpc/test/cpp/qps/ |
| D | server_async.cc | 536 BenchmarkService::AsyncService* service) { in RegisterBenchmarkService()
574 BenchmarkService::AsyncService, in CreateAsyncServer()
577 &BenchmarkService::AsyncService::RequestUnaryCall, in CreateAsyncServer()
578 &BenchmarkService::AsyncService::RequestStreamingCall, in CreateAsyncServer()
579 &BenchmarkService::AsyncService::RequestStreamingFromClient, in CreateAsyncServer()
580 &BenchmarkService::AsyncService::RequestStreamingFromServer, in CreateAsyncServer()
581 &BenchmarkService::AsyncService::RequestStreamingBothWays, in CreateAsyncServer()
|
| /third_party/grpc/test/cpp/end2end/ |
| D | nonblocking_test.cc | 112 service_.reset(new grpc::testing::EchoTestService::AsyncService()); in BuildAndStartServer()
178 std::unique_ptr<grpc::testing::EchoTestService::AsyncService> service_;
|
| D | thread_stress_test.cc | 260 ::grpc::testing::EchoTestService::AsyncService service_;
308 CommonStressTestInsecure<grpc::testing::EchoTestService::AsyncService>>,
310 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 | 789 duplicate::EchoTestService::AsyncService dup_service; in TEST_F()
797 HandleEcho<duplicate::EchoTestService::AsyncService>, &dup_service, in TEST_F()
906 duplicate::EchoTestService::AsyncService dup_service; in TEST_F()
914 HandleEcho<duplicate::EchoTestService::AsyncService>, &dup_service, in TEST_F()
|
| D | server_interceptors_end2end_test.cc | 348 EchoTestService::AsyncService service; in TEST_F()
421 EchoTestService::AsyncService service; in TEST_F()
|
| D | async_end2end_test.cc | 281 service_.reset(new grpc::testing::EchoTestService::AsyncService()); in BuildAndStartServer()
343 std::unique_ptr<grpc::testing::EchoTestService::AsyncService> service_;
|
| /third_party/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 | 258 EchoTestService::AsyncService service; in BM_PumpStreamServerToClient_Trickle()
352 EchoTestService::AsyncService service; in BM_PumpUnbalancedUnary_Trickle()
|
| /third_party/grpc/src/cpp/server/load_reporter/ |
| D | load_reporter_async_service_impl.h | 40 : public grpc::lb::v1::LoadReporter::AsyncService {
|
| /third_party/grpc/test/cpp/server/ |
| D | server_request_call_test.cc | 49 testing::EchoTestService::AsyncService service; in TEST()
|
| /third_party/grpc/test/cpp/performance/ |
| D | writes_per_rpc_test.cc | 154 EchoTestService::AsyncService service; in UnaryPingPong()
|
| /third_party/flatbuffers/tests/ |
| D | monster_test.grpc.fb.h | 232 …ethod_GetMaxHitPoint< WithAsyncMethod_GetMinMaxHitPoints< Service > > > > AsyncService; typedef
|
| /third_party/grpc/test/cpp/codegen/ |
| D | compiler_test_golden | 368 …syncMethod_MethodA2<WithAsyncMethod_MethodA3<WithAsyncMethod_MethodA4<Service > > > > AsyncService;
1011 typedef WithAsyncMethod_MethodB1<Service > AsyncService;
|