Searched refs:bb (Results 1 - 25 of 81) sorted by relevance

1234

/httpd/modules/filters/
H A Dmod_data.c44 apr_bucket_brigade *bb; member in struct:data_ctx
65 static apr_status_t data_out_filter(ap_filter_t *f, apr_bucket_brigade *bb) argument
85 return ap_pass_brigade(f->next, bb);
89 ctx->bb = apr_brigade_create(r->pool, f->c->bucket_alloc);
103 apr_brigade_printf(ctx->bb, NULL, NULL, "data:%s%s;base64,",
109 apr_brigade_length(ctx->bb, 1, &len);
125 if (APR_BRIGADE_EMPTY(bb)) {
126 return ap_pass_brigade(f->next, bb);
129 while (APR_SUCCESS == rv && !APR_BRIGADE_EMPTY(bb)) {
138 e = APR_BRIGADE_FIRST(bb);
[all...]
H A Dmod_buffer.c45 apr_bucket_brigade *bb; member in struct:buffer_ctx
55 static apr_status_t buffer_out_filter(ap_filter_t *f, apr_bucket_brigade *bb) { argument
71 return ap_pass_brigade(f->next, bb);
75 ctx->bb = apr_brigade_create(r->pool, f->c->bucket_alloc);
81 if (APR_BRIGADE_EMPTY(bb)) {
82 return ap_pass_brigade(f->next, bb);
86 if (APR_BRIGADE_EMPTY(ctx->bb)) {
90 while (APR_SUCCESS == rv && !APR_BRIGADE_EMPTY(bb)) {
95 e = APR_BRIGADE_FIRST(bb);
104 APR_BRIGADE_INSERT_TAIL(ctx->bb,
189 buffer_in_filter(ap_filter_t *f, apr_bucket_brigade *bb, ap_input_mode_t mode, apr_read_type_e block, apr_off_t readbytes) argument
[all...]
H A Dmod_ratelimit.c44 static void brigade_dump(request_rec *r, apr_bucket_brigade *bb)
49 for (e = APR_BRIGADE_FIRST(bb);
50 e != APR_BRIGADE_SENTINEL(bb); e = APR_BUCKET_NEXT(e), i++) {
66 apr_bucket_brigade *bb = input_bb; local
70 apr_brigade_cleanup(bb);
82 return ap_pass_brigade(f->next, bb);
89 return ap_pass_brigade(f->next, bb);
97 return ap_pass_brigade(f->next, bb);
114 (!APR_BRIGADE_EMPTY(bb) || !APR_BRIGADE_EMPTY(ctx->holdingbb))) {
118 APR_BRIGADE_CONCAT(bb, ct
[all...]
H A Dmod_sed.c50 apr_bucket_brigade *bb; member in struct:sed_filter_ctxt
101 * Allocate a new bucket from buf and sz and append to ctx->bb
111 APR_BRIGADE_INSERT_TAIL(ctx->bb, b);
117 APR_BRIGADE_INSERT_TAIL(ctx->bb, b);
121 APR_BRIGADE_INSERT_TAIL(ctx->bb, b);
122 status = ap_pass_brigade(ctx->f->next, ctx->bb);
123 apr_brigade_cleanup(ctx->bb);
244 ctx->bb = NULL;
268 apr_bucket_brigade *bb)
280 return ap_pass_brigade(f->next, bb);
267 sed_response_filter(ap_filter_t *f, apr_bucket_brigade *bb) argument
372 sed_request_filter(ap_filter_t *f, apr_bucket_brigade *bb, ap_input_mode_t mode, apr_read_type_e block, apr_off_t readbytes) argument
[all...]
H A Dmod_include.h48 #define SSI_CREATE_ERROR_BUCKET(ctx, f, bb) APR_BRIGADE_INSERT_TAIL((bb), \
H A Dmod_deflate.c399 apr_bucket_brigade *bb, *proc_bb; member in struct:deflate_ctx_t
422 int len, int crc, apr_bucket_brigade *bb)
436 bb->bucket_alloc);
437 APR_BRIGADE_INSERT_TAIL(bb, b);
454 consume_buffer(ctx, c, deflate_len, crc, ctx->bb);
566 apr_bucket_brigade *bb)
578 if (APR_BRIGADE_EMPTY(bb)) {
600 return ap_pass_brigade(f->next, bb);
603 /* We have checked above that bb is not empty */
604 e = APR_BRIGADE_LAST(bb);
421 consume_buffer(deflate_ctx *ctx, deflate_filter_config *c, int len, int crc, apr_bucket_brigade *bb) argument
565 deflate_out_filter(ap_filter_t *f, apr_bucket_brigade *bb) argument
1110 deflate_in_filter(ap_filter_t *f, apr_bucket_brigade *bb, ap_input_mode_t mode, apr_read_type_e block, apr_off_t readbytes) argument
1512 inflate_out_filter(ap_filter_t *f, apr_bucket_brigade *bb) argument
[all...]
/httpd/modules/debugging/
H A Dmod_bucketeer.c58 apr_bucket_brigade *bb; member in struct:bucketeer_ctx_t
62 apr_bucket_brigade *bb)
75 return ap_pass_brigade(f->next, bb);
80 ctx->bb = apr_brigade_create(f->r->pool, f->c->bucket_alloc);
84 for (e = APR_BRIGADE_FIRST(bb);
85 e != APR_BRIGADE_SENTINEL(bb);
93 APR_BRIGADE_INSERT_TAIL(ctx->bb, e);
98 return ap_pass_brigade(f->next, ctx->bb);
113 APR_BRIGADE_INSERT_TAIL(ctx->bb, cpy);
134 APR_BRIGADE_INSERT_TAIL(ctx->bb,
61 bucketeer_out_filter(ap_filter_t *f, apr_bucket_brigade *bb) argument
[all...]
/httpd/server/
H A Dapreq_parser_header.c27 else if (bb == NULL) \
33 apr_bucket_brigade *bb; member in struct:hdr_ctx
53 apr_bucket_brigade *bb,
80 e = APR_BRIGADE_FIRST(bb);
146 while ((f = APR_BRIGADE_FIRST(bb)) != e)
164 ctx->bb = apr_brigade_create(pool, parser->bucket_alloc);
172 e = APR_BRIGADE_LAST(ctx->bb);
173 APR_BRIGADE_CONCAT(ctx->bb, bb);
183 e != APR_BRIGADE_SENTINEL(ctx->bb);
51 split_header_line(apreq_param_t **p, apr_pool_t *pool, apr_bucket_brigade *bb, apr_size_t nlen, apr_size_t glen, apr_size_t vlen) argument
[all...]
H A Dcore_filters.c333 apr_bucket_brigade *bb,
337 apr_bucket_brigade *bb,
341 static void remove_empty_buckets(apr_bucket_brigade *bb);
344 apr_bucket_brigade *bb,
350 apr_bucket_brigade *bb,
376 apr_bucket_brigade *bb = NULL; local
397 * allocated from bb->pool which might be wrong.
405 bb = new_bb;
410 APR_BRIGADE_PREPEND(bb, ctx->buffered_bb);
413 bb
610 setaside_remaining_output(ap_filter_t *f, core_output_filter_ctx_t *ctx, apr_bucket_brigade *bb, conn_rec *c) argument
649 send_brigade_nonblocking(apr_socket_t *s, apr_bucket_brigade *bb, apr_size_t *bytes_written, conn_rec *c) argument
749 remove_empty_buckets(apr_bucket_brigade *bb) argument
758 send_brigade_blocking(apr_socket_t *s, apr_bucket_brigade *bb, apr_size_t *bytes_written, conn_rec *c) argument
795 writev_nonblocking(apr_socket_t *s, struct iovec *vec, apr_size_t nvec, apr_bucket_brigade *bb, apr_size_t *cumulative_bytes_written, conn_rec *c) argument
[all...]
H A Dapreq_parser_urlencoded.c28 else if (bb == NULL) \
35 apr_bucket_brigade *bb; member in struct:url_ctx
50 apr_bucket_brigade *bb,
76 e = APR_BRIGADE_FIRST(bb);
150 while ((f = APR_BRIGADE_FIRST(bb)) != e)
167 ctx->bb = apr_brigade_create(pool, parser->bucket_alloc);
175 e = APR_BRIGADE_LAST(ctx->bb);
176 APR_BRIGADE_CONCAT(ctx->bb, bb);
181 e != APR_BRIGADE_SENTINEL(ctx->bb);
49 split_urlword(apreq_param_t **p, apr_pool_t *pool, apr_bucket_brigade *bb, apr_size_t nlen, apr_size_t vlen) argument
[all...]
H A Dapreq_parser_multipart.c35 else if (bb == NULL) \
45 apr_bucket_brigade *bb; member in struct:mfd_ctx
71 static apr_status_t brigade_start_string(apr_bucket_brigade *bb, argument
77 for (e = APR_BRIGADE_FIRST(bb); e != APR_BRIGADE_SENTINEL(bb);
251 ctx->bb = apr_brigade_create(pool, ba);
282 APR_BRIGADE_CONCAT(ctx->in, bb);
290 s = split_on_bdry(ctx->bb, ctx->in, NULL, ctx->bdry + 2);
293 apreq_brigade_setaside(ctx->bb, pool);
298 APR_BRIGADE_CONCAT(bb, ct
[all...]
H A Dconnection.c70 apr_bucket_brigade *bb; local
73 bb = apr_brigade_create(c->pool, c->bucket_alloc);
78 APR_BRIGADE_INSERT_TAIL(bb, b);
83 APR_BRIGADE_INSERT_TAIL(bb, b);
85 rv = ap_pass_brigade(c->output_filters, bb);
86 apr_brigade_destroy(bb);
H A Dapreq_parser.c30 else if (bb == NULL) \
192 return (bb == NULL) ? APR_SUCCESS : APREQ_ERROR_GENERAL;
199 s = apreq_hook_run(hook->next, param, bb);
200 if (bb != NULL)
201 apr_brigade_cleanup(bb);
222 apr_bucket *e = APR_BRIGADE_LAST(bb);
237 while (e != APR_BRIGADE_SENTINEL(bb)) {
246 s = apreq_hook_run(parser->hook, ctx->param, bb);
253 apreq_brigade_setaside(bb, pool);
255 ctx->param->upload, bb);
[all...]
/httpd/include/
H A Dapreq_parser.h49 apr_bucket_brigade *bb
54 apr_bucket_brigade *bb
120 * @remark bb == NULL is valid: the parser should return its
125 apr_bucket_brigade *bb)
127 return psr->parser(psr, t, bb);
134 * be added to the parameter's bb attribute.
139 apr_bucket_brigade *bb)
141 return h->hook(h, param, bb);
169 * no hooks are configured, the dummy param's bb slot will
124 apreq_parser_run(struct apreq_parser_t *psr, apr_table_t *t, apr_bucket_brigade *bb) argument
138 apreq_hook_run(struct apreq_hook_t *h, apreq_param_t *param, apr_bucket_brigade *bb) argument
H A Dutil_filter.h538 * @param bb The brigade to flush
543 AP_DECLARE_NONSTD(apr_status_t) ap_filter_flush(apr_bucket_brigade *bb,
549 * @param bb The brigade to flush
551 AP_DECLARE(apr_status_t) ap_fflush(ap_filter_t *f, apr_bucket_brigade *bb);
556 * @param bb The brigade to buffer into
560 #define ap_fwrite(f, bb, data, nbyte) \
561 apr_brigade_write(bb, ap_filter_flush, f, data, nbyte)
566 * @param bb The brigade to buffer into
569 #define ap_fputs(f, bb, str) \
570 apr_brigade_write(bb, ap_filter_flus
[all...]
H A Dutil_script.h113 * @param bb The brigade from which to read
117 * @fn int ap_scan_script_header_err_brigade(request_rec *r, apr_bucket_brigade *bb, char *buffer)
120 apr_bucket_brigade *bb,
128 * @param bb The brigade from which to read
135 apr_bucket_brigade *bb,
/httpd/modules/echo/
H A Dmod_echo.c132 apr_bucket_brigade *bb; local
145 bb = apr_brigade_create(c->pool, c->bucket_alloc);
151 if (((rv = ap_get_brigade(c->input_filters, bb, AP_MODE_GETLINE,
153 apr_brigade_cleanup(bb);
162 if (APR_BRIGADE_EMPTY(bb)) {
174 update_echo_child_status(c->sbh, SERVER_BUSY_WRITE, NULL, bb);
178 APR_BRIGADE_INSERT_TAIL(bb, b);
179 rv = ap_pass_brigade(c->output_filters, bb);
186 apr_brigade_cleanup(bb);
191 apr_brigade_destroy(bb);
[all...]
/httpd/modules/generators/
H A Dmod_cgi.h41 apr_bucket_brigade **bb; member in struct:__anon182
H A Dmod_asis.c82 apr_bucket_brigade *bb; local
95 bb = apr_brigade_create(r->pool, c->bucket_alloc);
96 apr_brigade_insert_file(bb, f, pos, r->finfo.size - pos, r->pool);
99 APR_BRIGADE_INSERT_TAIL(bb, b);
100 rv = ap_pass_brigade(r->output_filters, bb);
/httpd/modules/http/
H A Dhttp_filters.c362 apr_bucket_brigade *bb; local
364 bb = apr_brigade_create(f->r->pool, f->c->bucket_alloc);
376 APR_BRIGADE_INSERT_HEAD(bb, e);
378 APR_BRIGADE_INSERT_TAIL(bb, e);
380 rv = ap_pass_brigade(f->c->output_filters, bb);
634 apr_bucket_brigade *bb; member in struct:header_struct
652 apr_brigade_write(h->bb, NULL, NULL, headfield, len);
667 apr_brigade_writev(h->bb, NULL, NULL, vec, 4);
805 return apr_brigade_write(h->bb, NULL, NULL, tmp, len);
808 return apr_brigade_writev(h->bb, NUL
893 basic_http_header(request_rec *r, apr_bucket_brigade *bb, const char *protocol) argument
987 ap_basic_http_header(request_rec *r, apr_bucket_brigade *bb) argument
995 terminate_header(apr_bucket_brigade *bb) argument
1009 apr_bucket_brigade *bb; local
1408 apr_bucket_brigade *bb; local
1585 apr_bucket_brigade *bb; local
[all...]
/httpd/modules/test/
H A Dmod_dialup.c42 apr_bucket_brigade *bb; member in struct:dialup_baton_t
53 while (!APR_BRIGADE_EMPTY(db->bb) && bytes_sent < db->bytes_per_second) {
60 status = apr_brigade_partition(db->bb, db->bytes_per_second, &e);
67 if (e != APR_BRIGADE_SENTINEL(db->bb)) {
70 f = APR_RING_FIRST(&db->bb->list);
75 APR_BRIGADE_CONCAT(db->tmpbb, db->bb);
95 if (APR_BRIGADE_EMPTY(db->bb)) {
197 db->bb = apr_brigade_create(r->pool, r->connection->bucket_alloc);
200 e = apr_brigade_insert_file(db->bb, fd, 0, r->finfo.size, r->pool);
215 APR_BRIGADE_INSERT_TAIL(db->bb,
[all...]
H A Dmod_policy.c136 const char *message, const char *url, apr_bucket_brigade *bb,
170 apr_brigade_cleanup(bb);
173 APR_BRIGADE_INSERT_TAIL(bb, e);
175 APR_BRIGADE_INSERT_TAIL(bb, e);
191 apr_bucket_brigade *bb)
244 f->r->content_type, types), conf->type_url, bb, HTTP_BAD_GATEWAY);
251 return ap_pass_brigade(f->next, bb);
261 apr_bucket_brigade *bb)
275 conf->length_url, bb, HTTP_BAD_GATEWAY);
282 return ap_pass_brigade(f->next, bb);
135 handle_policy(request_rec *r, policy_result result, const char *message, const char *url, apr_bucket_brigade *bb, int status) argument
190 policy_type_out_filter(ap_filter_t *f, apr_bucket_brigade *bb) argument
260 policy_length_out_filter(ap_filter_t *f, apr_bucket_brigade *bb) argument
307 policy_keepalive_out_filter(ap_filter_t *f, apr_bucket_brigade *bb) argument
368 policy_vary_out_filter(ap_filter_t *f, apr_bucket_brigade *bb) argument
411 policy_validation_out_filter(ap_filter_t *f, apr_bucket_brigade *bb) argument
487 policy_conditional_out_filter(ap_filter_t *f, apr_bucket_brigade *bb) argument
528 policy_nocache_out_filter(ap_filter_t *f, apr_bucket_brigade *bb) argument
636 policy_maxage_out_filter(ap_filter_t *f, apr_bucket_brigade *bb) argument
828 policy_version_out_filter(ap_filter_t *f, apr_bucket_brigade *bb) argument
[all...]
/httpd/modules/ssl/
H A Dssl_engine_io.c117 apr_bucket_brigade *bb; /* Brigade used as a buffer. */ member in struct:__anon317
128 outctx->bb = apr_brigade_create(c->pool, c->bucket_alloc);
137 AP_DEBUG_ASSERT(!APR_BRIGADE_EMPTY(outctx->bb));
140 outctx->bb);
155 AP_DEBUG_ASSERT(APR_BRIGADE_EMPTY(outctx->bb));
157 e = apr_bucket_flush_create(outctx->bb->bucket_alloc);
158 APR_BRIGADE_INSERT_TAIL(outctx->bb, e);
214 e = apr_bucket_transient_create(in, inl, outctx->bb->bucket_alloc);
215 APR_BRIGADE_INSERT_TAIL(outctx->bb, e);
313 apr_bucket_brigade *bb; member in struct:__anon319
366 brigade_consume(apr_bucket_brigade *bb, apr_read_type_e block, char *c, apr_size_t *len) argument
914 ssl_io_filter_error(ap_filter_t *f, apr_bucket_brigade *bb, apr_status_t status) argument
1375 ssl_io_filter_input(ap_filter_t *f, apr_bucket_brigade *bb, ap_input_mode_t mode, apr_read_type_e block, apr_off_t readbytes) argument
1571 ssl_io_filter_coalesce(ap_filter_t *f, apr_bucket_brigade *bb) argument
1695 ssl_io_filter_output(ap_filter_t *f, apr_bucket_brigade *bb) argument
1804 apr_bucket_brigade *bb; member in struct:modssl_buffer_ctx
1911 ssl_io_filter_buffer(ap_filter_t *f, apr_bucket_brigade *bb, ap_input_mode_t mode, apr_read_type_e block, apr_off_t bytes) argument
[all...]
/httpd/modules/apreq/
H A Dfilter.c178 ctx->bb = apr_brigade_create(r->pool, ba);
270 rv = ap_get_brigade(f->next, ctx->bb, AP_MODE_READBYTES,
280 apreq_brigade_setaside(ctx->bb, r->pool);
281 apreq_brigade_copy(ctx->bbtmp, ctx->bb);
308 apr_brigade_length(ctx->bb, 1, &len);
320 ctx->body_status = apreq_parser_run(ctx->parser, ctx->body, ctx->bb);
321 apr_brigade_cleanup(ctx->bb);
329 apr_bucket_brigade *bb,
346 return ap_get_brigade(f->next, bb, mode, block, readbytes);
369 apreq_brigade_move(bb, ct
328 apreq_filter(ap_filter_t *f, apr_bucket_brigade *bb, ap_input_mode_t mode, apr_read_type_e block, apr_off_t readbytes) argument
[all...]
/httpd/modules/proxy/
H A Dmod_proxy_connect.c148 apr_bucket_brigade *bb, char *name)
156 apr_brigade_cleanup(bb);
157 rv = ap_get_brigade(c_i->input_filters, bb, AP_MODE_READBYTES,
162 if (APR_BRIGADE_EMPTY(bb))
166 apr_brigade_length(bb, 0, &len);
171 rv = ap_pass_brigade(c_o->output_filters, bb);
173 ap_fflush(c_o->output_filters, bb);
208 apr_bucket_brigade *bb = apr_brigade_create(p, c->bucket_alloc); local
371 ap_fprintf(backconn->output_filters, bb,
373 ap_fprintf(backconn->output_filters, bb,
147 proxy_connect_transfer(request_rec *r, conn_rec *c_i, conn_rec *c_o, apr_bucket_brigade *bb, char *name) argument
[all...]

Completed in 4345 milliseconds

1234