Lines Matching refs:task

22 static ssize_t nxt_http_idle_io_read_handler(nxt_task_t *task, nxt_conn_t *c);
23 static void nxt_http_conn_test(nxt_task_t *task, void *obj, void *data);
25 static ssize_t nxt_h1p_idle_io_read_handler(nxt_task_t *task, nxt_conn_t *c);
26 static void nxt_h1p_conn_proto_init(nxt_task_t *task, void *obj, void *data);
27 static void nxt_h1p_conn_request_init(nxt_task_t *task, void *obj, void *data);
28 static void nxt_h1p_conn_request_header_parse(nxt_task_t *task, void *obj,
30 static nxt_int_t nxt_h1p_header_process(nxt_task_t *task, nxt_h1proto_t *h1p,
32 static nxt_int_t nxt_h1p_header_buffer_test(nxt_task_t *task,
44 static void nxt_h1p_request_body_read(nxt_task_t *task, nxt_http_request_t *r);
45 static void nxt_h1p_conn_request_body_read(nxt_task_t *task, void *obj,
47 static void nxt_h1p_request_local_addr(nxt_task_t *task, nxt_http_request_t *r);
48 static void nxt_h1p_request_header_send(nxt_task_t *task,
50 static void nxt_h1p_request_send(nxt_task_t *task, nxt_http_request_t *r,
52 static nxt_buf_t *nxt_h1p_chunk_create(nxt_task_t *task, nxt_http_request_t *r,
54 static nxt_off_t nxt_h1p_request_body_bytes_sent(nxt_task_t *task,
56 static void nxt_h1p_request_discard(nxt_task_t *task, nxt_http_request_t *r,
58 static void nxt_h1p_conn_request_error(nxt_task_t *task, void *obj, void *data);
59 static void nxt_h1p_conn_request_timeout(nxt_task_t *task, void *obj,
61 static void nxt_h1p_conn_request_send_timeout(nxt_task_t *task, void *obj,
63 nxt_inline void nxt_h1p_request_error(nxt_task_t *task, nxt_h1proto_t *h1p,
65 static void nxt_h1p_request_close(nxt_task_t *task, nxt_http_proto_t proto,
67 static void nxt_h1p_conn_sent(nxt_task_t *task, void *obj, void *data);
68 static void nxt_h1p_conn_close(nxt_task_t *task, void *obj, void *data);
69 static void nxt_h1p_conn_error(nxt_task_t *task, void *obj, void *data);
71 static void nxt_h1p_keepalive(nxt_task_t *task, nxt_h1proto_t *h1p,
73 static void nxt_h1p_idle_close(nxt_task_t *task, void *obj, void *data);
74 static void nxt_h1p_idle_timeout(nxt_task_t *task, void *obj, void *data);
75 static void nxt_h1p_idle_response(nxt_task_t *task, nxt_conn_t *c);
76 static void nxt_h1p_idle_response_sent(nxt_task_t *task, void *obj, void *data);
77 static void nxt_h1p_idle_response_error(nxt_task_t *task, void *obj,
79 static void nxt_h1p_idle_response_timeout(nxt_task_t *task, void *obj,
83 static void nxt_h1p_shutdown(nxt_task_t *task, nxt_conn_t *c);
84 static void nxt_h1p_closing(nxt_task_t *task, nxt_conn_t *c);
85 static void nxt_h1p_conn_ws_shutdown(nxt_task_t *task, void *obj, void *data);
86 static void nxt_h1p_conn_closing(nxt_task_t *task, void *obj, void *data);
87 static void nxt_h1p_conn_free(nxt_task_t *task, void *obj, void *data);
89 static void nxt_h1p_peer_connect(nxt_task_t *task, nxt_http_peer_t *peer);
90 static void nxt_h1p_peer_connected(nxt_task_t *task, void *obj, void *data);
91 static void nxt_h1p_peer_refused(nxt_task_t *task, void *obj, void *data);
92 static void nxt_h1p_peer_header_send(nxt_task_t *task, nxt_http_peer_t *peer);
93 static void nxt_h1p_peer_header_sent(nxt_task_t *task, void *obj, void *data);
94 static void nxt_h1p_peer_header_read(nxt_task_t *task, nxt_http_peer_t *peer);
95 static ssize_t nxt_h1p_peer_io_read_handler(nxt_task_t *task, nxt_conn_t *c);
96 static void nxt_h1p_peer_header_read_done(nxt_task_t *task, void *obj,
100 static void nxt_h1p_peer_read(nxt_task_t *task, nxt_http_peer_t *peer);
101 static void nxt_h1p_peer_read_done(nxt_task_t *task, void *obj, void *data);
102 static void nxt_h1p_peer_body_process(nxt_task_t *task, nxt_http_peer_t *peer, nxt_buf_t *out);
103 static void nxt_h1p_peer_closed(nxt_task_t *task, void *obj, void *data);
104 static void nxt_h1p_peer_error(nxt_task_t *task, void *obj, void *data);
105 static void nxt_h1p_peer_send_timeout(nxt_task_t *task, void *obj, void *data);
106 static void nxt_h1p_peer_read_timeout(nxt_task_t *task, void *obj, void *data);
108 static void nxt_h1p_peer_close(nxt_task_t *task, nxt_http_peer_t *peer);
109 static void nxt_h1p_peer_free(nxt_task_t *task, void *obj, void *data);
194 nxt_h1p_init(nxt_task_t *task) in nxt_h1p_init() argument
212 nxt_http_conn_init(nxt_task_t *task, void *obj, void *data) in nxt_http_conn_init() argument
223 nxt_debug(task, "http conn init"); in nxt_http_conn_init()
229 engine = task->thread->engine; in nxt_http_conn_init()
263 nxt_http_idle_io_read_handler(nxt_task_t *task, nxt_conn_t *c) in nxt_http_idle_io_read_handler() argument
283 b = nxt_event_engine_buf_mem_alloc(task->thread->engine, size); in nxt_http_idle_io_read_handler()
301 nxt_event_engine_buf_mem_free(task->thread->engine, b); in nxt_http_idle_io_read_handler()
309 nxt_http_conn_test(nxt_task_t *task, void *obj, void *data) in nxt_http_conn_test() argument
320 nxt_debug(task, "h1p conn https test"); in nxt_http_conn_test()
322 engine = task->thread->engine; in nxt_http_conn_test()
355 nxt_debug(task, "SSL/TLS: %s%ud.%ud", protocol, major, minor); in nxt_http_conn_test()
370 nxt_h1p_closing(task, c); in nxt_http_conn_test()
376 tls->conn_init(task, tls, c); in nxt_http_conn_test()
399 nxt_h1p_idle_io_read_handler(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_idle_io_read_handler() argument
422 b = nxt_event_engine_buf_mem_alloc(task->thread->engine, size); in nxt_h1p_idle_io_read_handler()
436 nxt_event_engine_buf_mem_free(task->thread->engine, b); in nxt_h1p_idle_io_read_handler()
444 nxt_h1p_conn_proto_init(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_proto_init() argument
451 nxt_debug(task, "h1p conn proto init"); in nxt_h1p_conn_proto_init()
455 nxt_h1p_closing(task, c); in nxt_h1p_conn_proto_init()
462 nxt_h1p_conn_request_init(task, c, h1p); in nxt_h1p_conn_proto_init()
467 nxt_h1p_conn_request_init(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_request_init() argument
479 nxt_debug(task, "h1p conn request init"); in nxt_h1p_conn_request_init()
481 nxt_conn_active(task->thread->engine, c); in nxt_h1p_conn_request_init()
483 r = nxt_http_request_create(task); in nxt_h1p_conn_request_init()
496 r->task = c->task; in nxt_h1p_conn_request_init()
497 task = &r->task; in nxt_h1p_conn_request_init()
498 c->socket.task = task; in nxt_h1p_conn_request_init()
499 c->read_timer.task = task; in nxt_h1p_conn_request_init()
500 c->write_timer.task = task; in nxt_h1p_conn_request_init()
517 nxt_h1p_conn_request_header_parse(task, c, h1p); in nxt_h1p_conn_request_init()
528 nxt_h1p_closing(task, c); in nxt_h1p_conn_request_init()
546 nxt_h1p_conn_request_header_parse(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_request_header_parse() argument
557 nxt_debug(task, "h1p conn header parse"); in nxt_h1p_conn_request_header_parse()
564 nxt_timer_disable(task->thread->engine, &c->read_timer); in nxt_h1p_conn_request_header_parse()
579 ret = nxt_h1p_header_process(task, h1p, r); in nxt_h1p_conn_request_header_parse()
590 r->state->ready_handler(task, r, NULL); in nxt_h1p_conn_request_header_parse()
598 status = nxt_h1p_header_buffer_test(task, h1p, c, r->conf->socket_conf); in nxt_h1p_conn_request_header_parse()
603 nxt_conn_read(task->thread->engine, c); in nxt_h1p_conn_request_header_parse()
627 (void) nxt_h1p_header_process(task, h1p, r); in nxt_h1p_conn_request_header_parse()
633 nxt_http_request_error(task, r, status); in nxt_h1p_conn_request_header_parse()
638 nxt_h1p_header_process(nxt_task_t *task, nxt_h1proto_t *h1p, in nxt_h1p_header_process() argument
671 nxt_log(task, NXT_LOG_INFO, "h1p upgrade: bad method"); in nxt_h1p_header_process()
677 nxt_log(task, NXT_LOG_INFO, "h1p upgrade: bad protocol version"); in nxt_h1p_header_process()
683 nxt_log(task, NXT_LOG_INFO, in nxt_h1p_header_process()
690 nxt_log(task, NXT_LOG_INFO, in nxt_h1p_header_process()
704 nxt_h1p_header_buffer_test(nxt_task_t *task, nxt_h1proto_t *h1p, nxt_conn_t *c, in nxt_h1p_header_buffer_test() argument
841 nxt_h1p_request_body_read(nxt_task_t *task, nxt_http_request_t *r) in nxt_h1p_request_body_read() argument
855 nxt_debug(task, "h1p request body read %O te:%d", in nxt_h1p_request_body_read()
925 nxt_alert(task, "mkstemp(%s) failed %E", tmp_name.start, nxt_errno); in nxt_h1p_request_body_read()
931 nxt_debug(task, "create body tmp file \"%V\", %d", in nxt_h1p_request_body_read()
964 nxt_debug(task, "h1p body rest: %uz", body_rest); in nxt_h1p_request_body_read()
975 nxt_conn_read(task->thread->engine, c); in nxt_h1p_request_body_read()
988 r->state->ready_handler(task, r, NULL); in nxt_h1p_request_body_read()
996 nxt_http_request_error(task, r, status); in nxt_h1p_request_body_read()
1015 nxt_h1p_conn_request_body_read(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_request_body_read() argument
1028 nxt_debug(task, "h1p conn request body read"); in nxt_h1p_conn_request_body_read()
1032 engine = task->thread->engine; in nxt_h1p_conn_request_body_read()
1044 nxt_h1p_request_error(task, h1p, r); in nxt_h1p_conn_request_body_read()
1069 nxt_debug(task, "h1p body rest: %uz", body_rest); in nxt_h1p_conn_request_body_read()
1084 r->state->ready_handler(task, r, NULL); in nxt_h1p_conn_request_body_read()
1090 nxt_h1p_request_local_addr(nxt_task_t *task, nxt_http_request_t *r) in nxt_h1p_request_local_addr() argument
1092 r->local = nxt_conn_local_addr(task, r->proto.h1->conn); in nxt_h1p_request_local_addr()
1197 nxt_h1p_request_header_send(nxt_task_t *task, nxt_http_request_t *r, in nxt_h1p_request_header_send() argument
1224 nxt_debug(task, "h1p request header send"); in nxt_h1p_request_header_send()
1320 header = nxt_http_buf_mem(task, r, size); in nxt_h1p_request_header_send()
1322 nxt_h1p_request_error(task, h1p, r); in nxt_h1p_request_header_send()
1378 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_h1p_request_header_send()
1379 body_handler, task, r, data); in nxt_h1p_request_header_send()
1385 nxt_conn_write(task->thread->engine, c); in nxt_h1p_request_header_send()
1388 nxt_h1p_websocket_first_frame_start(task, r, c->read); in nxt_h1p_request_header_send()
1394 nxt_h1p_complete_buffers(nxt_task_t *task, nxt_h1proto_t *h1p, nxt_bool_t all) in nxt_h1p_complete_buffers() argument
1400 nxt_debug(task, "h1p complete buffers"); in nxt_h1p_complete_buffers()
1420 b->completion_handler(task, b, b->parent); in nxt_h1p_complete_buffers()
1433 in->completion_handler(task, in, in->parent); in nxt_h1p_complete_buffers()
1455 nxt_h1p_request_send(nxt_task_t *task, nxt_http_request_t *r, nxt_buf_t *out) in nxt_h1p_request_send() argument
1460 nxt_debug(task, "h1p request send"); in nxt_h1p_request_send()
1466 out = nxt_h1p_chunk_create(task, r, out); in nxt_h1p_request_send()
1468 nxt_h1p_request_error(task, h1p, r); in nxt_h1p_request_send()
1477 nxt_conn_write(task->thread->engine, c); in nxt_h1p_request_send()
1492 nxt_h1p_chunk_create(nxt_task_t *task, nxt_http_request_t *r, nxt_buf_t *out) in nxt_h1p_chunk_create() argument
1506 tail = nxt_http_buf_mem(task, r, sizeof(tail_chunk)); in nxt_h1p_chunk_create()
1531 header = nxt_http_buf_mem(task, r, chunk_size); in nxt_h1p_chunk_create()
1544 nxt_h1p_request_body_bytes_sent(nxt_task_t *task, nxt_http_proto_t proto) in nxt_h1p_request_body_bytes_sent() argument
1558 nxt_h1p_request_discard(nxt_task_t *task, nxt_http_request_t *r, in nxt_h1p_request_discard() argument
1566 nxt_debug(task, "h1p request discard"); in nxt_h1p_request_discard()
1575 wq = &task->thread->engine->fast_work_queue; in nxt_h1p_request_discard()
1577 nxt_sendbuf_drain(task, wq, b); in nxt_h1p_request_discard()
1578 nxt_sendbuf_drain(task, wq, last); in nxt_h1p_request_discard()
1583 nxt_h1p_conn_request_error(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_request_error() argument
1590 nxt_debug(task, "h1p conn request error"); in nxt_h1p_conn_request_error()
1595 nxt_h1p_shutdown(task, h1p->conn); in nxt_h1p_conn_request_error()
1600 (void) nxt_h1p_header_process(task, h1p, r); in nxt_h1p_conn_request_error()
1607 nxt_h1p_request_error(task, h1p, r); in nxt_h1p_conn_request_error()
1612 nxt_h1p_conn_request_timeout(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_request_timeout() argument
1621 nxt_debug(task, "h1p conn request timeout"); in nxt_h1p_conn_request_timeout()
1636 (void) nxt_h1p_header_process(task, h1p, r); in nxt_h1p_conn_request_timeout()
1639 nxt_http_request_error(task, r, NXT_HTTP_REQUEST_TIMEOUT); in nxt_h1p_conn_request_timeout()
1644 nxt_h1p_conn_request_send_timeout(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_request_send_timeout() argument
1652 nxt_debug(task, "h1p conn request send timeout"); in nxt_h1p_conn_request_send_timeout()
1658 nxt_h1p_request_error(task, h1p, h1p->request); in nxt_h1p_conn_request_send_timeout()
1674 nxt_h1p_request_error(nxt_task_t *task, nxt_h1proto_t *h1p, in nxt_h1p_request_error() argument
1679 r->state->error_handler(task, r, h1p); in nxt_h1p_request_error()
1684 nxt_h1p_request_close(nxt_task_t *task, nxt_http_proto_t proto, in nxt_h1p_request_close() argument
1690 nxt_debug(task, "h1p request close"); in nxt_h1p_request_close()
1696 nxt_router_conf_release(task, joint); in nxt_h1p_request_close()
1699 task = &c->task; in nxt_h1p_request_close()
1700 c->socket.task = task; in nxt_h1p_request_close()
1701 c->read_timer.task = task; in nxt_h1p_request_close()
1702 c->write_timer.task = task; in nxt_h1p_request_close()
1705 nxt_h1p_keepalive(task, h1p, c); in nxt_h1p_request_close()
1708 nxt_h1p_shutdown(task, c); in nxt_h1p_request_close()
1714 nxt_h1p_conn_sent(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_sent() argument
1721 nxt_debug(task, "h1p conn sent"); in nxt_h1p_conn_sent()
1723 engine = task->thread->engine; in nxt_h1p_conn_sent()
1725 c->write = nxt_sendbuf_completion(task, &engine->fast_work_queue, c->write); in nxt_h1p_conn_sent()
1734 nxt_h1p_conn_close(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_close() argument
1740 nxt_debug(task, "h1p conn close"); in nxt_h1p_conn_close()
1742 nxt_conn_active(task->thread->engine, c); in nxt_h1p_conn_close()
1744 nxt_h1p_shutdown(task, c); in nxt_h1p_conn_close()
1749 nxt_h1p_conn_error(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_error() argument
1755 nxt_debug(task, "h1p conn error"); in nxt_h1p_conn_error()
1757 nxt_conn_active(task->thread->engine, c); in nxt_h1p_conn_error()
1759 nxt_h1p_shutdown(task, c); in nxt_h1p_conn_error()
1783 nxt_h1p_keepalive(nxt_task_t *task, nxt_h1proto_t *h1p, nxt_conn_t *c) in nxt_h1p_keepalive() argument
1789 nxt_debug(task, "h1p keepalive"); in nxt_h1p_keepalive()
1792 nxt_conn_tcp_nodelay_on(task, c); in nxt_h1p_keepalive()
1795 nxt_h1p_complete_buffers(task, h1p, 0); in nxt_h1p_keepalive()
1803 engine = task->thread->engine; in nxt_h1p_keepalive()
1815 nxt_debug(task, "h1p pipelining"); in nxt_h1p_keepalive()
1822 nxt_h1p_conn_request_init(task, c, c->socket.data); in nxt_h1p_keepalive()
1851 nxt_h1p_idle_close(nxt_task_t *task, void *obj, void *data) in nxt_h1p_idle_close() argument
1857 nxt_debug(task, "h1p idle close"); in nxt_h1p_idle_close()
1859 nxt_conn_active(task->thread->engine, c); in nxt_h1p_idle_close()
1861 nxt_h1p_idle_response(task, c); in nxt_h1p_idle_close()
1866 nxt_h1p_idle_timeout(nxt_task_t *task, void *obj, void *data) in nxt_h1p_idle_timeout() argument
1873 nxt_debug(task, "h1p idle timeout"); in nxt_h1p_idle_timeout()
1878 nxt_conn_active(task->thread->engine, c); in nxt_h1p_idle_timeout()
1880 nxt_h1p_idle_response(task, c); in nxt_h1p_idle_timeout()
1893 nxt_h1p_idle_response(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_idle_response() argument
1911 p = nxt_thread_time_string(task->thread, &nxt_http_date_cache, p); in nxt_h1p_idle_response()
1930 nxt_conn_write(task->thread->engine, c); in nxt_h1p_idle_response()
1935 nxt_h1p_shutdown(task, c); in nxt_h1p_idle_response()
1951 nxt_h1p_idle_response_sent(nxt_task_t *task, void *obj, void *data) in nxt_h1p_idle_response_sent() argument
1957 nxt_debug(task, "h1p idle timeout response sent"); in nxt_h1p_idle_response_sent()
1959 nxt_h1p_shutdown(task, c); in nxt_h1p_idle_response_sent()
1964 nxt_h1p_idle_response_error(nxt_task_t *task, void *obj, void *data) in nxt_h1p_idle_response_error() argument
1970 nxt_debug(task, "h1p response error"); in nxt_h1p_idle_response_error()
1972 nxt_h1p_shutdown(task, c); in nxt_h1p_idle_response_error()
1977 nxt_h1p_idle_response_timeout(nxt_task_t *task, void *obj, void *data) in nxt_h1p_idle_response_timeout() argument
1984 nxt_debug(task, "h1p idle timeout response timeout"); in nxt_h1p_idle_response_timeout()
1989 nxt_h1p_shutdown(task, c); in nxt_h1p_idle_response_timeout()
2001 nxt_h1p_shutdown(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_shutdown() argument
2006 nxt_debug(task, "h1p shutdown"); in nxt_h1p_shutdown()
2011 nxt_h1p_complete_buffers(task, h1p, 1); in nxt_h1p_shutdown()
2018 nxt_timer_add(task->thread->engine, timer, 0); in nxt_h1p_shutdown()
2021 nxt_debug(task, "h1p already scheduled ws shutdown"); in nxt_h1p_shutdown()
2028 nxt_h1p_closing(task, c); in nxt_h1p_shutdown()
2033 nxt_h1p_conn_ws_shutdown(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_shutdown() argument
2038 nxt_debug(task, "h1p conn ws shutdown"); in nxt_h1p_conn_ws_shutdown()
2043 nxt_h1p_closing(task, ws_timer->h1p->conn); in nxt_h1p_conn_ws_shutdown()
2048 nxt_h1p_closing(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_closing() argument
2050 nxt_debug(task, "h1p closing"); in nxt_h1p_closing()
2059 c->io->shutdown(task, c, NULL); in nxt_h1p_closing()
2065 nxt_h1p_conn_closing(task, c, NULL); in nxt_h1p_closing()
2083 nxt_h1p_conn_closing(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_closing() argument
2089 nxt_debug(task, "h1p conn closing"); in nxt_h1p_conn_closing()
2093 nxt_conn_close(task->thread->engine, c); in nxt_h1p_conn_closing()
2105 nxt_h1p_conn_free(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_free() argument
2113 nxt_debug(task, "h1p conn free"); in nxt_h1p_conn_free()
2115 engine = task->thread->engine; in nxt_h1p_conn_free()
2121 nxt_conn_free(task, c); in nxt_h1p_conn_free()
2123 nxt_router_listen_event_release(&engine->task, lev, NULL); in nxt_h1p_conn_free()
2128 nxt_h1p_peer_connect(nxt_task_t *task, nxt_http_peer_t *peer) in nxt_h1p_peer_connect() argument
2138 nxt_debug(task, "h1p peer connect"); in nxt_h1p_peer_connect()
2159 c = nxt_conn_create(mp, task); in nxt_h1p_peer_connect()
2193 nxt_conn_connect(task->thread->engine, c); in nxt_h1p_peer_connect()
2201 r->state->error_handler(task, r, peer); in nxt_h1p_peer_connect()
2219 nxt_h1p_peer_connected(nxt_task_t *task, void *obj, void *data) in nxt_h1p_peer_connected() argument
2226 nxt_debug(task, "h1p peer connected"); in nxt_h1p_peer_connected()
2229 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_connected()
2234 nxt_h1p_peer_refused(nxt_task_t *task, void *obj, void *data) in nxt_h1p_peer_refused() argument
2241 nxt_debug(task, "h1p peer refused"); in nxt_h1p_peer_refused()
2247 r->state->error_handler(task, r, peer); in nxt_h1p_peer_refused()
2252 nxt_h1p_peer_header_send(nxt_task_t *task, nxt_http_peer_t *peer) in nxt_h1p_peer_header_send() argument
2261 nxt_debug(task, "h1p peer header send"); in nxt_h1p_peer_header_send()
2279 header = nxt_http_buf_mem(task, r, size); in nxt_h1p_peer_header_send()
2281 r->state->error_handler(task, r, peer); in nxt_h1p_peer_header_send()
2321 r->state->error_handler(task, r, peer); in nxt_h1p_peer_header_send()
2345 nxt_conn_write(task->thread->engine, c); in nxt_h1p_peer_header_send()
2375 nxt_h1p_peer_header_sent(nxt_task_t *task, void *obj, void *data) in nxt_h1p_peer_header_sent() argument
2385 nxt_debug(task, "h1p peer header sent"); in nxt_h1p_peer_header_sent()
2387 engine = task->thread->engine; in nxt_h1p_peer_header_sent()
2389 c->write = nxt_sendbuf_completion(task, &engine->fast_work_queue, c->write); in nxt_h1p_peer_header_sent()
2397 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_header_sent()
2402 nxt_h1p_peer_header_read(nxt_task_t *task, nxt_http_peer_t *peer) in nxt_h1p_peer_header_read() argument
2406 nxt_debug(task, "h1p peer header read"); in nxt_h1p_peer_header_read()
2417 nxt_conn_read(task->thread->engine, c); in nxt_h1p_peer_header_read()
2448 nxt_h1p_peer_io_read_handler(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_peer_io_read_handler() argument
2467 nxt_debug(task, "h1p peer io read: %z", size); in nxt_h1p_peer_io_read_handler()
2469 b = nxt_http_proxy_buf_mem_alloc(task, r, size); in nxt_h1p_peer_io_read_handler()
2483 nxt_http_proxy_buf_mem_free(task, r, b); in nxt_h1p_peer_io_read_handler()
2491 nxt_h1p_peer_header_read_done(nxt_task_t *task, void *obj, void *data) in nxt_h1p_peer_header_read_done() argument
2504 nxt_debug(task, "h1p peer header read done"); in nxt_h1p_peer_header_read_done()
2515 engine = task->thread->engine; in nxt_h1p_peer_header_read_done()
2551 nxt_h1p_peer_body_process(task, peer, b); in nxt_h1p_peer_header_read_done()
2555 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_header_read_done()
2560 nxt_conn_read(task->thread->engine, c); in nxt_h1p_peer_header_read_done()
2575 nxt_http_proxy_buf_mem_free(task, r, b); in nxt_h1p_peer_header_read_done()
2577 r->state->error_handler(task, r, peer); in nxt_h1p_peer_header_read_done()
2627 nxt_h1p_peer_read(nxt_task_t *task, nxt_http_peer_t *peer) in nxt_h1p_peer_read() argument
2631 nxt_debug(task, "h1p peer read"); in nxt_h1p_peer_read()
2636 nxt_conn_read(task->thread->engine, c); in nxt_h1p_peer_read()
2657 nxt_h1p_peer_read_done(nxt_task_t *task, void *obj, void *data) in nxt_h1p_peer_read_done() argument
2666 nxt_debug(task, "h1p peer read done"); in nxt_h1p_peer_read_done()
2671 nxt_h1p_peer_body_process(task, peer, out); in nxt_h1p_peer_read_done()
2676 nxt_h1p_peer_body_process(nxt_task_t *task, nxt_http_peer_t *peer, in nxt_h1p_peer_body_process() argument
2686 out = nxt_http_chunk_parse(task, &h1p->chunked_parse, out); in nxt_h1p_peer_body_process()
2691 r->state->error_handler(task, r, peer); in nxt_h1p_peer_body_process()
2708 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_body_process()
2713 nxt_h1p_peer_closed(nxt_task_t *task, void *obj, void *data) in nxt_h1p_peer_closed() argument
2720 nxt_debug(task, "h1p peer closed"); in nxt_h1p_peer_closed()
2729 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_closed()
2734 r->state->error_handler(task, r, peer); in nxt_h1p_peer_closed()
2740 nxt_h1p_peer_error(nxt_task_t *task, void *obj, void *data) in nxt_h1p_peer_error() argument
2747 nxt_debug(task, "h1p peer error"); in nxt_h1p_peer_error()
2752 r->state->error_handler(task, r, peer); in nxt_h1p_peer_error()
2757 nxt_h1p_peer_send_timeout(nxt_task_t *task, void *obj, void *data) in nxt_h1p_peer_send_timeout() argument
2766 nxt_debug(task, "h1p peer send timeout"); in nxt_h1p_peer_send_timeout()
2776 r->state->error_handler(task, r, peer); in nxt_h1p_peer_send_timeout()
2781 nxt_h1p_peer_read_timeout(nxt_task_t *task, void *obj, void *data) in nxt_h1p_peer_read_timeout() argument
2790 nxt_debug(task, "h1p peer read timeout"); in nxt_h1p_peer_read_timeout()
2800 r->state->error_handler(task, r, peer); in nxt_h1p_peer_read_timeout()
2816 nxt_h1p_peer_close(nxt_task_t *task, nxt_http_peer_t *peer) in nxt_h1p_peer_close() argument
2820 nxt_debug(task, "h1p peer close"); in nxt_h1p_peer_close()
2825 task = &c->task; in nxt_h1p_peer_close()
2826 c->socket.task = task; in nxt_h1p_peer_close()
2827 c->read_timer.task = task; in nxt_h1p_peer_close()
2828 c->write_timer.task = task; in nxt_h1p_peer_close()
2833 nxt_conn_close(task->thread->engine, c); in nxt_h1p_peer_close()
2836 nxt_h1p_peer_free(task, c, NULL); in nxt_h1p_peer_close()
2849 nxt_h1p_peer_free(nxt_task_t *task, void *obj, void *data) in nxt_h1p_peer_free() argument
2855 nxt_debug(task, "h1p peer free"); in nxt_h1p_peer_free()
2857 nxt_conn_free(task, c); in nxt_h1p_peer_free()