/unit/src/ |
H A D | nxt_http_route.c | 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() 797 nxt_http_route_rule_name_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_rule_name_create() 825 nxt_http_route_rule_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_rule_create() 867 nxt_http_route_addr_rule_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_addr_rule_create() 908 nxt_http_route_types_rule_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_types_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() 1361 nxt_http_pass_query_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_pass_query_ready() 1564 nxt_http_route_handler(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_route_handler() [all …]
|
H A D | nxt_http.h | 168 nxt_task_t task; member
|
H A D | nxt_h1proto.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() 648 nxt_h1p_header_process(nxt_task_t *task, nxt_h1proto_t *h1p, in nxt_h1p_header_process() 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() 2058 nxt_h1p_closing(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_closing() 2115 nxt_h1p_conn_free(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_free() 2637 nxt_h1p_peer_read(nxt_task_t *task, nxt_http_peer_t *peer) in nxt_h1p_peer_read() [all …]
|
H A D | nxt_tstr.c | 250 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 D | nxt_script.c | 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() 630 nxt_script_store_delete_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_script_store_delete_handler()
|
H A D | nxt_port.h | 341 nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_socket_write()
|
H A D | nxt_process.h | 210 #define nxt_process_title(task, fmt, ...) \ argument
|
H A D | nxt_kqueue_engine.c | 525 nxt_kqueue_fd_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_kqueue_fd_error_handler() 549 nxt_kqueue_file_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_kqueue_file_error_handler() 671 nxt_task_t *task; in nxt_kqueue_poll() local 852 nxt_kqueue_conn_io_connect(nxt_task_t *task, void *obj, void *data) in nxt_kqueue_conn_io_connect() 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() 974 nxt_kqueue_conn_io_read(nxt_task_t *task, void *obj, void *data) in nxt_kqueue_conn_io_read()
|
H A D | nxt_process.c | 137 nxt_process_use(nxt_task_t *task, nxt_process_t *process, int i) in nxt_process_use() 148 nxt_process_init_start(nxt_task_t *task, nxt_process_init_t init) in nxt_process_init_start() 180 nxt_process_start(nxt_task_t *task, nxt_process_t *process) in nxt_process_start() 263 nxt_process_child_fixup(nxt_task_t *task, nxt_process_t *process) in nxt_process_child_fixup() 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() 709 nxt_process_do_start(nxt_task_t *task, nxt_process_t *process) in nxt_process_do_start() 759 nxt_process_whoami(nxt_task_t *task, nxt_process_t *process) in nxt_process_whoami() 1117 nxt_process_daemon(nxt_task_t *task) in nxt_process_daemon() [all …]
|
H A D | nxt_job.c | 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 D | nxt_cgroup.c | 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 D | nxt_http_return.c | 75 nxt_http_return(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_return() 177 nxt_http_return_send_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_return_send_ready() 220 nxt_http_return_send_error(nxt_task_t *task, void *obj, void *data) in nxt_http_return_send_error()
|
H A D | nxt_sockaddr.c | 184 nxt_getsockname(nxt_task_t *task, nxt_mp_t *mp, nxt_socket_t s) in nxt_getsockname()
|
H A D | nxt_port.c | 23 nxt_port_mp_cleanup(nxt_task_t *task, void *obj, void *data) in nxt_port_mp_cleanup() 49 nxt_port_new(nxt_task_t *task, nxt_port_id_t id, nxt_pid_t pid, in nxt_port_new() 88 nxt_port_close(nxt_task_t *task, nxt_port_t *port) in nxt_port_close() 127 nxt_port_release(nxt_task_t *task, nxt_port_t *port) in nxt_port_release() 161 nxt_port_enable(nxt_task_t *task, nxt_port_t *port, in nxt_port_enable() 173 nxt_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_handler() 195 nxt_port_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_quit_handler() 203 nxt_port_send_new_port(nxt_task_t *task, nxt_runtime_t *rt, in nxt_port_send_new_port() 555 nxt_port_post_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_post_handler() 574 nxt_port_post(nxt_task_t *task, nxt_port_t *port, in nxt_port_post() [all …]
|
H A D | nxt_capability.c | 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 D | nxt_fs_mount.c | 16 nxt_fs_mount(nxt_task_t *task, nxt_fs_mount_t *mnt) in nxt_fs_mount() 81 nxt_fs_mount(nxt_task_t *task, nxt_fs_mount_t *mnt) in nxt_fs_mount()
|
H A D | nxt_conn.h | 99 nxt_task_t task; member 151 nxt_task_t task; member 194 #define nxt_conn_tcp_nodelay_on(task, c) \ argument 209 #define nxt_conn_tcp_nodelay_on(task, c) \ argument
|
H A D | nxt_conn_close.c | 75 nxt_conn_shutdown_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_shutdown_handler() 95 nxt_conn_close_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_handler() 142 nxt_conn_close_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_timer_handler() 171 nxt_conn_close_error_ignore(nxt_task_t *task, void *obj, void *data) in nxt_conn_close_error_ignore()
|
H A D | nxt_event_engine.h | 420 nxt_task_t task; member
|
H A D | nxt_conn_accept.c | 38 nxt_listen_event(nxt_task_t *task, nxt_listen_socket_t *ls) in nxt_listen_event() 86 nxt_conn_accept_alloc(nxt_task_t *task, nxt_listen_event_t *lev) in nxt_conn_accept_alloc() 124 nxt_conn_listen_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_listen_handler() 136 nxt_conn_io_accept(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_accept() 188 nxt_conn_accept(nxt_task_t *task, nxt_listen_event_t *lev, nxt_conn_t *c) in nxt_conn_accept() 235 nxt_conn_accept_next(nxt_task_t *task, nxt_listen_event_t *lev) in nxt_conn_accept_next() 254 nxt_conn_accept_close_idle(nxt_task_t *task, nxt_listen_event_t *lev) in nxt_conn_accept_close_idle() 272 nxt_conn_accept_close_idle_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_accept_close_idle_handler() 317 nxt_conn_accept_error(nxt_task_t *task, nxt_listen_event_t *lev, in nxt_conn_accept_error() 357 nxt_conn_listen_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_conn_listen_timer_handler() [all …]
|
/unit/src/python/ |
H A D | nxt_python_asgi.c | 452 PyObject *scope, *res, *task, *receive, *send, *done, *asgi; in nxt_py_asgi_request_handler() local
|
H A D | nxt_python.c | 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()
|
/unit/src/perl/ |
H A D | nxt_perl_psgi.c | 1130 nxt_perl_psgi_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_perl_psgi_start()
|
/unit/src/test/ |
H A D | nxt_tests.c | 28 nxt_task_t task; in main() local
|
H A D | nxt_utf8_file_name_test.c | 47 nxt_task_t task; in nxt_utf8_file_name_test() local
|