Lines Matching refs:stream

97 	struct squashfs_xz *stream;  in squashfs_xz_init()  local
100 stream = kmalloc(sizeof(*stream), GFP_KERNEL); in squashfs_xz_init()
101 if (stream == NULL) { in squashfs_xz_init()
106 stream->state = xz_dec_init(XZ_PREALLOC, comp_opts->dict_size); in squashfs_xz_init()
107 if (stream->state == NULL) { in squashfs_xz_init()
108 kfree(stream); in squashfs_xz_init()
113 return stream; in squashfs_xz_init()
123 struct squashfs_xz *stream = strm; in squashfs_xz_free() local
125 if (stream) { in squashfs_xz_free()
126 xz_dec_end(stream->state); in squashfs_xz_free()
127 kfree(stream); in squashfs_xz_free()
138 struct squashfs_xz *stream = strm; in squashfs_xz_uncompress() local
140 xz_dec_reset(stream->state); in squashfs_xz_uncompress()
141 stream->buf.in_pos = 0; in squashfs_xz_uncompress()
142 stream->buf.in_size = 0; in squashfs_xz_uncompress()
143 stream->buf.out_pos = 0; in squashfs_xz_uncompress()
144 stream->buf.out_size = PAGE_CACHE_SIZE; in squashfs_xz_uncompress()
145 stream->buf.out = squashfs_first_page(output); in squashfs_xz_uncompress()
148 if (stream->buf.in_pos == stream->buf.in_size && k < b) { in squashfs_xz_uncompress()
151 stream->buf.in = bh[k]->b_data + offset; in squashfs_xz_uncompress()
152 stream->buf.in_size = avail; in squashfs_xz_uncompress()
153 stream->buf.in_pos = 0; in squashfs_xz_uncompress()
157 if (stream->buf.out_pos == stream->buf.out_size) { in squashfs_xz_uncompress()
158 stream->buf.out = squashfs_next_page(output); in squashfs_xz_uncompress()
159 if (stream->buf.out != NULL) { in squashfs_xz_uncompress()
160 stream->buf.out_pos = 0; in squashfs_xz_uncompress()
165 xz_err = xz_dec_run(stream->state, &stream->buf); in squashfs_xz_uncompress()
167 if (stream->buf.in_pos == stream->buf.in_size && k < b) in squashfs_xz_uncompress()
176 return total + stream->buf.out_pos; in squashfs_xz_uncompress()