| /unit/src/ |
| H A D | nxt_application.c | 157 nxt_discovery_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_discovery_start()
199 nxt_discovery_modules(nxt_task_t *task, const char *path) in nxt_discovery_modules()
499 nxt_proto_setup(nxt_task_t *task, nxt_process_t *process) in nxt_proto_setup()
579 nxt_proto_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_proto_start()
678 nxt_proto_quit_children(nxt_task_t *task) in nxt_proto_quit_children()
821 nxt_app_module_load(nxt_task_t *task, const char *name) in nxt_app_module_load()
916 nxt_app_setup(nxt_task_t *task, nxt_process_t *process) in nxt_app_setup()
1013 nxt_unit_default_init(nxt_task_t *task, nxt_unit_init_t *init, in nxt_unit_default_init()
1103 nxt_proto_process_add(nxt_task_t *task, nxt_process_t *process) in nxt_proto_process_add()
1133 nxt_proto_process_remove(nxt_task_t *task, nxt_pid_t pid) in nxt_proto_process_remove()
[all …]
|
| H A D | nxt_buf.c | 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 D | nxt_buf.h | 264 nxt_buf_dummy_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_dummy_completion()
|
| H A D | nxt_buf_filter.c | 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()
332 nxt_buf_filter_file_job_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter_file_job_completion()
400 nxt_buf_filter_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter_buf_completion()
441 nxt_buf_filter_file_read_error(nxt_task_t *task, void *obj, void *data) in nxt_buf_filter_file_read_error()
|
| H A D | nxt_capability.c | 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 D | nxt_cert.c | 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()
1124 nxt_cert_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_cert_store_get_handler()
1192 nxt_cert_store_delete(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp) in nxt_cert_store_delete()
1214 nxt_cert_store_delete_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_cert_store_delete_handler()
|
| H A D | nxt_clone.c | 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 D | nxt_conn.c | 43 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 D | nxt_conn.h | 99 nxt_task_t task; member
151 nxt_task_t task; member
193 #define nxt_conn_tcp_nodelay_on(task, c) \ argument
208 #define nxt_conn_tcp_nodelay_on(task, c) \ argument
|
| H A D | nxt_conn_accept.c | 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()
188 nxt_conn_accept(nxt_task_t *task, nxt_listen_event_t *lev, nxt_conn_t *c) in nxt_conn_accept()
230 nxt_conn_accept_next(nxt_task_t *task, nxt_listen_event_t *lev) in nxt_conn_accept_next()
249 nxt_conn_accept_close_idle(nxt_task_t *task, nxt_listen_event_t *lev) in nxt_conn_accept_close_idle()
267 nxt_conn_accept_close_idle_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_accept_close_idle_handler()
312 nxt_conn_accept_error(nxt_task_t *task, nxt_listen_event_t *lev, in nxt_conn_accept_error()
352 nxt_conn_listen_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_listen_timer_handler()
[all …]
|
| H A D | nxt_conn_close.c | 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 D | nxt_conn_connect.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 D | nxt_conn_proxy.c | 100 nxt_conn_proxy(nxt_task_t *task, nxt_conn_proxy_t *p) in nxt_conn_proxy()
205 nxt_conn_proxy_peer_connect(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_peer_connect()
243 nxt_conn_proxy_connected(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_connected()
293 nxt_conn_proxy_peer_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_peer_read()
377 nxt_conn_proxy_read_process(nxt_task_t *task, nxt_conn_proxy_t *p, in nxt_conn_proxy_read_process()
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()
790 nxt_conn_proxy_refused(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_refused()
851 nxt_conn_proxy_shutdown(nxt_task_t *task, nxt_conn_proxy_t *p, in nxt_conn_proxy_shutdown()
[all …]
|
| H A D | nxt_conn_read.c | 38 nxt_conn_io_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_read()
|
| H A D | nxt_conn_write.c | 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 D | nxt_controller.c | 288 nxt_controller_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_controller_start()
377 nxt_controller_process_new_port_handler(nxt_task_t *task, in nxt_controller_process_new_port_handler()
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()
672 nxt_controller_conn_init(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_init()
733 nxt_controller_conn_read(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_read()
981 nxt_controller_conn_free(nxt_task_t *task, void *obj, void *data) in nxt_controller_conn_free()
1434 nxt_controller_check_postpone_request(nxt_task_t *task) in nxt_controller_check_postpone_request()
1457 nxt_controller_process_cert(nxt_task_t *task, in nxt_controller_process_cert()
[all …]
|
| H A D | nxt_credential.c | 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 D | nxt_epoll_engine.c | 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()
1130 nxt_epoll_edge_conn_connected(nxt_task_t *task, void *obj, void *data) in nxt_epoll_edge_conn_connected()
|
| H A D | nxt_event_conn_job_sendfile.c | 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()
|
| H A D | nxt_event_engine.c | 42 nxt_event_engine_create(nxt_task_t *task, in nxt_event_engine_create()
238 nxt_event_engine_signal_pipe_close(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_signal_pipe_close()
289 nxt_event_engine_signal_pipe(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_signal_pipe()
330 nxt_event_engine_post_handler(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_post_handler()
344 nxt_event_engine_signal_pipe_error(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_signal_pipe_error()
361 nxt_event_engine_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_signal_handler()
466 nxt_event_engine_queue_pop(nxt_event_engine_t *engine, nxt_task_t **task, in nxt_event_engine_queue_pop()
512 nxt_task_t *task; in nxt_event_engine_start() local
721 nxt_event_engine_buf_mem_completion(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_buf_mem_completion()
|
| H A D | nxt_event_engine.h | 420 nxt_task_t task; member
|
| H A D | nxt_eventport_engine.c | 363 nxt_eventport_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_eventport_error_handler()
|
| H A D | nxt_external.c | 31 nxt_external_fd_no_cloexec(nxt_task_t *task, nxt_socket_t fd) in nxt_external_fd_no_cloexec()
60 nxt_external_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_external_start()
|
| H A D | nxt_fastcgi_record_parse.c | 20 nxt_fastcgi_record_parse(nxt_task_t *task, nxt_fastcgi_parse_t *fp, in nxt_fastcgi_record_parse()
|
| H A D | nxt_fastcgi_source.c | 121 nxt_fastcgi_source_handler(nxt_task_t *task, nxt_upstream_source_t *us, in nxt_fastcgi_source_handler()
386 nxt_fastcgi_source_record_filter(nxt_task_t *task, void *obj, void *data) in nxt_fastcgi_source_record_filter()
452 nxt_fastcgi_source_record_error(nxt_task_t *task, void *obj, void *data) in nxt_fastcgi_source_record_error()
463 nxt_fastcgi_source_header_filter(nxt_task_t *task, void *obj, void *data) in nxt_fastcgi_source_header_filter()
524 nxt_fastcgi_source_sync_buffer(nxt_task_t *task, nxt_fastcgi_source_t *fs, in nxt_fastcgi_source_sync_buffer()
543 nxt_fastcgi_source_header_process(nxt_task_t *task, nxt_fastcgi_source_t *fs) in nxt_fastcgi_source_header_process()
682 nxt_fastcgi_source_body_filter(nxt_task_t *task, void *obj, void *data) in nxt_fastcgi_source_body_filter()
730 nxt_fastcgi_source_error(nxt_task_t *task, nxt_stream_source_t *stream) in nxt_fastcgi_source_error()
743 nxt_fastcgi_source_fail(nxt_task_t *task, nxt_fastcgi_source_t *fs) in nxt_fastcgi_source_fail()
|