Searched refs:cli_cqs_ (Results 1 – 1 of 1) sorted by relevance
174 cli_cqs_.emplace_back(new CompletionQueue); in AsyncClient()178 cq_.emplace_back(i % cli_cqs_.size()); in AsyncClient()186 auto* cq = cli_cqs_[t].get(); in AsyncClient()191 t = (t + 1) % cli_cqs_.size(); in AsyncClient()195 for (auto cq = cli_cqs_.begin(); cq != cli_cqs_.end(); cq++) { in ~AsyncClient()206 for (auto cq = cli_cqs_.begin(); cq != cli_cqs_.end(); cq++) { in GetPollCount()235 for (auto cq = cli_cqs_.begin(); cq != cli_cqs_.end(); cq++) { in DestroyMultithreading()247 while (cli_cqs_[cq_[thread_idx]]->Next(&tag, &ok)) { in ProcessTag()263 if (!cli_cqs_[cq_[thread_idx]]->Next(&got_tag, &ok)) { in ThreadFunc()273 while (cli_cqs_[cq_[thread_idx]]->DoThenAsyncNext( in ThreadFunc()[all …]