Home
last modified time | relevance | path

Searched refs:nxt_task_t (Results 26 – 50 of 123) sorted by last modified time

12345

/unit/src/
H A Dnxt_php_sapi.c82 static nxt_int_t nxt_php_setup(nxt_task_t *task, nxt_process_t *process,
84 static nxt_int_t nxt_php_start(nxt_task_t *task, nxt_process_data_t *data);
85 static nxt_int_t nxt_php_set_target(nxt_task_t *task, nxt_php_target_t *target,
87 static nxt_int_t nxt_php_set_ini_path(nxt_task_t *task, nxt_str_t *path,
89 static void nxt_php_set_options(nxt_task_t *task, nxt_conf_value_t *options,
96 static void nxt_php_disable(nxt_task_t *task, const char *type,
372 nxt_php_setup(nxt_task_t *task, nxt_process_t *process, in nxt_php_setup()
455 nxt_php_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_php_start()
524 nxt_php_set_target(nxt_task_t *task, nxt_php_target_t *target, in nxt_php_set_target()
638 nxt_php_set_ini_path(nxt_task_t *task, nxt_str_t *ini_path, char *workdir) in nxt_php_set_ini_path()
[all …]
H A Dnxt_credential.c9 static nxt_int_t nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp,
14 nxt_credential_get(nxt_task_t *task, nxt_mp_t *mp, nxt_credential_t *uc, in nxt_credential_get()
98 nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp, in nxt_credential_groups_get()
183 nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp, nxt_credential_t *uc) in nxt_credential_groups_get()
286 nxt_credential_setuid(nxt_task_t *task, nxt_credential_t *uc) in nxt_credential_setuid()
309 nxt_credential_setgids(nxt_task_t *task, nxt_credential_t *uc) in nxt_credential_setgids()
H A Dnxt_http_rewrite.c29 nxt_http_rewrite(nxt_task_t *task, nxt_http_request_t *r) in nxt_http_rewrite()
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_signal_handlers.c14 static void nxt_signal_handler(nxt_task_t *task, void *obj, void *data);
15 static void nxt_signal_sigterm_handler(nxt_task_t *task, void *obj, void *data);
16 static void nxt_signal_sigquit_handler(nxt_task_t *task, void *obj, void *data);
32 nxt_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_handler()
40 nxt_signal_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_signal_quit_handler()
47 nxt_signal_sigterm_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_sigterm_handler()
59 nxt_signal_sigquit_handler(nxt_task_t *task, void *obj, void *data) in nxt_signal_sigquit_handler()
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,
710 nxt_http_route_table_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_table_create()
749 nxt_http_route_ruleset_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_ruleset_create()
825 nxt_http_route_rule_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_rule_create()
949 nxt_http_route_pattern_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_pattern_create()
1317 nxt_http_pass_var(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_pass_var()
[all …]
H A Dnxt_http.h168 nxt_task_t task;
273 void (*close)(nxt_task_t *task, nxt_http_proto_t proto,
320 nxt_int_t nxt_http_init(nxt_task_t *task);
321 nxt_int_t nxt_h1p_init(nxt_task_t *task);
322 nxt_int_t nxt_http_response_hash_init(nxt_task_t *task);
325 nxt_http_request_t *nxt_http_request_create(nxt_task_t *task);
357 nxt_http_routes_t *nxt_http_routes_create(nxt_task_t *task,
359 nxt_http_action_t *nxt_http_action_create(nxt_task_t *task,
361 nxt_int_t nxt_http_routes_resolve(nxt_task_t *task,
368 nxt_task_t *task, nxt_mp_t *mp, nxt_conf_value_t *cv);
[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_h1proto.c32 static nxt_int_t nxt_h1p_header_buffer_test(nxt_task_t *task,
48 static void nxt_h1p_request_header_send(nxt_task_t *task,
83 static void nxt_h1p_shutdown(nxt_task_t *task, nxt_conn_t *c);
84 static void nxt_h1p_closing(nxt_task_t *task, nxt_conn_t *c);
194 nxt_h1p_init(nxt_task_t *task) in nxt_h1p_init()
212 nxt_http_conn_init(nxt_task_t *task, void *obj, void *data) in nxt_http_conn_init()
309 nxt_http_conn_test(nxt_task_t *task, void *obj, void *data) in nxt_http_conn_test()
1724 nxt_h1p_conn_sent(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_sent()
1903 nxt_h1p_idle_response(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_idle_response()
2011 nxt_h1p_shutdown(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_shutdown()
[all …]
H A Dnxt_tstr.c250 nxt_tstr_query(nxt_task_t *task, nxt_tstr_query_t *query, nxt_tstr_t *tstr, in nxt_tstr_query()
308 nxt_tstr_query_resolve(nxt_task_t *task, nxt_tstr_query_t *query, void *data, in nxt_tstr_query_resolve()
324 nxt_tstr_query_handle(nxt_task_t *task, nxt_tstr_query_t *query, in nxt_tstr_query_handle()
H A Dnxt_tstr.h53 void nxt_tstr_query(nxt_task_t *task, nxt_tstr_query_t *query, nxt_tstr_t *tstr,
56 void nxt_tstr_query_resolve(nxt_task_t *task, nxt_tstr_query_t *query,
58 void nxt_tstr_query_handle(nxt_task_t *task, nxt_tstr_query_t *query,
H A Dnxt_script.h13 nxt_script_t *nxt_script_new(nxt_task_t *task, nxt_str_t *name, u_char *data,
17 void nxt_script_info_init(nxt_task_t *task, nxt_array_t *scripts);
23 nxt_array_t *nxt_script_store_load(nxt_task_t *task, nxt_mp_t *mem_pool);
26 void nxt_script_store_get(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp,
28 void nxt_script_store_delete(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp);
30 void nxt_script_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
31 void nxt_script_store_delete_handler(nxt_task_t *task,
H A Dnxt_script.c31 static nxt_script_t *nxt_script_get(nxt_task_t *task, nxt_str_t *name,
34 static void nxt_script_buf_completion(nxt_task_t *task, void *obj, void *data);
49 nxt_script_new(nxt_task_t *task, nxt_str_t *name, u_char *data, size_t size, in nxt_script_new()
110 nxt_script_get(nxt_task_t *task, nxt_str_t *name, nxt_fd_t fd) in nxt_script_get()
163 nxt_script_info_init(nxt_task_t *task, nxt_array_t *scripts) in nxt_script_info_init()
344 nxt_script_store_load(nxt_task_t *task, nxt_mp_t *mp) in nxt_script_store_load()
479 nxt_script_store_get(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp, in nxt_script_store_get()
526 nxt_script_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_script_buf_completion()
541 nxt_script_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_script_store_get_handler()
608 nxt_script_store_delete(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp) in nxt_script_store_delete()
[all …]
H A Dnxt_port.h328 nxt_int_t nxt_port_socket_init(nxt_task_t *task, nxt_port_t *port,
331 void nxt_port_close(nxt_task_t *task, nxt_port_t *port);
332 void nxt_port_write_enable(nxt_task_t *task, nxt_port_t *port);
334 void nxt_port_read_enable(nxt_task_t *task, nxt_port_t *port);
341 nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_socket_write()
349 void nxt_port_enable(nxt_task_t *task, nxt_port_t *port,
351 nxt_int_t nxt_port_send_port(nxt_task_t *task, nxt_port_t *port,
353 void nxt_port_change_log_file(nxt_task_t *task, nxt_runtime_t *rt,
360 void nxt_port_change_log_file_handler(nxt_task_t *task,
367 nxt_int_t nxt_port_post(nxt_task_t *task, nxt_port_t *port,
[all …]
H A Dnxt_process.h56 typedef void (*nxt_isolation_cleanup_t)(nxt_task_t *task,
58 typedef void (*nxt_cgroup_cleanup_t)(nxt_task_t *task,
132 typedef nxt_int_t (*nxt_process_prefork_t)(nxt_task_t *task,
134 typedef nxt_int_t (*nxt_process_postfork_t)(nxt_task_t *task,
136 typedef nxt_int_t (*nxt_process_setup_t)(nxt_task_t *task,
138 typedef nxt_int_t (*nxt_process_start_t)(nxt_task_t *task,
164 NXT_EXPORT nxt_pid_t nxt_process_execute(nxt_task_t *task, char *name,
166 NXT_EXPORT nxt_int_t nxt_process_daemon(nxt_task_t *task);
191 void nxt_process_use(nxt_task_t *task, nxt_process_t *process, int i);
193 nxt_int_t nxt_process_start(nxt_task_t *task, nxt_process_t *process);
[all …]
H A Dnxt_js.h34 nxt_int_t nxt_js_call(nxt_task_t *task, nxt_js_conf_t *jcf,
H A Dnxt_http_parse.h131 nxt_buf_t *nxt_http_chunk_parse(nxt_task_t *task, nxt_http_chunk_parse_t *hcp,
H A Dnxt_kqueue_engine.c88 static void nxt_kqueue_fd_error_handler(nxt_task_t *task, void *obj,
90 static void nxt_kqueue_file_error_handler(nxt_task_t *task, void *obj,
101 static void nxt_kqueue_conn_io_connect(nxt_task_t *task, void *obj,
103 static void nxt_kqueue_conn_connected(nxt_task_t *task, void *obj,
106 static void nxt_kqueue_conn_io_accept(nxt_task_t *task, void *obj,
108 static void nxt_kqueue_conn_io_read(nxt_task_t *task, void *obj,
671 nxt_task_t *task; in nxt_kqueue_poll()
894 nxt_kqueue_conn_connected(nxt_task_t *task, void *obj, void *data) in nxt_kqueue_conn_connected()
914 nxt_kqueue_listen_handler(nxt_task_t *task, void *obj, void *data) in nxt_kqueue_listen_handler()
930 nxt_kqueue_conn_io_accept(nxt_task_t *task, void *obj, void *data) in nxt_kqueue_conn_io_accept()
[all …]
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_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_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_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()
/unit/src/wasm/
H A Dnxt_wasm.c199 nxt_wasm_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_wasm_start()
242 nxt_wasm_setup(nxt_task_t *task, nxt_process_t *process, in nxt_wasm_setup()
/unit/src/perl/
H A Dnxt_perl_psgi.c91 static nxt_int_t nxt_perl_psgi_start(nxt_task_t *task,
1130 nxt_perl_psgi_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_perl_psgi_start()
/unit/src/python/
H A Dnxt_python.c29 static nxt_int_t nxt_python_start(nxt_task_t *task,
31 static nxt_int_t nxt_python_set_target(nxt_task_t *task,
33 nxt_inline nxt_int_t nxt_python_set_prefix(nxt_task_t *task,
35 static nxt_int_t nxt_python_set_path(nxt_task_t *task, nxt_conf_value_t *value);
147 nxt_python_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_python_start()
400 nxt_python_set_target(nxt_task_t *task, nxt_python_target_t *target, in nxt_python_set_target()
481 nxt_python_set_prefix(nxt_task_t *task, nxt_python_target_t *target, in nxt_python_set_prefix()
523 nxt_python_set_path(nxt_task_t *task, nxt_conf_value_t *value) in nxt_python_set_path()

12345