Lines Matching refs:cq

769     chunkqueue * const cq = &r->write_queue;  in webdav_xml_log_response()  local
771 if (chunkqueue_length(cq) <= 65536) in webdav_xml_log_response()
772 chunkqueue_read_squash(cq, errh); in webdav_xml_log_response()
775 for (chunk *c = cq->first; c; c = c->next) { in webdav_xml_log_response()
1021 chunkqueue * const cq = &r->write_queue; in webdav_xml_doc_multistatus() local
1022 buffer * const b = chunkqueue_prepend_buffer_open(cq); in webdav_xml_doc_multistatus()
1026 chunkqueue_prepend_buffer_commit(cq); in webdav_xml_doc_multistatus()
1028 chunkqueue_append_mem(cq, CONST_STR_LEN( in webdav_xml_doc_multistatus()
1044 chunkqueue * const cq = &r->write_queue; in webdav_xml_doc_multistatus_response() local
1045 buffer * const b = chunkqueue_prepend_buffer_open(cq); in webdav_xml_doc_multistatus_response()
1051 chunkqueue_prepend_buffer_commit(cq); in webdav_xml_doc_multistatus_response()
1052 chunkqueue_append_buffer(cq, ms); /*(might move/steal/reset buffer)*/ in webdav_xml_doc_multistatus_response()
1053 chunkqueue_append_mem(cq, CONST_STR_LEN( in webdav_xml_doc_multistatus_response()
1159 chunkqueue * const cq = &r->write_queue; in webdav_xml_doc_423_locked() local
1160 buffer * const b = chunkqueue_prepend_buffer_open(cq); in webdav_xml_doc_423_locked()
1169 chunkqueue_prepend_buffer_commit(cq); in webdav_xml_doc_423_locked()
1177 chunkqueue_append_buffer(cq, hrefs); /*(might move/steal/reset buffer)*/ in webdav_xml_doc_423_locked()
3845 chunkqueue * const cq = &r->reqbody_queue; in webdav_parse_chunkqueue() local
3846 size_t weWant = chunkqueue_length(cq); in webdav_parse_chunkqueue()
3851 chunk *c = cq->first; in webdav_parse_chunkqueue()
3869 if (0 == chunkqueue_peek_data(cq, &data, &dlen, r->conf.errh)) { in webdav_parse_chunkqueue()
3895 (long long int)cq->bytes_out, weHave, err); in webdav_parse_chunkqueue()
3900 chunkqueue_mark_written(cq, weHave); in webdav_parse_chunkqueue()
4506 mod_webdav_write_cq (request_st * const r, chunkqueue * const cq, const int fd) in mod_webdav_write_cq() argument
4509 while (!chunkqueue_is_empty(cq)) { in mod_webdav_write_cq()
4510 ssize_t wr = chunkqueue_write_chunk(fd, cq, r->conf.errh); in mod_webdav_write_cq()
4512 chunkqueue_mark_written(cq, wr); in mod_webdav_write_cq()
4518 chunkqueue_remove_finished_chunks(cq); in mod_webdav_write_cq()
4526 mod_webdav_write_single_file_chunk (request_st * const r, chunkqueue * const cq) in mod_webdav_write_single_file_chunk() argument
4532 chunk * const c = cq->first; in mod_webdav_write_single_file_chunk()
4533 cq->first = c->next; in mod_webdav_write_single_file_chunk()
4534 const off_t len = chunkqueue_length(cq); in mod_webdav_write_single_file_chunk()
4535 const off_t bytes_out = cq->bytes_out; in mod_webdav_write_single_file_chunk()
4536 if (mod_webdav_write_cq(r, cq, c->file.fd)) { in mod_webdav_write_single_file_chunk()
4540 cq->bytes_out = bytes_out; in mod_webdav_write_single_file_chunk()
4543 cq->first = cq->last = c; in mod_webdav_write_single_file_chunk()
4548 c->next = cq->first; in mod_webdav_write_single_file_chunk()
4549 cq->first = c; in mod_webdav_write_single_file_chunk()
4671 chunkqueue * const cq = &r->reqbody_queue; in mod_webdav_put_prep() local
4672 off_t cqlen = chunkqueue_length(cq); in mod_webdav_put_prep()
4673 if (!mod_webdav_write_cq(r, cq, fd)) { in mod_webdav_put_prep()
4678 chunkqueue_reset(cq); in mod_webdav_put_prep()
4680 chunkqueue_append_file_fd(cq, &r->physical.path, fd, 0, cqlen); in mod_webdav_put_prep()
4683 chunkqueue_append_file_fd(cq, &r->physical.path, fd, 0, 1); in mod_webdav_put_prep()
4684 cq->last->file.length = 0; in mod_webdav_put_prep()
4685 cq->bytes_in = 0; in mod_webdav_put_prep()
4690 force_assert(cq->last); in mod_webdav_put_prep()
4692 buffer_clear(cq->last->mem); /* file already unlink()ed */ in mod_webdav_put_prep()
4693 cq->upload_temp_file_size = (off_t)((1uLL << (sizeof(off_t)*8-1))-1); in mod_webdav_put_prep()
4694 cq->last->file.is_temp = 1; in mod_webdav_put_prep()
4706 chunkqueue * const cq = &r->reqbody_queue; in mod_webdav_put_linkat_rename() local
4707 chunk *c = cq->first; in mod_webdav_put_linkat_rename()
4746 chunkqueue_mark_written(cq, c->file.length); /*(c->offset == 0)*/ in mod_webdav_put_linkat_rename()
4824 chunkqueue * const cq = &r->reqbody_queue; in mod_webdav_put_range() local
4825 chunk *c = cq->first; in mod_webdav_put_range()
4826 off_t cqlen = chunkqueue_length(cq); in mod_webdav_put_range()
4844 off_t wrote = chunkqueue_length(cq) - cqlen; in mod_webdav_put_range()
4846 chunkqueue_mark_written(cq, wrote); in mod_webdav_put_range()
4943 chunkqueue * const cq = &r->reqbody_queue; in mod_webdav_put() local
4944 chunk *c = cq->first; in mod_webdav_put()
4979 if (!mod_webdav_write_single_file_chunk(r, cq)) in mod_webdav_put()
5000 mod_webdav_write_cq(r, cq, fd); in mod_webdav_put()