Lines Matching refs:nxt_task_t

94 static nxt_int_t nxt_router_prefork(nxt_task_t *task, nxt_process_t *process,
96 static nxt_int_t nxt_router_start(nxt_task_t *task, nxt_process_data_t *data);
97 static void nxt_router_greet_controller(nxt_task_t *task,
100 static nxt_int_t nxt_router_start_app_process(nxt_task_t *task, nxt_app_t *app);
102 static void nxt_router_new_port_handler(nxt_task_t *task,
104 static void nxt_router_conf_data_handler(nxt_task_t *task,
106 static void nxt_router_app_restart_handler(nxt_task_t *task,
108 static void nxt_router_status_handler(nxt_task_t *task,
110 static void nxt_router_remove_pid_handler(nxt_task_t *task,
113 static nxt_router_temp_conf_t *nxt_router_temp_conf(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,
119 static nxt_int_t nxt_router_conf_create(nxt_task_t *task,
121 static nxt_int_t nxt_router_conf_process_static(nxt_task_t *task,
123 static nxt_http_forward_t *nxt_router_conf_forward(nxt_task_t *task,
134 static void nxt_router_apps_hash_use(nxt_task_t *task, nxt_router_conf_t *rtcf,
137 static nxt_int_t nxt_router_app_queue_init(nxt_task_t *task,
139 static nxt_int_t nxt_router_port_queue_init(nxt_task_t *task,
141 static nxt_int_t nxt_router_port_queue_map(nxt_task_t *task,
143 static void nxt_router_listen_socket_rpc_create(nxt_task_t *task,
145 static void nxt_router_listen_socket_ready(nxt_task_t *task,
147 static void nxt_router_listen_socket_error(nxt_task_t *task,
150 static void nxt_router_tls_rpc_handler(nxt_task_t *task,
157 static void nxt_router_js_module_rpc_handler(nxt_task_t *task,
162 static void nxt_router_app_rpc_create(nxt_task_t *task,
164 static void nxt_router_app_prefork_ready(nxt_task_t *task,
166 static void nxt_router_app_prefork_error(nxt_task_t *task,
168 static nxt_socket_conf_t *nxt_router_socket_conf(nxt_task_t *task,
173 static nxt_int_t nxt_router_engines_create(nxt_task_t *task,
190 static nxt_int_t nxt_router_threads_create(nxt_task_t *task, nxt_runtime_t *rt,
192 static nxt_int_t nxt_router_thread_create(nxt_task_t *task, nxt_runtime_t *rt,
194 static void nxt_router_apps_sort(nxt_task_t *task, nxt_router_t *router,
203 static void nxt_router_rt_add_port(nxt_task_t *task, void *obj,
205 static void nxt_router_listen_socket_create(nxt_task_t *task, void *obj,
207 static void nxt_router_listen_socket_update(nxt_task_t *task, void *obj,
209 static void nxt_router_listen_socket_delete(nxt_task_t *task, void *obj,
211 static void nxt_router_worker_thread_quit(nxt_task_t *task, void *obj,
213 static void nxt_router_listen_socket_close(nxt_task_t *task, void *obj,
215 static void nxt_router_thread_exit_handler(nxt_task_t *task, void *obj,
217 static void nxt_router_req_headers_ack_handler(nxt_task_t *task,
219 static void nxt_router_listen_socket_release(nxt_task_t *task,
222 static void nxt_router_app_port_ready(nxt_task_t *task,
224 static void nxt_router_app_port_error(nxt_task_t *task,
227 static void nxt_router_app_use(nxt_task_t *task, nxt_app_t *app, int i);
228 static void nxt_router_app_unlink(nxt_task_t *task, nxt_app_t *app);
230 static void nxt_router_app_port_release(nxt_task_t *task, nxt_app_t *app,
232 static void nxt_router_app_port_get(nxt_task_t *task, nxt_app_t *app,
234 static void nxt_router_http_request_error(nxt_task_t *task, void *obj,
236 static void nxt_router_http_request_done(nxt_task_t *task, void *obj,
239 static void nxt_router_app_prepare_request(nxt_task_t *task,
241 static nxt_buf_t *nxt_router_prepare_msg(nxt_task_t *task,
244 static void nxt_router_app_timeout(nxt_task_t *task, void *obj, void *data);
245 static void nxt_router_adjust_idle_timer(nxt_task_t *task, void *obj,
247 static void nxt_router_app_idle_timeout(nxt_task_t *task, void *obj,
249 static void nxt_router_app_joint_release_handler(nxt_task_t *task, void *obj,
251 static void nxt_router_free_app(nxt_task_t *task, void *obj, void *data);
254 static void nxt_http_request_send_body(nxt_task_t *task, void *obj, void *data);
256 static void nxt_router_app_joint_use(nxt_task_t *task,
259 static void nxt_router_http_request_release_post(nxt_task_t *task,
261 static void nxt_router_http_request_release(nxt_task_t *task, void *obj,
263 static void nxt_router_oosm_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
264 static void nxt_router_get_port_handler(nxt_task_t *task,
266 static void nxt_router_get_mmap_handler(nxt_task_t *task,
327 nxt_router_prefork(nxt_task_t *task, nxt_process_t *process, nxt_mp_t *mp) in nxt_router_prefork()
336 nxt_router_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_router_start()
385 nxt_router_greet_controller(nxt_task_t *task, nxt_port_t *controller_port) in nxt_router_greet_controller()
393 nxt_router_start_app_process_handler(nxt_task_t *task, nxt_port_t *port, in nxt_router_start_app_process_handler()
494 nxt_router_app_joint_use(nxt_task_t *task, nxt_app_joint_t *app_joint, int i) in nxt_router_app_joint_use()
507 nxt_router_start_app_process(nxt_task_t *task, nxt_app_t *app) in nxt_router_start_app_process()
540 nxt_router_msg_cancel(nxt_task_t *task, nxt_request_rpc_data_t *req_rpc_data) in nxt_router_msg_cancel()
602 nxt_request_rpc_data_unlink(nxt_task_t *task, in nxt_request_rpc_data_unlink()
672 nxt_router_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_new_port_handler()
758 nxt_router_conf_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_conf_data_handler()
851 nxt_router_app_restart_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_app_restart_handler()
948 nxt_router_status_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_status_handler()
1026 nxt_router_app_process_remove_pid(nxt_task_t *task, nxt_port_t *port, in nxt_router_app_process_remove_pid()
1041 nxt_router_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_remove_pid_handler()
1067 nxt_router_temp_conf(nxt_task_t *task) in nxt_router_temp_conf()
1169 nxt_router_conf_apply(nxt_task_t *task, void *obj, void *data) in nxt_router_conf_apply()
1297 nxt_router_conf_wait(nxt_task_t *task, void *obj, void *data) in nxt_router_conf_wait()
1308 nxt_router_conf_ready(nxt_task_t *task, nxt_router_temp_conf_t *tmcf) in nxt_router_conf_ready()
1347 nxt_router_conf_error(nxt_task_t *task, nxt_router_temp_conf_t *tmcf) in nxt_router_conf_error()
1400 nxt_router_conf_send(nxt_task_t *task, nxt_router_temp_conf_t *tmcf, in nxt_router_conf_send()
1602 nxt_router_conf_create(nxt_task_t *task, nxt_router_temp_conf_t *tmcf, in nxt_router_conf_create()
2203 nxt_router_js_module_rpc_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_js_module_rpc_handler()
2274 nxt_router_conf_process_static(nxt_task_t *task, nxt_router_conf_t *rtcf, in nxt_router_conf_process_static()
2353 nxt_router_conf_forward(nxt_task_t *task, nxt_mp_t *mp, nxt_conf_value_t *conf) in nxt_router_conf_forward()
2469 nxt_router_app_queue_init(nxt_task_t *task, nxt_port_t *port) in nxt_router_app_queue_init()
2497 nxt_router_port_queue_init(nxt_task_t *task, nxt_port_t *port) in nxt_router_port_queue_init()
2525 nxt_router_port_queue_map(nxt_task_t *task, nxt_port_t *port, nxt_fd_t fd) in nxt_router_port_queue_map()
2608 nxt_router_apps_hash_use(nxt_task_t *task, nxt_router_conf_t *rtcf, int i) in nxt_router_apps_hash_use()
2673 nxt_router_socket_conf(nxt_task_t *task, nxt_router_temp_conf_t *tmcf, in nxt_router_socket_conf()
2788 nxt_router_listen_socket_rpc_create(nxt_task_t *task, in nxt_router_listen_socket_rpc_create()
2847 nxt_router_listen_socket_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_listen_socket_ready()
2886 nxt_router_listen_socket_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_listen_socket_error()
2949 nxt_router_tls_rpc_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_tls_rpc_handler()
3017 nxt_router_app_rpc_create(nxt_task_t *task, in nxt_router_app_rpc_create()
3100 nxt_router_app_prefork_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_app_prefork_ready()
3162 nxt_router_app_prefork_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_app_prefork_error()
3189 nxt_router_engines_create(nxt_task_t *task, nxt_router_t *router, in nxt_router_engines_create()
3446 nxt_router_threads_create(nxt_task_t *task, nxt_runtime_t *rt, in nxt_router_threads_create()
3468 nxt_router_thread_create(nxt_task_t *task, nxt_runtime_t *rt, in nxt_router_thread_create()
3500 nxt_router_apps_sort(nxt_task_t *task, nxt_router_t *router, in nxt_router_apps_sort()
3577 nxt_task_t *task; in nxt_router_thread_start()
3646 nxt_router_rt_add_port(nxt_task_t *task, void *obj, void *data) in nxt_router_rt_add_port()
3666 nxt_router_listen_socket_create(nxt_task_t *task, void *obj, void *data) in nxt_router_listen_socket_create()
3730 nxt_router_listen_socket_update(nxt_task_t *task, void *obj, void *data) in nxt_router_listen_socket_update()
3766 nxt_router_listen_socket_delete(nxt_task_t *task, void *obj, void *data) in nxt_router_listen_socket_delete()
3795 nxt_router_worker_thread_quit(nxt_task_t *task, void *obj, void *data) in nxt_router_worker_thread_quit()
3812 nxt_router_listen_socket_close(nxt_task_t *task, void *obj, void *data) in nxt_router_listen_socket_close()
3846 nxt_router_listen_socket_release(nxt_task_t *task, nxt_socket_conf_t *skcf) in nxt_router_listen_socket_release()
3908 nxt_router_listen_event_release(nxt_task_t *task, nxt_listen_event_t *lev, in nxt_router_listen_event_release()
3938 nxt_router_conf_release(nxt_task_t *task, nxt_socket_conf_joint_t *joint) in nxt_router_conf_release()
4005 nxt_router_thread_exit_handler(nxt_task_t *task, void *obj, void *data) in nxt_router_thread_exit_handler()
4039 nxt_router_response_ready_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_response_ready_handler()
4228 nxt_router_req_headers_ack_handler(nxt_task_t *task, in nxt_router_req_headers_ack_handler()
4374 nxt_http_request_send_body(nxt_task_t *task, void *obj, void *data) in nxt_http_request_send_body()
4391 nxt_router_response_error_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_response_error_handler()
4413 nxt_router_app_port_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_app_port_ready()
4532 nxt_router_app_port_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_app_port_error()
4601 nxt_router_app_get_port_for_quit(nxt_task_t *task, nxt_app_t *app) in nxt_router_app_get_port_for_quit()
4639 nxt_router_app_use(nxt_task_t *task, nxt_app_t *app, int i) in nxt_router_app_use()
4658 nxt_router_app_unlink(nxt_task_t *task, nxt_app_t *app) in nxt_router_app_unlink()
4669 nxt_router_app_port_release(nxt_task_t *task, nxt_app_t *app, nxt_port_t *port, in nxt_router_app_port_release()
4786 nxt_router_app_port_close(nxt_task_t *task, nxt_port_t *port) in nxt_router_app_port_close()
4878 nxt_router_adjust_idle_timer(nxt_task_t *task, void *obj, void *data) in nxt_router_adjust_idle_timer()
4970 nxt_router_app_idle_timeout(nxt_task_t *task, void *obj, void *data) in nxt_router_app_idle_timeout()
4985 nxt_router_app_joint_release_handler(nxt_task_t *task, void *obj, void *data) in nxt_router_app_joint_release_handler()
4998 nxt_router_free_app(nxt_task_t *task, void *obj, void *data) in nxt_router_free_app()
5091 nxt_router_app_port_get(nxt_task_t *task, nxt_app_t *app, in nxt_router_app_port_get()
5138 nxt_router_process_http_request(nxt_task_t *task, nxt_http_request_t *r, in nxt_router_process_http_request()
5199 nxt_router_http_request_error(nxt_task_t *task, void *obj, void *data) in nxt_router_http_request_error()
5218 nxt_router_http_request_done(nxt_task_t *task, void *obj, void *data) in nxt_router_http_request_done()
5235 nxt_router_app_prepare_request(nxt_task_t *task, in nxt_router_app_prepare_request()
5386 nxt_router_prepare_msg(nxt_task_t *task, nxt_http_request_t *r, in nxt_router_prepare_msg()
5667 nxt_router_app_timeout(nxt_task_t *task, void *obj, void *data) in nxt_router_app_timeout()
5687 nxt_router_http_request_release_post(nxt_task_t *task, nxt_http_request_t *r) in nxt_router_http_request_release_post()
5695 nxt_router_http_request_release(nxt_task_t *task, void *obj, void *data) in nxt_router_http_request_release()
5708 nxt_router_oosm_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_oosm_handler()
5765 nxt_router_get_mmap_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_get_mmap_handler()
5838 nxt_router_get_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_get_port_handler()