Home
last modified time | relevance | path

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

12345

/unit/src/
H A Dnxt_sockaddr.h73 NXT_EXPORT nxt_sockaddr_t *nxt_getsockname(nxt_task_t *task, nxt_mp_t *mp,
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()
753 nxt_runtime_conf_init(nxt_task_t *task, nxt_runtime_t *rt) in nxt_runtime_conf_init()
1147 nxt_runtime_hostname(nxt_task_t *task, nxt_runtime_t *rt) in nxt_runtime_hostname()
[all …]
H A Dnxt_sockaddr.c184 nxt_getsockname(nxt_task_t *task, nxt_mp_t *mp, nxt_socket_t s) in nxt_getsockname()
H A Dnxt_process.h64 typedef void (*nxt_isolation_cleanup_t)(nxt_task_t *task,
128 typedef nxt_int_t (*nxt_process_prefork_t)(nxt_task_t *task,
130 typedef nxt_int_t (*nxt_process_postfork_t)(nxt_task_t *task,
132 typedef nxt_int_t (*nxt_process_setup_t)(nxt_task_t *task,
134 typedef nxt_int_t (*nxt_process_start_t)(nxt_task_t *task,
160 NXT_EXPORT nxt_pid_t nxt_process_execute(nxt_task_t *task, char *name,
162 NXT_EXPORT nxt_int_t nxt_process_daemon(nxt_task_t *task);
187 void nxt_process_use(nxt_task_t *task, nxt_process_t *process, int i);
189 nxt_int_t nxt_process_start(nxt_task_t *task, nxt_process_t *process);
192 void nxt_process_use(nxt_task_t *task, nxt_process_t *process, int i);
[all …]
H A Dnxt_main.h17 typedef struct nxt_task_s nxt_task_t; typedef
19 typedef void (*nxt_port_handler_t)(nxt_task_t *task, nxt_port_recv_msg_t *msg);
29 typedef void (*nxt_work_handler_t)(nxt_task_t *task, void *obj, void *data);
168 NXT_EXPORT extern nxt_task_t nxt_main_task;
H A Dnxt_process.c33 static nxt_int_t nxt_process_child_fixup(nxt_task_t *task,
39 static nxt_int_t nxt_process_send_created(nxt_task_t *task,
41 static nxt_int_t nxt_process_send_ready(nxt_task_t *task,
45 static void nxt_process_created_error(nxt_task_t *task,
121 nxt_process_use(nxt_task_t *task, nxt_process_t *process, int i) in nxt_process_use()
164 nxt_process_start(nxt_task_t *task, nxt_process_t *process) in nxt_process_start()
314 nxt_process_create(nxt_task_t *task, nxt_process_t *process) in nxt_process_create()
386 nxt_process_setup(nxt_task_t *task, nxt_process_t *process) in nxt_process_setup()
503 nxt_process_whoami(nxt_task_t *task, nxt_process_t *process) in nxt_process_whoami()
861 nxt_process_daemon(nxt_task_t *task) in nxt_process_daemon()
[all …]
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,
59 static void nxt_proto_process_created_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()
959 nxt_app_setup(nxt_task_t *task, nxt_process_t *process) in nxt_app_setup()
[all …]
H A Dnxt_isolation.c15 static nxt_int_t nxt_isolation_set(nxt_task_t *task,
19 static nxt_int_t nxt_isolation_set_namespaces(nxt_task_t *task,
21 static nxt_int_t nxt_isolation_clone_flags(nxt_task_t *task,
26 static nxt_int_t nxt_isolation_set_creds(nxt_task_t *task,
28 static nxt_int_t nxt_isolation_credential_map(nxt_task_t *task,
31 static nxt_int_t nxt_isolation_vldt_creds(nxt_task_t *task,
36 static nxt_int_t nxt_isolation_set_rootfs(nxt_task_t *task,
38 static nxt_int_t nxt_isolation_set_automount(nxt_task_t *task,
40 static nxt_int_t nxt_isolation_set_mounts(nxt_task_t *task,
59 static nxt_int_t nxt_isolation_set_new_privs(nxt_task_t *task,
[all …]
H A Dnxt_var.c61 static nxt_str_t *nxt_var_cache_value(nxt_task_t *task, nxt_var_query_t *query,
236 nxt_var_cache_value(nxt_task_t *task, nxt_var_query_t *query, uint32_t index) in nxt_var_cache_value()
567 nxt_var_query(nxt_task_t *task, nxt_var_query_t *query, nxt_var_t *var, in nxt_var_query()
665 nxt_var_query_resolve(nxt_task_t *task, nxt_var_query_t *query, void *data, in nxt_var_query_resolve()
681 nxt_var_query_handle(nxt_task_t *task, nxt_var_query_t *query, in nxt_var_query_handle()
H A Dnxt_var.h14 typedef nxt_int_t (*nxt_var_handler_t)(nxt_task_t *task,
62 void nxt_var_query(nxt_task_t *task, nxt_var_query_t *query,
64 void nxt_var_query_resolve(nxt_task_t *task, nxt_var_query_t *query, void *data,
66 void nxt_var_query_handle(nxt_task_t *task, nxt_var_query_t *query,
H A Dnxt_router_access_log.c25 static void nxt_router_access_log_writer(nxt_task_t *task,
28 static void nxt_router_access_log_write_ready(nxt_task_t *task, void *obj,
30 static void nxt_router_access_log_write_error(nxt_task_t *task, void *obj,
32 static void nxt_router_access_log_ready(nxt_task_t *task,
34 static void nxt_router_access_log_error(nxt_task_t *task,
38 static void nxt_router_access_log_reopen_ready(nxt_task_t *task,
40 static void nxt_router_access_log_reopen_error(nxt_task_t *task,
60 nxt_router_access_log_create(nxt_task_t *task, nxt_router_conf_t *rtcf, in nxt_router_access_log_create()
142 nxt_router_access_log_writer(nxt_task_t *task, nxt_http_request_t *r, in nxt_router_access_log_writer()
247 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_router.c82 static void nxt_router_greet_controller(nxt_task_t *task,
87 static void nxt_router_new_port_handler(nxt_task_t *task,
97 static void nxt_router_conf_ready(nxt_task_t *task,
99 static void nxt_router_conf_send(nxt_task_t *task,
139 static void nxt_router_app_rpc_create(nxt_task_t *task,
233 static void nxt_router_app_joint_use(nxt_task_t *task,
576 nxt_request_rpc_data_unlink(nxt_task_t *task, in nxt_request_rpc_data_unlink()
963 nxt_router_temp_conf(nxt_task_t *task) in nxt_router_temp_conf()
2763 nxt_router_app_rpc_create(nxt_task_t *task, in nxt_router_app_rpc_create()
3323 nxt_task_t *task; in nxt_router_thread_start()
[all …]
H A Dnxt_router.h93 nxt_task_t task;
226 void (*handler)(nxt_task_t *task, nxt_http_request_t *r,
235 void nxt_router_process_http_request(nxt_task_t *task, nxt_http_request_t *r,
237 void nxt_router_app_port_close(nxt_task_t *task, nxt_port_t *port);
240 void nxt_router_listen_event_release(nxt_task_t *task, nxt_listen_event_t *lev,
243 void nxt_router_conf_apply(nxt_task_t *task, void *obj, void *data);
244 void nxt_router_conf_error(nxt_task_t *task, nxt_router_temp_conf_t *tmcf);
245 void nxt_router_conf_release(nxt_task_t *task, nxt_socket_conf_joint_t *joint);
247 nxt_int_t nxt_router_access_log_create(nxt_task_t *task,
252 void nxt_router_access_log_release(nxt_task_t *task,
[all …]
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()
189 nxt_http_static(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_static()
228 nxt_http_static_iterate(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_static_iterate()
297 nxt_http_static_send_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_static_send_ready()
661 nxt_http_static_var_error(nxt_task_t *task, void *obj, void *data) in nxt_http_static_var_error()
[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,
66 nxt_http_init(nxt_task_t *task) in nxt_http_init()
244 nxt_http_request_create(nxt_task_t *task) in nxt_http_request_create()
300 nxt_http_request_start(nxt_task_t *task, void *obj, void *data) in nxt_http_request_start()
336 nxt_http_request_forward(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_request_forward()
536 nxt_http_request_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_request_ready()
549 nxt_http_request_action(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_request_action()
607 nxt_http_request_read_body(nxt_task_t *task, nxt_http_request_t *r) in nxt_http_request_read_body()
[all …]
H A Dnxt_http_route.c159 static nxt_http_route_t *nxt_http_route_create(nxt_task_t *task,
190 static nxt_int_t nxt_http_route_resolve(nxt_task_t *task,
192 static nxt_int_t nxt_http_action_resolve(nxt_task_t *task,
194 static nxt_http_action_t *nxt_http_pass_var(nxt_task_t *task,
205 static nxt_http_action_t *nxt_http_route_match(nxt_task_t *task,
686 nxt_http_route_table_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_table_create()
725 nxt_http_route_ruleset_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_ruleset_create()
801 nxt_http_route_rule_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_rule_create()
925 nxt_http_route_pattern_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_pattern_create()
1293 nxt_http_pass_var(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_pass_var()
[all …]
H A Dnxt_http_variables.c10 static nxt_int_t nxt_http_var_dollar(nxt_task_t *task, nxt_str_t *str,
12 static nxt_int_t nxt_http_var_method(nxt_task_t *task, nxt_str_t *str,
14 static nxt_int_t nxt_http_var_request_uri(nxt_task_t *task, nxt_str_t *str,
22 static nxt_int_t nxt_http_var_time_local(nxt_task_t *task, nxt_str_t *str,
28 static nxt_int_t nxt_http_var_status(nxt_task_t *task, nxt_str_t *str,
32 static nxt_int_t nxt_http_var_referer(nxt_task_t *task, nxt_str_t *str,
38 static nxt_int_t nxt_http_var_header(nxt_task_t *task, nxt_str_t *str,
40 static nxt_int_t nxt_http_var_cookie(nxt_task_t *task, nxt_str_t *str,
127 nxt_http_var_request_uri(nxt_task_t *task, nxt_str_t *str, void *ctx, in nxt_http_var_request_uri()
182 nxt_http_var_time_local(nxt_task_t *task, nxt_str_t *str, void *ctx, in nxt_http_var_time_local()
[all …]
H A Dnxt_clone.c28 nxt_int_t nxt_clone_credential_setgroups(nxt_task_t *task, pid_t child_pid,
30 nxt_int_t nxt_clone_credential_map_set(nxt_task_t *task, const char* mapfile,
33 nxt_int_t nxt_clone_credential_map_write(nxt_task_t *task, const char *mapfile,
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 Dnxt_http_return.c23 static nxt_http_action_t *nxt_http_return(nxt_task_t *task,
27 static void nxt_http_return_send_ready(nxt_task_t *task, void *obj, void *data);
28 static void nxt_http_return_var_error(nxt_task_t *task, void *obj, void *data);
75 nxt_http_return(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_return()
173 nxt_http_return_send_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_return_send_ready()
216 nxt_http_return_var_error(nxt_task_t *task, void *obj, void *data) in nxt_http_return_var_error()
H A Dnxt_http.h165 nxt_task_t task;
262 void (*close)(nxt_task_t *task, nxt_http_proto_t proto,
309 nxt_int_t nxt_http_init(nxt_task_t *task);
310 nxt_int_t nxt_h1p_init(nxt_task_t *task);
311 nxt_int_t nxt_http_response_hash_init(nxt_task_t *task);
314 nxt_http_request_t *nxt_http_request_create(nxt_task_t *task);
346 nxt_http_routes_t *nxt_http_routes_create(nxt_task_t *task,
348 nxt_http_action_t *nxt_http_action_create(nxt_task_t *task,
350 nxt_int_t nxt_http_routes_resolve(nxt_task_t *task,
357 nxt_task_t *task, nxt_mp_t *mp, nxt_conf_value_t *cv);
[all …]
H A Dnxt_controller.c42 static nxt_int_t nxt_controller_prefork(nxt_task_t *task,
46 static nxt_int_t nxt_controller_start(nxt_task_t *task,
89 static void nxt_controller_process_cert(nxt_task_t *task,
101 static void nxt_controller_conf_handler(nxt_task_t *task,
103 static void nxt_controller_conf_store(nxt_task_t *task,
105 static void nxt_controller_response(nxt_task_t *task,
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()
1457 nxt_controller_process_cert(nxt_task_t *task, in nxt_controller_process_cert()
[all …]
H A Dnxt_port_socket.c18 static uint8_t nxt_port_enqueue_buf(nxt_task_t *task, nxt_port_msg_t *pm,
27 static nxt_buf_t *nxt_port_buf_completion(nxt_task_t *task,
32 static void nxt_port_queue_read_handler(nxt_task_t *task, void *obj,
128 nxt_port_write_enable(nxt_task_t *task, nxt_port_t *port) in nxt_port_write_enable()
303 nxt_port_msg_chk_insert(nxt_task_t *task, nxt_port_t *port, in nxt_port_msg_chk_insert()
367 nxt_port_write_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_write_handler()
703 nxt_port_read_enable(nxt_task_t *task, nxt_port_t *port) in nxt_port_read_enable()
731 nxt_port_read_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_read_handler()
1076 nxt_port_frag_start(nxt_task_t *task, nxt_port_t *port, in nxt_port_frag_start()
1171 nxt_port_read_msg_process(nxt_task_t *task, nxt_port_t *port, in nxt_port_read_msg_process()
[all …]
H A Dnxt_mp.c1042 nxt_task_t *task, void *obj, void *data) in nxt_mp_cleanup()
H A Dnxt_http_parse.h129 nxt_buf_t *nxt_http_chunk_parse(nxt_task_t *task, nxt_http_chunk_parse_t *hcp,
/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