fs/f2fs/compress.c

1054 			struct compress_io_ctx *cic, int submitted)
1061 		while (atomic_read(&cic->pending_pages) !=
1290 	struct compress_io_ctx *cic;
1335 	cic = f2fs_kmem_cache_alloc(cic_entry_slab, GFP_F2FS_ZERO, false, sbi);
1336 	if (!cic)
1339 	cic->magic = F2FS_COMPRESSED_PAGE_MAGIC;
1340 	cic->inode = inode;
1341 	atomic_set(&cic->pending_pages, cc->valid_nr_cpages);
1342 	cic->rpages = page_array_alloc(sbi, cc->cluster_size);
1343 	if (!cic->rpages)
1346 	cic->nr_rpages = cc->cluster_size;
1350 				page_folio(cc->rpages[i + 1])->index, cic);
1371 		cic->rpages[i] = cc->rpages[i];
1412 			cancel_cluster_writeback(cc, cic, i);
1450 	page_array_free(sbi, cic->rpages, cc->cluster_size);
1458 	kmem_cache_free(cic_entry_slab, cic);
1480 	struct compress_io_ctx *cic = folio->private;
1486 		mapping_set_error(cic->inode->i_mapping, -EIO);
1492 	if (atomic_dec_return(&cic->pending_pages))
1495 	for (i = 0; i < cic->nr_rpages; i++) {
1496 		WARN_ON(!cic->rpages[i]);
1497 		clear_page_private_gcing(cic->rpages[i]);
1498 		end_page_writeback(cic->rpages[i]);
1501 	page_array_free(sbi, cic->rpages, cic->nr_rpages);
1502 	kmem_cache_free(cic_entry_slab, cic);