| /fs/squashfs/ |
| A D | decompressor_multi.c | 47 void *stream; member
58 wake_up(&stream->wait); in put_decomp_stream()
68 stream = kzalloc(sizeof(*stream), GFP_KERNEL); in squashfs_decompressor_create()
69 if (!stream) in squashfs_decompressor_create()
88 stream->comp_opts); in squashfs_decompressor_create()
96 return stream; in squashfs_decompressor_create()
100 kfree(stream); in squashfs_decompressor_create()
107 struct squashfs_stream *stream = msblk->stream; in squashfs_decompressor_destroy() local
108 if (stream) { in squashfs_decompressor_destroy()
121 kfree(stream); in squashfs_decompressor_destroy()
[all …]
|
| A D | xz_wrapper.c | 87 stream = kmalloc(sizeof(*stream), GFP_KERNEL); in squashfs_xz_init()
88 if (stream == NULL) { in squashfs_xz_init()
95 kfree(stream); in squashfs_xz_init()
100 return stream; in squashfs_xz_init()
112 if (stream) { in squashfs_xz_free()
114 kfree(stream); in squashfs_xz_free()
129 stream->buf.in_pos = 0; in squashfs_xz_uncompress()
130 stream->buf.in_size = 0; in squashfs_xz_uncompress()
142 if (stream->buf.in_pos == stream->buf.in_size) { in squashfs_xz_uncompress()
161 if (stream->buf.out_pos == stream->buf.out_size) { in squashfs_xz_uncompress()
[all …]
|
| A D | decompressor_single.c | 23 void *stream; member
33 stream = kmalloc(sizeof(*stream), GFP_KERNEL); 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()
45 return stream; in squashfs_decompressor_create()
48 kfree(stream); in squashfs_decompressor_create()
54 struct squashfs_stream *stream = msblk->stream; in squashfs_decompressor_destroy() local
56 if (stream) { in squashfs_decompressor_destroy()
57 msblk->decompressor->free(stream->stream); in squashfs_decompressor_destroy()
[all …]
|
| A D | zlib_wrapper.c | 27 if (stream == NULL) 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()
59 z_stream *stream = strm; in zlib_uncompress() local
63 stream->avail_in = 0; in zlib_uncompress()
[all …]
|
| A D | decompressor_multi_percpu.c | 23 void *stream; member
30 struct squashfs_stream *stream; in squashfs_decompressor_create() local
40 stream->stream = msblk->decompressor->init(msblk, comp_opts); in squashfs_decompressor_create()
41 if (IS_ERR(stream->stream)) { in squashfs_decompressor_create()
42 err = PTR_ERR(stream->stream); in squashfs_decompressor_create()
54 if (!IS_ERR_OR_NULL(stream->stream)) in squashfs_decompressor_create()
55 msblk->decompressor->free(stream->stream); in squashfs_decompressor_create()
68 if (msblk->stream) { in squashfs_decompressor_destroy()
71 msblk->decompressor->free(stream->stream); in squashfs_decompressor_destroy()
86 stream = this_cpu_ptr(percpu); in squashfs_decompress()
[all …]
|
| A D | lz4_wrapper.c | 57 stream = kzalloc(sizeof(*stream), GFP_KERNEL); in lz4_init()
58 if (stream == NULL) in lz4_init()
67 return stream; in lz4_init()
70 vfree(stream->input); in lz4_init()
72 kfree(stream); in lz4_init()
83 if (stream) { in lz4_free()
84 vfree(stream->input); in lz4_free()
85 vfree(stream->output); in lz4_free()
87 kfree(stream); in lz4_free()
111 res = LZ4_decompress_safe(stream->input, stream->output, in lz4_uncompress()
[all …]
|
| A 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()
36 if (stream->input == NULL) in lzo_init()
42 return stream; in lzo_init()
45 vfree(stream->input); in lzo_init()
48 kfree(stream); in lzo_init()
57 if (stream) { in lzo_free()
58 vfree(stream->input); in lzo_free()
59 vfree(stream->output); in lzo_free()
61 kfree(stream); in lzo_free()
[all …]
|
| A D | decompressor.c | 131 void *stream, *comp_opts = get_comp_opts(sb, flags); in squashfs_decompressor_setup() local
136 stream = msblk->thread_ops->create(msblk, comp_opts); in squashfs_decompressor_setup()
137 if (IS_ERR(stream)) in squashfs_decompressor_setup()
140 return stream; in squashfs_decompressor_setup()
|
| A D | zstd_wrapper.c | 66 zstd_dstream *stream; in zstd_uncompress() local
74 stream = zstd_init_dstream(wksp->window_size, wksp->mem, wksp->mem_size); in zstd_uncompress()
76 if (!stream) { in zstd_uncompress()
126 zstd_err = zstd_decompress_stream(stream, &out_buf, &in_buf); in zstd_uncompress()
|
| /fs/netfs/ |
| A D | write_issue.c | 211 if (!stream->active) { in netfs_prepare_write()
212 stream->collected_to = stream->front->start; in netfs_prepare_write()
285 if (!stream->avail) { in netfs_advance_write()
297 if (!stream->construct) in netfs_advance_write()
457 if (!stream->avail || in netfs_write_folio()
497 stream->submit_extendable_to = fsize - stream->submit_off; in netfs_write_folio()
498 part = netfs_advance_write(wreq, stream, fpos + stream->submit_off, in netfs_write_folio()
537 if (!stream->active) in netfs_end_issue_write()
789 if (!stream->avail) { in netfs_write_folio_single()
826 stream->submit_extendable_to = fsize - stream->submit_off; in netfs_write_folio_single()
[all …]
|
| A D | write_retry.c | 31 if (unlikely(stream->failed)) in netfs_retry_write_stream()
35 if (!stream->prepare_write) { in netfs_retry_write_stream()
53 next = stream->subrequests.next; in netfs_retry_write_stream()
105 stream->sreq_max_len = len; in netfs_retry_write_stream()
106 stream->prepare_write(subreq); in netfs_retry_write_stream()
161 stream->sreq_max_len = len; in netfs_retry_write_stream()
163 switch (stream->source) { in netfs_retry_write_stream()
202 struct netfs_io_stream *stream; in netfs_retry_writes() local
213 if (stream->active) in netfs_retry_writes()
225 if (stream->need_retry) { in netfs_retry_writes()
[all …]
|
| A D | write_collect.c | 200 struct netfs_io_stream *stream; in netfs_collect_write_results() local
226 stream = &wreq->io_streams[s]; in netfs_collect_write_results()
231 front = stream->front; in netfs_collect_write_results()
249 if (stream->failed) { in netfs_collect_write_results()
256 stream->transferred = stream->collected_to - wreq->start; in netfs_collect_write_results()
261 stream->failed = true; in netfs_collect_write_results()
269 stream->need_retry = true; in netfs_collect_write_results()
282 stream->front = front; in netfs_collect_write_results()
306 stream = &wreq->io_streams[s]; in netfs_collect_write_results()
307 if (stream->active) in netfs_collect_write_results()
[all …]
|
| A D | read_retry.c | 33 if (list_empty(&stream->subrequests)) in netfs_retry_read_subrequests()
72 next = stream->subrequests.next; in netfs_retry_read_subrequests()
134 stream->sreq_max_len = subreq->len; in netfs_retry_read_subrequests()
142 part = umin(len, stream->sreq_max_len); in netfs_retry_read_subrequests()
143 if (unlikely(stream->sreq_max_segs)) in netfs_retry_read_subrequests()
173 &stream->subrequests, rreq_link) { in netfs_retry_read_subrequests()
195 subreq->stream_nr = stream->stream_nr; in netfs_retry_read_subrequests()
206 stream->sreq_max_len = umin(len, rreq->rsize); in netfs_retry_read_subrequests()
207 stream->sreq_max_segs = 0; in netfs_retry_read_subrequests()
208 if (unlikely(stream->sreq_max_segs)) in netfs_retry_read_subrequests()
[all …]
|
| A D | read_collect.c | 208 front = READ_ONCE(stream->front); in netfs_collect_read_results()
218 stream->collected_to = front->start; in netfs_collect_read_results()
270 if (!stream->failed) { in netfs_collect_read_results()
271 stream->error = front->error; in netfs_collect_read_results()
274 stream->failed = true; in netfs_collect_read_results()
278 stream->need_retry = true; in netfs_collect_read_results()
284 if (!stream->failed) { in netfs_collect_read_results()
285 stream->transferred += transferred; in netfs_collect_read_results()
286 stream->transferred_valid = true; in netfs_collect_read_results()
294 stream->source = front->source; in netfs_collect_read_results()
[all …]
|
| A D | direct_read.c | 50 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_dispatch_unbuffered_reads() local
72 list_add_tail(&subreq->rreq_link, &stream->subrequests); in netfs_dispatch_unbuffered_reads()
73 if (list_is_first(&subreq->rreq_link, &stream->subrequests)) { in netfs_dispatch_unbuffered_reads()
74 stream->front = subreq; in netfs_dispatch_unbuffered_reads()
75 if (!stream->active) { in netfs_dispatch_unbuffered_reads()
76 stream->collected_to = stream->front->start; in netfs_dispatch_unbuffered_reads()
78 smp_store_release(&stream->active, true); in netfs_dispatch_unbuffered_reads()
|
| A D | misc.c | 338 struct netfs_io_stream *stream = &rreq->io_streams[subreq->stream_nr]; in netfs_subreq_clear_in_progress() local
344 if (list_is_first(&subreq->rreq_link, &stream->subrequests) || in netfs_subreq_clear_in_progress()
353 struct netfs_io_stream *stream) in netfs_wait_for_in_progress_stream() argument
358 list_for_each_entry(subreq, &stream->subrequests, rreq_link) { in netfs_wait_for_in_progress_stream()
393 struct netfs_io_stream *stream = &rreq->io_streams[i]; in netfs_collect_in_app() local
395 if (!stream->active) in netfs_collect_in_app()
398 trace_netfs_collect_stream(rreq, stream); in netfs_collect_in_app()
399 subreq = list_first_entry_or_null(&stream->subrequests, in netfs_collect_in_app()
|
| A D | read_single.c | 92 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_single_dispatch_read() local
108 list_add_tail(&subreq->rreq_link, &stream->subrequests); in netfs_single_dispatch_read()
110 stream->front = subreq; in netfs_single_dispatch_read()
112 smp_store_release(&stream->active, true); in netfs_single_dispatch_read()
|
| /fs/cramfs/ |
| A 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()
44 zlib_inflateEnd(&stream); in cramfs_uncompress_block()
51 return stream.total_out; in cramfs_uncompress_block()
63 if (!stream.workspace) { in cramfs_uncompress_init()
67 stream.next_in = NULL; in cramfs_uncompress_init()
68 stream.avail_in = 0; in cramfs_uncompress_init()
[all …]
|
| /fs/isofs/ |
| A D | compress.c | 120 if (!stream.avail_out) { in zisofs_uncompress_block()
131 if (!stream.avail_in) { in zisofs_uncompress_block()
146 while (stream.avail_out && stream.avail_in) { in zisofs_uncompress_block()
165 stream.avail_out); in zisofs_uncompress_block()
172 if (!stream.avail_out) { in zisofs_uncompress_block()
180 stream.next_out = NULL; in zisofs_uncompress_block()
184 if (!stream.avail_in) in zisofs_uncompress_block()
188 zlib_inflateEnd(&stream); in zisofs_uncompress_block()
189 if (stream.next_out && stream.next_out != (unsigned char *)zisofs_sink_page) in zisofs_uncompress_block()
190 kunmap_local(stream.next_out); in zisofs_uncompress_block()
[all …]
|
| /fs/nfs/filelayout/ |
| A D | filelayoutdev.c | 74 struct xdr_stream stream; in nfs4_fl_alloc_deviceid_node() local
86 xdr_init_decode_pages(&stream, &buf, pdev->pages, pdev->pglen); in nfs4_fl_alloc_deviceid_node()
87 xdr_set_scratch_page(&stream, scratch); in nfs4_fl_alloc_deviceid_node()
90 p = xdr_inline_decode(&stream, 4); in nfs4_fl_alloc_deviceid_node()
108 p = xdr_inline_decode(&stream, cnt << 2); in nfs4_fl_alloc_deviceid_node()
121 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()
163 da = nfs4_decode_mp_ds_addr(net, &stream, gfp_flags); in nfs4_fl_alloc_deviceid_node()
|
| /fs/btrfs/ |
| A D | zstd.c | 392 zstd_cstream *stream; in zstd_compress_folios() local
413 if (unlikely(!stream)) { in zstd_compress_folios()
447 ret2 = zstd_compress_stream(stream, &workspace->out_buf, in zstd_compress_folios()
523 ret2 = zstd_end_stream(stream, &workspace->out_buf); in zstd_compress_folios()
584 zstd_dstream *stream; in zstd_decompress_bio() local
591 stream = zstd_init_dstream( in zstd_decompress_bio()
593 if (unlikely(!stream)) { in zstd_decompress_bio()
614 ret2 = zstd_decompress_stream(stream, &workspace->out_buf, in zstd_decompress_bio()
671 zstd_dstream *stream; in zstd_decompress() local
675 stream = zstd_init_dstream( in zstd_decompress()
[all …]
|
| /fs/hostfs/ |
| A D | hostfs_user.c | 111 void seek_dir(void *stream, unsigned long long pos) in seek_dir() argument
113 DIR *dir = stream; in seek_dir()
118 char *read_dir(void *stream, unsigned long long *pos_out, in read_dir() argument
122 DIR *dir = stream; in read_dir()
185 void close_file(void *stream) in close_file() argument
187 close(*((int *) stream)); in close_file()
190 void close_dir(void *stream) in close_dir() argument
192 closedir(stream); in close_dir()
|
| A D | hostfs.h | 76 extern void seek_dir(void *stream, unsigned long long pos);
77 extern char *read_dir(void *stream, unsigned long long *pos_out,
80 extern void close_file(void *stream);
82 extern void close_dir(void *stream);
|
| /fs/smb/server/ |
| A D | vfs_cache.h | 44 struct stream { struct
99 struct stream stream; member
137 return fp->stream.name != NULL; in ksmbd_stream_fd()
|
| /fs/afs/ |
| A D | write.c | 92 struct netfs_io_stream *stream = &subreq->rreq->io_streams[subreq->stream_nr]; in afs_prepare_write() local
97 stream->sreq_max_len = 256 * 1024 * 1024; in afs_prepare_write()
193 void afs_retry_request(struct netfs_io_request *wreq, struct netfs_io_stream *stream) in afs_retry_request() argument
196 list_first_entry(&stream->subrequests, in afs_retry_request()
221 stream->failed = true; in afs_retry_request()
|