Lines Matching refs:brecv

955     apr_bucket *bsender, *brecv, *ng;  in h2_beam_receive()  local
980 brecv = APR_BRIGADE_FIRST(beam->recv_buffer); in h2_beam_receive()
981 if (brecv->length > 0 && remain <= 0) { in h2_beam_receive()
984 APR_BUCKET_REMOVE(brecv); in h2_beam_receive()
985 APR_BRIGADE_INSERT_TAIL(bb, brecv); in h2_beam_receive()
986 remain -= brecv->length; in h2_beam_receive()
994 brecv = NULL; in h2_beam_receive()
1002 brecv = apr_bucket_eos_create(bb->bucket_alloc); in h2_beam_receive()
1006 brecv = apr_bucket_flush_create(bb->bucket_alloc); in h2_beam_receive()
1010 brecv = ap_bucket_error_create(eb->status, eb->data, in h2_beam_receive()
1057 brecv = h2_beam_bucket_create(beam, bsender, bb->bucket_alloc, in h2_beam_receive()
1069 if (brecv) { in h2_beam_receive()
1070 APR_BRIGADE_INSERT_TAIL(bb, brecv); in h2_beam_receive()
1071 remain -= brecv->length; in h2_beam_receive()
1077 brecv = h2_beam_bucket(beam, bb, bsender); in h2_beam_receive()
1080 while (brecv && brecv != APR_BRIGADE_SENTINEL(bb)) { in h2_beam_receive()
1082 remain -= brecv->length; in h2_beam_receive()
1083 brecv = APR_BUCKET_NEXT(brecv); in h2_beam_receive()
1091 for (brecv = APR_BRIGADE_FIRST(bb); in h2_beam_receive()
1092 brecv != APR_BRIGADE_SENTINEL(bb); in h2_beam_receive()
1093 brecv = APR_BUCKET_NEXT(brecv)) { in h2_beam_receive()
1094 remain -= (beam->tx_mem_limits? bucket_mem_used(brecv) in h2_beam_receive()
1095 : (apr_off_t)brecv->length); in h2_beam_receive()
1097 apr_bucket_split(brecv, (apr_size_t)((apr_off_t)brecv->length+remain)); in h2_beam_receive()
1099 APR_BUCKET_NEXT(brecv), in h2_beam_receive()