Blame view
fs/squashfs/decompressor_multi_percpu.c
2.19 KB
20c8ccb19 treewide: Replace... |
1 |
// SPDX-License-Identifier: GPL-2.0-only |
d208383d6 Squashfs: add mul... |
2 3 4 |
/* * Copyright (c) 2013 * Phillip Lougher <phillip@squashfs.org.uk> |
d208383d6 Squashfs: add mul... |
5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 |
*/ #include <linux/types.h> #include <linux/slab.h> #include <linux/percpu.h> #include <linux/buffer_head.h> #include "squashfs_fs.h" #include "squashfs_fs_sb.h" #include "decompressor.h" #include "squashfs.h" /* * This file implements multi-threaded decompression using percpu * variables, one thread per cpu core. */ struct squashfs_stream { void *stream; }; void *squashfs_decompressor_create(struct squashfs_sb_info *msblk, void *comp_opts) { struct squashfs_stream *stream; struct squashfs_stream __percpu *percpu; int err, cpu; percpu = alloc_percpu(struct squashfs_stream); if (percpu == NULL) return ERR_PTR(-ENOMEM); for_each_possible_cpu(cpu) { stream = per_cpu_ptr(percpu, cpu); stream->stream = msblk->decompressor->init(msblk, comp_opts); if (IS_ERR(stream->stream)) { err = PTR_ERR(stream->stream); goto out; } } kfree(comp_opts); return (__force void *) percpu; out: for_each_possible_cpu(cpu) { stream = per_cpu_ptr(percpu, cpu); if (!IS_ERR_OR_NULL(stream->stream)) msblk->decompressor->free(stream->stream); } free_percpu(percpu); return ERR_PTR(err); } void squashfs_decompressor_destroy(struct squashfs_sb_info *msblk) { struct squashfs_stream __percpu *percpu = (struct squashfs_stream __percpu *) msblk->stream; struct squashfs_stream *stream; int cpu; if (msblk->stream) { for_each_possible_cpu(cpu) { stream = per_cpu_ptr(percpu, cpu); msblk->decompressor->free(stream->stream); } free_percpu(percpu); } } |
846b730e9 Squashfs: General... |
74 75 |
int squashfs_decompress(struct squashfs_sb_info *msblk, struct buffer_head **bh, int b, int offset, int length, struct squashfs_page_actor *output) |
d208383d6 Squashfs: add mul... |
76 77 78 79 |
{ struct squashfs_stream __percpu *percpu = (struct squashfs_stream __percpu *) msblk->stream; struct squashfs_stream *stream = get_cpu_ptr(percpu); |
846b730e9 Squashfs: General... |
80 81 |
int res = msblk->decompressor->decompress(msblk, stream->stream, bh, b, offset, length, output); |
d208383d6 Squashfs: add mul... |
82 83 84 85 86 87 88 89 90 91 92 93 94 95 |
put_cpu_ptr(stream); if (res < 0) ERROR("%s decompression failed, data probably corrupt ", msblk->decompressor->name); return res; } int squashfs_max_decompressors(void) { return num_possible_cpus(); } |