Home
last modified time | relevance | path

Searched refs:cqs_ (Results 1 – 6 of 6) sorted by relevance

/third_party/grpc/test/cpp/end2end/
Dhybrid_end2end_test.cc290 cqs_.push_back(builder.AddCompletionQueue(false)); in SetUpServer()
306 for (auto it = cqs_.begin(); it != cqs_.end(); ++it) { in TearDown()
448 std::vector<std::unique_ptr<ServerCompletionQueue>> cqs_; member in grpc::testing::__anon3c9619430111::HybridEnd2endTest
460 std::thread echo_handler_thread(HandleEcho<SType>, &service, cqs_[0].get(), in TEST_F()
471 std::thread echo_handler_thread(HandleRawEcho<SType>, &service, cqs_[0].get(), in TEST_F()
483 &service, cqs_[0].get()); in TEST_F()
495 std::thread echo_handler_thread(HandleEcho<SType>, &service, cqs_[0].get(), in TEST_F()
498 &service, cqs_[1].get()); in TEST_F()
513 cqs_[0].get()); in TEST_F()
515 &service, cqs_[1].get()); in TEST_F()
[all …]
/third_party/grpc/src/cpp/server/
Dserver_builder.cc77 cqs_.push_back(cq); in AddCompletionQueue()
290 for (const auto& cq : cqs_) { in BuildAndStart()
367 for (const auto& cq : cqs_) { in BuildAndStart()
423 auto cqs_data = cqs_.empty() ? nullptr : &cqs_[0]; in BuildAndStart()
424 server->Start(cqs_data, cqs_.size()); in BuildAndStart()
/third_party/grpc/src/core/lib/surface/
Dserver.cc197 : server_(server), requests_per_cq_(server->cqs_.size()) {} in RealRequestMatcher()
327 for (idx = 0; idx < server->cqs_.size(); idx++) { in AllocatingRequestMatcherBase()
328 if (server->cqs_[idx] == cq) { in AllocatingRequestMatcherBase()
332 GPR_ASSERT(idx < server->cqs_.size()); in AllocatingRequestMatcherBase()
549 for (size_t i = 0; i < cqs_.size(); i++) { in ~Server()
550 GRPC_CQ_INTERNAL_UNREF(cqs_[i], "server"); in ~Server()
565 for (grpc_completion_queue* cq : cqs_) { in Start()
617 for (cq_idx = 0; cq_idx < cqs_.size(); cq_idx++) { in SetupTransport()
618 if (grpc_cq_pollset(cqs_[cq_idx]) == accepting_pollset) break; in SetupTransport()
620 if (cq_idx == cqs_.size()) { in SetupTransport()
[all …]
Dserver.h364 std::vector<grpc_completion_queue*> cqs_; variable
/third_party/grpc/include/grpcpp/
Dserver_builder_impl.h386 std::vector<grpc_impl::ServerCompletionQueue*> cqs_; variable
Dserver_builder.h391 std::vector<grpc::ServerCompletionQueue*> cqs_; variable