Searched refs:compress_threads_ (Results 1 – 2 of 2) sorted by relevance
141 for (size_t i = 0; i < compress_threads_.size(); i++) { in ~CowWriter()142 CompressWorker* worker = compress_threads_[i].get(); in ~CowWriter()156 compress_threads_.clear(); in ~CowWriter()285 compress_threads_.push_back(std::move(wt)); in InitWorkers()321 if (ret && !compress_threads_.size()) { in InitializeAppend()463 CompressWorker* worker = compress_threads_[i].get(); in CompressBlocks()473 CompressWorker* worker = compress_threads_[i].get(); in CompressBlocks()
230 std::vector<std::unique_ptr<CompressWorker>> compress_threads_; variable