Lines Matching refs:data
76 php_bz2_filter_data *data; in php_bz2_decompress_filter() local
88 data = (php_bz2_filter_data *)Z_PTR(thisfilter->abstract); in php_bz2_decompress_filter()
89 streamp = &(data->strm); in php_bz2_decompress_filter()
96 if (data->status == PHP_BZ2_UNITIALIZED) { in php_bz2_decompress_filter()
97 status = BZ2_bzDecompressInit(streamp, 0, data->small_footprint); in php_bz2_decompress_filter()
104 data->status = PHP_BZ2_RUNNING; in php_bz2_decompress_filter()
107 if (data->status != PHP_BZ2_RUNNING) { in php_bz2_decompress_filter()
113 if (desired > data->inbuf_len) { in php_bz2_decompress_filter()
114 desired = data->inbuf_len; in php_bz2_decompress_filter()
116 memcpy(data->strm.next_in, bucket->buf + bin, desired); in php_bz2_decompress_filter()
117 data->strm.avail_in = desired; in php_bz2_decompress_filter()
119 status = BZ2_bzDecompress(&(data->strm)); in php_bz2_decompress_filter()
122 BZ2_bzDecompressEnd(&(data->strm)); in php_bz2_decompress_filter()
123 if (data->expect_concatenated) { in php_bz2_decompress_filter()
124 data->status = PHP_BZ2_UNITIALIZED; in php_bz2_decompress_filter()
126 data->status = PHP_BZ2_FINISHED; in php_bz2_decompress_filter()
133 desired -= data->strm.avail_in; /* desired becomes what we consumed this round through */ in php_bz2_decompress_filter()
134 data->strm.next_in = data->inbuf; in php_bz2_decompress_filter()
135 data->strm.avail_in = 0; in php_bz2_decompress_filter()
139 if (data->strm.avail_out < data->outbuf_len) { in php_bz2_decompress_filter()
141 size_t bucketlen = data->outbuf_len - data->strm.avail_out; in php_bz2_decompress_filter()
142 out_bucket = php_stream_bucket_new(stream, estrndup(data->outbuf, bucketlen), bucketlen, 1, 0); in php_bz2_decompress_filter()
144 data->strm.avail_out = data->outbuf_len; in php_bz2_decompress_filter()
145 data->strm.next_out = data->outbuf; in php_bz2_decompress_filter()
147 } else if (status == BZ_STREAM_END && data->strm.avail_out >= data->outbuf_len) { in php_bz2_decompress_filter()
157 if ((data->status == PHP_BZ2_RUNNING) && (flags & PSFS_FLAG_FLUSH_CLOSE)) { in php_bz2_decompress_filter()
161 status = BZ2_bzDecompress(&(data->strm)); in php_bz2_decompress_filter()
162 if (data->strm.avail_out < data->outbuf_len) { in php_bz2_decompress_filter()
163 size_t bucketlen = data->outbuf_len - data->strm.avail_out; in php_bz2_decompress_filter()
165 bucket = php_stream_bucket_new(stream, estrndup(data->outbuf, bucketlen), bucketlen, 1, 0); in php_bz2_decompress_filter()
167 data->strm.avail_out = data->outbuf_len; in php_bz2_decompress_filter()
168 data->strm.next_out = data->outbuf; in php_bz2_decompress_filter()
186 php_bz2_filter_data *data = Z_PTR(thisfilter->abstract); in php_bz2_decompress_dtor() local
187 if (data->status == PHP_BZ2_RUNNING) { in php_bz2_decompress_dtor()
188 BZ2_bzDecompressEnd(&(data->strm)); in php_bz2_decompress_dtor()
190 pefree(data->inbuf, data->persistent); in php_bz2_decompress_dtor()
191 pefree(data->outbuf, data->persistent); in php_bz2_decompress_dtor()
192 pefree(data, data->persistent); in php_bz2_decompress_dtor()
214 php_bz2_filter_data *data; in php_bz2_compress_filter() local
225 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()
240 …status = BZ2_bzCompress(&(data->strm), flags & PSFS_FLAG_FLUSH_CLOSE ? BZ_FINISH : (flags & PSFS_F… in php_bz2_compress_filter()
246 desired -= data->strm.avail_in; /* desired becomes what we consumed this round through */ in php_bz2_compress_filter()
247 data->strm.next_in = data->inbuf; in php_bz2_compress_filter()
248 data->strm.avail_in = 0; in php_bz2_compress_filter()
252 if (data->strm.avail_out < data->outbuf_len) { in php_bz2_compress_filter()
254 size_t bucketlen = data->outbuf_len - data->strm.avail_out; in php_bz2_compress_filter()
256 out_bucket = php_stream_bucket_new(stream, estrndup(data->outbuf, bucketlen), bucketlen, 1, 0); in php_bz2_compress_filter()
258 data->strm.avail_out = data->outbuf_len; in php_bz2_compress_filter()
259 data->strm.next_out = data->outbuf; in php_bz2_compress_filter()
270 status = BZ2_bzCompress(&(data->strm), BZ_FINISH); in php_bz2_compress_filter()
271 if (data->strm.avail_out < data->outbuf_len) { in php_bz2_compress_filter()
272 size_t bucketlen = data->outbuf_len - data->strm.avail_out; in php_bz2_compress_filter()
274 bucket = php_stream_bucket_new(stream, estrndup(data->outbuf, bucketlen), bucketlen, 1, 0); in php_bz2_compress_filter()
276 data->strm.avail_out = data->outbuf_len; in php_bz2_compress_filter()
277 data->strm.next_out = data->outbuf; in php_bz2_compress_filter()
292 php_bz2_filter_data *data = Z_PTR(thisfilter->abstract); in php_bz2_compress_dtor() local
293 BZ2_bzCompressEnd(&(data->strm)); in php_bz2_compress_dtor()
294 pefree(data->inbuf, data->persistent); in php_bz2_compress_dtor()
295 pefree(data->outbuf, data->persistent); in php_bz2_compress_dtor()
296 pefree(data, data->persistent); in php_bz2_compress_dtor()
313 php_bz2_filter_data *data; in php_bz2_filter_create() local
317 data = pecalloc(1, sizeof(php_bz2_filter_data), persistent); in php_bz2_filter_create()
318 if (!data) { in php_bz2_filter_create()
324 data->strm.opaque = (void *) data; in php_bz2_filter_create()
326 data->strm.bzalloc = php_bz2_alloc; in php_bz2_filter_create()
327 data->strm.bzfree = php_bz2_free; in php_bz2_filter_create()
328 data->persistent = persistent; in php_bz2_filter_create()
329 data->strm.avail_out = data->outbuf_len = data->inbuf_len = 2048; in php_bz2_filter_create()
330 data->strm.next_in = data->inbuf = (char *) pemalloc(data->inbuf_len, persistent); in php_bz2_filter_create()
331 if (!data->inbuf) { in php_bz2_filter_create()
332 php_error_docref(NULL, E_WARNING, "Failed allocating %zu bytes", data->inbuf_len); in php_bz2_filter_create()
333 pefree(data, persistent); in php_bz2_filter_create()
336 data->strm.avail_in = 0; in php_bz2_filter_create()
337 data->strm.next_out = data->outbuf = (char *) pemalloc(data->outbuf_len, persistent); in php_bz2_filter_create()
338 if (!data->outbuf) { in php_bz2_filter_create()
339 php_error_docref(NULL, E_WARNING, "Failed allocating %zu bytes", data->outbuf_len); in php_bz2_filter_create()
340 pefree(data->inbuf, persistent); in php_bz2_filter_create()
341 pefree(data, persistent); in php_bz2_filter_create()
346 data->small_footprint = 0; in php_bz2_filter_create()
347 data->expect_concatenated = 0; in php_bz2_filter_create()
354 data->expect_concatenated = zend_is_true(tmpzval); in php_bz2_filter_create()
364 data->small_footprint = zend_is_true(tmpzval); in php_bz2_filter_create()
368 data->status = PHP_BZ2_UNITIALIZED; in php_bz2_filter_create()
400 status = BZ2_bzCompressInit(&(data->strm), blockSize100k, 0, workFactor); in php_bz2_filter_create()
408 pefree(data->strm.next_in, persistent); in php_bz2_filter_create()
409 pefree(data->strm.next_out, persistent); in php_bz2_filter_create()
410 pefree(data, persistent); in php_bz2_filter_create()
414 return php_stream_filter_alloc(fops, data, persistent); in php_bz2_filter_create()
