/unit/src/ |
H A D | nxt_isolation.c | 16 static nxt_int_t nxt_isolation_set(nxt_task_t *task, 20 static nxt_int_t nxt_isolation_set_cgroup(nxt_task_t *task, 25 static nxt_int_t nxt_isolation_set_namespaces(nxt_task_t *task, 27 static nxt_int_t nxt_isolation_clone_flags(nxt_task_t *task, 32 static nxt_int_t nxt_isolation_set_creds(nxt_task_t *task, 34 static nxt_int_t nxt_isolation_credential_map(nxt_task_t *task, 37 static nxt_int_t nxt_isolation_vldt_creds(nxt_task_t *task, 42 static nxt_int_t nxt_isolation_set_rootfs(nxt_task_t *task, 44 static nxt_int_t nxt_isolation_set_automount(nxt_task_t *task, 46 static nxt_int_t nxt_isolation_set_mounts(nxt_task_t *task, [all …]
|
H A D | nxt_main.h | 18 typedef struct nxt_task_s nxt_task_t; typedef 20 typedef void (*nxt_port_handler_t)(nxt_task_t *task, nxt_port_recv_msg_t *msg); 30 typedef void (*nxt_work_handler_t)(nxt_task_t *task, void *obj, void *data); 169 NXT_EXPORT extern nxt_task_t nxt_main_task;
|
H A D | nxt_credential.h | 22 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 D | nxt_process.c | 40 static nxt_int_t nxt_process_init_pidns(nxt_task_t *task, 49 static nxt_int_t nxt_process_child_fixup(nxt_task_t *task, 55 static nxt_int_t nxt_process_send_created(nxt_task_t *task, 57 static nxt_int_t nxt_process_send_ready(nxt_task_t *task, 61 static void nxt_process_created_error(nxt_task_t *task, 180 nxt_process_start(nxt_task_t *task, nxt_process_t *process) in nxt_process_start() 441 nxt_process_unshare(nxt_task_t *task, nxt_process_t *process, in nxt_process_unshare() 541 nxt_process_create(nxt_task_t *task, nxt_process_t *process) in nxt_process_create() 638 nxt_process_setup(nxt_task_t *task, nxt_process_t *process) in nxt_process_setup() 1117 nxt_process_daemon(nxt_task_t *task) in nxt_process_daemon() [all …]
|
H A D | nxt_h1proto_websocket.c | 20 static void nxt_h1p_conn_ws_frame_header_read(nxt_task_t *task, void *obj, 22 static void nxt_h1p_conn_ws_keepalive_disable(nxt_task_t *task, 24 static void nxt_h1p_conn_ws_keepalive_enable(nxt_task_t *task, 26 static void nxt_h1p_conn_ws_frame_process(nxt_task_t *task, nxt_conn_t *c, 161 nxt_h1p_conn_ws_keepalive(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_keepalive() 399 nxt_h1p_conn_ws_frame_process(nxt_task_t *task, nxt_conn_t *c, in nxt_h1p_conn_ws_frame_process() 442 nxt_h1p_conn_ws_error(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_error() 462 nxt_h1p_ws_io_read_handler(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_ws_io_read_handler() 496 nxt_h1p_conn_ws_timeout(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_timeout() 578 hxt_h1p_send_ws_error(nxt_task_t *task, nxt_http_request_t *r, in hxt_h1p_send_ws_error() [all …]
|
H A D | nxt_file.h | 102 NXT_EXPORT nxt_int_t nxt_file_open(nxt_task_t *task, nxt_file_t *file, 106 NXT_EXPORT nxt_int_t nxt_file_openat2(nxt_task_t *task, nxt_file_t *file, 154 NXT_EXPORT void nxt_file_close(nxt_task_t *task, nxt_file_t *file); 185 NXT_EXPORT nxt_int_t nxt_fd_nonblocking(nxt_task_t *task, nxt_fd_t fd); 186 NXT_EXPORT nxt_int_t nxt_fd_blocking(nxt_task_t *task, nxt_fd_t fd); 191 NXT_EXPORT FILE *nxt_file_fopen(nxt_task_t *task, const char *pathname, 193 NXT_EXPORT void nxt_file_fclose(nxt_task_t *task, FILE *fp); 212 NXT_EXPORT nxt_int_t nxt_pipe_create(nxt_task_t *task, nxt_fd_t *pp, 214 NXT_EXPORT void nxt_pipe_close(nxt_task_t *task, nxt_fd_t *pp);
|
H A D | nxt_application.c | 41 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, 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() 941 nxt_task_t *task; in nxt_app_set_logs() 1012 nxt_app_setup(nxt_task_t *task, nxt_process_t *process) in nxt_app_setup() [all …]
|
H A D | nxt_fiber.c | 10 static char *nxt_fiber_create_stack(nxt_task_t *task, nxt_fiber_t *fib); 13 static void nxt_fiber_switch(nxt_task_t *task, nxt_fiber_t *fib); 124 nxt_fiber_create_stack(nxt_task_t *task, nxt_fiber_t *fib) in nxt_fiber_create_stack() 159 nxt_fiber_create_stack(nxt_task_t *task, nxt_fiber_t *fib) in nxt_fiber_create_stack() 235 nxt_task_t *task; in nxt_fiber_trampoline() 300 nxt_task_t *task; in nxt_fiber_trampoline() 343 nxt_fiber_switch(nxt_task_t *task, nxt_fiber_t *fib) in nxt_fiber_switch() 363 nxt_fiber_yield(nxt_task_t *task) in nxt_fiber_yield() 385 nxt_fiber_sleep(nxt_task_t *task, nxt_msec_t timeout) in nxt_fiber_sleep() 431 nxt_fiber_wait(nxt_task_t *task) in nxt_fiber_wait() [all …]
|
H A D | nxt_job.c | 10 static void nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data); 11 static void nxt_job_thread_return_handler(nxt_task_t *task, void *obj, 62 nxt_job_destroy(nxt_task_t *task, void *data) in nxt_job_destroy() 109 nxt_job_start(nxt_task_t *task, nxt_job_t *job, nxt_work_handler_t handler) in nxt_job_start() 137 nxt_job_thread_trampoline(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_trampoline() 157 nxt_job_return(nxt_task_t *task, nxt_job_t *job, nxt_work_handler_t handler) in nxt_job_return() 183 nxt_job_thread_return_handler(nxt_task_t *task, void *obj, void *data) in nxt_job_thread_return_handler()
|
H A D | nxt_controller.c | 44 static nxt_int_t nxt_controller_prefork(nxt_task_t *task, 48 static nxt_int_t nxt_controller_start(nxt_task_t *task, 97 static void nxt_controller_process_cert(nxt_task_t *task, 120 static void nxt_controller_conf_store(nxt_task_t *task, 122 static void nxt_controller_response(nxt_task_t *task, 425 nxt_controller_send_current_conf(nxt_task_t *task) in nxt_controller_send_current_conf() 467 nxt_controller_router_ready_handler(nxt_task_t *task, in nxt_controller_router_ready_handler() 571 nxt_controller_flush_requests(nxt_task_t *task) in nxt_controller_flush_requests() 1692 nxt_controller_process_cert(nxt_task_t *task, in nxt_controller_process_cert() 1951 nxt_controller_process_script(nxt_task_t *task, in nxt_controller_process_script() [all …]
|
H A D | nxt_capability.c | 31 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 D | nxt_clone.h | 44 NXT_EXPORT nxt_int_t nxt_clone_credential_map(nxt_task_t *task, pid_t pid, 46 NXT_EXPORT nxt_int_t nxt_clone_vldt_credential_uidmap(nxt_task_t *task, 48 NXT_EXPORT nxt_int_t nxt_clone_vldt_credential_gidmap(nxt_task_t *task,
|
H A D | nxt_conn_connect.c | 10 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 D | nxt_cgroup.c | 11 static int nxt_mk_cgpath_relative(nxt_task_t *task, const char *dir, 13 static nxt_int_t nxt_mk_cgpath(nxt_task_t *task, const char *dir, 18 nxt_cgroup_proc_add(nxt_task_t *task, nxt_process_t *process) in nxt_cgroup_proc_add() 68 nxt_cgroup_cleanup(nxt_task_t *task, const nxt_process_t *process) in nxt_cgroup_cleanup() 93 nxt_mk_cgpath_relative(nxt_task_t *task, const char *dir, char *cgpath) in nxt_mk_cgpath_relative() 148 nxt_mk_cgpath(nxt_task_t *task, const char *dir, char *cgpath) in nxt_mk_cgpath()
|
H A D | nxt_event_conn_job_sendfile.c | 19 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()
|
H A D | nxt_listen_socket.h | 54 NXT_EXPORT nxt_int_t nxt_listen_socket(nxt_task_t *task, nxt_socket_t s, 57 NXT_EXPORT nxt_int_t nxt_listen_socket_create(nxt_task_t *task, nxt_mp_t *mp, 59 NXT_EXPORT nxt_int_t nxt_listen_socket_update(nxt_task_t *task,
|
H A D | nxt_cgroup.h | 10 nxt_int_t nxt_cgroup_proc_add(nxt_task_t *task, nxt_process_t *process); 11 void nxt_cgroup_cleanup(nxt_task_t *task, const nxt_process_t *process);
|
H A D | nxt_socket.c | 15 nxt_socket_create(nxt_task_t *task, nxt_uint_t domain, nxt_uint_t type, in nxt_socket_create() 54 nxt_socket_defer_accept(nxt_task_t *task, nxt_socket_t s, nxt_sockaddr_t *sa) in nxt_socket_defer_accept() 75 nxt_socket_getsockopt(nxt_task_t *task, nxt_socket_t s, nxt_uint_t level, in nxt_socket_getsockopt() 98 nxt_socket_setsockopt(nxt_task_t *task, nxt_socket_t s, nxt_uint_t level, in nxt_socket_setsockopt() 175 nxt_socket_bind(nxt_task_t *task, nxt_socket_t s, nxt_sockaddr_t *sa) in nxt_socket_bind() 192 nxt_socket_connect(nxt_task_t *task, nxt_socket_t s, nxt_sockaddr_t *sa) in nxt_socket_connect() 248 nxt_socket_shutdown(nxt_task_t *task, nxt_socket_t s, nxt_uint_t how) in nxt_socket_shutdown() 283 nxt_socket_close(nxt_task_t *task, nxt_socket_t s) in nxt_socket_close()
|
H A D | nxt_fd_event.c | 11 static void nxt_fd_event_hash_error(nxt_task_t *task, nxt_fd_t fd); 56 nxt_fd_event_hash_get(nxt_task_t *task, nxt_lvlhsh_t *lvlhsh, nxt_fd_t fd) in nxt_fd_event_hash_get() 77 nxt_fd_event_hash_delete(nxt_task_t *task, nxt_lvlhsh_t *lvlhsh, nxt_fd_t fd, in nxt_fd_event_hash_delete() 109 nxt_fd_event_hash_error(nxt_task_t *task, nxt_fd_t fd) in nxt_fd_event_hash_error()
|
H A D | nxt_sendbuf.h | 110 nxt_uint_t nxt_sendbuf_mem_coalesce0(nxt_task_t *task, nxt_sendbuf_t *sb, 112 nxt_uint_t nxt_sendbuf_mem_coalesce(nxt_task_t *task, 126 nxt_buf_t *nxt_sendbuf_completion(nxt_task_t *task, nxt_work_queue_t *wq, 128 void nxt_sendbuf_drain(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b);
|
H A D | nxt_work_queue.h | 41 nxt_task_t *task; 90 nxt_work_handler_t handler, nxt_task_t *task, void *obj, void *data); 92 nxt_task_t **task, void **obj, void **data); 122 nxt_locked_work_queue_t *lwq, nxt_task_t **task, void **obj, void **data);
|
H A D | nxt_openssl.c | 56 static nxt_int_t nxt_openssl_library_init(nxt_task_t *task); 57 static void nxt_openssl_library_free(nxt_task_t *task); 73 static nxt_int_t nxt_tls_ticket_keys(nxt_task_t *task, SSL_CTX *ctx, 84 static nxt_int_t nxt_openssl_bundle_hash_insert(nxt_task_t *task, 103 static void nxt_cdecl nxt_openssl_conn_error(nxt_task_t *task, 133 nxt_openssl_library_init(nxt_task_t *task) in nxt_openssl_library_init() 208 nxt_openssl_library_free(nxt_task_t *task) in nxt_openssl_library_free() 268 nxt_openssl_library_free(nxt_task_t *task) in nxt_openssl_library_free() 294 nxt_openssl_server_init(nxt_task_t *task, nxt_mp_t *mp, in nxt_openssl_server_init() 1136 nxt_openssl_server_free(nxt_task_t *task, nxt_tls_conf_t *conf) [all …]
|
H A D | nxt_router.c | 97 static void nxt_router_greet_controller(nxt_task_t *task, 102 static void nxt_router_new_port_handler(nxt_task_t *task, 108 static void nxt_router_status_handler(nxt_task_t *task, 114 static void nxt_router_conf_ready(nxt_task_t *task, 116 static void nxt_router_conf_send(nxt_task_t *task, 162 static void nxt_router_app_rpc_create(nxt_task_t *task, 602 nxt_request_rpc_data_unlink(nxt_task_t *task, in nxt_request_rpc_data_unlink() 1067 nxt_router_temp_conf(nxt_task_t *task) in nxt_router_temp_conf() 3017 nxt_router_app_rpc_create(nxt_task_t *task, in nxt_router_app_rpc_create() 3577 nxt_task_t *task; in nxt_router_thread_start() [all …]
|
H A D | nxt_runtime.c | 18 static nxt_int_t nxt_runtime_systemd_listen_sockets(nxt_task_t *task, 27 static nxt_int_t nxt_runtime_event_engine_change(nxt_task_t *task, 33 static nxt_int_t nxt_runtime_log_files_create(nxt_task_t *task, 35 static nxt_int_t nxt_runtime_pid_file_create(nxt_task_t *task, 47 nxt_runtime_create(nxt_task_t *task) in nxt_runtime_create() 340 nxt_runtime_start(nxt_task_t *task, void *obj, void *data) in nxt_runtime_start() 431 nxt_runtime_quit(nxt_task_t *task, nxt_uint_t status) in nxt_runtime_quit() 543 nxt_runtime_exit(nxt_task_t *task, void *obj, void *data) in nxt_runtime_exit() 770 nxt_runtime_conf_init(nxt_task_t *task, nxt_runtime_t *rt) in nxt_runtime_conf_init() 1268 nxt_runtime_hostname(nxt_task_t *task, nxt_runtime_t *rt) in nxt_runtime_hostname() [all …]
|
H A D | nxt_var.h | 14 typedef nxt_int_t (*nxt_var_handler_t)(nxt_task_t *task, 59 nxt_int_t nxt_var_interpreter(nxt_task_t *task, nxt_tstr_state_t *state, 62 nxt_str_t *nxt_var_get(nxt_task_t *task, nxt_tstr_state_t *state,
|