Home
last modified time | relevance | path

Searched refs:nxt_conn_t (Results 1 – 25 of 28) sorted by last modified time

12

/unit/src/
H A Dnxt_sockaddr.h63 void nxt_sockaddr_cache_free(nxt_event_engine_t *engine, nxt_conn_t *c);
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_sockaddr.c53 nxt_sockaddr_cache_free(nxt_event_engine_t *engine, nxt_conn_t *c) in nxt_sockaddr_cache_free()
H A Dnxt_main.h112 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 Dnxt_http.h418 nxt_msec_t nxt_h1p_conn_request_timer_value(nxt_conn_t *c, uintptr_t data);
H A Dnxt_controller.c25 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 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()
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 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_tls.h71 nxt_tls_conf_t *conf, nxt_conn_t *c);
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_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_stream_module.c20 nxt_conn_t *c; in nxt_stream_connection_init()
60 nxt_conn_t *c; in nxt_stream_connection_peer()
H A Dnxt_stream_source.h17 nxt_conn_t *conn;
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_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_listen_socket.c370 + sizeof(nxt_conn_t) in nxt_listen_socket_pool_min_size()
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_h1proto.h51 nxt_conn_t *conn;
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_conn.h109 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 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()
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 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()
140 nxt_conn_t *c; in nxt_conn_close_timer_handler()
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()

12