/httpd/modules/generators/ |
H A D | mod_asis.c | 82 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);
|
H A D | mod_cgi.h | 41 apr_bucket_brigade **bb; member in struct:__anon182
|
/httpd/include/ |
H A D | apreq_util.h | 267 * @param bb Bucket brigade. 273 * @remarks This function leaks a bucket brigade into bb->p whenever 274 * the final bucket in bb is a spool bucket. 279 apr_bucket_brigade *bb); 303 * @param bb Brigade. 310 apr_status_t apreq_brigade_setaside(apr_bucket_brigade *bb, apr_pool_t *p) argument 313 for (e = APR_BRIGADE_FIRST(bb); e != APR_BRIGADE_SENTINEL(bb); 434 * @param bb the bucket brigade 437 APREQ_DECLARE(apr_file_t *) apreq_brigade_spoolfile(apr_bucket_brigade *bb); variable [all...] |
H A D | apreq_parser.h | 49 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
|
/httpd/server/ |
H A D | connection.c | 70 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 D | apreq_parser_header.c | 27 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 D | apreq_parser_urlencoded.c | 28 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 D | apreq_parser_multipart.c | 35 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...] |
/httpd/modules/apreq/ |
H A D | apreq_private_apache2.h | 20 apr_bucket_brigade *bb; /* input brigade that's passed to the parser */ member in struct:filter_ctx 21 apr_bucket_brigade *bbtmp; /* temporary copy of bb, destined for the spool */ 37 apr_bucket_brigade *bb,
|
H A D | filter.c | 178 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/debugging/ |
H A D | mod_bucketeer.c | 58 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...] |
H A D | mod_dumpio.c | 126 static int dumpio_input_filter (ap_filter_t *f, apr_bucket_brigade *bb, argument 142 ret = ap_get_brigade(f->next, bb, mode, block, readbytes); 145 for (b = APR_BRIGADE_FIRST(bb); b != APR_BRIGADE_SENTINEL(bb); b = APR_BUCKET_NEXT(b)) { 158 static int dumpio_output_filter (ap_filter_t *f, apr_bucket_brigade *bb) argument 166 for (b = APR_BRIGADE_FIRST(bb); b != APR_BRIGADE_SENTINEL(bb); b = APR_BUCKET_NEXT(b)) { 177 return ap_pass_brigade(f->next, bb) ;
|
/httpd/modules/filters/ |
H A D | mod_data.c | 44 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 D | mod_ratelimit.c | 44 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 D | mod_buffer.c | 45 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 D | mod_request.c | 40 static apr_status_t bail_out_on_error(apr_bucket_brigade *bb, argument 46 apr_brigade_cleanup(bb); 50 APR_BRIGADE_INSERT_TAIL(bb, e); 52 APR_BRIGADE_INSERT_TAIL(bb, e); 53 return ap_pass_brigade(f->r->output_filters, bb);
|
H A D | mod_sed.c | 50 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...] |
/httpd/modules/echo/ |
H A D | mod_echo.c | 132 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/proxy/ |
H A D | mod_proxy_fdpass.c | 201 apr_bucket_brigade *bb; local 206 bb = apr_brigade_create(r->pool, r->connection->bucket_alloc); 209 APR_BRIGADE_INSERT_TAIL(bb, e); 211 status = ap_pass_brigade(r->output_filters, bb);
|
H A D | mod_proxy_connect.c | 148 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...] |
/httpd/modules/ssl/ |
H A D | ssl_util_ocsp.c | 185 apr_bucket_brigade *bb, *tmpbb; local 193 bb = apr_brigade_create(p, c->bucket_alloc); 195 APR_BRIGADE_INSERT_TAIL(bb, apr_bucket_socket_create(sd, c->bucket_alloc)); 197 line = get_line(tmpbb, bb, c, p); 211 while ((line = get_line(tmpbb, bb, c, p)) != NULL && line[0] 231 while (!APR_BRIGADE_EMPTY(bb)) { 235 apr_bucket *e = APR_BRIGADE_FIRST(bb); 269 apr_brigade_destroy(bb);
|
/httpd/modules/cache/ |
H A D | mod_file_cache.c | 276 apr_bucket_brigade *bb = apr_brigade_create(r->pool, c->bucket_alloc); local 281 APR_BRIGADE_INSERT_TAIL(bb, b); 283 APR_BRIGADE_INSERT_TAIL(bb, b); 285 if (ap_pass_brigade(r->output_filters, bb) != APR_SUCCESS) 296 apr_bucket_brigade *bb = apr_brigade_create(r->pool, c->bucket_alloc); local 298 apr_brigade_insert_file(bb, file->file, 0, file->finfo.size, r->pool); 301 APR_BRIGADE_INSERT_TAIL(bb, b); 303 if (ap_pass_brigade(r->output_filters, bb) != APR_SUCCESS)
|
/httpd/modules/http/ |
H A D | http_request.c | 231 static void check_pipeline(conn_rec *c, apr_bucket_brigade *bb) argument 236 AP_DEBUG_ASSERT(APR_BRIGADE_EMPTY(bb)); 237 rv = ap_get_brigade(c->input_filters, bb, AP_MODE_SPECULATIVE, 239 if (rv != APR_SUCCESS || APR_BRIGADE_EMPTY(bb)) { 255 apr_bucket_brigade *bb; local 263 bb = apr_brigade_create(c->pool, c->bucket_alloc); 265 APR_BRIGADE_INSERT_HEAD(bb, b); 267 ap_pass_brigade(c->output_filters, bb); 270 * deleted or moved to a buffered_bb => no more in bb), or an error 271 * occured before that (eg. c->aborted => still in bb) an 368 apr_bucket_brigade *bb; local [all...] |
/httpd/modules/loggers/ |
H A D | mod_logio.c | 179 apr_bucket_brigade *bb, 188 status = ap_get_brigade(f->next, bb, mode, block, readbytes); 190 apr_brigade_length (bb, 0, &length); 178 logio_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
|
/httpd/modules/test/ |
H A D | mod_dialup.c | 42 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...] |