/unit/src/wasm-wasi-component/src/ |
H A D | lib.rs | 60 task: *mut bindings::nxt_task_t, in setup() argument 101 task: *mut bindings::nxt_task_t, in start() argument 134 task: *mut bindings::nxt_task_t, in handle_result() argument 146 unsafe fn alert(task: *mut bindings::nxt_task_t, msg: &str) { in handle_result() argument
|
/unit/src/ |
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_main_process.c | 38 static nxt_int_t nxt_main_process_port_create(nxt_task_t *task, 40 static void nxt_main_process_title(nxt_task_t *task); 52 static void nxt_main_port_socket_handler(nxt_task_t *task, 54 static void nxt_main_port_socket_unlink_handler(nxt_task_t *task, 58 static void nxt_main_port_modules_handler(nxt_task_t *task, 61 static void nxt_main_process_whoami_handler(nxt_task_t *task, 63 static void nxt_main_port_conf_store_handler(nxt_task_t *task, 67 static void nxt_main_port_access_log_handler(nxt_task_t *task, 87 nxt_main_process_start(nxt_thread_t *thr, nxt_task_t *task, in nxt_main_process_start() 407 nxt_main_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_data_handler() [all …]
|
H A D | nxt_application.h | 32 typedef nxt_int_t (*nxt_application_setup_t)(nxt_task_t *task, 172 NXT_EXPORT nxt_int_t nxt_unit_default_init(nxt_task_t *task,
|
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_js.c | 385 nxt_js_call(nxt_task_t *task, nxt_js_conf_t *jcf, nxt_js_cache_t *cache, in nxt_js_call()
|
H A D | nxt_listen_socket.c | 15 nxt_listen_socket(nxt_task_t *task, nxt_socket_t s, int backlog) in nxt_listen_socket() 30 nxt_listen_socket_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_listen_socket_create() 229 nxt_listen_socket_update(nxt_task_t *task, nxt_listen_socket_t *ls, in nxt_listen_socket_update()
|
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,
|
H A D | nxt_http_variables.c | 11 static nxt_int_t nxt_http_var_dollar(nxt_task_t *task, nxt_str_t *str, 13 static nxt_int_t nxt_http_var_request_time(nxt_task_t *task, nxt_str_t *str, 15 static nxt_int_t nxt_http_var_method(nxt_task_t *task, nxt_str_t *str, 17 static nxt_int_t nxt_http_var_request_uri(nxt_task_t *task, nxt_str_t *str, 25 static nxt_int_t nxt_http_var_time_local(nxt_task_t *task, nxt_str_t *str, 33 static nxt_int_t nxt_http_var_status(nxt_task_t *task, nxt_str_t *str, 37 static nxt_int_t nxt_http_var_referer(nxt_task_t *task, nxt_str_t *str, 41 static nxt_int_t nxt_http_var_response_connection(nxt_task_t *task, 43 static nxt_int_t nxt_http_var_response_content_length(nxt_task_t *task, 49 static nxt_int_t nxt_http_var_header(nxt_task_t *task, nxt_str_t *str, [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_runtime.h | 12 typedef void (*nxt_runtime_cont_t)(nxt_task_t *task, nxt_uint_t status); 94 nxt_int_t nxt_runtime_create(nxt_task_t *task); 95 void nxt_runtime_quit(nxt_task_t *task, nxt_uint_t status); 103 void nxt_runtime_process_add(nxt_task_t *task, nxt_process_t *process); 116 nxt_port_t *nxt_runtime_process_port_create(nxt_task_t *task, nxt_runtime_t *rt, 119 void nxt_runtime_port_remove(nxt_task_t *task, nxt_port_t *port); 120 void nxt_runtime_stop_app_processes(nxt_task_t *task, nxt_runtime_t *rt); 127 nxt_int_t nxt_runtime_controller_socket(nxt_task_t *task, nxt_runtime_t *rt); 133 nxt_int_t nxt_runtime_listen_sockets_create(nxt_task_t *task, 135 nxt_int_t nxt_runtime_listen_sockets_enable(nxt_task_t *task, [all …]
|
H A D | nxt_var.c | 57 static nxt_str_t *nxt_var_cache_value(nxt_task_t *task, nxt_tstr_state_t *state, 218 nxt_var_cache_value(nxt_task_t *task, nxt_tstr_state_t *state, in nxt_var_cache_value() 497 nxt_var_interpreter(nxt_task_t *task, nxt_tstr_state_t *state, in nxt_var_interpreter() 577 nxt_var_get(nxt_task_t *task, nxt_tstr_state_t *state, nxt_var_cache_t *cache, in nxt_var_get()
|
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_file.c | 11 nxt_file_open(nxt_task_t *task, nxt_file_t *file, nxt_uint_t mode, in nxt_file_open() 48 nxt_file_openat2(nxt_task_t *task, nxt_file_t *file, nxt_uint_t mode, in nxt_file_openat2() 90 nxt_file_close(nxt_task_t *task, nxt_file_t *file) in nxt_file_close() 444 nxt_fd_nonblocking(nxt_task_t *task, nxt_fd_t fd) in nxt_fd_nonblocking() 462 nxt_fd_blocking(nxt_task_t *task, nxt_fd_t fd) in nxt_fd_blocking() 480 nxt_fd_nonblocking(nxt_task_t *task, nxt_fd_t fd) in nxt_fd_nonblocking() 504 nxt_fd_blocking(nxt_task_t *task, nxt_fd_t fd) in nxt_fd_blocking() 586 nxt_file_fopen(nxt_task_t *task, const char *pathname, const char *mode) in nxt_file_fopen() 612 nxt_file_fclose(nxt_task_t *task, FILE *fp) in nxt_file_fclose() 725 nxt_pipe_create(nxt_task_t *task, nxt_fd_t *pp, nxt_bool_t nbread, in nxt_pipe_create() [all …]
|
H A D | nxt_conn_write.c | 10 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() 191 nxt_conn_io_sendfile(nxt_task_t *task, nxt_sendbuf_t *sb) in nxt_conn_io_sendfile() 304 nxt_conn_io_writev(nxt_task_t *task, nxt_sendbuf_t *sb, struct iovec *iov, in nxt_conn_io_writev() 352 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_http_static.c | 46 static nxt_http_action_t *nxt_http_static(nxt_task_t *task, 48 static void nxt_http_static_iterate(nxt_task_t *task, nxt_http_request_t *r, 52 static void nxt_http_static_next(nxt_task_t *task, nxt_http_request_t *r, 59 static void nxt_http_static_body_handler(nxt_task_t *task, void *obj, 61 static void nxt_http_static_buf_completion(nxt_task_t *task, void *obj, 74 nxt_http_static_init(nxt_task_t *task, nxt_router_temp_conf_t *tmcf, in nxt_http_static_init() 187 nxt_http_static(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_static() 229 nxt_http_static_iterate(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_static_iterate() 302 nxt_http_static_send_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_static_send_ready() 666 nxt_http_static_send_error(nxt_task_t *task, void *obj, void *data) in nxt_http_static_send_error() [all …]
|
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_router.h | 99 nxt_task_t task; 236 void (*handler)(nxt_task_t *task, nxt_http_request_t *r, 245 void nxt_router_process_http_request(nxt_task_t *task, nxt_http_request_t *r, 247 void nxt_router_app_port_close(nxt_task_t *task, nxt_port_t *port); 250 void nxt_router_listen_event_release(nxt_task_t *task, nxt_listen_event_t *lev, 253 void nxt_router_conf_apply(nxt_task_t *task, void *obj, void *data); 254 void nxt_router_conf_error(nxt_task_t *task, nxt_router_temp_conf_t *tmcf); 255 void nxt_router_conf_release(nxt_task_t *task, nxt_socket_conf_joint_t *joint); 257 nxt_int_t nxt_router_access_log_create(nxt_task_t *task, 262 void nxt_router_access_log_release(nxt_task_t *task, [all …]
|
H A D | nxt_http_request.c | 12 static void nxt_http_request_start(nxt_task_t *task, void *obj, void *data); 13 static nxt_int_t nxt_http_request_forward(nxt_task_t *task, 22 static void nxt_http_request_proto_info(nxt_task_t *task, 27 static nxt_int_t nxt_http_request_access_log(nxt_task_t *task, 68 nxt_http_init(nxt_task_t *task) in nxt_http_init() 246 nxt_http_request_create(nxt_task_t *task) in nxt_http_request_create() 308 nxt_http_request_start(nxt_task_t *task, void *obj, void *data) in nxt_http_request_start() 344 nxt_http_request_forward(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_request_forward() 544 nxt_http_request_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_request_ready() 557 nxt_http_request_action(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_request_action() [all …]
|
H A D | nxt_router_access_log.c | 26 static void nxt_router_access_log_writer(nxt_task_t *task, 29 static void nxt_router_access_log_write_ready(nxt_task_t *task, void *obj, 31 static void nxt_router_access_log_write_error(nxt_task_t *task, void *obj, 33 static void nxt_router_access_log_ready(nxt_task_t *task, 35 static void nxt_router_access_log_error(nxt_task_t *task, 39 static void nxt_router_access_log_reopen_ready(nxt_task_t *task, 41 static void nxt_router_access_log_reopen_error(nxt_task_t *task, 67 nxt_router_access_log_create(nxt_task_t *task, nxt_router_conf_t *rtcf, in nxt_router_access_log_create() 166 nxt_router_access_log_writer(nxt_task_t *task, nxt_http_request_t *r, in nxt_router_access_log_writer() 275 nxt_router_access_log_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_ready() [all …]
|
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_clone.c | 14 nxt_int_t nxt_clone_credential_setgroups(nxt_task_t *task, pid_t child_pid, 16 nxt_int_t nxt_clone_credential_map_set(nxt_task_t *task, const char* mapfile, 19 nxt_int_t nxt_clone_credential_map_write(nxt_task_t *task, const char *mapfile, 24 nxt_clone_credential_setgroups(nxt_task_t *task, pid_t child_pid, in nxt_clone_credential_setgroups() 70 nxt_clone_credential_map_write(nxt_task_t *task, const char *mapfile, in nxt_clone_credential_map_write() 120 nxt_clone_credential_map_set(nxt_task_t *task, const char* mapfile, pid_t pid, in nxt_clone_credential_map_set() 190 nxt_clone_credential_map(nxt_task_t *task, pid_t pid, in nxt_clone_credential_map() 243 nxt_clone_vldt_credential_uidmap(nxt_task_t *task, in nxt_clone_vldt_credential_uidmap() 297 nxt_clone_vldt_credential_gidmap(nxt_task_t *task, in nxt_clone_vldt_credential_gidmap()
|
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_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 …]
|
/unit/src/ruby/ |
H A D | nxt_ruby.c | 23 nxt_task_t *task; 29 static nxt_int_t nxt_ruby_start(nxt_task_t *task, 260 nxt_ruby_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_ruby_start()
|