Searched refs:service_impl (Results 1 – 4 of 4) sorted by relevance
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/ |
D | graph_data_server.h | 105 CallData(ServiceImpl *service_impl, AsyncService *async_service, grpc::ServerCompletionQueue *cq, in CallData() argument 108 service_impl_(service_impl), in CallData() 117 …static Status EnqueueRequest(ServiceImpl *service_impl, AsyncService *async_service, grpc::ServerC… in EnqueueRequest() argument 120 service_impl, async_service, cq, enqueue_function, handle_request_function); in EnqueueRequest() 161 #define ENQUEUE_REQUEST(service_impl, async_service, cq, method, request_msg, response_msg) … argument 165 …service_impl, async_service, cq, &GnnGraphData::AsyncService::Request##method, … 172 GraphDataGrpcServer(const std::string &host, int32_t port, GraphDataServiceImpl *service_impl) in GraphDataGrpcServer() argument 173 : GrpcAsyncServer(host, port), service_impl_(service_impl) {} in GraphDataGrpcServer()
|
/third_party/grpc/src/ruby/end2end/ |
D | killed_client_thread_test.rb | 48 service_impl = SleepingEchoServerImpl.new(received_rpc_callback) 52 server_runner = ServerRunner.new(service_impl, rpc_server_args: rpc_server_args)
|
D | killed_client_thread_driver.rb | 48 service_impl = SleepingEchoServerImpl.new(received_rpc_callback) 52 server_runner = ServerRunner.new(service_impl, rpc_server_args: rpc_server_args)
|
D | end2end_common.rb | 83 def initialize(service_impl, rpc_server_args: {}) argument 84 @service_impl = service_impl
|