Searched refs:queue_ (Results 1 – 5 of 5) sorted by relevance
81 for (auto& r : queue_[Env::IO_HIGH]) { in ~GenericRateLimiter()84 for (auto& r : queue_[Env::IO_LOW]) { in ~GenericRateLimiter()135 queue_[pri].push_back(&r); in Request()146 ((!queue_[Env::IO_HIGH].empty() && in Request()148 (!queue_[Env::IO_LOW].empty() && in Request()175 (!queue_[Env::IO_HIGH].empty() && in Request()177 (!queue_[Env::IO_LOW].empty() && in Request()180 (!queue_[Env::IO_HIGH].empty() && in Request()182 (!queue_[Env::IO_LOW].empty() && in Request()203 if (!queue_[Env::IO_HIGH].empty()) { in Request()[all …]
122 BGQueue queue_; member141 queue_(), in Impl()203 queue_.empty()) { in BGThread()223 auto func = std::move(queue_.front().function); in BGThread()224 queue_.pop_front(); in BGThread()370 queue_.push_back(BGItem()); in Submit()372 auto& item = queue_.back(); in Submit()377 queue_len_.store(static_cast<unsigned int>(queue_.size()), in Submit()398 BGQueue::iterator it = queue_.begin(); in UnSchedule()399 while (it != queue_.end()) { in UnSchedule()[all …]
104 std::deque<Req*> queue_[Env::IO_TOTAL]; variable
94 queue_.emplace(trash_file, dir_to_sync); in DeleteFile()195 while (queue_.empty() && !closing_) { in BackgroundEmptyTrash()207 while (!queue_.empty() && !closing_) { in BackgroundEmptyTrash()216 const FileAndDir& fad = queue_.front(); in BackgroundEmptyTrash()229 queue_.pop(); in BackgroundEmptyTrash()
114 std::queue<FileAndDir> queue_; variable