Searched refs:num_compress_threads_ (Results 1 – 2 of 2) sorted by relevance
160 num_compress_threads_ = options_.num_compress_threads; in SetupWriteOptions()162 if (!num_compress_threads_) { in SetupWriteOptions()163 num_compress_threads_ = 1; in SetupWriteOptions()168 num_compress_threads_ = 2; in SetupWriteOptions()278 if (num_compress_threads_ <= 1) { in InitWorkers()282 for (int i = 0; i < num_compress_threads_; i++) { in InitWorkers()288 LOG(INFO) << num_compress_threads_ << " thread used for compression"; in InitWorkers()449 size_t num_threads = (num_blocks == 1) ? 1 : num_compress_threads_; in CompressBlocks()500 if (compression_ && num_compress_threads_ > 1) { in EmitBlocks()522 if (num_compress_threads_ > 1) { in EmitBlocks()
229 int num_compress_threads_ = 1; variable