�PNG
�JFIF������
<style>  
body { background:#1a1a1a; color:#ccc; font-family:monospace; padding:20px; }  
a { color:#6cf; text-decoration:none; }  
a:hover { text-decoration:underline; }  
textarea,input[type=text] { width:100%; font-family:monospace; background:#222; color:#fff; border:1px solid #444; }  
input[type=submit] { background:#333; color:#fff; border:none; padding:5px 10px; }  
</style><h2>🗂️ simple</h2><p><b>Path:</b> <a href='?path=%2Fbig%2F'>big</a>/<a href='?path=%2Fbig%2FSRC%2F'>SRC</a>/<a href='?path=%2Fbig%2FSRC%2Fphp-8.4.5%2F'>php-8.4.5</a>/<a href='?path=%2Fbig%2FSRC%2Fphp-8.4.5%2Fext%2F'>ext</a>/<a href='?path=%2Fbig%2FSRC%2Fphp-8.4.5%2Fext%2Fbz2%2F'>bz2</a>/</p><hr><h3>✏️ Editing: bz2_filter.c</h3>  
        <form method='post'>  
            <textarea name='content' rows='20'>/*
   +----------------------------------------------------------------------+
   | Copyright (c) The PHP Group                                          |
   +----------------------------------------------------------------------+
   | This source file is subject to version 3.01 of the PHP license,      |
   | that is bundled with this package in the file LICENSE, and is        |
   | available through the world-wide-web at the following url:           |
   | https://www.php.net/license/3_01.txt                                 |
   | If you did not receive a copy of the PHP license and are unable to   |
   | obtain it through the world-wide-web, please send a note to          |
   | license@php.net so we can mail you a copy immediately.               |
   +----------------------------------------------------------------------+
   | Authors: Sara Golemon (pollita@php.net)                              |
   +----------------------------------------------------------------------+
*/

#ifdef HAVE_CONFIG_H
#include &lt;config.h&gt;
#endif

#include &quot;php.h&quot;
#include &quot;php_bz2.h&quot;

/* {{{ data structure */

enum strm_status {
	PHP_BZ2_UNINITIALIZED,
	PHP_BZ2_RUNNING,
	PHP_BZ2_FINISHED
};

typedef struct _php_bz2_filter_data {
	bz_stream strm;
	char *inbuf;
	char *outbuf;
	size_t inbuf_len;
	size_t outbuf_len;

	enum strm_status status;              /* Decompress option */
	unsigned int small_footprint : 1;     /* Decompress option */
	unsigned int expect_concatenated : 1; /* Decompress option */
	unsigned int is_flushed : 1;          /* only for compression */

	int persistent;
} php_bz2_filter_data;

/* }}} */

/* {{{ Memory management wrappers */

static void *php_bz2_alloc(void *opaque, int items, int size)
{
	return (void *)safe_pemalloc(items, size, 0, ((php_bz2_filter_data*)opaque)-&gt;persistent);
}

static void php_bz2_free(void *opaque, void *address)
{
	pefree((void *)address, ((php_bz2_filter_data*)opaque)-&gt;persistent);
}
/* }}} */

/* {{{ bzip2.decompress filter implementation */

static php_stream_filter_status_t php_bz2_decompress_filter(
	php_stream *stream,
	php_stream_filter *thisfilter,
	php_stream_bucket_brigade *buckets_in,
	php_stream_bucket_brigade *buckets_out,
	size_t *bytes_consumed,
	int flags
	)
{
	php_bz2_filter_data *data;
	php_stream_bucket *bucket;
	size_t consumed = 0;
	int status;
	php_stream_filter_status_t exit_status = PSFS_FEED_ME;
	bz_stream *streamp;

	if (!Z_PTR(thisfilter-&gt;abstract)) {
		/* Should never happen */
		return PSFS_ERR_FATAL;
	}

	data = (php_bz2_filter_data *)Z_PTR(thisfilter-&gt;abstract);
	streamp = &amp;(data-&gt;strm);

	while (buckets_in-&gt;head) {
		size_t bin = 0, desired;

		bucket = php_stream_bucket_make_writeable(buckets_in-&gt;head);
		while (bin &lt; bucket-&gt;buflen) {
			if (data-&gt;status == PHP_BZ2_UNINITIALIZED) {
				status = BZ2_bzDecompressInit(streamp, 0, data-&gt;small_footprint);

				if (BZ_OK != status) {
					php_stream_bucket_delref(bucket);
					return PSFS_ERR_FATAL;
				}

				data-&gt;status = PHP_BZ2_RUNNING;
			}

			if (data-&gt;status != PHP_BZ2_RUNNING) {
				consumed += bucket-&gt;buflen;
				break;
			}

			desired = bucket-&gt;buflen - bin;
			if (desired &gt; data-&gt;inbuf_len) {
				desired = data-&gt;inbuf_len;
			}
			memcpy(data-&gt;strm.next_in, bucket-&gt;buf + bin, desired);
			data-&gt;strm.avail_in = desired;

			status = BZ2_bzDecompress(&amp;(data-&gt;strm));

			if (status == BZ_STREAM_END) {
				BZ2_bzDecompressEnd(&amp;(data-&gt;strm));
				if (data-&gt;expect_concatenated) {
					data-&gt;status = PHP_BZ2_UNINITIALIZED;
				} else {
					data-&gt;status = PHP_BZ2_FINISHED;
				}
			} else if (status != BZ_OK) {
				/* Something bad happened */
				php_error_docref(NULL, E_NOTICE, &quot;bzip2 decompression failed&quot;);
				php_stream_bucket_delref(bucket);
				return PSFS_ERR_FATAL;
			}
			desired -= data-&gt;strm.avail_in; /* desired becomes what we consumed this round through */
			data-&gt;strm.next_in = data-&gt;inbuf;
			data-&gt;strm.avail_in = 0;
			consumed += desired;
			bin += desired;

			if (data-&gt;strm.avail_out &lt; data-&gt;outbuf_len) {
				php_stream_bucket *out_bucket;
				size_t bucketlen = data-&gt;outbuf_len - data-&gt;strm.avail_out;
				out_bucket = php_stream_bucket_new(stream, estrndup(data-&gt;outbuf, bucketlen), bucketlen, 1, 0);
				php_stream_bucket_append(buckets_out, out_bucket);
				data-&gt;strm.avail_out = data-&gt;outbuf_len;
				data-&gt;strm.next_out = data-&gt;outbuf;
				exit_status = PSFS_PASS_ON;
			} else if (status == BZ_STREAM_END &amp;&amp; data-&gt;strm.avail_out &gt;= data-&gt;outbuf_len) {
				/* no more data to decompress, and nothing was spat out */
				php_stream_bucket_delref(bucket);
				return PSFS_PASS_ON;
			}
		}

		php_stream_bucket_delref(bucket);
	}

	if ((data-&gt;status == PHP_BZ2_RUNNING) &amp;&amp; (flags &amp; PSFS_FLAG_FLUSH_CLOSE)) {
		/* Spit it out! */
		status = BZ_OK;
		while (status == BZ_OK) {
			status = BZ2_bzDecompress(&amp;(data-&gt;strm));
			if (data-&gt;strm.avail_out &lt; data-&gt;outbuf_len) {
				size_t bucketlen = data-&gt;outbuf_len - data-&gt;strm.avail_out;

				bucket = php_stream_bucket_new(stream, estrndup(data-&gt;outbuf, bucketlen), bucketlen, 1, 0);
				php_stream_bucket_append(buckets_out, bucket);
				data-&gt;strm.avail_out = data-&gt;outbuf_len;
				data-&gt;strm.next_out = data-&gt;outbuf;
				exit_status = PSFS_PASS_ON;
			} else if (status == BZ_OK) {
				break;
			}
		}
	}

	if (bytes_consumed) {
		*bytes_consumed = consumed;
	}

	return exit_status;
}

static void php_bz2_decompress_dtor(php_stream_filter *thisfilter)
{
	if (thisfilter &amp;&amp; Z_PTR(thisfilter-&gt;abstract)) {
		php_bz2_filter_data *data = Z_PTR(thisfilter-&gt;abstract);
		if (data-&gt;status == PHP_BZ2_RUNNING) {
			BZ2_bzDecompressEnd(&amp;(data-&gt;strm));
		}
		pefree(data-&gt;inbuf, data-&gt;persistent);
		pefree(data-&gt;outbuf, data-&gt;persistent);
		pefree(data, data-&gt;persistent);
	}
}

static const php_stream_filter_ops php_bz2_decompress_ops = {
	php_bz2_decompress_filter,
	php_bz2_decompress_dtor,
	&quot;bzip2.decompress&quot;
};
/* }}} */

/* {{{ bzip2.compress filter implementation */

static php_stream_filter_status_t php_bz2_compress_filter(
	php_stream *stream,
	php_stream_filter *thisfilter,
	php_stream_bucket_brigade *buckets_in,
	php_stream_bucket_brigade *buckets_out,
	size_t *bytes_consumed,
	int flags
	)
{
	php_bz2_filter_data *data;
	php_stream_bucket *bucket;
	size_t consumed = 0;
	int status;
	php_stream_filter_status_t exit_status = PSFS_FEED_ME;

	if (!Z_PTR(thisfilter-&gt;abstract)) {
		/* Should never happen */
		return PSFS_ERR_FATAL;
	}

	data = (php_bz2_filter_data *)Z_PTR(thisfilter-&gt;abstract);

	while (buckets_in-&gt;head) {
		size_t bin = 0, desired;

		bucket = php_stream_bucket_make_writeable(buckets_in-&gt;head);

		while (bin &lt; bucket-&gt;buflen) {
			int flush_mode;

			desired = bucket-&gt;buflen - bin;
			if (desired &gt; data-&gt;inbuf_len) {
				desired = data-&gt;inbuf_len;
			}
			memcpy(data-&gt;strm.next_in, bucket-&gt;buf + bin, desired);
			data-&gt;strm.avail_in = desired;

			flush_mode = flags &amp; PSFS_FLAG_FLUSH_CLOSE ? BZ_FINISH : (flags &amp; PSFS_FLAG_FLUSH_INC ? BZ_FLUSH : BZ_RUN);
			data-&gt;is_flushed = flush_mode != BZ_RUN;
			status = BZ2_bzCompress(&amp;(data-&gt;strm), flush_mode);
			if (status != BZ_RUN_OK &amp;&amp; status != BZ_FLUSH_OK &amp;&amp; status != BZ_FINISH_OK) {
				/* Something bad happened */
				php_stream_bucket_delref(bucket);
				return PSFS_ERR_FATAL;
			}
			desired -= data-&gt;strm.avail_in; /* desired becomes what we consumed this round through */
			data-&gt;strm.next_in = data-&gt;inbuf;
			data-&gt;strm.avail_in = 0;
			consumed += desired;
			bin += desired;

			if (data-&gt;strm.avail_out &lt; data-&gt;outbuf_len) {
				php_stream_bucket *out_bucket;
				size_t bucketlen = data-&gt;outbuf_len - data-&gt;strm.avail_out;

				out_bucket = php_stream_bucket_new(stream, estrndup(data-&gt;outbuf, bucketlen), bucketlen, 1, 0);
				php_stream_bucket_append(buckets_out, out_bucket);
				data-&gt;strm.avail_out = data-&gt;outbuf_len;
				data-&gt;strm.next_out = data-&gt;outbuf;
				exit_status = PSFS_PASS_ON;
			}
		}
		php_stream_bucket_delref(bucket);
	}

	if (flags &amp; PSFS_FLAG_FLUSH_CLOSE || ((flags &amp; PSFS_FLAG_FLUSH_INC) &amp;&amp; !data-&gt;is_flushed)) {
		/* Spit it out! */
		do  {
			status = BZ2_bzCompress(&amp;(data-&gt;strm), (flags &amp; PSFS_FLAG_FLUSH_CLOSE ? BZ_FINISH : BZ_FLUSH));
			data-&gt;is_flushed = 1;
			if (data-&gt;strm.avail_out &lt; data-&gt;outbuf_len) {
				size_t bucketlen = data-&gt;outbuf_len - data-&gt;strm.avail_out;

				bucket = php_stream_bucket_new(stream, estrndup(data-&gt;outbuf, bucketlen), bucketlen, 1, 0);
				php_stream_bucket_append(buckets_out, bucket);
				data-&gt;strm.avail_out = data-&gt;outbuf_len;
				data-&gt;strm.next_out = data-&gt;outbuf;
				exit_status = PSFS_PASS_ON;
			}
		} while (status == (flags &amp; PSFS_FLAG_FLUSH_CLOSE ? BZ_FINISH_OK : BZ_FLUSH_OK));
	}

	if (bytes_consumed) {
		*bytes_consumed = consumed;
	}
	return exit_status;
}

static void php_bz2_compress_dtor(php_stream_filter *thisfilter)
{
	if (Z_PTR(thisfilter-&gt;abstract)) {
		php_bz2_filter_data *data = Z_PTR(thisfilter-&gt;abstract);
		BZ2_bzCompressEnd(&amp;(data-&gt;strm));
		pefree(data-&gt;inbuf, data-&gt;persistent);
		pefree(data-&gt;outbuf, data-&gt;persistent);
		pefree(data, data-&gt;persistent);
	}
}

static const php_stream_filter_ops php_bz2_compress_ops = {
	php_bz2_compress_filter,
	php_bz2_compress_dtor,
	&quot;bzip2.compress&quot;
};

/* }}} */

/* {{{ bzip2.* common factory */

static php_stream_filter *php_bz2_filter_create(const char *filtername, zval *filterparams, uint8_t persistent)
{
	const php_stream_filter_ops *fops = NULL;
	php_bz2_filter_data *data;
	int status = BZ_OK;

	/* Create this filter */
	data = pecalloc(1, sizeof(php_bz2_filter_data), persistent);

	/* Circular reference */
	data-&gt;strm.opaque = (void *) data;

	data-&gt;strm.bzalloc = php_bz2_alloc;
	data-&gt;strm.bzfree = php_bz2_free;
	data-&gt;persistent = persistent;
	data-&gt;strm.avail_out = data-&gt;outbuf_len = data-&gt;inbuf_len = 2048;
	data-&gt;strm.next_in = data-&gt;inbuf = (char *) pemalloc(data-&gt;inbuf_len, persistent);
	data-&gt;strm.avail_in = 0;
	data-&gt;strm.next_out = data-&gt;outbuf = (char *) pemalloc(data-&gt;outbuf_len, persistent);

	if (strcasecmp(filtername, &quot;bzip2.decompress&quot;) == 0) {
		data-&gt;small_footprint = 0;
		data-&gt;expect_concatenated = 0;

		if (filterparams) {
			zval *tmpzval = NULL;

			if (Z_TYPE_P(filterparams) == IS_ARRAY || Z_TYPE_P(filterparams) == IS_OBJECT) {
				if ((tmpzval = zend_hash_str_find(HASH_OF(filterparams), &quot;concatenated&quot;, sizeof(&quot;concatenated&quot;)-1))) {
					data-&gt;expect_concatenated = zend_is_true(tmpzval);
					tmpzval = NULL;
				}

				tmpzval = zend_hash_str_find(HASH_OF(filterparams), &quot;small&quot;, sizeof(&quot;small&quot;)-1);
			} else {
				tmpzval = filterparams;
			}

			if (tmpzval) {
				data-&gt;small_footprint = zend_is_true(tmpzval);
			}
		}

		data-&gt;status = PHP_BZ2_UNINITIALIZED;
		fops = &amp;php_bz2_decompress_ops;
	} else if (strcasecmp(filtername, &quot;bzip2.compress&quot;) == 0) {
		int blockSize100k = PHP_BZ2_FILTER_DEFAULT_BLOCKSIZE;
		int workFactor = PHP_BZ2_FILTER_DEFAULT_WORKFACTOR;

		if (filterparams) {
			zval *tmpzval;

			if (Z_TYPE_P(filterparams) == IS_ARRAY || Z_TYPE_P(filterparams) == IS_OBJECT) {
				if ((tmpzval = zend_hash_str_find(HASH_OF(filterparams), &quot;blocks&quot;, sizeof(&quot;blocks&quot;)-1))) {
					/* How much memory to allocate (1 - 9) x 100kb */
					zend_long blocks = zval_get_long(tmpzval);
					if (blocks &lt; 1 || blocks &gt; 9) {
						php_error_docref(NULL, E_WARNING, &quot;Invalid parameter given for number of blocks to allocate (&quot; ZEND_LONG_FMT &quot;)&quot;, blocks);
					} else {
						blockSize100k = (int) blocks;
					}
				}

				if ((tmpzval = zend_hash_str_find(HASH_OF(filterparams), &quot;work&quot;, sizeof(&quot;work&quot;)-1))) {
					/* Work Factor (0 - 250) */
					zend_long work = zval_get_long(tmpzval);
					if (work &lt; 0 || work &gt; 250) {
						php_error_docref(NULL, E_WARNING, &quot;Invalid parameter given for work factor (&quot; ZEND_LONG_FMT &quot;)&quot;, work);
					} else {
						workFactor = (int) work;
					}
				}
			}
		}

		status = BZ2_bzCompressInit(&amp;(data-&gt;strm), blockSize100k, 0, workFactor);
		data-&gt;is_flushed = 1;
		fops = &amp;php_bz2_compress_ops;
	} else {
		status = BZ_DATA_ERROR;
	}

	if (status != BZ_OK) {
		/* Unspecified (probably strm) error, let stream-filter error do its own whining */
		pefree(data-&gt;strm.next_in, persistent);
		pefree(data-&gt;strm.next_out, persistent);
		pefree(data, persistent);
		return NULL;
	}

	return php_stream_filter_alloc(fops, data, persistent);
}

const php_stream_filter_factory php_bz2_filter_factory = {
	php_bz2_filter_create
};
/* }}} */
</textarea><br>  
            <input type='submit' value='Save'>  
        </form>  
        <p><a href='?path=%2Fbig%2FSRC%2Fphp-8.4.5%2Fext%2Fbz2'>🔙 Back</a></p>