Lines Matching refs:cq
2325 return con->network_read(con, cq, max_bytes); in mod_gnutls_read_err()
2371 connection_write_cq_ssl (connection * const con, chunkqueue * const cq, off_t max_bytes) in connection_write_cq_ssl() argument
2383 chunkqueue_mark_written(cq, wr); in connection_write_cq_ssl()
2402 while (max_bytes > 0 && !chunkqueue_is_empty(cq)) { in connection_write_cq_ssl()
2409 if (0 != chunkqueue_peek_data(cq, &data, &data_len, errh)) return -1; in connection_write_cq_ssl()
2411 chunkqueue_remove_finished_chunks(cq); in connection_write_cq_ssl()
2434 if (wr_total) chunkqueue_mark_written(cq, wr_total); in connection_write_cq_ssl()
2440 chunkqueue_mark_written(cq, wr_total); in connection_write_cq_ssl()
2450 connection_write_cq_ssl_ktls (connection * const con, chunkqueue * const cq, off_t max_bytes) in connection_write_cq_ssl_ktls() argument
2468 chunkqueue_mark_written(cq, wr); in connection_write_cq_ssl_ktls()
2480 for (chunk *c; (c = cq->first) && c->type == FILE_CHUNK; ) { in connection_write_cq_ssl_ktls()
2484 if (-1 == c->file.fd && 0 != chunkqueue_open_file_chunk(cq, hctx->errh)) in connection_write_cq_ssl_ktls()
2494 chunkqueue_mark_written(cq, wr); in connection_write_cq_ssl_ktls()
2500 return connection_write_cq_ssl(con, cq, max_bytes); in connection_write_cq_ssl_ktls()
2543 connection_read_cq_ssl (connection * const con, chunkqueue * const cq, off_t max_bytes) in connection_read_cq_ssl() argument
2564 chunk * const ckpt = cq->last; in connection_read_cq_ssl()
2565 mem = chunkqueue_get_memory(cq, &mem_len); in connection_read_cq_ssl()
2568 chunkqueue_use_memory(cq, ckpt, len > 0 ? len : 0); in connection_read_cq_ssl()