Lines Matching refs:ws
73 static int compression_compress_pages(int type, struct list_head *ws, in compression_compress_pages() argument
80 return zlib_compress_pages(ws, mapping, start, pages, in compression_compress_pages()
83 return lzo_compress_pages(ws, mapping, start, pages, in compression_compress_pages()
86 return zstd_compress_pages(ws, mapping, start, pages, in compression_compress_pages()
104 static int compression_decompress_bio(struct list_head *ws, in compression_decompress_bio() argument
108 case BTRFS_COMPRESS_ZLIB: return zlib_decompress_bio(ws, cb); in compression_decompress_bio()
109 case BTRFS_COMPRESS_LZO: return lzo_decompress_bio(ws, cb); in compression_decompress_bio()
110 case BTRFS_COMPRESS_ZSTD: return zstd_decompress_bio(ws, cb); in compression_decompress_bio()
121 static int compression_decompress(int type, struct list_head *ws, in compression_decompress() argument
126 case BTRFS_COMPRESS_ZLIB: return zlib_decompress(ws, data_in, dest_page, in compression_decompress()
128 case BTRFS_COMPRESS_LZO: return lzo_decompress(ws, data_in, dest_page, in compression_decompress()
130 case BTRFS_COMPRESS_ZSTD: return zstd_decompress(ws, data_in, dest_page, in compression_decompress()
701 static void free_heuristic_ws(struct list_head *ws) in free_heuristic_ws() argument
705 workspace = list_entry(ws, struct heuristic_ws, list); in free_heuristic_ws()
715 struct heuristic_ws *ws; in alloc_heuristic_ws() local
717 ws = kzalloc(sizeof(*ws), GFP_KERNEL); in alloc_heuristic_ws()
718 if (!ws) in alloc_heuristic_ws()
721 ws->sample = kvmalloc(MAX_SAMPLE_SIZE, GFP_KERNEL); in alloc_heuristic_ws()
722 if (!ws->sample) in alloc_heuristic_ws()
725 ws->bucket = kcalloc(BUCKET_SIZE, sizeof(*ws->bucket), GFP_KERNEL); in alloc_heuristic_ws()
726 if (!ws->bucket) in alloc_heuristic_ws()
729 ws->bucket_b = kcalloc(BUCKET_SIZE, sizeof(*ws->bucket_b), GFP_KERNEL); in alloc_heuristic_ws()
730 if (!ws->bucket_b) in alloc_heuristic_ws()
733 INIT_LIST_HEAD(&ws->list); in alloc_heuristic_ws()
734 return &ws->list; in alloc_heuristic_ws()
736 free_heuristic_ws(&ws->list); in alloc_heuristic_ws()
768 static void free_workspace(int type, struct list_head *ws) in free_workspace() argument
771 case BTRFS_COMPRESS_NONE: return free_heuristic_ws(ws); in free_workspace()
772 case BTRFS_COMPRESS_ZLIB: return zlib_free_workspace(ws); in free_workspace()
773 case BTRFS_COMPRESS_LZO: return lzo_free_workspace(ws); in free_workspace()
774 case BTRFS_COMPRESS_ZSTD: return zstd_free_workspace(ws); in free_workspace()
813 struct list_head *ws; in btrfs_cleanup_workspace_manager() local
817 ws = wsman->idle_ws.next; in btrfs_cleanup_workspace_manager()
818 list_del(ws); in btrfs_cleanup_workspace_manager()
819 free_workspace(type, ws); in btrfs_cleanup_workspace_manager()
929 void btrfs_put_workspace(int type, struct list_head *ws) in btrfs_put_workspace() argument
947 list_add(ws, idle_ws); in btrfs_put_workspace()
954 free_workspace(type, ws); in btrfs_put_workspace()
960 static void put_workspace(int type, struct list_head *ws) in put_workspace() argument
963 case BTRFS_COMPRESS_NONE: return btrfs_put_workspace(type, ws); in put_workspace()
964 case BTRFS_COMPRESS_ZLIB: return btrfs_put_workspace(type, ws); in put_workspace()
965 case BTRFS_COMPRESS_LZO: return btrfs_put_workspace(type, ws); in put_workspace()
966 case BTRFS_COMPRESS_ZSTD: return zstd_put_workspace(ws); in put_workspace()
1194 static u32 shannon_entropy(struct heuristic_ws *ws) in shannon_entropy() argument
1201 sz_base = ilog2_w(ws->sample_size); in shannon_entropy()
1202 for (i = 0; i < BUCKET_SIZE && ws->bucket[i].count > 0; i++) { in shannon_entropy()
1203 p = ws->bucket[i].count; in shannon_entropy()
1208 entropy_sum /= ws->sample_size; in shannon_entropy()
1330 static int byte_core_set_size(struct heuristic_ws *ws) in byte_core_set_size() argument
1334 const u32 core_set_threshold = ws->sample_size * 90 / 100; in byte_core_set_size()
1335 struct bucket_item *bucket = ws->bucket; in byte_core_set_size()
1338 radix_sort(ws->bucket, ws->bucket_b, BUCKET_SIZE); in byte_core_set_size()
1368 static u32 byte_set_size(const struct heuristic_ws *ws) in byte_set_size() argument
1374 if (ws->bucket[i].count > 0) in byte_set_size()
1384 if (ws->bucket[i].count > 0) { in byte_set_size()
1394 static bool sample_repeated_patterns(struct heuristic_ws *ws) in sample_repeated_patterns() argument
1396 const u32 half_of_sample = ws->sample_size / 2; in sample_repeated_patterns()
1397 const u8 *data = ws->sample; in sample_repeated_patterns()
1403 struct heuristic_ws *ws) in heuristic_collect_sample() argument
1439 memcpy(&ws->sample[curr_sample_pos], &in_data[i], in heuristic_collect_sample()
1451 ws->sample_size = curr_sample_pos; in heuristic_collect_sample()
1472 struct heuristic_ws *ws; in btrfs_compress_heuristic() local
1477 ws = list_entry(ws_list, struct heuristic_ws, list); in btrfs_compress_heuristic()
1479 heuristic_collect_sample(inode, start, end, ws); in btrfs_compress_heuristic()
1481 if (sample_repeated_patterns(ws)) { in btrfs_compress_heuristic()
1486 memset(ws->bucket, 0, sizeof(*ws->bucket)*BUCKET_SIZE); in btrfs_compress_heuristic()
1488 for (i = 0; i < ws->sample_size; i++) { in btrfs_compress_heuristic()
1489 byte = ws->sample[i]; in btrfs_compress_heuristic()
1490 ws->bucket[byte].count++; in btrfs_compress_heuristic()
1493 i = byte_set_size(ws); in btrfs_compress_heuristic()
1499 i = byte_core_set_size(ws); in btrfs_compress_heuristic()
1510 i = shannon_entropy(ws); in btrfs_compress_heuristic()