Home
last modified time | relevance | path

Searched refs:nxt_task_t (Results 26 – 50 of 123) sorted by relevance

12345

/unit/src/
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_main.h18 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 Dnxt_credential.h22 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 Dnxt_process.c40 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 Dnxt_h1proto_websocket.c20 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 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_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_fiber.c10 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 Dnxt_job.c10 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 Dnxt_controller.c44 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 Dnxt_capability.c31 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 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_conn_connect.c10 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 Dnxt_cgroup.c11 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 Dnxt_event_conn_job_sendfile.c19 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 Dnxt_listen_socket.h54 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 Dnxt_cgroup.h10 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 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_fd_event.c11 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 Dnxt_sendbuf.h110 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 Dnxt_work_queue.h41 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 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 …]
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_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_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,

12345