Home
last modified time | relevance | path

Searched refs:nxt_task_t (Results 1 – 25 of 125) sorted by path

12345

/unit/src/
H A Dnxt_application.c41 static nxt_int_t nxt_discovery_start(nxt_task_t *task,
50 static nxt_app_module_t *nxt_app_module_load(nxt_task_t *task,
56 static void nxt_proto_start_process_handler(nxt_task_t *task,
59 static void nxt_proto_process_created_handler(nxt_task_t *task,
61 static void nxt_proto_quit_children(nxt_task_t *task);
206 nxt_discovery_modules(nxt_task_t *task, const char *path) in nxt_discovery_modules()
506 nxt_proto_setup(nxt_task_t *task, nxt_process_t *process) in nxt_proto_setup()
687 nxt_proto_quit_children(nxt_task_t *task) in nxt_proto_quit_children()
864 nxt_app_module_load(nxt_task_t *task, const char *name) in nxt_app_module_load()
959 nxt_app_setup(nxt_task_t *task, nxt_process_t *process) in nxt_app_setup()
[all …]
H A Dnxt_application.h30 typedef nxt_int_t (*nxt_application_setup_t)(nxt_task_t *task,
143 NXT_EXPORT nxt_int_t nxt_unit_default_init(nxt_task_t *task,
H A Dnxt_buf.c10 static void nxt_buf_completion(nxt_task_t *task, void *obj, void *data);
11 static void nxt_buf_ts_completion(nxt_task_t *task, void *obj, void *data);
57 nxt_buf_mem_ts_alloc(nxt_task_t *task, nxt_mp_t *mp, size_t size) in nxt_buf_mem_ts_alloc()
198 nxt_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_completion()
224 nxt_buf_parent_completion(nxt_task_t *task, nxt_buf_t *parent) in nxt_buf_parent_completion()
241 nxt_buf_ts_handle(nxt_task_t *task, void *obj, void *data) in nxt_buf_ts_handle()
271 nxt_buf_ts_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_ts_completion()
H A Dnxt_buf.h217 NXT_EXPORT nxt_buf_t *nxt_buf_mem_ts_alloc(nxt_task_t *task, nxt_mp_t *mp,
224 NXT_EXPORT nxt_int_t nxt_buf_ts_handle(nxt_task_t *task, void *obj, void *data);
226 NXT_EXPORT void nxt_buf_parent_completion(nxt_task_t *task, nxt_buf_t *parent);
264 nxt_buf_dummy_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_dummy_completion()
H A Dnxt_buf_filter.c12 static void nxt_buf_filter_file_read_start(nxt_task_t *task,
14 static void nxt_buf_filter_file_read(nxt_task_t *task, nxt_buf_filter_t *f);
15 static void nxt_buf_filter_file_job_completion(nxt_task_t *task, void *obj,
17 static void nxt_buf_filter_buf_completion(nxt_task_t *task, void *obj,
19 static void nxt_buf_filter_file_read_error(nxt_task_t *task, void *obj,
24 nxt_buf_filter_add(nxt_task_t *task, nxt_buf_filter_t *f, nxt_buf_t *b) in nxt_buf_filter_add()
33 nxt_buf_filter(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter()
211 nxt_buf_filter_enqueue(nxt_task_t *task, nxt_buf_filter_t *f) in nxt_buf_filter_enqueue()
224 nxt_buf_filter_file_read_start(nxt_task_t *task, nxt_buf_filter_t *f) in nxt_buf_filter_file_read_start()
255 nxt_buf_filter_file_read(nxt_task_t *task, nxt_buf_filter_t *f) in nxt_buf_filter_file_read()
[all …]
H A Dnxt_buf_filter.h109 NXT_EXPORT void nxt_buf_filter_add(nxt_task_t *task, nxt_buf_filter_t *f,
111 NXT_EXPORT void nxt_buf_filter(nxt_task_t *task, void *obj, void *data);
112 NXT_EXPORT void nxt_buf_filter_enqueue(nxt_task_t *task, nxt_buf_filter_t *f);
H A Dnxt_capability.c31 static nxt_int_t nxt_capability_specific_set(nxt_task_t *task,
36 nxt_capability_set(nxt_task_t *task, nxt_capabilities_t *cap) in nxt_capability_set()
66 nxt_capability_specific_set(nxt_task_t *task, nxt_capabilities_t *cap) in nxt_capability_specific_set()
114 nxt_capability_specific_set(nxt_task_t *task, nxt_capabilities_t *cap) in nxt_capability_specific_set()
H A Dnxt_capability.h15 NXT_EXPORT nxt_int_t nxt_capability_set(nxt_task_t *task,
H A Dnxt_cert.c42 static nxt_cert_t *nxt_cert_fd(nxt_task_t *task, nxt_fd_t fd);
43 static nxt_cert_t *nxt_cert_bio(nxt_task_t *task, BIO *bio);
51 static void nxt_cert_buf_completion(nxt_task_t *task, void *obj, void *data);
58 nxt_cert_mem(nxt_task_t *task, nxt_buf_mem_t *mbuf) in nxt_cert_mem()
78 nxt_cert_fd(nxt_task_t *task, nxt_fd_t fd) in nxt_cert_fd()
98 nxt_cert_bio(nxt_task_t *task, BIO *bio) in nxt_cert_bio()
345 nxt_cert_info_init(nxt_task_t *task, nxt_array_t *certs) in nxt_cert_info_init()
814 nxt_cert_store_load(nxt_task_t *task, nxt_mp_t *mp) in nxt_cert_store_load()
1062 nxt_cert_store_get(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp, in nxt_cert_store_get()
1109 nxt_cert_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_cert_buf_completion()
[all …]
H A Dnxt_cert.h13 nxt_cert_t *nxt_cert_mem(nxt_task_t *task, nxt_buf_mem_t *mbuf);
16 void nxt_cert_info_init(nxt_task_t *task, nxt_array_t *certs);
22 nxt_array_t *nxt_cert_store_load(nxt_task_t *task, nxt_mp_t *mem_pool);
25 void nxt_cert_store_get(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp,
27 void nxt_cert_store_delete(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp);
29 void nxt_cert_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
30 void nxt_cert_store_delete_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
H A Dnxt_clone.c28 nxt_int_t nxt_clone_credential_setgroups(nxt_task_t *task, pid_t child_pid,
30 nxt_int_t nxt_clone_credential_map_set(nxt_task_t *task, const char* mapfile,
33 nxt_int_t nxt_clone_credential_map_write(nxt_task_t *task, const char *mapfile,
38 nxt_clone_credential_setgroups(nxt_task_t *task, pid_t child_pid, in nxt_clone_credential_setgroups()
84 nxt_clone_credential_map_write(nxt_task_t *task, const char *mapfile, in nxt_clone_credential_map_write()
134 nxt_clone_credential_map_set(nxt_task_t *task, const char* mapfile, pid_t pid, in nxt_clone_credential_map_set()
204 nxt_clone_credential_map(nxt_task_t *task, pid_t pid, in nxt_clone_credential_map()
257 nxt_clone_vldt_credential_uidmap(nxt_task_t *task, in nxt_clone_vldt_credential_uidmap()
311 nxt_clone_vldt_credential_gidmap(nxt_task_t *task, in nxt_clone_vldt_credential_gidmap()
H A Dnxt_clone.h45 NXT_EXPORT nxt_int_t nxt_clone_credential_map(nxt_task_t *task, pid_t pid,
47 NXT_EXPORT nxt_int_t nxt_clone_vldt_credential_uidmap(nxt_task_t *task,
49 NXT_EXPORT nxt_int_t nxt_clone_vldt_credential_gidmap(nxt_task_t *task,
H A Dnxt_conn.c43 nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task) in nxt_conn_create()
93 nxt_conn_free(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_free()
132 nxt_conn_local_addr(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_local_addr()
H A Dnxt_conn.h11 typedef ssize_t (*nxt_conn_io_read_t)(nxt_task_t *task, nxt_conn_t *c);
66 ssize_t (*sendbuf)(nxt_task_t *task,
99 nxt_task_t task;
151 nxt_task_t task;
222 NXT_EXPORT void nxt_conn_free(nxt_task_t *task, nxt_conn_t *c);
228 NXT_EXPORT nxt_sockaddr_t *nxt_conn_local_addr(nxt_task_t *task,
233 nxt_int_t nxt_conn_socket(nxt_task_t *task, nxt_conn_t *c);
247 void nxt_conn_io_read(nxt_task_t *task, void *obj, void *data);
252 void nxt_conn_io_write(nxt_task_t *task, void *obj, void *data);
254 ssize_t nxt_conn_io_writev(nxt_task_t *task, nxt_sendbuf_t *sb,
[all …]
H A Dnxt_conn_accept.c21 static nxt_conn_t *nxt_conn_accept_alloc(nxt_task_t *task,
23 static void nxt_conn_listen_handler(nxt_task_t *task, void *obj,
25 static nxt_conn_t *nxt_conn_accept_next(nxt_task_t *task,
27 static void nxt_conn_accept_close_idle(nxt_task_t *task,
31 static void nxt_conn_listen_event_error(nxt_task_t *task, void *obj,
38 nxt_listen_event(nxt_task_t *task, nxt_listen_socket_t *ls) in nxt_listen_event()
86 nxt_conn_accept_alloc(nxt_task_t *task, nxt_listen_event_t *lev) in nxt_conn_accept_alloc()
124 nxt_conn_listen_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_listen_handler()
136 nxt_conn_io_accept(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_accept()
230 nxt_conn_accept_next(nxt_task_t *task, nxt_listen_event_t *lev) in nxt_conn_accept_next()
[all …]
H A Dnxt_conn_close.c10 static void nxt_conn_shutdown_handler(nxt_task_t *task, void *obj, void *data);
11 static void nxt_conn_close_handler(nxt_task_t *task, void *obj, void *data);
12 static void nxt_conn_close_timer_handler(nxt_task_t *task, void *obj,
14 static void nxt_conn_close_error_ignore(nxt_task_t *task, void *obj,
75 nxt_conn_shutdown_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_shutdown_handler()
95 nxt_conn_close_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_handler()
138 nxt_conn_close_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_timer_handler()
161 nxt_conn_close_error_ignore(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_error_ignore()
H A Dnxt_conn_connect.c10 static nxt_err_t nxt_conn_connect_test_error(nxt_task_t *task, nxt_conn_t *c);
14 nxt_conn_sys_socket(nxt_task_t *task, void *obj, void *data) in nxt_conn_sys_socket()
35 nxt_conn_io_connect(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_connect()
78 nxt_conn_socket(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_socket()
122 nxt_conn_connect_test(nxt_task_t *task, void *obj, void *data) in nxt_conn_connect_test()
149 nxt_conn_connect_error(nxt_task_t *task, void *obj, void *data) 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.c10 static void nxt_conn_proxy_client_buffer_alloc(nxt_task_t *task, void *obj,
12 static void nxt_conn_proxy_peer_connect(nxt_task_t *task, void *obj,
16 static void nxt_conn_proxy_client_read_ready(nxt_task_t *task, void *obj,
18 static void nxt_conn_proxy_peer_read_ready(nxt_task_t *task, void *obj,
33 static void nxt_conn_proxy_read_timeout(nxt_task_t *task, void *obj,
100 nxt_conn_proxy(nxt_task_t *task, nxt_conn_proxy_t *p) in nxt_conn_proxy()
491 nxt_conn_proxy_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_read()
702 nxt_conn_proxy_close(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_close()
732 nxt_conn_proxy_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_error()
851 nxt_conn_proxy_shutdown(nxt_task_t *task, nxt_conn_proxy_t *p, in nxt_conn_proxy_shutdown()
[all …]
H A Dnxt_conn_read.c38 nxt_conn_io_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_read()
H A Dnxt_conn_write.c10 static void nxt_conn_write_timer_handler(nxt_task_t *task, void *obj,
12 static ssize_t nxt_conn_io_sendfile(nxt_task_t *task, nxt_sendbuf_t *sb);
17 nxt_conn_io_write(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_write()
147 nxt_conn_write_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_write_timer_handler()
164 nxt_conn_io_sendbuf(nxt_task_t *task, nxt_sendbuf_t *sb) in nxt_conn_io_sendbuf()
184 nxt_conn_io_sendfile(nxt_task_t *task, nxt_sendbuf_t *sb) in nxt_conn_io_sendfile()
297 nxt_conn_io_writev(nxt_task_t *task, nxt_sendbuf_t *sb, struct iovec *iov, in nxt_conn_io_writev()
345 nxt_conn_io_send(nxt_task_t *task, nxt_sendbuf_t *sb, void *buf, size_t size) in nxt_conn_io_send()
H A Dnxt_controller.c42 static nxt_int_t nxt_controller_prefork(nxt_task_t *task,
46 static nxt_int_t nxt_controller_start(nxt_task_t *task,
89 static void nxt_controller_process_cert(nxt_task_t *task,
101 static void nxt_controller_conf_handler(nxt_task_t *task,
103 static void nxt_controller_conf_store(nxt_task_t *task,
105 static void nxt_controller_response(nxt_task_t *task,
393 nxt_controller_send_current_conf(nxt_task_t *task) in nxt_controller_send_current_conf()
435 nxt_controller_router_ready_handler(nxt_task_t *task, in nxt_controller_router_ready_handler()
538 nxt_controller_flush_requests(nxt_task_t *task) in nxt_controller_flush_requests()
1457 nxt_controller_process_cert(nxt_task_t *task, in nxt_controller_process_cert()
[all …]
H A Dnxt_credential.c9 static nxt_int_t nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp,
14 nxt_credential_get(nxt_task_t *task, nxt_mp_t *mp, nxt_credential_t *uc, in nxt_credential_get()
95 nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp, in nxt_credential_groups_get()
180 nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp, nxt_credential_t *uc) in nxt_credential_groups_get()
283 nxt_credential_setuid(nxt_task_t *task, nxt_credential_t *uc) in nxt_credential_setuid()
306 nxt_credential_setgids(nxt_task_t *task, nxt_credential_t *uc) in nxt_credential_setgids()
H A Dnxt_credential.h22 NXT_EXPORT nxt_int_t nxt_credential_get(nxt_task_t *task, nxt_mp_t *mp,
24 NXT_EXPORT nxt_int_t nxt_credential_setuid(nxt_task_t *task,
26 NXT_EXPORT nxt_int_t nxt_credential_setgids(nxt_task_t *task,
H A Dnxt_epoll_engine.c71 static void nxt_epoll_error_handler(nxt_task_t *task, void *obj, void *data);
79 static void nxt_epoll_eventfd_handler(nxt_task_t *task, void *obj, void *data);
85 static void nxt_epoll_conn_io_accept4(nxt_task_t *task, void *obj,
92 static void nxt_epoll_edge_conn_io_connect(nxt_task_t *task, void *obj,
94 static void nxt_epoll_edge_conn_connected(nxt_task_t *task, void *obj,
650 nxt_epoll_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_error_handler()
722 nxt_epoll_signalfd_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_signalfd_handler()
809 nxt_epoll_eventfd_handler(nxt_task_t *task, void *obj, void *data) in nxt_epoll_eventfd_handler()
1008 nxt_epoll_conn_io_accept4(nxt_task_t *task, void *obj, void *data) in nxt_epoll_conn_io_accept4()
1058 nxt_epoll_edge_conn_io_connect(nxt_task_t *task, void *obj, void *data) in nxt_epoll_edge_conn_io_connect()
[all …]
H A Dnxt_event_conn_job_sendfile.c19 static void nxt_event_conn_job_sendfile_start(nxt_task_t *task, void *obj,
21 static void nxt_event_conn_job_sendfile_handler(nxt_task_t *task, void *obj,
23 static void nxt_event_conn_job_sendfile_return(nxt_task_t *task, void *obj,
25 static nxt_buf_t *nxt_event_conn_job_sendfile_completion(nxt_task_t *task,
30 nxt_event_conn_job_sendfile(nxt_task_t *task, nxt_conn_t *c) in nxt_event_conn_job_sendfile()
40 nxt_event_conn_job_sendfile_start(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_start()
96 nxt_event_conn_job_sendfile_handler(nxt_task_t *task, void *obj, void *data) in nxt_event_conn_job_sendfile_handler()
163 nxt_event_conn_job_sendfile_return(nxt_task_t *task, void *obj, void *data) 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()

12345