Home
last modified time | relevance | path

Searched refs:nxt_conn_t (Results 1 – 25 of 28) sorted by path

12

/unit/src/
H A Dnxt_conn.c42 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 Dnxt_conn.h109 nxt_conn_t *next;
185 nxt_timer_data(ev, nxt_conn_t, read_timer)
189 nxt_timer_data(ev, nxt_conn_t, write_timer)
230 nxt_conn_t *c);
242 nxt_conn_t *c);
246 void nxt_conn_wait(nxt_conn_t *c);
262 nxt_conn_t *c, size_t sent);
268 nxt_conn_t *c);
327 nxt_conn_t *client;
328 nxt_conn_t *peer;
[all …]
H A Dnxt_conn_accept.c21 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()
234 static nxt_conn_t *
237 nxt_conn_t *c; in nxt_conn_accept_next()
275 nxt_conn_t *c; in nxt_conn_accept_close_idle_handler()
294 c = nxt_queue_link_data(link, nxt_conn_t, link); in nxt_conn_accept_close_idle_handler()
[all …]
H A Dnxt_conn_close.c19 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()
144 nxt_conn_t *c; in nxt_conn_close_timer_handler()
H A Dnxt_conn_connect.c10 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 Dnxt_conn_proxy.c21 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 Dnxt_conn_read.c11 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 Dnxt_conn_write.c21 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 Dnxt_controller.c26 nxt_conn_t *conn;
691 nxt_conn_t *c; in nxt_controller_conn_init()
754 nxt_conn_t *c; in nxt_controller_conn_read()
837 nxt_conn_t *c; in nxt_controller_conn_read_error()
851 nxt_conn_t *c; in nxt_controller_conn_read_timeout()
922 nxt_conn_t *c; in nxt_controller_conn_write()
944 nxt_conn_t *c; in nxt_controller_conn_write_error()
957 nxt_conn_t *c; in nxt_controller_conn_write_timeout()
982 nxt_conn_t *c; in nxt_controller_conn_close()
999 nxt_conn_t *c; in nxt_controller_conn_free()
[all …]
H A Dnxt_epoll_engine.c96 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 Dnxt_event_conn_job_sendfile.c26 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 Dnxt_h1proto.c72 nxt_conn_t *c);
1736 nxt_conn_t *c; in nxt_h1p_conn_close()
1751 nxt_conn_t *c; in nxt_h1p_conn_error()
1853 nxt_conn_t *c; in nxt_h1p_idle_close()
1953 nxt_conn_t *c; in nxt_h1p_idle_response_sent()
1966 nxt_conn_t *c; in nxt_h1p_idle_response_error()
2085 nxt_conn_t *c; in nxt_h1p_conn_closing()
2404 nxt_conn_t *c; in nxt_h1p_peer_header_read()
2629 nxt_conn_t *c; in nxt_h1p_peer_read()
2818 nxt_conn_t *c; in nxt_h1p_peer_close()
[all …]
H A Dnxt_h1proto.h51 nxt_conn_t *conn;
H A Dnxt_h1proto_websocket.c26 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 Dnxt_http.h421 nxt_msec_t nxt_h1p_conn_request_timer_value(nxt_conn_t *c, uintptr_t data);
H A Dnxt_kqueue_engine.c110 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 Dnxt_listen_socket.c370 + sizeof(nxt_conn_t) in nxt_listen_socket_pool_min_size()
H A Dnxt_macosx_sendfile.c29 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 Dnxt_main.h114 typedef struct nxt_conn_s nxt_conn_t; typedef
141 typedef void (*nxt_event_conn_handler_t)(nxt_thread_t *thr, nxt_conn_t *c);
H A Dnxt_openssl.c23 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 Dnxt_runtime.c471 nxt_conn_t *c; in nxt_runtime_close_idle_connections()
484 c = nxt_queue_link_data(link, nxt_conn_t, link); in nxt_runtime_close_idle_connections()
H A Dnxt_sendbuf.c211 nxt_sendbuf_copy_coalesce(nxt_conn_t *c, nxt_buf_mem_t *bm, nxt_buf_t *b, in nxt_sendbuf_copy_coalesce()
H A Dnxt_sendbuf.h72 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 Dnxt_sockaddr.c53 nxt_sockaddr_cache_free(nxt_event_engine_t *engine, nxt_conn_t *c) in nxt_sockaddr_cache_free()
H A Dnxt_sockaddr.h63 void nxt_sockaddr_cache_free(nxt_event_engine_t *engine, nxt_conn_t *c);

12