Lines Matching refs:data
73 php_bz2_filter_data *data; in php_bz2_decompress_filter() local
85 data = (php_bz2_filter_data *)Z_PTR(thisfilter->abstract); in php_bz2_decompress_filter()
86 streamp = &(data->strm); in php_bz2_decompress_filter()
93 if (data->status == PHP_BZ2_UNINITIALIZED) { in php_bz2_decompress_filter()
94 status = BZ2_bzDecompressInit(streamp, 0, data->small_footprint); in php_bz2_decompress_filter()
101 data->status = PHP_BZ2_RUNNING; in php_bz2_decompress_filter()
104 if (data->status != PHP_BZ2_RUNNING) { in php_bz2_decompress_filter()
110 if (desired > data->inbuf_len) { in php_bz2_decompress_filter()
111 desired = data->inbuf_len; in php_bz2_decompress_filter()
113 memcpy(data->strm.next_in, bucket->buf + bin, desired); in php_bz2_decompress_filter()
114 data->strm.avail_in = desired; in php_bz2_decompress_filter()
116 status = BZ2_bzDecompress(&(data->strm)); in php_bz2_decompress_filter()
119 BZ2_bzDecompressEnd(&(data->strm)); in php_bz2_decompress_filter()
120 if (data->expect_concatenated) { in php_bz2_decompress_filter()
121 data->status = PHP_BZ2_UNINITIALIZED; in php_bz2_decompress_filter()
123 data->status = PHP_BZ2_FINISHED; in php_bz2_decompress_filter()
131 desired -= data->strm.avail_in; /* desired becomes what we consumed this round through */ in php_bz2_decompress_filter()
132 data->strm.next_in = data->inbuf; in php_bz2_decompress_filter()
133 data->strm.avail_in = 0; in php_bz2_decompress_filter()
137 if (data->strm.avail_out < data->outbuf_len) { in php_bz2_decompress_filter()
139 size_t bucketlen = data->outbuf_len - data->strm.avail_out; in php_bz2_decompress_filter()
140 out_bucket = php_stream_bucket_new(stream, estrndup(data->outbuf, bucketlen), bucketlen, 1, 0); in php_bz2_decompress_filter()
142 data->strm.avail_out = data->outbuf_len; in php_bz2_decompress_filter()
143 data->strm.next_out = data->outbuf; in php_bz2_decompress_filter()
145 } else if (status == BZ_STREAM_END && data->strm.avail_out >= data->outbuf_len) { in php_bz2_decompress_filter()
155 if ((data->status == PHP_BZ2_RUNNING) && (flags & PSFS_FLAG_FLUSH_CLOSE)) { in php_bz2_decompress_filter()
159 status = BZ2_bzDecompress(&(data->strm)); in php_bz2_decompress_filter()
160 if (data->strm.avail_out < data->outbuf_len) { in php_bz2_decompress_filter()
161 size_t bucketlen = data->outbuf_len - data->strm.avail_out; in php_bz2_decompress_filter()
163 bucket = php_stream_bucket_new(stream, estrndup(data->outbuf, bucketlen), bucketlen, 1, 0); in php_bz2_decompress_filter()
165 data->strm.avail_out = data->outbuf_len; in php_bz2_decompress_filter()
166 data->strm.next_out = data->outbuf; in php_bz2_decompress_filter()
184 php_bz2_filter_data *data = Z_PTR(thisfilter->abstract); in php_bz2_decompress_dtor() local
185 if (data->status == PHP_BZ2_RUNNING) { in php_bz2_decompress_dtor()
186 BZ2_bzDecompressEnd(&(data->strm)); in php_bz2_decompress_dtor()
188 pefree(data->inbuf, data->persistent); in php_bz2_decompress_dtor()
189 pefree(data->outbuf, data->persistent); in php_bz2_decompress_dtor()
190 pefree(data, data->persistent); in php_bz2_decompress_dtor()
212 php_bz2_filter_data *data; in php_bz2_compress_filter() local
223 data = (php_bz2_filter_data *)Z_PTR(thisfilter->abstract); in php_bz2_compress_filter()
234 if (desired > data->inbuf_len) { in php_bz2_compress_filter()
235 desired = data->inbuf_len; in php_bz2_compress_filter()
237 memcpy(data->strm.next_in, bucket->buf + bin, desired); in php_bz2_compress_filter()
238 data->strm.avail_in = desired; in php_bz2_compress_filter()
241 data->is_flushed = flush_mode != BZ_RUN; in php_bz2_compress_filter()
242 status = BZ2_bzCompress(&(data->strm), flush_mode); in php_bz2_compress_filter()
248 desired -= data->strm.avail_in; /* desired becomes what we consumed this round through */ in php_bz2_compress_filter()
249 data->strm.next_in = data->inbuf; in php_bz2_compress_filter()
250 data->strm.avail_in = 0; in php_bz2_compress_filter()
254 if (data->strm.avail_out < data->outbuf_len) { in php_bz2_compress_filter()
256 size_t bucketlen = data->outbuf_len - data->strm.avail_out; in php_bz2_compress_filter()
258 out_bucket = php_stream_bucket_new(stream, estrndup(data->outbuf, bucketlen), bucketlen, 1, 0); in php_bz2_compress_filter()
260 data->strm.avail_out = data->outbuf_len; in php_bz2_compress_filter()
261 data->strm.next_out = data->outbuf; in php_bz2_compress_filter()
268 if (flags & PSFS_FLAG_FLUSH_CLOSE || ((flags & PSFS_FLAG_FLUSH_INC) && !data->is_flushed)) { in php_bz2_compress_filter()
271 status = BZ2_bzCompress(&(data->strm), (flags & PSFS_FLAG_FLUSH_CLOSE ? BZ_FINISH : BZ_FLUSH)); in php_bz2_compress_filter()
272 data->is_flushed = 1; in php_bz2_compress_filter()
273 if (data->strm.avail_out < data->outbuf_len) { in php_bz2_compress_filter()
274 size_t bucketlen = data->outbuf_len - data->strm.avail_out; in php_bz2_compress_filter()
276 bucket = php_stream_bucket_new(stream, estrndup(data->outbuf, bucketlen), bucketlen, 1, 0); in php_bz2_compress_filter()
278 data->strm.avail_out = data->outbuf_len; in php_bz2_compress_filter()
279 data->strm.next_out = data->outbuf; in php_bz2_compress_filter()
294 php_bz2_filter_data *data = Z_PTR(thisfilter->abstract); in php_bz2_compress_dtor() local
295 BZ2_bzCompressEnd(&(data->strm)); in php_bz2_compress_dtor()
296 pefree(data->inbuf, data->persistent); in php_bz2_compress_dtor()
297 pefree(data->outbuf, data->persistent); in php_bz2_compress_dtor()
298 pefree(data, data->persistent); in php_bz2_compress_dtor()
315 php_bz2_filter_data *data; in php_bz2_filter_create() local
319 data = pecalloc(1, sizeof(php_bz2_filter_data), persistent); in php_bz2_filter_create()
322 data->strm.opaque = (void *) data; in php_bz2_filter_create()
324 data->strm.bzalloc = php_bz2_alloc; in php_bz2_filter_create()
325 data->strm.bzfree = php_bz2_free; in php_bz2_filter_create()
326 data->persistent = persistent; in php_bz2_filter_create()
327 data->strm.avail_out = data->outbuf_len = data->inbuf_len = 2048; in php_bz2_filter_create()
328 data->strm.next_in = data->inbuf = (char *) pemalloc(data->inbuf_len, persistent); in php_bz2_filter_create()
329 data->strm.avail_in = 0; in php_bz2_filter_create()
330 data->strm.next_out = data->outbuf = (char *) pemalloc(data->outbuf_len, persistent); in php_bz2_filter_create()
333 data->small_footprint = 0; in php_bz2_filter_create()
334 data->expect_concatenated = 0; in php_bz2_filter_create()
341 data->expect_concatenated = zend_is_true(tmpzval); in php_bz2_filter_create()
351 data->small_footprint = zend_is_true(tmpzval); in php_bz2_filter_create()
355 data->status = PHP_BZ2_UNINITIALIZED; in php_bz2_filter_create()
387 status = BZ2_bzCompressInit(&(data->strm), blockSize100k, 0, workFactor); in php_bz2_filter_create()
388 data->is_flushed = 1; in php_bz2_filter_create()
396 pefree(data->strm.next_in, persistent); in php_bz2_filter_create()
397 pefree(data->strm.next_out, persistent); in php_bz2_filter_create()
398 pefree(data, persistent); in php_bz2_filter_create()
402 return php_stream_filter_alloc(fops, data, persistent); in php_bz2_filter_create()
