| /unit/src/ |
| H A D | nxt_conn.h | 109 nxt_conn_t *next;
184 nxt_timer_data(ev, nxt_conn_t, read_timer)
188 nxt_timer_data(ev, nxt_conn_t, write_timer)
229 nxt_conn_t *c);
241 nxt_conn_t *c);
245 void nxt_conn_wait(nxt_conn_t *c);
261 nxt_conn_t *c, size_t sent);
267 nxt_conn_t *c);
305 nxt_conn_t *client;
306 nxt_conn_t *peer;
[all …]
|
| H A D | nxt_sendbuf.h | 72 ssize_t nxt_linux_event_conn_io_sendfile(nxt_conn_t *c, nxt_buf_t *b,
78 ssize_t nxt_freebsd_event_conn_io_sendfile(nxt_conn_t *c, nxt_buf_t *b,
84 ssize_t nxt_solaris_event_conn_io_sendfilev(nxt_conn_t *c, nxt_buf_t *b,
90 ssize_t nxt_macosx_event_conn_io_sendfile(nxt_conn_t *c, nxt_buf_t *b,
96 ssize_t nxt_aix_event_conn_io_send_file(nxt_conn_t *c, nxt_buf_t *b,
102 ssize_t nxt_hpux_event_conn_io_sendfile(nxt_conn_t *c, nxt_buf_t *b,
106 ssize_t nxt_event_conn_io_sendbuf(nxt_conn_t *c, nxt_buf_t *b,
122 ssize_t nxt_sendbuf_copy_coalesce(nxt_conn_t *c, nxt_buf_mem_t *bm,
|
| H A D | nxt_conn_proxy.c | 21 nxt_conn_t *source, nxt_conn_t *sink);
29 nxt_conn_t *sink, nxt_conn_t *source);
42 nxt_conn_t *source, nxt_conn_t *sink);
62 nxt_conn_t *peer; in nxt_conn_proxy_create()
102 nxt_conn_t *peer; in nxt_conn_proxy()
378 nxt_conn_t *source, nxt_conn_t *sink) in nxt_conn_proxy_read_process()
569 nxt_conn_t *sink, nxt_conn_t *source) in nxt_conn_proxy_write_process()
734 nxt_conn_t *c; in nxt_conn_proxy_error()
749 nxt_conn_t *c; in nxt_conn_proxy_read_timeout()
767 nxt_conn_t *c; in nxt_conn_proxy_write_timeout()
[all …]
|
| H A D | nxt_conn.c | 42 nxt_conn_t *
45 nxt_conn_t *c; in nxt_conn_create()
48 c = nxt_mp_zget(mp, sizeof(nxt_conn_t)); in nxt_conn_create()
93 nxt_conn_free(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_free()
105 nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c, in nxt_conn_timer()
122 nxt_conn_work_queue_set(nxt_conn_t *c, nxt_work_queue_t *wq) in nxt_conn_work_queue_set()
132 nxt_conn_local_addr(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_local_addr()
|
| H A D | nxt_conn_connect.c | 10 static nxt_err_t nxt_conn_connect_test_error(nxt_task_t *task, nxt_conn_t *c);
16 nxt_conn_t *c; in nxt_conn_sys_socket()
37 nxt_conn_t *c; in nxt_conn_io_connect()
78 nxt_conn_socket(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_socket()
125 nxt_conn_t *c; in nxt_conn_connect_test()
152 nxt_conn_t *c; in nxt_conn_connect_error()
188 nxt_conn_connect_test_error(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_connect_test_error()
|
| H A D | nxt_conn_accept.c | 21 static nxt_conn_t *nxt_conn_accept_alloc(nxt_task_t *task,
25 static nxt_conn_t *nxt_conn_accept_next(nxt_task_t *task,
85 static nxt_conn_t *
89 nxt_conn_t *c; in nxt_conn_accept_alloc()
139 nxt_conn_t *c; in nxt_conn_io_accept()
190 nxt_conn_t *next; in nxt_conn_accept()
229 static nxt_conn_t *
232 nxt_conn_t *c; in nxt_conn_accept_next()
270 nxt_conn_t *c; in nxt_conn_accept_close_idle_handler()
289 c = nxt_queue_link_data(link, nxt_conn_t, link); in nxt_conn_accept_close_idle_handler()
[all …]
|
| H A D | nxt_h1proto.c | 72 nxt_conn_t *c);
1736 nxt_conn_t *c; in nxt_h1p_conn_close()
1751 nxt_conn_t *c; in nxt_h1p_conn_error()
1852 nxt_conn_t *c; in nxt_h1p_idle_close()
1952 nxt_conn_t *c; in nxt_h1p_idle_response_sent()
1965 nxt_conn_t *c; in nxt_h1p_idle_response_error()
2084 nxt_conn_t *c; in nxt_h1p_conn_closing()
2403 nxt_conn_t *c; in nxt_h1p_peer_header_read()
2628 nxt_conn_t *c; in nxt_h1p_peer_read()
2817 nxt_conn_t *c; in nxt_h1p_peer_close()
[all …]
|
| H A D | nxt_event_conn_job_sendfile.c | 26 nxt_conn_t *c, nxt_buf_t *b);
30 nxt_event_conn_job_sendfile(nxt_task_t *task, nxt_conn_t *c) in nxt_event_conn_job_sendfile()
42 nxt_conn_t *c; in nxt_event_conn_job_sendfile_start()
101 nxt_conn_t *c; in nxt_event_conn_job_sendfile_handler()
168 nxt_conn_t *c; in nxt_event_conn_job_sendfile_return()
238 nxt_event_conn_job_sendfile_completion(nxt_task_t *task, nxt_conn_t *c, in nxt_event_conn_job_sendfile_completion()
|
| H A D | nxt_conn_close.c | 19 nxt_conn_close(nxt_event_engine_t *engine, nxt_conn_t *c) in nxt_conn_close()
77 nxt_conn_t *c; in nxt_conn_shutdown_handler()
98 nxt_conn_t *c; in nxt_conn_close_handler()
140 nxt_conn_t *c; in nxt_conn_close_timer_handler()
|
| H A D | nxt_main.h | 112 typedef struct nxt_conn_s nxt_conn_t; typedef
139 typedef void (*nxt_event_conn_handler_t)(nxt_thread_t *thr, nxt_conn_t *c);
|
| H A D | nxt_conn_read.c | 11 nxt_conn_wait(nxt_conn_t *c) in nxt_conn_wait()
41 nxt_conn_t *c; in nxt_conn_io_read()
132 nxt_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b) in nxt_conn_io_recvbuf()
198 nxt_conn_io_recv(nxt_conn_t *c, void *buf, size_t size, nxt_uint_t flags) in nxt_conn_io_recv()
|
| H A D | nxt_conn_write.c | 21 nxt_conn_t *c; in nxt_conn_io_write()
149 nxt_conn_t *c; in nxt_conn_write_timer_handler()
389 nxt_event_conn_write_limit(nxt_conn_t *c) in nxt_event_conn_write_limit()
422 nxt_event_conn_write_delayed(nxt_event_engine_t *engine, nxt_conn_t *c, in nxt_event_conn_write_delayed()
430 nxt_event_conn_io_sendbuf(nxt_conn_t *c, nxt_buf_t *b, size_t limit) in nxt_event_conn_io_sendbuf()
454 nxt_event_conn_io_writev(nxt_conn_t *c, nxt_iobuf_t *iob, nxt_uint_t niob) in nxt_event_conn_io_writev()
499 nxt_event_conn_io_send(nxt_conn_t *c, void *buf, size_t size) in nxt_event_conn_io_send()
|
| H A D | nxt_stream_source.h | 17 nxt_conn_t *conn;
|
| H A D | nxt_stream_module.c | 20 nxt_conn_t *c; in nxt_stream_connection_init()
60 nxt_conn_t *c; in nxt_stream_connection_peer()
|
| H A D | nxt_h1proto_websocket.c | 26 static void nxt_h1p_conn_ws_frame_process(nxt_task_t *task, nxt_conn_t *c,
29 static ssize_t nxt_h1p_ws_io_read_handler(nxt_task_t *task, nxt_conn_t *c);
76 nxt_conn_t *c; in nxt_h1p_websocket_first_frame_start()
122 nxt_conn_t *c; in nxt_h1p_websocket_frame_start()
221 nxt_conn_t *c; in nxt_h1p_conn_ws_frame_header_read()
399 nxt_h1p_conn_ws_frame_process(nxt_task_t *task, nxt_conn_t *c, in nxt_h1p_conn_ws_frame_process()
462 nxt_h1p_ws_io_read_handler(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_ws_io_read_handler()
498 nxt_conn_t *c; in nxt_h1p_conn_ws_timeout()
544 nxt_conn_t *c; in nxt_h1p_conn_ws_frame_payload_read()
|
| H A D | nxt_h1proto.h | 51 nxt_conn_t *conn;
|
| H A D | nxt_openssl.c | 23 nxt_conn_t *conn;
91 nxt_conn_t *c);
93 static ssize_t nxt_openssl_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b);
739 nxt_conn_t *c;
1034 nxt_conn_t *c;
1221 nxt_openssl_conn_free(nxt_task_t *task, nxt_conn_t *c)
1243 nxt_conn_t *c;
1332 nxt_openssl_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b)
1389 nxt_conn_t *c;
1430 nxt_conn_t *c;
[all …]
|
| H A D | nxt_controller.c | 25 nxt_conn_t *conn;
675 nxt_conn_t *c; in nxt_controller_conn_init()
738 nxt_conn_t *c; in nxt_controller_conn_read()
821 nxt_conn_t *c; in nxt_controller_conn_read_error()
835 nxt_conn_t *c; in nxt_controller_conn_read_timeout()
906 nxt_conn_t *c; in nxt_controller_conn_write()
928 nxt_conn_t *c; in nxt_controller_conn_write_error()
941 nxt_conn_t *c; in nxt_controller_conn_write_timeout()
966 nxt_conn_t *c; in nxt_controller_conn_close()
983 nxt_conn_t *c; in nxt_controller_conn_free()
[all …]
|
| H A D | nxt_tls.h | 71 nxt_tls_conf_t *conf, nxt_conn_t *c);
|
| H A D | nxt_sockaddr.h | 72 void nxt_sockaddr_cache_free(nxt_event_engine_t *engine, nxt_conn_t *c);
|
| H A D | nxt_kqueue_engine.c | 110 static ssize_t nxt_kqueue_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b);
853 nxt_conn_t *c; in nxt_kqueue_conn_io_connect()
895 nxt_conn_t *c; in nxt_kqueue_conn_connected()
932 nxt_conn_t *c; in nxt_kqueue_conn_io_accept()
975 nxt_conn_t *c; in nxt_kqueue_conn_io_read()
1001 nxt_kqueue_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b) in nxt_kqueue_conn_io_recvbuf()
|
| H A D | nxt_macosx_sendfile.c | 29 nxt_macosx_event_conn_io_sendfile(nxt_conn_t *c, nxt_buf_t *b, size_t limit) in nxt_macosx_event_conn_io_sendfile()
|
| H A D | nxt_epoll_engine.c | 96 static ssize_t nxt_epoll_edge_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b);
1011 nxt_conn_t *c; in nxt_epoll_conn_io_accept4()
1060 nxt_conn_t *c; in nxt_epoll_edge_conn_io_connect()
1132 nxt_conn_t *c; in nxt_epoll_edge_conn_connected()
1161 nxt_epoll_edge_conn_io_recvbuf(nxt_conn_t *c, nxt_buf_t *b) in nxt_epoll_edge_conn_io_recvbuf()
|
| H A D | nxt_listen_socket.c | 370 + sizeof(nxt_conn_t) in nxt_listen_socket_pool_min_size()
|
| H A D | nxt_sendbuf.c | 211 nxt_sendbuf_copy_coalesce(nxt_conn_t *c, nxt_buf_mem_t *bm, nxt_buf_t *b, in nxt_sendbuf_copy_coalesce()
|