Searched refs:quePool_ (Results 1 – 2 of 2) sorted by relevance
31 for (auto que : quePool_) { in ~BlockQueuePool()129 if (quePool_.count(queueIndex) == 0) { in ResetQueue()138 quePool_[queueIndex].dataSize = 0; in ResetQueue()139 quePool_[queueIndex].isValid = true; in ResetQueue()147 quePool_[queueIndex].blockQue = nullptr; in FreeQueue()212 quePool_[queIndex].dataSize = in Pop()213 quePool_[queIndex].dataSize >= pktSize ? quePool_[queIndex].dataSize -= pktSize : 0; in Pop()267 … if (quePool_[lastQueIndex].blockQue != nullptr && quePool_[lastQueIndex].blockQue->Size() > 0) { in Back()280 for (auto pair : quePool_) { in GetValidQueue()286 quePool_[queCount_] = { in GetValidQueue()[all …]
52 : name_(std::move(name)), quePool_(), queMap_(), sizeMap_(), singleQueSize_(singleQueSize)77 std::map<uint32_t, InnerQueue> quePool_; variable