Lines Matching refs:write_queue

292     chunkqueue_append_mem(con->write_queue,  in h2_send_settings_ack()
316 chunkqueue_append_mem(con->write_queue, /*(+3 to skip over align padding)*/ in h2_send_rst_stream_id()
399 chunkqueue_append_mem(con->write_queue, /*(+3 to skip over align padding)*/ in h2_send_goaway()
575 chunkqueue_append_mem(con->write_queue, (const char *)s, 17); in h2_recv_ping()
830 chunkqueue_append_mem(con->write_queue, /*(+3 to skip over align padding)*/ in h2_send_window_update()
2012 chunkqueue_append_mem(con->write_queue, in h2_init_con()
2069 chunkqueue_append_buffer_open_sz(con->write_queue, dlen + (dlen>>10) + 9); in h2_send_hpack()
2081 chunkqueue_append_mem(con->write_queue, /*(+3 to skip over align pad)*/ in h2_send_hpack()
2083 chunkqueue_append_mem(con->write_queue, data, len); in h2_send_hpack()
2096 chunkqueue_append_buffer_commit(con->write_queue); in h2_send_hpack()
2327 chunkqueue * const wq = &r->write_queue; in h2_send_headers()
2333 (r->resp_body_finished && chunkqueue_is_empty(&r->write_queue)) in h2_send_headers()
2534 chunk * const c = r->write_queue.first;
2540 chunkqueue_mark_written(&r->write_queue, len);
2590 chunkqueue_append_buffer_open_sz(con->write_queue, dlen + (dlen>>10) + 9);
2601 chunkqueue_append_mem(con->write_queue, /*(+3 to skip over align pad)*/
2603 chunkqueue_append_mem(con->write_queue, data, len);
2614 chunkqueue_append_buffer_commit(con->write_queue);
2679 chunkqueue_append_buffer_open_sz(con->write_queue, 9+len); in h2_send_cqdata()
2692 chunkqueue_append_buffer_commit(con->write_queue); in h2_send_cqdata()
2707 chunkqueue_append_mem(con->write_queue, /*(+3 to skip over align pad)*/ in h2_send_cqdata()
2709 chunkqueue_steal(con->write_queue, cq, (off_t)len); in h2_send_cqdata()
2736 chunkqueue_append_mem(con->write_queue, /*(+3 to skip over align pad)*/ in h2_send_end_stream_data()
2834 con->write_queue->bytes_out -= r->write_queue.bytes_out; in h2_release_stream()
2878 if (!chunkqueue_is_empty(con->write_queue)) { in h2_retire_con()
2884 chunkqueue * const cq = con->write_queue; in h2_retire_con()
2923 chunkqueue_append_mem(&h2r->write_queue, in h2_con_upgrade_h2c()