/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()
|