Home
last modified time | relevance | path

Searched defs:task (Results 26 – 50 of 98) sorted by last modified time

1234

/unit/src/
H A Dnxt_http_route.c710 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 Dnxt_http.h168 nxt_task_t task; member
H A Dnxt_h1proto.c194 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 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_script.c49 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 Dnxt_port.h341 nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_socket_write()
H A Dnxt_process.h210 #define nxt_process_title(task, fmt, ...) \ argument
H A Dnxt_kqueue_engine.c525 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 Dnxt_process.c137 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 Dnxt_job.c62 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.c18 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_http_return.c75 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 Dnxt_sockaddr.c184 nxt_getsockname(nxt_task_t *task, nxt_mp_t *mp, nxt_socket_t s) in nxt_getsockname()
H A Dnxt_port.c23 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 Dnxt_capability.c36 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_fs_mount.c16 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 Dnxt_conn.h99 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 Dnxt_conn_close.c75 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 Dnxt_event_engine.h420 nxt_task_t task; member
H A Dnxt_conn_accept.c38 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 Dnxt_python_asgi.c452 PyObject *scope, *res, *task, *receive, *send, *done, *asgi; in nxt_py_asgi_request_handler() local
H A Dnxt_python.c147 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 Dnxt_perl_psgi.c1130 nxt_perl_psgi_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_perl_psgi_start()
/unit/src/test/
H A Dnxt_tests.c28 nxt_task_t task; in main() local
H A Dnxt_utf8_file_name_test.c47 nxt_task_t task; in nxt_utf8_file_name_test() local

1234