Lines Matching refs:cq

488 			chunkqueue *cq = &r->reqbody_queue;  in cgi_process_wr_revents()  local
489 chunkqueue_mark_written(cq, chunkqueue_length(cq)); in cgi_process_wr_revents()
490 if (cq->bytes_in != (off_t)r->reqbody_length) { in cgi_process_wr_revents()
547 chunkqueue *cq = &r->reqbody_queue; in cgi_response_headers() local
550 if (cq->bytes_out == (off_t)r->reqbody_length) { in cgi_response_headers()
671 chunkqueue *cq = &r->reqbody_queue; in cgi_write_request() local
674 chunkqueue_remove_finished_chunks(cq); /* unnecessary? */ in cgi_write_request()
679 for (c = cq->first; c; c = cq->first) { in cgi_write_request()
680 ssize_t wr = chunkqueue_write_chunk_to_pipe(fd, cq, r->conf.errh); in cgi_write_request()
683 chunkqueue_mark_written(cq, wr); in cgi_write_request()
686 if (c != cq->first || wr == 16384) in cgi_write_request()
702 chunkqueue_mark_written(cq, chunkqueue_length(cq)); in cgi_write_request()
714 if (cq->bytes_out == (off_t)r->reqbody_length && !hctx->conf.upgrade) { in cgi_write_request()
726 off_t cqlen = chunkqueue_length(cq); in cgi_write_request()
727 if (cq->bytes_in != r->reqbody_length && cqlen < 65536 - 16384) { in cgi_write_request()
780 chunkqueue * const cq = &r->reqbody_queue; in cgi_create_env() local
781 chunk * const c = cq->first; in cgi_create_env()
782 if (c && c == cq->last && c->type == FILE_CHUNK && c->file.is_temp) { in cgi_create_env()
785 && 0 != chunkqueue_open_file_chunk(cq, r->conf.errh)) in cgi_create_env()
947 chunkqueue * const cq = &r->reqbody_queue; in cgi_create_env() local
948 chunkqueue_mark_written(cq, chunkqueue_length(cq)); in cgi_create_env()
1112 chunkqueue * const cq = &r->reqbody_queue; in SUBREQUEST_FUNC() local
1114 if (cq->bytes_in != (off_t)r->reqbody_length) { in SUBREQUEST_FUNC()
1117 if (chunkqueue_length(cq) > 65536 - 4096 in SUBREQUEST_FUNC()
1145 } else if (!chunkqueue_is_empty(cq)) { in SUBREQUEST_FUNC()