Searched refs:compressed_queue_ (Results 1 – 2 of 2) sorted by relevance
156 compressed_queue_.push(std::move(blocks)); in RunThread()186 while (compressed_queue_.empty() && !stopped_) { in GetCompressedBuffers()197 while (compressed_queue_.size() > 0) { in GetCompressedBuffers()198 CompressWork blocks = std::move(compressed_queue_.front()); in GetCompressedBuffers()199 compressed_queue_.pop(); in GetCompressedBuffers()
142 std::queue<CompressWork> compressed_queue_; variable