Lines Matching refs:data
75 php_bz2_filter_data *data; in php_bz2_decompress_filter() local
87 data = (php_bz2_filter_data *)Z_PTR(thisfilter->abstract); in php_bz2_decompress_filter()
88 streamp = &(data->strm); in php_bz2_decompress_filter()
95 if (data->status == PHP_BZ2_UNITIALIZED) { in php_bz2_decompress_filter()
96 status = BZ2_bzDecompressInit(streamp, 0, data->small_footprint); in php_bz2_decompress_filter()
103 data->status = PHP_BZ2_RUNNING; in php_bz2_decompress_filter()
106 if (data->status != PHP_BZ2_RUNNING) { in php_bz2_decompress_filter()
112 if (desired > data->inbuf_len) { in php_bz2_decompress_filter()
113 desired = data->inbuf_len; in php_bz2_decompress_filter()
115 memcpy(data->strm.next_in, bucket->buf + bin, desired); in php_bz2_decompress_filter()
116 data->strm.avail_in = desired; in php_bz2_decompress_filter()
118 status = BZ2_bzDecompress(&(data->strm)); in php_bz2_decompress_filter()
121 BZ2_bzDecompressEnd(&(data->strm)); in php_bz2_decompress_filter()
122 if (data->expect_concatenated) { in php_bz2_decompress_filter()
123 data->status = PHP_BZ2_UNITIALIZED; in php_bz2_decompress_filter()
125 data->status = PHP_BZ2_FINISHED; in php_bz2_decompress_filter()
132 desired -= data->strm.avail_in; /* desired becomes what we consumed this round through */ in php_bz2_decompress_filter()
133 data->strm.next_in = data->inbuf; in php_bz2_decompress_filter()
134 data->strm.avail_in = 0; in php_bz2_decompress_filter()
138 if (data->strm.avail_out < data->outbuf_len) { in php_bz2_decompress_filter()
140 size_t bucketlen = data->outbuf_len - data->strm.avail_out; in php_bz2_decompress_filter()
141 out_bucket = php_stream_bucket_new(stream, estrndup(data->outbuf, bucketlen), bucketlen, 1, 0); in php_bz2_decompress_filter()
143 data->strm.avail_out = data->outbuf_len; in php_bz2_decompress_filter()
144 data->strm.next_out = data->outbuf; in php_bz2_decompress_filter()
146 } else if (status == BZ_STREAM_END && data->strm.avail_out >= data->outbuf_len) { in php_bz2_decompress_filter()
156 if ((data->status == PHP_BZ2_RUNNING) && (flags & PSFS_FLAG_FLUSH_CLOSE)) { in php_bz2_decompress_filter()
160 status = BZ2_bzDecompress(&(data->strm)); in php_bz2_decompress_filter()
161 if (data->strm.avail_out < data->outbuf_len) { in php_bz2_decompress_filter()
162 size_t bucketlen = data->outbuf_len - data->strm.avail_out; in php_bz2_decompress_filter()
164 bucket = php_stream_bucket_new(stream, estrndup(data->outbuf, bucketlen), bucketlen, 1, 0); in php_bz2_decompress_filter()
166 data->strm.avail_out = data->outbuf_len; in php_bz2_decompress_filter()
167 data->strm.next_out = data->outbuf; in php_bz2_decompress_filter()
185 php_bz2_filter_data *data = Z_PTR(thisfilter->abstract); in php_bz2_decompress_dtor() local
186 if (data->status == PHP_BZ2_RUNNING) { in php_bz2_decompress_dtor()
187 BZ2_bzDecompressEnd(&(data->strm)); in php_bz2_decompress_dtor()
189 pefree(data->inbuf, data->persistent); in php_bz2_decompress_dtor()
190 pefree(data->outbuf, data->persistent); in php_bz2_decompress_dtor()
191 pefree(data, data->persistent); in php_bz2_decompress_dtor()
213 php_bz2_filter_data *data; in php_bz2_compress_filter() local
224 data = (php_bz2_filter_data *)Z_PTR(thisfilter->abstract); in php_bz2_compress_filter()
235 if (desired > data->inbuf_len) { in php_bz2_compress_filter()
236 desired = data->inbuf_len; in php_bz2_compress_filter()
238 memcpy(data->strm.next_in, bucket->buf + bin, desired); in php_bz2_compress_filter()
239 data->strm.avail_in = desired; in php_bz2_compress_filter()
242 data->is_flushed = flush_mode != BZ_RUN; in php_bz2_compress_filter()
243 status = BZ2_bzCompress(&(data->strm), flush_mode); in php_bz2_compress_filter()
249 desired -= data->strm.avail_in; /* desired becomes what we consumed this round through */ in php_bz2_compress_filter()
250 data->strm.next_in = data->inbuf; in php_bz2_compress_filter()
251 data->strm.avail_in = 0; in php_bz2_compress_filter()
255 if (data->strm.avail_out < data->outbuf_len) { in php_bz2_compress_filter()
257 size_t bucketlen = data->outbuf_len - data->strm.avail_out; in php_bz2_compress_filter()
259 out_bucket = php_stream_bucket_new(stream, estrndup(data->outbuf, bucketlen), bucketlen, 1, 0); in php_bz2_compress_filter()
261 data->strm.avail_out = data->outbuf_len; in php_bz2_compress_filter()
262 data->strm.next_out = data->outbuf; in php_bz2_compress_filter()
269 if (flags & PSFS_FLAG_FLUSH_CLOSE || ((flags & PSFS_FLAG_FLUSH_INC) && !data->is_flushed)) { in php_bz2_compress_filter()
272 status = BZ2_bzCompress(&(data->strm), (flags & PSFS_FLAG_FLUSH_CLOSE ? BZ_FINISH : BZ_FLUSH)); in php_bz2_compress_filter()
273 data->is_flushed = 1; in php_bz2_compress_filter()
274 if (data->strm.avail_out < data->outbuf_len) { in php_bz2_compress_filter()
275 size_t bucketlen = data->outbuf_len - data->strm.avail_out; in php_bz2_compress_filter()
277 bucket = php_stream_bucket_new(stream, estrndup(data->outbuf, bucketlen), bucketlen, 1, 0); in php_bz2_compress_filter()
279 data->strm.avail_out = data->outbuf_len; in php_bz2_compress_filter()
280 data->strm.next_out = data->outbuf; in php_bz2_compress_filter()
295 php_bz2_filter_data *data = Z_PTR(thisfilter->abstract); in php_bz2_compress_dtor() local
296 BZ2_bzCompressEnd(&(data->strm)); in php_bz2_compress_dtor()
297 pefree(data->inbuf, data->persistent); in php_bz2_compress_dtor()
298 pefree(data->outbuf, data->persistent); in php_bz2_compress_dtor()
299 pefree(data, data->persistent); in php_bz2_compress_dtor()
316 php_bz2_filter_data *data; in php_bz2_filter_create() local
320 data = pecalloc(1, sizeof(php_bz2_filter_data), persistent); in php_bz2_filter_create()
323 data->strm.opaque = (void *) data; in php_bz2_filter_create()
325 data->strm.bzalloc = php_bz2_alloc; in php_bz2_filter_create()
326 data->strm.bzfree = php_bz2_free; in php_bz2_filter_create()
327 data->persistent = persistent; in php_bz2_filter_create()
328 data->strm.avail_out = data->outbuf_len = data->inbuf_len = 2048; in php_bz2_filter_create()
329 data->strm.next_in = data->inbuf = (char *) pemalloc(data->inbuf_len, persistent); in php_bz2_filter_create()
330 data->strm.avail_in = 0; in php_bz2_filter_create()
331 data->strm.next_out = data->outbuf = (char *) pemalloc(data->outbuf_len, persistent); in php_bz2_filter_create()
334 data->small_footprint = 0; in php_bz2_filter_create()
335 data->expect_concatenated = 0; in php_bz2_filter_create()
342 data->expect_concatenated = zend_is_true(tmpzval); in php_bz2_filter_create()
352 data->small_footprint = zend_is_true(tmpzval); in php_bz2_filter_create()
356 data->status = PHP_BZ2_UNITIALIZED; in php_bz2_filter_create()
388 status = BZ2_bzCompressInit(&(data->strm), blockSize100k, 0, workFactor); in php_bz2_filter_create()
389 data->is_flushed = 1; in php_bz2_filter_create()
397 pefree(data->strm.next_in, persistent); in php_bz2_filter_create()
398 pefree(data->strm.next_out, persistent); in php_bz2_filter_create()
399 pefree(data, persistent); in php_bz2_filter_create()
403 return php_stream_filter_alloc(fops, data, persistent); in php_bz2_filter_create()
