Searched refs:requests_per_cq_ (Results 1 – 1 of 1) sorted by relevance
197 : server_(server), requests_per_cq_(server->cqs_.size()) {} in RealRequestMatcher()200 for (LockedMultiProducerSingleConsumerQueue& queue : requests_per_cq_) { in ~RealRequestMatcher()215 for (size_t i = 0; i < requests_per_cq_.size(); i++) { in KillRequests()218 requests_per_cq_[i].Pop())) != nullptr) { in KillRequests()226 return requests_per_cq_.size(); in request_queue_count()231 if (requests_per_cq_[request_queue_index].Push(&call->mpscq_node)) { in RequestCallWithPossiblePublish()244 requests_per_cq_[request_queue_index].Pop()); in RequestCallWithPossiblePublish()268 for (size_t i = 0; i < requests_per_cq_.size(); i++) { in MatchOrQueue()269 size_t cq_idx = (start_request_queue_index + i) % requests_per_cq_.size(); in MatchOrQueue()271 reinterpret_cast<RequestedCall*>(requests_per_cq_[cq_idx].TryPop()); in MatchOrQueue()[all …]