Lines Matching refs:cq
3031 connection_write_cq_ssl (connection * const con, chunkqueue * const cq, off_t max_bytes) in connection_write_cq_ssl() argument
3040 while (max_bytes > 0 && !chunkqueue_is_empty(cq)) { in connection_write_cq_ssl()
3047 if (0 != chunkqueue_peek_data(cq, &data, &data_len, errh)) return -1; in connection_write_cq_ssl()
3049 chunkqueue_remove_finished_chunks(cq); in connection_write_cq_ssl()
3074 chunkqueue_mark_written(cq, wr); in connection_write_cq_ssl()
3086 connection_write_cq_ssl_ktls (connection * const con, chunkqueue * const cq, off_t max_bytes) in connection_write_cq_ssl_ktls() argument
3099 for (chunk *c; (c = cq->first) && c->type == FILE_CHUNK; ) { in connection_write_cq_ssl_ktls()
3103 if (-1 == c->file.fd && 0 != chunkqueue_open_file_chunk(cq, hctx->errh)) in connection_write_cq_ssl_ktls()
3111 chunkqueue_mark_written(cq, wr); in connection_write_cq_ssl_ktls()
3117 return connection_write_cq_ssl(con, cq, max_bytes); in connection_write_cq_ssl_ktls()
3123 connection_read_cq_ssl (connection * const con, chunkqueue * const cq, off_t max_bytes) in connection_read_cq_ssl() argument
3139 chunk * const ckpt = cq->last; in connection_read_cq_ssl()
3140 mem = chunkqueue_get_memory(cq, &mem_len); in connection_read_cq_ssl()
3143 chunkqueue_use_memory(cq, ckpt, len > 0 ? len : 0); in connection_read_cq_ssl()
3171 chunkqueue_reset(cq); in connection_read_cq_ssl()
3231 if (0==oerrno && 0==cq->bytes_in && !hctx->conf.ssl_log_noise) in connection_read_cq_ssl()