612 	struct crc_data *d = data;  in crc32_threadfn()  local
616 		wait_event(d->go, atomic_read_acquire(&d->ready) ||  in crc32_threadfn()
619 			d->thr = NULL;  in crc32_threadfn()
620 			atomic_set_release(&d->stop, 1);  in crc32_threadfn()
621 			wake_up(&d->done);  in crc32_threadfn()
624 		atomic_set(&d->ready, 0);  in crc32_threadfn()
626 		for (i = 0; i < d->run_threads; i++)  in crc32_threadfn()
627 			*d->crc32 = crc32_le(*d->crc32,  in crc32_threadfn()
628 			                     d->unc[i], *d->unc_len[i]);  in crc32_threadfn()
629 		atomic_set_release(&d->stop, 1);  in crc32_threadfn()
630 		wake_up(&d->done);  in crc32_threadfn()
656 	struct cmp_data *d = data;  in lzo_compress_threadfn()  local
659 		wait_event(d->go, atomic_read_acquire(&d->ready) ||  in lzo_compress_threadfn()
662 			d->thr = NULL;  in lzo_compress_threadfn()
663 			d->ret = -1;  in lzo_compress_threadfn()
664 			atomic_set_release(&d->stop, 1);  in lzo_compress_threadfn()
665 			wake_up(&d->done);  in lzo_compress_threadfn()
668 		atomic_set(&d->ready, 0);  in lzo_compress_threadfn()
670 		d->ret = lzo1x_1_compress(d->unc, d->unc_len,  in lzo_compress_threadfn()
671 		                          d->cmp + LZO_HEADER, &d->cmp_len,  in lzo_compress_threadfn()
672 		                          d->wrk);  in lzo_compress_threadfn()
673 		atomic_set_release(&d->stop, 1);  in lzo_compress_threadfn()
674 		wake_up(&d->done);  in lzo_compress_threadfn()
1140 	struct dec_data *d = data;  in lzo_decompress_threadfn()  local
1143 		wait_event(d->go, atomic_read_acquire(&d->ready) ||  in lzo_decompress_threadfn()
1146 			d->thr = NULL;  in lzo_decompress_threadfn()
1147 			d->ret = -1;  in lzo_decompress_threadfn()
1148 			atomic_set_release(&d->stop, 1);  in lzo_decompress_threadfn()
1149 			wake_up(&d->done);  in lzo_decompress_threadfn()
1152 		atomic_set(&d->ready, 0);  in lzo_decompress_threadfn()
1154 		d->unc_len = LZO_UNC_SIZE;  in lzo_decompress_threadfn()
1155 		d->ret = lzo1x_decompress_safe(d->cmp + LZO_HEADER, d->cmp_len,  in lzo_decompress_threadfn()
1156 		                               d->unc, &d->unc_len);  in lzo_decompress_threadfn()
1158 			flush_icache_range((unsigned long)d->unc,  in lzo_decompress_threadfn()
1159 					   (unsigned long)d->unc + d->unc_len);  in lzo_decompress_threadfn()
1161 		atomic_set_release(&d->stop, 1);  in lzo_decompress_threadfn()
1162 		wake_up(&d->done);  in lzo_decompress_threadfn()