/* {{{ consumed filter implementation */
typedef struct _php_consumed_filter_data {
int persistent;
size_t consumed;
off_t offset;
} php_consumed_filter_data;
static php_stream_filter_status_t consumed_filter_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
TSRMLS_DC)
{
php_consumed_filter_data *data = (php_consumed_filter_data *)(thisfilter->abstract);
php_stream_bucket *bucket;
size_t consumed = 0;
if (data->offset == ~0) {
data->offset = php_stream_tell(stream);
}
while ((bucket = buckets_in->head) != NULL) {
php_stream_bucket_unlink(bucket TSRMLS_CC);
consumed += bucket->buflen;
php_stream_bucket_append(buckets_out, bucket TSRMLS_CC);
}
if (bytes_consumed) {
*bytes_consumed = consumed;
}
if (flags & PSFS_FLAG_FLUSH_CLOSE) {
php_stream_seek(stream, data->offset + data->consumed, SEEK_SET);
}
data->consumed += consumed;
return PSFS_PASS_ON;
}
static void consumed_filter_dtor(php_stream_filter *thisfilter TSRMLS_DC)
{
if (thisfilter && thisfilter->abstract) {
php_consumed_filter_data *data = (php_consumed_filter_data*)thisfilter->abstract;
pefree(data, data->persistent);
}
}
static php_stream_filter_ops consumed_filter_ops = {
consumed_filter_filter,
consumed_filter_dtor,
"consumed"
};
static php_stream_filter *consumed_filter_create(const char *filtername, zval *filterparams, int persistent TSRMLS_DC)
{
php_stream_filter_ops *fops = NULL;
php_consumed_filter_data *data;
if (strcasecmp(filtername, "consumed")) {
return NULL;
}
/* Create this filter */
data = pecalloc(1, sizeof(php_consumed_filter_data), persistent);
if (!data) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Failed allocating %zd bytes", sizeof(php_consumed_filter_data));
return NULL;
}
data->persistent = persistent;
data->consumed = 0;
data->offset = ~0;
fops = &consumed_filter_ops;
return php_stream_filter_alloc(fops, data, persistent);
}
php_stream_filter_factory consumed_filter_factory = {
consumed_filter_create
};
/* }}} */
