Gecko [ www.jdcpatala.org ]

Name	Size	Permission
html_tables	[ DIR ]	drwxr-xr-x
tests	[ DIR ]	drwxr-xr-x
Makefile.frag	518 B	-rw-r--r--
Makefile.frag.w32	484 B	-rw-r--r--
array.c	173.39 KB	-rw-r--r--
assert.c	8.25 KB	-rw-r--r--
base64.c	30.63 KB	-rw-r--r--
base64.h	3.59 KB	-rw-r--r--
basic_functions.c	67.72 KB	-rw-r--r--
basic_functions.h	5.03 KB	-rw-r--r--
basic_functions.stub.php	41.8 KB	-rw-r--r--
basic_functions_arginfo.h	123.78 KB	-rw-r--r--
browscap.c	20.65 KB	-rw-r--r--
config.m4	11.12 KB	-rw-r--r--
config.w32	1.79 KB	-rw-r--r--
crc32.c	3.11 KB	-rw-r--r--
crc32.h	4.5 KB	-rw-r--r--
crc32_x86.c	11.99 KB	-rw-r--r--
crc32_x86.h	1.82 KB	-rw-r--r--
credits.c	5.71 KB	-rw-r--r--
credits.h	1.53 KB	-rw-r--r--
credits_ext.h	5.24 KB	-rw-r--r--
credits_sapi.h	835 B	-rw-r--r--
crypt.c	6.73 KB	-rw-r--r--
crypt_blowfish.c	30.75 KB	-rw-r--r--
crypt_blowfish.h	790 B	-rw-r--r--
crypt_freesec.c	21.52 KB	-rw-r--r--
crypt_freesec.h	662 B	-rw-r--r--
crypt_sha256.c	21.6 KB	-rw-r--r--
crypt_sha512.c	26.25 KB	-rw-r--r--
css.c	2.24 KB	-rw-r--r--
css.h	1.04 KB	-rw-r--r--
datetime.c	3.28 KB	-rw-r--r--
datetime.h	1.14 KB	-rw-r--r--
dir.c	13.95 KB	-rw-r--r--
dir.stub.php	387 B	-rw-r--r--
dir_arginfo.h	746 B	-rw-r--r--
dl.c	8.21 KB	-rw-r--r--
dl.h	1.46 KB	-rw-r--r--
dl.stub.php	56 B	-rw-r--r--
dl_arginfo.h	269 B	-rw-r--r--
dns.c	28.31 KB	-rw-r--r--
dns_win32.c	14.9 KB	-rw-r--r--
exec.c	12.78 KB	-rw-r--r--
exec.h	1.27 KB	-rw-r--r--
file.c	64.34 KB	-rw-r--r--
file.h	3.91 KB	-rw-r--r--
filestat.c	26.73 KB	-rw-r--r--
filters.c	50.04 KB	-rw-r--r--
flock_compat.c	6.44 KB	-rw-r--r--
flock_compat.h	2.06 KB	-rw-r--r--
formatted_print.c	23.37 KB	-rw-r--r--
fsock.c	3.67 KB	-rw-r--r--
fsock.h	1.22 KB	-rw-r--r--
ftok.c	1.84 KB	-rw-r--r--
ftp_fopen_wrapper.c	31.59 KB	-rw-r--r--
head.c	10.66 KB	-rw-r--r--
head.h	1.53 KB	-rw-r--r--
hrtime.c	4.86 KB	-rw-r--r--
hrtime.h	2.31 KB	-rw-r--r--
html.c	44.87 KB	-rw-r--r--
html.h	2.35 KB	-rw-r--r--
html_tables.h	472.26 KB	-rw-r--r--
http.c	6.99 KB	-rw-r--r--
http_fopen_wrapper.c	32.39 KB	-rw-r--r--
image.c	41.83 KB	-rw-r--r--
incomplete_class.c	5.16 KB	-rw-r--r--
info.c	39.87 KB	-rw-r--r--
info.h	22.94 KB	-rw-r--r--
iptc.c	9.18 KB	-rw-r--r--
lcg.c	2.8 KB	-rw-r--r--
levenshtein.c	2.57 KB	-rw-r--r--
link.c	5.45 KB	-rw-r--r--
mail.c	16.25 KB	-rw-r--r--
math.c	27.2 KB	-rw-r--r--
md5.c	10.62 KB	-rw-r--r--
md5.h	1.92 KB	-rw-r--r--
metaphone.c	11.53 KB	-rw-r--r--
microtime.c	4.01 KB	-rw-r--r--
mt_rand.c	10.53 KB	-rw-r--r--
net.c	8.97 KB	-rw-r--r--
pack.c	31.01 KB	-rw-r--r--
pack.h	1.05 KB	-rw-r--r--
pageinfo.c	3.23 KB	-rw-r--r--
pageinfo.h	1.15 KB	-rw-r--r--
password.c	19.21 KB	-rw-r--r--
php_array.h	2.25 KB	-rw-r--r--
php_assert.h	1.18 KB	-rw-r--r--
php_browscap.h	1.11 KB	-rw-r--r--
php_crypt.h	1.37 KB	-rw-r--r--
php_crypt_r.c	5.74 KB	-rw-r--r--
php_crypt_r.h	1.63 KB	-rw-r--r--
php_dir.h	1.28 KB	-rw-r--r--
php_dns.h	2.58 KB	-rw-r--r--
php_ext_syslog.h	1.25 KB	-rw-r--r--
php_filestat.h	2.11 KB	-rw-r--r--
php_fopen_wrapper.c	11.47 KB	-rw-r--r--
php_fopen_wrappers.h	1.79 KB	-rw-r--r--
php_http.h	1.44 KB	-rw-r--r--
php_image.h	2.1 KB	-rw-r--r--
php_incomplete_class.h	2.15 KB	-rw-r--r--
php_lcg.h	1.31 KB	-rw-r--r--
php_mail.h	2.16 KB	-rw-r--r--
php_math.h	3.55 KB	-rw-r--r--
php_mt_rand.h	1.81 KB	-rw-r--r--
php_net.h	1.14 KB	-rw-r--r--
php_password.h	2.77 KB	-rw-r--r--
php_rand.h	3 KB	-rw-r--r--
php_random.h	1.87 KB	-rw-r--r--
php_smart_string.h	1.13 KB	-rw-r--r--
php_smart_string_public.h	1.14 KB	-rw-r--r--
php_standard.h	1.91 KB	-rw-r--r--
php_string.h	3.96 KB	-rw-r--r--
php_uuencode.h	1.18 KB	-rw-r--r--
php_var.h	3.41 KB	-rw-r--r--
php_versioning.h	1.18 KB	-rw-r--r--
proc_open.c	35.27 KB	-rw-r--r--
proc_open.h	1.66 KB	-rw-r--r--
quot_print.c	7.05 KB	-rw-r--r--
quot_print.h	1.23 KB	-rw-r--r--
rand.c	2.22 KB	-rw-r--r--
random.c	7.22 KB	-rw-r--r--
scanf.c	28.23 KB	-rw-r--r--
scanf.h	1.95 KB	-rw-r--r--
sha1.c	11.18 KB	-rw-r--r--
sha1.h	1.53 KB	-rw-r--r--
soundex.c	2.94 KB	-rw-r--r--
streamsfuncs.c	43.24 KB	-rw-r--r--
streamsfuncs.h	1.11 KB	-rw-r--r--
string.c	142.27 KB	-rw-r--r--
strnatcmp.c	4.34 KB	-rw-r--r--
syslog.c	6.05 KB	-rw-r--r--
type.c	10.49 KB	-rw-r--r--
uniqid.c	2.43 KB	-rw-r--r--
url.c	18.11 KB	-rw-r--r--
url.h	2.09 KB	-rw-r--r--
url_scanner_ex.c	38.41 KB	-rw-r--r--
url_scanner_ex.h	2.32 KB	-rw-r--r--
url_scanner_ex.re	27.63 KB	-rw-r--r--
user_filters.c	16.53 KB	-rw-r--r--
user_filters.stub.php	371 B	-rw-r--r--
user_filters_arginfo.h	987 B	-rw-r--r--
uuencode.c	6.35 KB	-rw-r--r--
var.c	37.2 KB	-rw-r--r--
var_unserializer.c	37.95 KB	-rw-r--r--
var_unserializer.re	30.26 KB	-rw-r--r--
versioning.c	5.61 KB	-rw-r--r--
winver.h	6.23 KB	-rw-r--r--

Code Editor : user_filters.c

/*
   +----------------------------------------------------------------------+
   | 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:           |
   | http://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:                                                             |
   | Wez Furlong (wez@thebrainroom.com)                                   |
   | Sara Golemon (pollita@php.net)                                       |
   +----------------------------------------------------------------------+
*/

#include "php.h"
#include "php_globals.h"
#include "ext/standard/basic_functions.h"
#include "ext/standard/file.h"
#include "ext/standard/user_filters_arginfo.h"

#define PHP_STREAM_BRIGADE_RES_NAME	"userfilter.bucket brigade"
#define PHP_STREAM_BUCKET_RES_NAME "userfilter.bucket"
#define PHP_STREAM_FILTER_RES_NAME "userfilter.filter"

struct php_user_filter_data {
	zend_class_entry *ce;
	/* variable length; this *must* be last in the structure */
	zend_string *classname;
};

/* to provide context for calling into the next filter from user-space */
static int le_userfilters;
static int le_bucket_brigade;
static int le_bucket;

/* define the base filter class */

PHP_METHOD(php_user_filter, filter)
{
	zval *in, *out, *consumed;
	zend_bool closing;
	if (zend_parse_parameters(ZEND_NUM_ARGS(), "rrzb", &in, &out, &consumed, &closing) == FAILURE) {
		RETURN_THROWS();
	}
}

PHP_METHOD(php_user_filter, onCreate)
{
	ZEND_PARSE_PARAMETERS_NONE();

RETURN_TRUE;
}

PHP_METHOD(php_user_filter, onClose)
{
	ZEND_PARSE_PARAMETERS_NONE();
}

static zend_class_entry user_filter_class_entry;

static ZEND_RSRC_DTOR_FUNC(php_bucket_dtor)
{
	php_stream_bucket *bucket = (php_stream_bucket *)res->ptr;
	if (bucket) {
		php_stream_bucket_delref(bucket);
		bucket = NULL;
	}
}

PHP_MINIT_FUNCTION(user_filters)
{
	zend_class_entry *php_user_filter;
	/* init the filter class ancestor */
	INIT_CLASS_ENTRY(user_filter_class_entry, "php_user_filter", class_php_user_filter_methods);
	if ((php_user_filter = zend_register_internal_class(&user_filter_class_entry)) == NULL) {
		return FAILURE;
	}
	zend_declare_property_string(php_user_filter, "filtername", sizeof("filtername")-1, "", ZEND_ACC_PUBLIC);
	zend_declare_property_string(php_user_filter, "params", sizeof("params")-1, "", ZEND_ACC_PUBLIC);

/* init the filter resource; it has no dtor, as streams will always clean it up
	 * at the correct time */
	le_userfilters = zend_register_list_destructors_ex(NULL, NULL, PHP_STREAM_FILTER_RES_NAME, 0);

if (le_userfilters == FAILURE) {
		return FAILURE;
	}

/* Filters will dispose of their brigades */
	le_bucket_brigade = zend_register_list_destructors_ex(NULL, NULL, PHP_STREAM_BRIGADE_RES_NAME, module_number);
	/* Brigades will dispose of their buckets */
	le_bucket = zend_register_list_destructors_ex(php_bucket_dtor, NULL, PHP_STREAM_BUCKET_RES_NAME, module_number);

if (le_bucket_brigade == FAILURE) {
		return FAILURE;
	}

REGISTER_LONG_CONSTANT("PSFS_PASS_ON",			PSFS_PASS_ON,			CONST_CS | CONST_PERSISTENT);
	REGISTER_LONG_CONSTANT("PSFS_FEED_ME",			PSFS_FEED_ME,			CONST_CS | CONST_PERSISTENT);
	REGISTER_LONG_CONSTANT("PSFS_ERR_FATAL",		PSFS_ERR_FATAL,			CONST_CS | CONST_PERSISTENT);

REGISTER_LONG_CONSTANT("PSFS_FLAG_NORMAL",		PSFS_FLAG_NORMAL,		CONST_CS | CONST_PERSISTENT);
	REGISTER_LONG_CONSTANT("PSFS_FLAG_FLUSH_INC",	PSFS_FLAG_FLUSH_INC,	CONST_CS | CONST_PERSISTENT);
	REGISTER_LONG_CONSTANT("PSFS_FLAG_FLUSH_CLOSE",	PSFS_FLAG_FLUSH_CLOSE,	CONST_CS | CONST_PERSISTENT);

return SUCCESS;
}

PHP_RSHUTDOWN_FUNCTION(user_filters)
{
	if (BG(user_filter_map)) {
		zend_hash_destroy(BG(user_filter_map));
		efree(BG(user_filter_map));
		BG(user_filter_map) = NULL;
	}

return SUCCESS;
}

static void userfilter_dtor(php_stream_filter *thisfilter)
{
	zval *obj = &thisfilter->abstract;
	zval func_name;
	zval retval;

if (obj == NULL) {
		/* If there's no object associated then there's nothing to dispose of */
		return;
	}

ZVAL_STRINGL(&func_name, "onclose", sizeof("onclose")-1);

call_user_function(NULL,
			obj,
			&func_name,
			&retval,
			0, NULL);

zval_ptr_dtor(&retval);
	zval_ptr_dtor(&func_name);

/* kill the object */
	zval_ptr_dtor(obj);
}

php_stream_filter_status_t userfilter_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
			)
{
	int ret = PSFS_ERR_FATAL;
	zval *obj = &thisfilter->abstract;
	zval func_name;
	zval retval;
	zval args[4];
	zend_string *propname;
	int call_result;

/* the userfilter object probably doesn't exist anymore */
	if (CG(unclean_shutdown)) {
		return ret;
	}

/* Make sure the stream is not closed while the filter callback executes. */
	uint32_t orig_no_fclose = stream->flags & PHP_STREAM_FLAG_NO_FCLOSE;
	stream->flags |= PHP_STREAM_FLAG_NO_FCLOSE;

if (!zend_hash_str_exists_ind(Z_OBJPROP_P(obj), "stream", sizeof("stream")-1)) {
		zval tmp;

/* Give the userfilter class a hook back to the stream */
		php_stream_to_zval(stream, &tmp);
		Z_ADDREF(tmp);
		add_property_zval(obj, "stream", &tmp);
		/* add_property_zval increments the refcount which is unwanted here */
		zval_ptr_dtor(&tmp);
	}

ZVAL_STRINGL(&func_name, "filter", sizeof("filter")-1);

/* Setup calling arguments */
	ZVAL_RES(&args[0], zend_register_resource(buckets_in, le_bucket_brigade));
	ZVAL_RES(&args[1], zend_register_resource(buckets_out, le_bucket_brigade));

if (bytes_consumed) {
		ZVAL_LONG(&args[2], *bytes_consumed);
	} else {
		ZVAL_NULL(&args[2]);
	}
	ZVAL_MAKE_REF(&args[2]);

ZVAL_BOOL(&args[3], flags & PSFS_FLAG_FLUSH_CLOSE);

call_result = call_user_function(NULL,
			obj,
			&func_name,
			&retval,
			4, args);

zval_ptr_dtor(&func_name);

if (call_result == SUCCESS && Z_TYPE(retval) != IS_UNDEF) {
		convert_to_long(&retval);
		ret = (int)Z_LVAL(retval);
	} else if (call_result == FAILURE) {
		php_error_docref(NULL, E_WARNING, "Failed to call filter function");
	}

if (bytes_consumed) {
		*bytes_consumed = zval_get_long(&args[2]);
	}

if (buckets_in->head) {
		php_stream_bucket *bucket = buckets_in->head;

php_error_docref(NULL, E_WARNING, "Unprocessed filter buckets remaining on input brigade");
		while ((bucket = buckets_in->head)) {
			/* Remove unconsumed buckets from the brigade */
			php_stream_bucket_unlink(bucket);
			php_stream_bucket_delref(bucket);
		}
	}
	if (ret != PSFS_PASS_ON) {
		php_stream_bucket *bucket = buckets_out->head;
		while (bucket != NULL) {
			php_stream_bucket_unlink(bucket);
			php_stream_bucket_delref(bucket);
			bucket = buckets_out->head;
		}
	}

/* filter resources are cleaned up by the stream destructor,
	 * keeping a reference to the stream resource here would prevent it
	 * from being destroyed properly */
	propname = zend_string_init("stream", sizeof("stream")-1, 0);
	Z_OBJ_HANDLER_P(obj, unset_property)(Z_OBJ_P(obj), propname, NULL);
	zend_string_release_ex(propname, 0);

zval_ptr_dtor(&args[3]);
	zval_ptr_dtor(&args[2]);
	zval_ptr_dtor(&args[1]);
	zval_ptr_dtor(&args[0]);

stream->flags &= ~PHP_STREAM_FLAG_NO_FCLOSE;
	stream->flags |= orig_no_fclose;

return ret;
}

static const php_stream_filter_ops userfilter_ops = {
	userfilter_filter,
	userfilter_dtor,
	"user-filter"
};

static php_stream_filter *user_filter_factory_create(const char *filtername,
		zval *filterparams, uint8_t persistent)
{
	struct php_user_filter_data *fdat = NULL;
	php_stream_filter *filter;
	zval obj, zfilter;
	zval func_name;
	zval retval;
	size_t len;

/* some sanity checks */
	if (persistent) {
		php_error_docref(NULL, E_WARNING,
				"Cannot use a user-space filter with a persistent stream");
		return NULL;
	}

len = strlen(filtername);

/* determine the classname/class entry */
	if (NULL == (fdat = zend_hash_str_find_ptr(BG(user_filter_map), (char*)filtername, len))) {
		char *period;

/* Userspace Filters using ambiguous wildcards could cause problems.
           i.e.: myfilter.foo.bar will always call into myfilter.foo.*
                 never seeing myfilter.*
           TODO: Allow failed userfilter creations to continue
                 scanning through the list */
		if ((period = strrchr(filtername, '.'))) {
			char *wildcard = safe_emalloc(len, 1, 3);

/* Search for wildcard matches instead */
			memcpy(wildcard, filtername, len + 1); /* copy \0 */
			period = wildcard + (period - filtername);
			while (period) {
				ZEND_ASSERT(period[0] == '.');
				period[1] = '*';
				period[2] = '\0';
				if (NULL != (fdat = zend_hash_str_find_ptr(BG(user_filter_map), wildcard, strlen(wildcard)))) {
					period = NULL;
				} else {
					*period = '\0';
					period = strrchr(wildcard, '.');
				}
			}
			efree(wildcard);
		}
		ZEND_ASSERT(fdat);
	}

/* bind the classname to the actual class */
	if (fdat->ce == NULL) {
		if (NULL == (fdat->ce = zend_lookup_class(fdat->classname))) {
			php_error_docref(NULL, E_WARNING,
					"User-filter \"%s\" requires class \"%s\", but that class is not defined",
					filtername, ZSTR_VAL(fdat->classname));
			return NULL;
		}
	}

/* create the object */
	if (object_init_ex(&obj, fdat->ce) == FAILURE) {
		return NULL;
	}

filter = php_stream_filter_alloc(&userfilter_ops, NULL, 0);
	if (filter == NULL) {
		zval_ptr_dtor(&obj);
		return NULL;
	}

/* filtername */
	add_property_string(&obj, "filtername", (char*)filtername);

/* and the parameters, if any */
	if (filterparams) {
		add_property_zval(&obj, "params", filterparams);
	} else {
		add_property_null(&obj, "params");
	}

/* invoke the constructor */
	ZVAL_STRINGL(&func_name, "oncreate", sizeof("oncreate")-1);

call_user_function(NULL,
			&obj,
			&func_name,
			&retval,
			0, NULL);

zval_ptr_dtor(&func_name);

if (Z_TYPE(retval) != IS_UNDEF) {
		if (Z_TYPE(retval) == IS_FALSE) {
			/* User reported filter creation error "return false;" */
			zval_ptr_dtor(&retval);

/* Kill the filter (safely) */
			ZVAL_UNDEF(&filter->abstract);
			php_stream_filter_free(filter);

/* Kill the object */
			zval_ptr_dtor(&obj);

/* Report failure to filter_alloc */
			return NULL;
		}
		zval_ptr_dtor(&retval);
	}

/* set the filter property, this will be used during cleanup */
	ZVAL_RES(&zfilter, zend_register_resource(filter, le_userfilters));
	ZVAL_OBJ(&filter->abstract, Z_OBJ(obj));
	add_property_zval(&obj, "filter", &zfilter);
	/* add_property_zval increments the refcount which is unwanted here */
	zval_ptr_dtor(&zfilter);

return filter;
}

static const php_stream_filter_factory user_filter_factory = {
	user_filter_factory_create
};

static void filter_item_dtor(zval *zv)
{
	struct php_user_filter_data *fdat = Z_PTR_P(zv);
	zend_string_release_ex(fdat->classname, 0);
	efree(fdat);
}

/* {{{ Return a bucket object from the brigade for operating on */
PHP_FUNCTION(stream_bucket_make_writeable)
{
	zval *zbrigade, zbucket;
	php_stream_bucket_brigade *brigade;
	php_stream_bucket *bucket;

ZEND_PARSE_PARAMETERS_START(1, 1)
		Z_PARAM_RESOURCE(zbrigade)
	ZEND_PARSE_PARAMETERS_END();

if ((brigade = (php_stream_bucket_brigade*)zend_fetch_resource(
					Z_RES_P(zbrigade), PHP_STREAM_BRIGADE_RES_NAME, le_bucket_brigade)) == NULL) {
		RETURN_THROWS();
	}

ZVAL_NULL(return_value);

if (brigade->head && (bucket = php_stream_bucket_make_writeable(brigade->head))) {
		ZVAL_RES(&zbucket, zend_register_resource(bucket, le_bucket));
		object_init(return_value);
		add_property_zval(return_value, "bucket", &zbucket);
		/* add_property_zval increments the refcount which is unwanted here */
		zval_ptr_dtor(&zbucket);
		add_property_stringl(return_value, "data", bucket->buf, bucket->buflen);
		add_property_long(return_value, "datalen", bucket->buflen);
	}
}
/* }}} */

/* {{{ php_stream_bucket_attach */
static void php_stream_bucket_attach(int append, INTERNAL_FUNCTION_PARAMETERS)
{
	zval *zbrigade, *zobject;
	zval *pzbucket, *pzdata;
	php_stream_bucket_brigade *brigade;
	php_stream_bucket *bucket;

ZEND_PARSE_PARAMETERS_START(2, 2)
		Z_PARAM_RESOURCE(zbrigade)
		Z_PARAM_OBJECT(zobject)
	ZEND_PARSE_PARAMETERS_END();

if (NULL == (pzbucket = zend_hash_str_find_deref(Z_OBJPROP_P(zobject), "bucket", sizeof("bucket")-1))) {
		zend_argument_value_error(2, "must be an object that has a \"bucket\" property");
		RETURN_THROWS();
	}

if ((brigade = (php_stream_bucket_brigade*)zend_fetch_resource(
					Z_RES_P(zbrigade), PHP_STREAM_BRIGADE_RES_NAME, le_bucket_brigade)) == NULL) {
		RETURN_THROWS();
	}

if ((bucket = (php_stream_bucket *)zend_fetch_resource_ex(pzbucket, PHP_STREAM_BUCKET_RES_NAME, le_bucket)) == NULL) {
		RETURN_THROWS();
	}

if (NULL != (pzdata = zend_hash_str_find_deref(Z_OBJPROP_P(zobject), "data", sizeof("data")-1)) && Z_TYPE_P(pzdata) == IS_STRING) {
		if (!bucket->own_buf) {
			bucket = php_stream_bucket_make_writeable(bucket);
		}
		if (bucket->buflen != Z_STRLEN_P(pzdata)) {
			bucket->buf = perealloc(bucket->buf, Z_STRLEN_P(pzdata), bucket->is_persistent);
			bucket->buflen = Z_STRLEN_P(pzdata);
		}
		memcpy(bucket->buf, Z_STRVAL_P(pzdata), bucket->buflen);
	}

if (append) {
		php_stream_bucket_append(brigade, bucket);
	} else {
		php_stream_bucket_prepend(brigade, bucket);
	}
	/* This is a hack necessary to accommodate situations where bucket is appended to the stream
 	 * multiple times. See bug35916.phpt for reference.
	 */
	if (bucket->refcount == 1) {
		bucket->refcount++;
	}
}
/* }}} */

/* {{{ Prepend bucket to brigade */
PHP_FUNCTION(stream_bucket_prepend)
{
	php_stream_bucket_attach(0, INTERNAL_FUNCTION_PARAM_PASSTHRU);
}
/* }}} */

/* {{{ Append bucket to brigade */
PHP_FUNCTION(stream_bucket_append)
{
	php_stream_bucket_attach(1, INTERNAL_FUNCTION_PARAM_PASSTHRU);
}
/* }}} */

/* {{{ Create a new bucket for use on the current stream */
PHP_FUNCTION(stream_bucket_new)
{
	zval *zstream, zbucket;
	php_stream *stream;
	char *buffer;
	char *pbuffer;
	size_t buffer_len;
	php_stream_bucket *bucket;

ZEND_PARSE_PARAMETERS_START(2, 2)
		Z_PARAM_ZVAL(zstream)
		Z_PARAM_STRING(buffer, buffer_len)
	ZEND_PARSE_PARAMETERS_END();

php_stream_from_zval(stream, zstream);
	pbuffer = pemalloc(buffer_len, php_stream_is_persistent(stream));

memcpy(pbuffer, buffer, buffer_len);

bucket = php_stream_bucket_new(stream, pbuffer, buffer_len, 1, php_stream_is_persistent(stream));

ZVAL_RES(&zbucket, zend_register_resource(bucket, le_bucket));
	object_init(return_value);
	add_property_zval(return_value, "bucket", &zbucket);
	/* add_property_zval increments the refcount which is unwanted here */
	zval_ptr_dtor(&zbucket);
	add_property_stringl(return_value, "data", bucket->buf, bucket->buflen);
	add_property_long(return_value, "datalen", bucket->buflen);
}
/* }}} */

/* {{{ Returns a list of registered filters */
PHP_FUNCTION(stream_get_filters)
{
	zend_string *filter_name;
	HashTable *filters_hash;

ZEND_PARSE_PARAMETERS_NONE();

array_init(return_value);

filters_hash = php_get_stream_filters_hash();

if (filters_hash) {
		ZEND_HASH_FOREACH_STR_KEY(filters_hash, filter_name) {
			if (filter_name) {
				add_next_index_str(return_value, zend_string_copy(filter_name));
			}
		} ZEND_HASH_FOREACH_END();
	}
	/* It's okay to return an empty array if no filters are registered */
}
/* }}} */

/* {{{ Registers a custom filter handler class */
PHP_FUNCTION(stream_filter_register)
{
	zend_string *filtername, *classname;
	struct php_user_filter_data *fdat;

ZEND_PARSE_PARAMETERS_START(2, 2)
		Z_PARAM_STR(filtername)
		Z_PARAM_STR(classname)
	ZEND_PARSE_PARAMETERS_END();

if (!ZSTR_LEN(filtername)) {
		zend_argument_value_error(1, "must be a non-empty string");
		RETURN_THROWS();
	}

if (!ZSTR_LEN(classname)) {
		zend_argument_value_error(2, "must be a non-empty string");
		RETURN_THROWS();
	}

if (!BG(user_filter_map)) {
		BG(user_filter_map) = (HashTable*) emalloc(sizeof(HashTable));
		zend_hash_init(BG(user_filter_map), 8, NULL, (dtor_func_t) filter_item_dtor, 0);
	}

fdat = ecalloc(1, sizeof(struct php_user_filter_data));
	fdat->classname = zend_string_copy(classname);

if (zend_hash_add_ptr(BG(user_filter_map), filtername, fdat) != NULL &&
			php_stream_filter_register_factory_volatile(filtername, &user_filter_factory) == SUCCESS) {
		RETVAL_TRUE;
	} else {
		zend_string_release_ex(classname, 0);
		efree(fdat);
		RETVAL_FALSE;
	}
}
/* }}} */

${this.title}

Code Editor : user_filters.c