Lines Matching refs:cq
2024 connection_write_cq_ssl (connection * const con, chunkqueue * const cq, off_t max_bytes) in connection_write_cq_ssl() argument
2043 chunkqueue_mark_written(cq, wr); in connection_write_cq_ssl()
2053 while (max_bytes > 0 && !chunkqueue_is_empty(cq)) { in connection_write_cq_ssl()
2060 if (0 != chunkqueue_peek_data(cq, &data, &data_len, errh)) return -1; in connection_write_cq_ssl()
2062 chunkqueue_remove_finished_chunks(cq); in connection_write_cq_ssl()
2091 if (wr_total) chunkqueue_mark_written(cq, wr_total); in connection_write_cq_ssl()
2097 chunkqueue_mark_written(cq, wr_total); in connection_write_cq_ssl()
2243 connection_read_cq_ssl (connection * const con, chunkqueue * const cq, off_t max_bytes) in connection_read_cq_ssl() argument
2263 chunk * const ckpt = cq->last; in connection_read_cq_ssl()
2264 mem = chunkqueue_get_memory(cq, &mem_len); in connection_read_cq_ssl()
2267 chunkqueue_use_memory(cq, ckpt, len > 0 ? len : 0); in connection_read_cq_ssl()