| /fs/squashfs/ |
| D | decompressor_multi.c | 48 void *stream; member
54 struct squashfs_stream *stream) in put_decomp_stream() argument
56 mutex_lock(&stream->mutex); in put_decomp_stream()
57 list_add(&decomp_strm->list, &stream->strm_list); in put_decomp_stream()
58 mutex_unlock(&stream->mutex); in put_decomp_stream()
59 wake_up(&stream->wait); in put_decomp_stream()
65 struct squashfs_stream *stream; in squashfs_decompressor_create() local
69 stream = kzalloc(sizeof(*stream), GFP_KERNEL); in squashfs_decompressor_create()
70 if (!stream) in squashfs_decompressor_create()
73 stream->comp_opts = comp_opts; in squashfs_decompressor_create()
[all …]
|
| D | xz_wrapper.c | 84 struct squashfs_xz *stream; in squashfs_xz_init() local
87 stream = kmalloc(sizeof(*stream), GFP_KERNEL); in squashfs_xz_init()
88 if (stream == NULL) { in squashfs_xz_init()
93 stream->state = xz_dec_init(XZ_PREALLOC, comp_opts->dict_size); in squashfs_xz_init()
94 if (stream->state == NULL) { in squashfs_xz_init()
95 kfree(stream); in squashfs_xz_init()
100 return stream; in squashfs_xz_init()
110 struct squashfs_xz *stream = strm; in squashfs_xz_free() local
112 if (stream) { in squashfs_xz_free()
113 xz_dec_end(stream->state); in squashfs_xz_free()
[all …]
|
| D | decompressor_single.c | 23 void *stream; member
30 struct squashfs_stream *stream; in squashfs_decompressor_create() local
33 stream = kmalloc(sizeof(*stream), GFP_KERNEL); in squashfs_decompressor_create()
34 if (stream == NULL) in squashfs_decompressor_create()
37 stream->stream = msblk->decompressor->init(msblk, comp_opts); in squashfs_decompressor_create()
38 if (IS_ERR(stream->stream)) { in squashfs_decompressor_create()
39 err = PTR_ERR(stream->stream); in squashfs_decompressor_create()
44 mutex_init(&stream->mutex); in squashfs_decompressor_create()
45 return stream; in squashfs_decompressor_create()
48 kfree(stream); in squashfs_decompressor_create()
[all …]
|
| D | decompressor_multi_percpu.c | 24 void *stream; member
31 struct squashfs_stream *stream; in squashfs_decompressor_create() local
40 stream = per_cpu_ptr(percpu, cpu); in squashfs_decompressor_create()
41 stream->stream = msblk->decompressor->init(msblk, comp_opts); in squashfs_decompressor_create()
42 if (IS_ERR(stream->stream)) { in squashfs_decompressor_create()
43 err = PTR_ERR(stream->stream); in squashfs_decompressor_create()
46 local_lock_init(&stream->lock); in squashfs_decompressor_create()
54 stream = per_cpu_ptr(percpu, cpu); in squashfs_decompressor_create()
55 if (!IS_ERR_OR_NULL(stream->stream)) in squashfs_decompressor_create()
56 msblk->decompressor->free(stream->stream); in squashfs_decompressor_create()
[all …]
|
| D | zlib_wrapper.c | 26 z_stream *stream = kmalloc(sizeof(z_stream), GFP_KERNEL); in zlib_init() local
27 if (stream == NULL) in zlib_init()
29 stream->workspace = vmalloc(zlib_inflate_workspacesize()); in zlib_init()
30 if (stream->workspace == NULL) in zlib_init()
33 return stream; in zlib_init()
37 kfree(stream); in zlib_init()
44 z_stream *stream = strm; in zlib_free() local
46 if (stream) in zlib_free()
47 vfree(stream->workspace); in zlib_free()
48 kfree(stream); in zlib_free()
[all …]
|
| D | lz4_wrapper.c | 55 struct squashfs_lz4 *stream; in lz4_init() local
57 stream = kzalloc(sizeof(*stream), GFP_KERNEL); in lz4_init()
58 if (stream == NULL) in lz4_init()
60 stream->input = vmalloc(block_size); in lz4_init()
61 if (stream->input == NULL) in lz4_init()
63 stream->output = vmalloc(block_size); in lz4_init()
64 if (stream->output == NULL) in lz4_init()
67 return stream; in lz4_init()
70 vfree(stream->input); in lz4_init()
72 kfree(stream); in lz4_init()
[all …]
|
| D | lzo_wrapper.c | 32 struct squashfs_lzo *stream = kzalloc(sizeof(*stream), GFP_KERNEL); in lzo_init() local
33 if (stream == NULL) in lzo_init()
35 stream->input = vmalloc(block_size); in lzo_init()
36 if (stream->input == NULL) in lzo_init()
38 stream->output = vmalloc(block_size); in lzo_init()
39 if (stream->output == NULL) in lzo_init()
42 return stream; in lzo_init()
45 vfree(stream->input); in lzo_init()
48 kfree(stream); in lzo_init()
55 struct squashfs_lzo *stream = strm; in lzo_free() local
[all …]
|
| D | decompressor.c | 132 void *stream, *comp_opts = get_comp_opts(sb, flags); in squashfs_decompressor_setup() local
137 stream = squashfs_decompressor_create(msblk, comp_opts); in squashfs_decompressor_setup()
138 if (IS_ERR(stream)) in squashfs_decompressor_setup()
141 return stream; in squashfs_decompressor_setup()
|
| D | zstd_wrapper.c | 66 ZSTD_DStream *stream; in zstd_uncompress() local
74 stream = ZSTD_initDStream(wksp->window_size, wksp->mem, wksp->mem_size); in zstd_uncompress()
76 if (!stream) { in zstd_uncompress()
126 zstd_err = ZSTD_decompressStream(stream, &out_buf, &in_buf); in zstd_uncompress()
|
| D | super.c | 273 msblk->stream = squashfs_decompressor_setup(sb, flags); in squashfs_fill_super()
274 if (IS_ERR(msblk->stream)) { in squashfs_fill_super()
275 err = PTR_ERR(msblk->stream); in squashfs_fill_super()
276 msblk->stream = NULL; in squashfs_fill_super()
|
| /fs/cramfs/ |
| D | uncompress.c | 27 static z_stream stream; variable
35 stream.next_in = src; in cramfs_uncompress_block()
36 stream.avail_in = srclen; in cramfs_uncompress_block()
38 stream.next_out = dst; in cramfs_uncompress_block()
39 stream.avail_out = dstlen; in cramfs_uncompress_block()
41 err = zlib_inflateReset(&stream); in cramfs_uncompress_block()
44 zlib_inflateEnd(&stream); in cramfs_uncompress_block()
45 zlib_inflateInit(&stream); in cramfs_uncompress_block()
48 err = zlib_inflate(&stream, Z_FINISH); in cramfs_uncompress_block()
51 return stream.total_out; in cramfs_uncompress_block()
[all …]
|
| /fs/isofs/ |
| D | compress.c | 50 z_stream stream = { .total_out = 0, in zisofs_uncompress_block() local
105 stream.workspace = zisofs_zlib_workspace; in zisofs_uncompress_block()
108 zerr = zlib_inflateInit(&stream); in zisofs_uncompress_block()
121 if (!stream.avail_out) { in zisofs_uncompress_block()
123 stream.next_out = page_address(pages[curpage]) in zisofs_uncompress_block()
125 stream.avail_out = PAGE_SIZE - poffset; in zisofs_uncompress_block()
128 stream.next_out = (void *)&zisofs_sink_page; in zisofs_uncompress_block()
129 stream.avail_out = PAGE_SIZE; in zisofs_uncompress_block()
132 if (!stream.avail_in) { in zisofs_uncompress_block()
138 stream.next_in = bhs[curbh]->b_data + in zisofs_uncompress_block()
[all …]
|
| /fs/nfs/filelayout/ |
| D | filelayoutdev.c | 73 struct xdr_stream stream; in nfs4_fl_alloc_deviceid_node() local
84 xdr_init_decode_pages(&stream, &buf, pdev->pages, pdev->pglen); in nfs4_fl_alloc_deviceid_node()
85 xdr_set_scratch_page(&stream, scratch); in nfs4_fl_alloc_deviceid_node()
88 p = xdr_inline_decode(&stream, 4); in nfs4_fl_alloc_deviceid_node()
106 p = xdr_inline_decode(&stream, cnt << 2); in nfs4_fl_alloc_deviceid_node()
119 p = xdr_inline_decode(&stream, 4); in nfs4_fl_alloc_deviceid_node()
157 p = xdr_inline_decode(&stream, 4); in nfs4_fl_alloc_deviceid_node()
164 &stream, gfp_flags); in nfs4_fl_alloc_deviceid_node()
|
| D | filelayout.c | 655 struct xdr_stream stream; in filelayout_decode_layout() local
668 xdr_init_decode_pages(&stream, &buf, lgr->layoutp->pages, lgr->layoutp->len); in filelayout_decode_layout()
669 xdr_set_scratch_page(&stream, scratch); in filelayout_decode_layout()
673 p = xdr_inline_decode(&stream, NFS4_DEVICEID4_SIZE + 20); in filelayout_decode_layout()
717 p = xdr_inline_decode(&stream, 4); in filelayout_decode_layout()
727 p = xdr_inline_decode(&stream, fl->fh_array[i]->size); in filelayout_decode_layout()
|
| /fs/btrfs/ |
| D | zstd.c | 374 ZSTD_CStream *stream; in zstd_compress_pages() local
392 stream = ZSTD_initCStream(params, len, workspace->mem, in zstd_compress_pages()
394 if (!stream) { in zstd_compress_pages()
421 ret2 = ZSTD_compressStream(stream, &workspace->out_buf, in zstd_compress_pages()
490 ret2 = ZSTD_endStream(stream, &workspace->out_buf); in zstd_compress_pages()
551 ZSTD_DStream *stream; in zstd_decompress_bio() local
558 stream = ZSTD_initDStream( in zstd_decompress_bio()
560 if (!stream) { in zstd_decompress_bio()
577 ret2 = ZSTD_decompressStream(stream, &workspace->out_buf, in zstd_decompress_bio()
627 ZSTD_DStream *stream; in zstd_decompress() local
[all …]
|
| /fs/hostfs/ |
| D | hostfs_user.c | 100 void seek_dir(void *stream, unsigned long long pos) in seek_dir() argument
102 DIR *dir = stream; in seek_dir()
107 char *read_dir(void *stream, unsigned long long *pos_out, in read_dir() argument
111 DIR *dir = stream; in read_dir()
174 void close_file(void *stream) in close_file() argument
176 close(*((int *) stream)); in close_file()
179 void close_dir(void *stream) in close_dir() argument
181 closedir(stream); in close_dir()
|
| D | hostfs.h | 74 extern void seek_dir(void *stream, unsigned long long pos);
75 extern char *read_dir(void *stream, unsigned long long *pos_out,
78 extern void close_file(void *stream);
80 extern void close_dir(void *stream);
|
| /fs/ksmbd/ |
| D | vfs_cache.h | 43 struct stream { struct
97 struct stream stream; member
131 return fp->stream.name != NULL; in ksmbd_stream_fd()
|
| /fs/exfat/ |
| D | file.c | 176 ep2->dentry.stream.valid_size = 0; in __exfat_truncate()
177 ep2->dentry.stream.size = 0; in __exfat_truncate()
179 ep2->dentry.stream.valid_size = cpu_to_le64(new_size); in __exfat_truncate()
180 ep2->dentry.stream.size = ep2->dentry.stream.valid_size; in __exfat_truncate()
187 ep2->dentry.stream.flags = ALLOC_FAT_CHAIN; in __exfat_truncate()
188 ep2->dentry.stream.start_clu = EXFAT_FREE_CLUSTER; in __exfat_truncate()
|
| D | inode.c | 76 ep2->dentry.stream.valid_size = cpu_to_le64(on_disk_size); in __exfat_write_inode()
77 ep2->dentry.stream.size = ep2->dentry.stream.valid_size; in __exfat_write_inode()
232 ep->dentry.stream.flags = ei->flags; in exfat_map_cluster()
233 ep->dentry.stream.start_clu = in exfat_map_cluster()
235 ep->dentry.stream.valid_size = in exfat_map_cluster()
237 ep->dentry.stream.size = in exfat_map_cluster()
238 ep->dentry.stream.valid_size; in exfat_map_cluster()
|
| D | dir.c | 167 le64_to_cpu(ep->dentry.stream.valid_size); in exfat_readdir()
415 ep->dentry.stream.flags = flags; in exfat_init_stream_entry()
416 ep->dentry.stream.start_clu = cpu_to_le32(start_clu); in exfat_init_stream_entry()
417 ep->dentry.stream.valid_size = cpu_to_le64(size); in exfat_init_stream_entry()
418 ep->dentry.stream.size = cpu_to_le64(size); in exfat_init_stream_entry()
550 ep->dentry.stream.name_len = p_uniname->name_len; in exfat_init_ext_entry()
551 ep->dentry.stream.name_hash = cpu_to_le16(p_uniname->name_hash); in exfat_init_ext_entry()
1023 ep->dentry.stream.name_hash); in exfat_find_dir_entry()
1026 ep->dentry.stream.name_len) { in exfat_find_dir_entry()
|
| D | namei.c | 397 ep->dentry.stream.valid_size = cpu_to_le64(size); in exfat_find_empty_entry()
398 ep->dentry.stream.size = ep->dentry.stream.valid_size; in exfat_find_empty_entry()
399 ep->dentry.stream.flags = p_dir->flags; in exfat_find_empty_entry()
657 info->size = le64_to_cpu(ep2->dentry.stream.valid_size); in exfat_find()
662 info->flags = ep2->dentry.stream.flags; in exfat_find()
664 le32_to_cpu(ep2->dentry.stream.start_clu); in exfat_find()
|
| /fs/nfs/flexfilelayout/ |
| D | flexfilelayoutdev.c | 45 struct xdr_stream stream; in nfs4_ff_alloc_deviceid_node() local
71 xdr_init_decode_pages(&stream, &buf, pdev->pages, pdev->pglen); in nfs4_ff_alloc_deviceid_node()
72 xdr_set_scratch_page(&stream, scratch); in nfs4_ff_alloc_deviceid_node()
75 p = xdr_inline_decode(&stream, 4); in nfs4_ff_alloc_deviceid_node()
84 &stream, gfp_flags); in nfs4_ff_alloc_deviceid_node()
96 p = xdr_inline_decode(&stream, 4); in nfs4_ff_alloc_deviceid_node()
111 p = xdr_inline_decode(&stream, 20); in nfs4_ff_alloc_deviceid_node()
|
| D | flexfilelayout.c | 366 struct xdr_stream stream; in ff_layout_alloc_lseg() local
379 xdr_init_decode_pages(&stream, &buf, lgr->layoutp->pages, in ff_layout_alloc_lseg()
381 xdr_set_scratch_page(&stream, scratch); in ff_layout_alloc_lseg()
385 p = xdr_inline_decode(&stream, 8 + 4); in ff_layout_alloc_lseg()
417 p = xdr_inline_decode(&stream, 4); in ff_layout_alloc_lseg()
435 rc = decode_deviceid(&stream, &fls->mirror_array[i]->devid); in ff_layout_alloc_lseg()
441 p = xdr_inline_decode(&stream, 4); in ff_layout_alloc_lseg()
447 rc = decode_pnfs_stateid(&stream, &fls->mirror_array[i]->stateid); in ff_layout_alloc_lseg()
453 p = xdr_inline_decode(&stream, 4); in ff_layout_alloc_lseg()
467 rc = decode_nfs_fh(&stream, in ff_layout_alloc_lseg()
[all …]
|
| /fs/f2fs/ |
| D | compress.c | 339 ZSTD_CStream *stream; in zstd_init_compress_ctx() local
356 stream = ZSTD_initCStream(params, 0, workspace, workspace_size); in zstd_init_compress_ctx()
357 if (!stream) { in zstd_init_compress_ctx()
366 cc->private2 = stream; in zstd_init_compress_ctx()
381 ZSTD_CStream *stream = cc->private2; in zstd_compress_pages() local
396 ret = ZSTD_compressStream(stream, &outbuf, &inbuf); in zstd_compress_pages()
404 ret = ZSTD_endStream(stream, &outbuf); in zstd_compress_pages()
425 ZSTD_DStream *stream; in zstd_init_decompress_ctx() local
438 stream = ZSTD_initDStream(max_window_size, workspace, workspace_size); in zstd_init_decompress_ctx()
439 if (!stream) { in zstd_init_decompress_ctx()
[all …]
|