Lines Matching refs:write_queue
197 if (&r->write_queue != con->write_queue) { /*(for HTTP/1.1)*/ in connection_handle_response_end_state()
198 chunkqueue_free(con->write_queue); in connection_handle_response_end_state()
199 con->write_queue = &r->write_queue; in connection_handle_response_end_state()
209 r->bytes_written_ckpt = r->write_queue.bytes_out; in connection_handle_response_end_state()
330 chunkqueue * const cq = con->write_queue; in connection_write_1xx_info()
347 if (cq == &r->write_queue) { in connection_write_1xx_info()
351 con->write_queue = chunkqueue_init(NULL); in connection_write_1xx_info()
353 con->write_queue->bytes_in = cq->bytes_out; /*(yes, bytes_out)*/ in connection_write_1xx_info()
354 con->write_queue->bytes_out = cq->bytes_out; in connection_write_1xx_info()
355 chunkqueue_append_chunkqueue(con->write_queue, cq); in connection_write_1xx_info()
370 r->write_queue.bytes_in = r->write_queue.bytes_out = 0; in connection_write_1xx_info()
388 chunkqueue * const cq = con->write_queue; /*(bypass r->write_queue)*/ in connection_send_1xx()
420 chunkqueue * const cq = con->write_queue; /*(bypass r->write_queue)*/ in connection_write_100_continue()
430 int rc = connection_write_chunkqueue(con, con->write_queue, MAX_WRITE_LIMIT); in connection_handle_write()
448 if (con->write_queue->bytes_out) in connection_handle_write()
461 if (!chunkqueue_is_empty(&r->write_queue)) { in connection_handle_write_state()
491 && (!chunkqueue_is_empty(&r->write_queue) in connection_handle_write_state()
509 con->write_queue = &r->write_queue; in connection_init()
523 if (con->write_queue != &r->write_queue) in connection_free()
524 chunkqueue_free(con->write_queue); in connection_free()
1128 if (!chunkqueue_is_empty(con->write_queue) in connection_set_fdevent_interest()
1217 const off_t cqlen = chunkqueue_length(con->write_queue); in connection_state_machine_h2()
1242 if (__builtin_expect((!chunkqueue_is_empty(&r->write_queue)), 1) in connection_state_machine_h2()
1254 dlen = h2_send_cqdata(r, con, &r->write_queue, dlen); in connection_state_machine_h2()
1257 if (!chunkqueue_is_empty(&r->write_queue)) in connection_state_machine_h2()
1261 if (!chunkqueue_is_empty(&r->write_queue) in connection_state_machine_h2()
1308 if (!chunkqueue_is_empty(con->write_queue)) in connection_state_machine_h2()
1311 if (chunkqueue_is_empty(con->write_queue) in connection_state_machine_h2()
1414 (long long)r->write_queue.bytes_out, in connection_check_timeout()
1498 (long long)con->write_queue->bytes_out, in connection_check_timeout()
1514 || con->write_queue->bytes_out in connection_check_timeout()
1555 if (0 == con->h2->rused && chunkqueue_is_empty(con->write_queue)) { in connection_graceful_shutdown_maint()
1840 || !chunkqueue_is_empty(&r->write_queue)) in connection_check_expect_100()