Searched refs:CompressWorker (Results 1 – 6 of 6) sorted by relevance
| /system/core/fs_mgr/libsnapshot/libsnapshot_cow/ |
| D | cow_compress.cpp | 82 uint32_t CompressWorker::GetDefaultCompressionLevel(CowCompressionAlgorithm compression) { in GetDefaultCompressionLevel()
213 bool CompressWorker::CompressBlocks(const void* buffer, size_t num_blocks, size_t block_size, in CompressBlocks()
218 bool CompressWorker::CompressBlocks(ICompressor* compressor, size_t block_size, const void* buffer, in CompressBlocks()
240 bool CompressWorker::RunThread() { in RunThread()
279 void CompressWorker::EnqueueCompressBlocks(const void* buffer, size_t block_size, in EnqueueCompressBlocks()
294 bool CompressWorker::GetCompressedBuffers(std::vector<std::vector<uint8_t>>* compressed_buf) { in GetCompressedBuffers()
342 void CompressWorker::Finalize() { in Finalize()
350 CompressWorker::CompressWorker(std::unique_ptr<ICompressor>&& compressor) in CompressWorker() function in android::snapshot::CompressWorker
|
| D | writer_v2.cpp | 69 CompressWorker* worker = compress_threads_[i].get(); in ~CowWriterV2()
143 CompressWorker::GetDefaultCompressionLevel(algorithm.value()); in ParseOptions()
188 auto wt = std::make_unique<CompressWorker>(std::move(compressor)); in InitWorkers()
189 threads_.emplace_back(std::async(std::launch::async, &CompressWorker::RunThread, wt.get())); in InitWorkers()
344 return CompressWorker::CompressBlocks(compressor_.get(), options_.block_size, data, in CompressBlocks()
352 CompressWorker* worker = compress_threads_[i].get(); in CompressBlocks()
362 CompressWorker* worker = compress_threads_[i].get(); in CompressBlocks()
|
| D | writer_v2.h | 82 std::vector<std::unique_ptr<CompressWorker>> compress_threads_;
|
| D | writer_v3.cpp | 84 std::make_unique<CompressWorker>(std::move(compressor))); in InitWorkers()
158 CompressWorker::GetDefaultCompressionLevel(algorithm.value()); in ParseOptions()
615 CompressWorker* worker = compress_threads_[iteration % num_threads].get(); in ProcessBlocksWithThreadedCompression()
633 CompressWorker* worker = compress_threads_[i].get(); in ProcessBlocksWithThreadedCompression()
|
| D | writer_v3.h | 106 std::vector<std::unique_ptr<CompressWorker>> compress_threads_;
|
| /system/core/fs_mgr/libsnapshot/include/libsnapshot/ |
| D | cow_writer.h | 120 class CompressWorker {
122 CompressWorker(std::unique_ptr<ICompressor>&& compressor);
|