| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 34 class ServerCompletionQueue; variable
136 virtual void Start(ServerCompletionQueue** cqs, size_t num_cqs) = 0;
177 ServerCompletionQueue* notification_cq);
186 ServerCompletionQueue* notification_cq, void* tag) in NoPayloadAsyncRequest()
201 ServerCompletionQueue* notification_cq, void* tag, in PayloadAsyncRequest()
247 ServerCompletionQueue* const notification_cq_;
258 ServerCompletionQueue* notification_cq, void* tag,
272 ServerCompletionQueue* notification_cq, void* tag, in RequestAsyncCall()
284 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncCall()
293 ServerCompletionQueue* notification_cq, in RequestAsyncGenericCall()
|
| D | service_type.h | 34 class ServerCompletionQueue; variable
95 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncUnary()
106 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncClientStreaming()
115 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncServerStreaming()
123 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncBidiStreaming()
|
| D | completion_queue.h | 370 class ServerCompletionQueue : public CompletionQueue {
376 ServerCompletionQueue() : polling_type_(GRPC_CQ_DEFAULT_POLLING) {} in ServerCompletionQueue() function
383 ServerCompletionQueue(grpc_cq_polling_type polling_type) in ServerCompletionQueue() function
|
| D | async_generic_service.h | 72 ServerCompletionQueue* notification_cq, void* tag);
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_master_service_impl.h | 133 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestCreateSession()
141 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestExtendSession()
149 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestPartialRunSetup()
157 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestRunStep()
165 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestCloseSession()
173 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestListDevices()
181 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestReset()
189 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestMakeCallable()
197 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestRunCallable()
205 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestReleaseCallable()
|
| D | grpc_call.h | 144 ::grpc::CompletionQueue*, ::grpc::ServerCompletionQueue*, void*);
197 ::grpc::ServerCompletionQueue* cq, in EnqueueRequest()
219 GrpcService* grpc_service, ::grpc::ServerCompletionQueue* cq, in EnqueueRequestForMethod()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service.h | 115 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestCreateContext()
123 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestEnqueue()
131 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestWaitQueueDone()
139 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestKeepAlive()
147 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestCloseContext()
155 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestRegisterFunction()
163 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestSendTensor()
|
| D | grpc_eager_service_impl.h | 73 std::unique_ptr<::grpc::ServerCompletionQueue> cq_;
|
| /external/grpc-grpc/src/cpp/server/load_reporter/ |
| D | load_reporter_async_service_impl.h | 42 std::unique_ptr<ServerCompletionQueue> cq);
99 static void CreateAndStart(ServerCompletionQueue* cq,
105 ReportLoadHandler(ServerCompletionQueue* cq,
147 ServerCompletionQueue* cq_;
181 std::unique_ptr<ServerCompletionQueue> cq_;
|
| D | load_reporter_async_service_impl.cc | 33 std::unique_ptr<ServerCompletionQueue> cq) in LoadReporterAsyncServiceImpl()
116 ServerCompletionQueue* cq, LoadReporterAsyncServiceImpl* service, in CreateAndStart()
139 ServerCompletionQueue* cq, LoadReporterAsyncServiceImpl* service, in ReportLoadHandler()
|
| /external/grpc-grpc/examples/cpp/helloworld/ |
| D | greeter_async_server.cc | 33 using grpc::ServerCompletionQueue;
75 CallData(Greeter::AsyncService* service, ServerCompletionQueue* cq) in CallData()
120 ServerCompletionQueue* cq_;
157 std::unique_ptr<ServerCompletionQueue> cq_;
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_builder.cc | 71 std::unique_ptr<ServerCompletionQueue> ServerBuilder::AddCompletionQueue( in AddCompletionQueue()
73 ServerCompletionQueue* cq = new ServerCompletionQueue( in AddCompletionQueue()
76 return std::unique_ptr<ServerCompletionQueue>(cq); in AddCompletionQueue()
239 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>> in BuildAndStart()
241 std::vector<std::unique_ptr<ServerCompletionQueue>>>()); in BuildAndStart()
259 sync_server_cqs->emplace_back(new ServerCompletionQueue(polling_type)); in BuildAndStart()
|
| D | server_cc.cc | 104 UnimplementedAsyncRequest(Server* server, ServerCompletionQueue* cq) in UnimplementedAsyncRequest()
117 ServerCompletionQueue* const cq_;
390 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>> in Server()
555 void Server::Start(ServerCompletionQueue** cqs, size_t num_cqs) { in Start()
714 ServerCompletionQueue* notification_cq) { in IssueRequest()
725 ServerCompletionQueue* notification_cq, void* tag, bool delete_on_finalize) in GenericAsyncRequest()
|
| D | async_generic_service.cc | 27 CompletionQueue* call_cq, ServerCompletionQueue* notification_cq, in RequestCall()
|
| /external/grpc-grpc/include/grpcpp/ |
| D | server.h | 149 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>>
160 void Start(ServerCompletionQueue** cqs, size_t num_cqs) override;
199 std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>>
|
| D | server_builder.h | 43 class ServerCompletionQueue; variable
125 std::unique_ptr<ServerCompletionQueue> AddCompletionQueue(
285 std::vector<ServerCompletionQueue*> cqs_;
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | fullstack_fixtures.h | 116 ServerCompletionQueue* cq() { return cq_.get(); } in cq()
121 std::unique_ptr<ServerCompletionQueue> cq_;
245 ServerCompletionQueue* cq() { return cq_.get(); } in cq()
255 std::unique_ptr<ServerCompletionQueue> cq_;
|
| /external/grpc-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_;
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | hybrid_end2end_test.cc | 61 void HandleEcho(Service* service, ServerCompletionQueue* cq, bool dup_service) { in HandleEcho()
81 void HandleRawEcho(Service* service, ServerCompletionQueue* cq, in HandleRawEcho()
99 void HandleClientStreaming(Service* service, ServerCompletionQueue* cq) { in HandleClientStreaming()
117 void HandleRawClientStreaming(Service* service, ServerCompletionQueue* cq) { in HandleRawClientStreaming()
141 void HandleServerStreaming(Service* service, ServerCompletionQueue* cq) { in HandleServerStreaming()
202 ServerCompletionQueue* cq) { in HandleGenericCall()
410 std::vector<std::unique_ptr<ServerCompletionQueue>> cqs_;
|
| D | health_service_end2end_test.cc | 109 void LoopCompletionQueue(ServerCompletionQueue* cq) { in LoopCompletionQueue()
224 std::unique_ptr<ServerCompletionQueue> cq_;
|
| /external/grpc-grpc/test/cpp/codegen/ |
| D | compiler_test_golden | 44 class ServerCompletionQueue;
245 …esponse>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notificat…
265 …::Request>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notificat…
285 …:Response>* writer, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notificat…
305 …::Request>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notificat…
394 …eBuffer>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notificat…
414 …yteBuffer>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notificat…
434 …yteBuffer>* writer, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notificat…
454 …yteBuffer>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notificat…
588 …esponse>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notificat…
[all …]
|
| /external/grpc-grpc/test/cpp/performance/ |
| D | writes_per_rpc_test.cc | 134 ServerCompletionQueue* cq() { return cq_.get(); } in cq()
139 std::unique_ptr<ServerCompletionQueue> cq_;
|
| /external/tensorflow/tensorflow/contrib/verbs/ |
| D | grpc_verbs_service.h | 47 ::grpc::ServerCompletionQueue* cq_;
|
| D | grpc_verbs_service_impl.h | 70 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestGetRemoteAddress()
|
| /external/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()
|