Searched refs:cqs_ (Results 1 – 3 of 3) sorted by relevance
| /external/grpc-grpc/test/cpp/end2end/ |
| D | hybrid_end2end_test.cc | 259 cqs_.push_back(builder.AddCompletionQueue(false)); in SetUpServer()
270 for (auto it = cqs_.begin(); it != cqs_.end(); ++it) { in TearDown()
410 std::vector<std::unique_ptr<ServerCompletionQueue>> cqs_; member in grpc::testing::__anon28d039b20111::HybridEnd2endTest
421 std::thread echo_handler_thread(HandleEcho<SType>, &service, cqs_[0].get(), in TEST_F()
432 std::thread echo_handler_thread(HandleRawEcho<SType>, &service, cqs_[0].get(), in TEST_F()
444 &service, cqs_[0].get()); in TEST_F()
456 std::thread echo_handler_thread(HandleEcho<SType>, &service, cqs_[0].get(), in TEST_F()
459 &service, cqs_[1].get()); in TEST_F()
474 cqs_[0].get()); in TEST_F()
476 &service, cqs_[1].get()); in TEST_F()
[all …]
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_builder.cc | 75 cqs_.push_back(cq); in AddCompletionQueue()
244 for (auto it = cqs_.begin(); it != cqs_.end(); ++it) { in BuildAndStart()
296 for (auto it = cqs_.begin(); it != cqs_.end(); ++it) { in BuildAndStart()
344 auto cqs_data = cqs_.empty() ? nullptr : &cqs_[0]; in BuildAndStart()
345 server->Start(cqs_data, cqs_.size()); in BuildAndStart()
|
| /external/grpc-grpc/include/grpcpp/ |
| D | server_builder.h | 285 std::vector<ServerCompletionQueue*> cqs_; variable
|