Lines Matching refs:dst_cq

1641 …n_handle_read_post_chunked (request_st * const r, chunkqueue * const cq, chunkqueue * const dst_cq)  in connection_handle_read_post_chunked()  argument
1732 r->reqbody_length = dst_cq->bytes_in; in connection_handle_read_post_chunked()
1742 || max_request_size - te_chunked < dst_cq->bytes_in)) { in connection_handle_read_post_chunked()
1745 (long long)(dst_cq->bytes_in + te_chunked)); in connection_handle_read_post_chunked()
1771 if (dst_cq->bytes_in + te_chunked <= 64*1024) { in connection_handle_read_post_chunked()
1773 chunkqueue_steal(dst_cq, cq, len); in connection_handle_read_post_chunked()
1775 else if (0 != chunkqueue_steal_with_tempfiles(dst_cq, cq, len, in connection_handle_read_post_chunked()
1805 …n_handle_read_body_unknown (request_st * const r, chunkqueue * const cq, chunkqueue * const dst_cq) in connection_handle_read_body_unknown() argument
1809 chunkqueue_append_chunkqueue(dst_cq, cq); in connection_handle_read_body_unknown()
1810 if (0 != max_request_size && dst_cq->bytes_in > max_request_size) { in connection_handle_read_body_unknown()
1812 "request-size too long: %lld -> 413", (long long)dst_cq->bytes_in); in connection_handle_read_body_unknown()
1859 chunkqueue * const dst_cq = &r->reqbody_queue; in connection_handle_read_post_state() local
1902 ? connection_handle_read_post_chunked(r, cq, dst_cq) in connection_handle_read_post_state()
1903 : connection_handle_read_body_unknown(r, cq, dst_cq); in connection_handle_read_post_state()
1908 off_t len = (off_t)r->reqbody_length - dst_cq->bytes_in; in connection_handle_read_post_state()
1911 chunkqueue_steal(dst_cq, cq, len); in connection_handle_read_post_state()
1913 else if (chunkqueue_length(dst_cq) + len <= 64*1024 in connection_handle_read_post_state()
1914 && (!dst_cq->first || dst_cq->first->type == MEM_CHUNK)) { in connection_handle_read_post_state()
1916 chunkqueue_steal(dst_cq, cq, len); in connection_handle_read_post_state()
1919 chunkqueue_steal_with_tempfiles(dst_cq,cq,len,r->conf.errh)) { in connection_handle_read_post_state()
1926 if (dst_cq->bytes_in == (off_t)r->reqbody_length) { in connection_handle_read_post_state()