Home
last modified time | relevance | path

Searched refs:nxt_task_t (Results 1 – 25 of 123) sorted by last modified time

12345

/unit/src/wasm-wasi-component/src/
H A Dlib.rs60 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 Dnxt_router.c97 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 Dnxt_main_process.c38 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 Dnxt_application.h32 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 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,
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 Dnxt_js.c385 nxt_js_call(nxt_task_t *task, nxt_js_conf_t *jcf, nxt_js_cache_t *cache, in nxt_js_call()
H A Dnxt_listen_socket.c15 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 Dnxt_var.h14 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 Dnxt_http_variables.c11 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 Dnxt_runtime.c18 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 Dnxt_runtime.h12 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 Dnxt_var.c57 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 Dnxt_file.h102 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 Dnxt_file.c11 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 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()
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 Dnxt_http_static.c46 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 Dnxt_isolation.c16 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 Dnxt_router.h99 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 Dnxt_http_request.c12 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 Dnxt_router_access_log.c26 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 Dnxt_clone.h44 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 Dnxt_clone.c14 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 Dnxt_socket.c15 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 Dnxt_openssl.c56 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 Dnxt_ruby.c23 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()

12345