| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 40 class ServerCompletionQueue; variable
183 virtual void Start(::grpc::ServerCompletionQueue** cqs, size_t num_cqs) = 0;
199 ::grpc::ServerCompletionQueue* notification_cq, void* tag,
213 ::grpc::ServerCompletionQueue* const notification_cq_;
229 ::grpc::ServerCompletionQueue* notification_cq,
247 ::grpc::ServerCompletionQueue* notification_cq);
259 ::grpc::ServerCompletionQueue* notification_cq, in NoPayloadAsyncRequest()
277 ::grpc::ServerCompletionQueue* notification_cq, in PayloadAsyncRequest()
333 ::grpc::ServerCompletionQueue* notification_cq,
347 ::grpc::ServerCompletionQueue* notification_cq, in RequestAsyncCall()
[all …]
|
| D | service_type.h | 130 ::grpc::ServerCompletionQueue* notification_cq, in RequestAsyncUnary()
143 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncClientStreaming()
153 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncServerStreaming()
162 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncBidiStreaming()
|
| D | completion_queue_impl.h | 424 class ServerCompletionQueue : public CompletionQueue {
430 ServerCompletionQueue() : polling_type_(GRPC_CQ_DEFAULT_POLLING) {} in ServerCompletionQueue() function
439 ServerCompletionQueue(grpc_cq_completion_type completion_type, in ServerCompletionQueue() function
|
| D | completion_queue.h | 426 class ServerCompletionQueue : public CompletionQueue {
432 ServerCompletionQueue() : polling_type_(GRPC_CQ_DEFAULT_POLLING) {} in ServerCompletionQueue() function
441 ServerCompletionQueue(grpc_cq_completion_type completion_type, in ServerCompletionQueue() function
|
| D | async_generic_service.h | 75 ::grpc::ServerCompletionQueue* notification_cq, void* tag);
|
| /third_party/grpc/src/cpp/server/health/ |
| D | default_health_check_service.h | 57 std::unique_ptr<ServerCompletionQueue> cq);
111 static void CreateAndStart(ServerCompletionQueue* cq,
117 CheckCallHandler(ServerCompletionQueue* cq,
134 ServerCompletionQueue* cq_;
154 static void CreateAndStart(ServerCompletionQueue* cq,
160 WatchCallHandler(ServerCompletionQueue* cq,
192 ServerCompletionQueue* cq_;
226 std::unique_ptr<ServerCompletionQueue> cq_;
245 std::unique_ptr<ServerCompletionQueue> cq);
|
| D | default_health_check_service.cc | 116 std::unique_ptr<ServerCompletionQueue> cq) { in GetHealthCheckService()
155 std::unique_ptr<ServerCompletionQueue> cq) in HealthCheckServiceImpl()
268 CreateAndStart(ServerCompletionQueue* cq, in CreateAndStart()
288 CheckCallHandler(ServerCompletionQueue* cq, in CheckCallHandler()
349 CreateAndStart(ServerCompletionQueue* cq, in CreateAndStart()
376 WatchCallHandler(ServerCompletionQueue* cq, in WatchCallHandler()
|
| /third_party/grpc/src/cpp/server/load_reporter/ |
| D | load_reporter_async_service_impl.h | 43 std::unique_ptr<ServerCompletionQueue> cq);
100 static void CreateAndStart(ServerCompletionQueue* cq,
106 ReportLoadHandler(ServerCompletionQueue* cq,
148 ServerCompletionQueue* cq_;
182 std::unique_ptr<ServerCompletionQueue> cq_;
|
| D | load_reporter_async_service_impl.cc | 37 std::unique_ptr<ServerCompletionQueue> cq) in LoadReporterAsyncServiceImpl()
121 ServerCompletionQueue* cq, LoadReporterAsyncServiceImpl* service, in CreateAndStart()
144 ServerCompletionQueue* cq, LoadReporterAsyncServiceImpl* service, in ReportLoadHandler()
|
| /third_party/grpc/examples/cpp/helloworld/ |
| D | greeter_async_server.cc | 37 using grpc::ServerCompletionQueue;
79 CallData(Greeter::AsyncService* service, ServerCompletionQueue* cq) in CallData()
124 ServerCompletionQueue* cq_;
161 std::unique_ptr<ServerCompletionQueue> cq_;
|
| /third_party/grpc/src/cpp/server/ |
| D | server_builder.cc | 71 std::unique_ptr<grpc::ServerCompletionQueue> ServerBuilder::AddCompletionQueue( in AddCompletionQueue()
73 grpc::ServerCompletionQueue* cq = new grpc::ServerCompletionQueue( in AddCompletionQueue()
78 return std::unique_ptr<grpc::ServerCompletionQueue>(cq); in AddCompletionQueue()
284 std::shared_ptr<std::vector<std::unique_ptr<grpc::ServerCompletionQueue>>> in BuildAndStart()
287 std::vector<std::unique_ptr<grpc::ServerCompletionQueue>>>()); in BuildAndStart()
316 new grpc::ServerCompletionQueue(GRPC_CQ_NEXT, polling_type, nullptr)); in BuildAndStart()
|
| D | server_cc.cc | 120 ServerCompletionQueue* notification_cq, void* tag, bool delete_on_finalize) in BaseAsyncRequest()
203 ServerCompletionQueue* notification_cq, void* tag, const char* name, in RegisteredAsyncRequest()
212 ServerCompletionQueue* notification_cq) { in IssueRequest()
225 ServerCompletionQueue* notification_cq, void* tag, bool delete_on_finalize) in GenericAsyncRequest()
301 grpc::ServerCompletionQueue* cq) in UnimplementedAsyncRequest()
892 std::shared_ptr<std::vector<std::unique_ptr<grpc::ServerCompletionQueue>>> in Server()
1147 void Server::Start(grpc::ServerCompletionQueue** cqs, size_t num_cqs) { in Start()
1154 grpc::ServerCompletionQueue* health_check_cq = nullptr; in Start()
1165 health_check_cq = new grpc::ServerCompletionQueue( in Start()
1171 std::unique_ptr<grpc::ServerCompletionQueue>(health_check_cq)); in Start()
|
| D | async_generic_service.cc | 28 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestCall()
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/ |
| D | graph_data_server.h | 102 … grpc::CompletionQueue *, grpc::ServerCompletionQueue *, void *);
105 CallData(ServiceImpl *service_impl, AsyncService *async_service, grpc::ServerCompletionQueue *cq, in CallData()
117 …eueRequest(ServiceImpl *service_impl, AsyncService *async_service, grpc::ServerCompletionQueue *cq, in EnqueueRequest()
152 grpc::ServerCompletionQueue *cq_;
|
| D | grpc_async_server.h | 54 std::unique_ptr<grpc::ServerCompletionQueue> cq_;
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/ |
| D | cache_grpc_server.h | 53 Status operator()(CacheServerGreeter::AsyncService *svc, grpc::ServerCompletionQueue *cq);
92 std::unique_ptr<grpc::ServerCompletionQueue> cq_;
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | fullstack_fixtures.h | 103 ServerCompletionQueue* cq() { return cq_.get(); } in cq()
108 std::unique_ptr<ServerCompletionQueue> cq_;
228 ServerCompletionQueue* cq() { return cq_.get(); } in cq()
238 std::unique_ptr<ServerCompletionQueue> cq_;
|
| /third_party/grpc/include/grpcpp/ |
| D | server.h | 177 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>>
195 void Start(ServerCompletionQueue** cqs, size_t num_cqs) override;
322 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>>
|
| D | server_impl.h | 183 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>>
201 void Start(ServerCompletionQueue** cqs, size_t num_cqs) override;
318 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>>
|
| D | server_builder_impl.h | 45 class ServerCompletionQueue; variable
170 std::unique_ptr<grpc_impl::ServerCompletionQueue> AddCompletionQueue(
386 std::vector<grpc_impl::ServerCompletionQueue*> cqs_;
|
| D | server_builder.h | 45 class ServerCompletionQueue; variable
166 std::unique_ptr<grpc::ServerCompletionQueue> AddCompletionQueue(
391 std::vector<grpc::ServerCompletionQueue*> cqs_;
|
| /third_party/grpc/test/cpp/qps/ |
| D | server_async.cc | 56 CompletionQueue*, ServerCompletionQueue*, void*)> in AsyncQpsServerTest() argument
60 CompletionQueue*, ServerCompletionQueue*, void*)> in AsyncQpsServerTest()
64 CompletionQueue*, ServerCompletionQueue*, void*)> in AsyncQpsServerTest()
68 ServerCompletionQueue*, void*)> in AsyncQpsServerTest()
72 CompletionQueue*, ServerCompletionQueue*, void*)> in AsyncQpsServerTest()
521 std::vector<std::unique_ptr<grpc::ServerCompletionQueue>> srv_cqs_;
|
| /third_party/grpc/test/cpp/end2end/ |
| D | hybrid_end2end_test.cc | 68 void HandleEcho(Service* service, ServerCompletionQueue* cq, bool dup_service) { in HandleEcho()
88 void HandleRawEcho(Service* service, ServerCompletionQueue* cq, in HandleRawEcho()
106 void HandleClientStreaming(Service* service, ServerCompletionQueue* cq) { in HandleClientStreaming()
124 void HandleRawClientStreaming(Service* service, ServerCompletionQueue* cq) { in HandleRawClientStreaming()
148 void HandleServerStreaming(Service* service, ServerCompletionQueue* cq) { in HandleServerStreaming()
209 ServerCompletionQueue* cq) { in HandleGenericCall()
448 std::vector<std::unique_ptr<ServerCompletionQueue>> cqs_;
|
| /third_party/grpc/test/cpp/performance/ |
| D | writes_per_rpc_test.cc | 118 ServerCompletionQueue* cq() { return cq_.get(); } in cq()
123 std::unique_ptr<ServerCompletionQueue> cq_;
|
| /third_party/flatbuffers/tests/ |
| D | monster_test.grpc.fb.h | 23 class ServerCompletionQueue; variable
168 …e<Stat>>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notificat… in RequestStore()
188 …<Monster>>* writer, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notificat… in RequestRetrieve()
208 …<Monster>>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notificat… in RequestGetMaxHitPoint()
228 …<Monster>>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notificat… in RequestGetMinMaxHitPoints()
|