Lines Matching defs:input_brigade
237 apr_bucket_brigade *input_brigade,
251 while (APR_BRIGADE_EMPTY(input_brigade)
252 || !APR_BUCKET_IS_EOS(APR_BRIGADE_FIRST(input_brigade)))
257 if (!APR_BRIGADE_EMPTY(input_brigade)) {
259 if (APR_BUCKET_IS_EOS(APR_BRIGADE_LAST(input_brigade))) {
266 e = APR_BRIGADE_LAST(input_brigade);
270 apr_brigade_length(input_brigade, 1, &bytes);
279 APR_BRIGADE_INSERT_HEAD(input_brigade, e);
285 APR_BRIGADE_INSERT_TAIL(input_brigade, e);
301 * Save input_brigade in bb brigade. (At least) in the SSL case
302 * input_brigade contains transient buckets whose data would get
309 status = ap_save_brigade(NULL, &bb, &input_brigade, p);
317 bb = input_brigade;
329 status = ap_get_brigade(r->input_filters, input_brigade,
351 if (!APR_BRIGADE_EMPTY(input_brigade)) {
353 e = APR_BRIGADE_LAST(input_brigade);
357 bb = input_brigade;
381 apr_bucket_brigade *input_brigade,
408 while (APR_BRIGADE_EMPTY(input_brigade)
409 || !APR_BUCKET_IS_EOS(APR_BRIGADE_FIRST(input_brigade)))
413 if (!APR_BRIGADE_EMPTY(input_brigade)) {
414 apr_brigade_length(input_brigade, 1, &bytes);
418 if (APR_BUCKET_IS_EOS(APR_BRIGADE_LAST(input_brigade))) {
425 e = APR_BRIGADE_LAST(input_brigade);
431 APR_BRIGADE_INSERT_TAIL(input_brigade, e);
466 * Save input_brigade in bb brigade. (At least) in the SSL case
467 * input_brigade contains transient buckets whose data would get
474 status = ap_save_brigade(NULL, &bb, &input_brigade, p);
482 bb = input_brigade;
494 status = ap_get_brigade(r->input_filters, input_brigade,
530 apr_bucket_brigade *input_brigade,
546 if (APR_BRIGADE_EMPTY(input_brigade)) {
547 status = ap_get_brigade(r->input_filters, input_brigade,
552 && !APR_BUCKET_IS_EOS(APR_BRIGADE_FIRST(input_brigade)))
555 if (APR_BUCKET_IS_EOS(APR_BRIGADE_LAST(input_brigade))) {
559 e = APR_BRIGADE_LAST(input_brigade);
563 apr_brigade_length(input_brigade, 1, &bytes);
599 for (e = APR_BRIGADE_FIRST(input_brigade);
600 e != APR_BRIGADE_SENTINEL(input_brigade);
621 apr_brigade_cleanup(input_brigade);
626 * Save input_brigade in body_brigade. (At least) in the SSL case
627 * input_brigade contains transient buckets whose data would get
634 status = ap_save_brigade(NULL, &body_brigade, &input_brigade, p);
647 status = ap_get_brigade(r->input_filters, input_brigade,
736 apr_bucket_brigade *input_brigade,
769 * Because the new logic looks at input_brigade, we will self-terminate
770 * input_brigade and jump past all of the request body logic...
783 e = apr_bucket_eos_create(input_brigade->bucket_alloc);
784 APR_BRIGADE_INSERT_TAIL(input_brigade, e);
847 * Save temp_brigade in input_brigade. (At least) in the SSL case
852 * input_brigade already has been created and does not need to get
855 status = ap_save_brigade(NULL, &input_brigade, &temp_brigade, p);
871 && !APR_BUCKET_IS_EOS(APR_BRIGADE_LAST(input_brigade))
909 if (!APR_BRIGADE_EMPTY(input_brigade)
910 && APR_BUCKET_IS_EOS(APR_BRIGADE_LAST(input_brigade))) {
960 rv = spool_reqbody_cl(p, r, header_brigade, input_brigade,
995 apr_bucket_brigade *input_brigade,
1006 input_brigade, flushall);
1010 input_brigade, old_cl_val, flushall);
1989 apr_bucket_brigade *input_brigade;
2086 input_brigade = apr_brigade_create(p, c->bucket_alloc);
2090 header_brigade, input_brigade,
2178 header_brigade, input_brigade,