Home
last modified time | relevance | path

Searched refs:service_impl (Results 1 – 4 of 4) sorted by relevance

/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/
Dgraph_data_server.h105 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
165service_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/
Dkilled_client_thread_test.rb48 service_impl = SleepingEchoServerImpl.new(received_rpc_callback)
52 server_runner = ServerRunner.new(service_impl, rpc_server_args: rpc_server_args)
Dkilled_client_thread_driver.rb48 service_impl = SleepingEchoServerImpl.new(received_rpc_callback)
52 server_runner = ServerRunner.new(service_impl, rpc_server_args: rpc_server_args)
Dend2end_common.rb83 def initialize(service_impl, rpc_server_args: {}) argument
84 @service_impl = service_impl