Lines Matching refs:data

96 static nxt_int_t nxt_router_start(nxt_task_t *task, nxt_process_data_t *data);
129 static nxt_int_t nxt_router_apps_hash_test(nxt_lvlhsh_query_t *lhq, void *data);
146 nxt_port_recv_msg_t *msg, void *data);
148 nxt_port_recv_msg_t *msg, void *data);
151 nxt_port_recv_msg_t *msg, void *data);
158 nxt_port_recv_msg_t *msg, void *data);
165 nxt_port_recv_msg_t *msg, void *data);
167 nxt_port_recv_msg_t *msg, void *data);
202 static void nxt_router_thread_start(void *data);
204 void *data);
206 void *data);
208 void *data);
210 void *data);
212 void *data);
214 void *data);
216 void *data);
223 nxt_port_recv_msg_t *msg, void *data);
225 nxt_port_recv_msg_t *msg, void *data);
235 void *data);
237 void *data);
244 static void nxt_router_app_timeout(nxt_task_t *task, void *obj, void *data);
246 void *data);
248 void *data);
250 void *data);
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);
262 void *data);
295 .data = nxt_router_conf_data_handler,
336 nxt_router_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_router_start() argument
394 void *data) in nxt_router_start_app_process_handler() argument
406 app = data; in nxt_router_start_app_process_handler()
484 nxt_mp_free(b->data, b); in nxt_router_start_app_process_handler()
1027 void *data) in nxt_router_app_process_remove_pid() argument
1031 void *data; in nxt_router_app_process_remove_pid() member
1034 u.data = data; in nxt_router_app_process_remove_pid()
1051 msg->u.data); in nxt_router_remove_pid_handler()
1169 nxt_router_conf_apply(nxt_task_t *task, void *obj, void *data) in nxt_router_conf_apply() argument
1297 nxt_router_conf_wait(nxt_task_t *task, void *obj, void *data) in nxt_router_conf_wait() argument
2204 void *data) in nxt_router_js_module_rpc_handler() argument
2214 js_module = data; in nxt_router_js_module_rpc_handler()
2553 nxt_router_apps_hash_test(nxt_lvlhsh_query_t *lhq, void *data) in nxt_router_apps_hash_test() argument
2557 app = data; in nxt_router_apps_hash_test()
2848 void *data) in nxt_router_listen_socket_ready() argument
2854 rpc = data; in nxt_router_listen_socket_ready()
2887 void *data) in nxt_router_listen_socket_error() argument
2892 rpc = data; in nxt_router_listen_socket_error()
2950 void *data) in nxt_router_tls_rpc_handler() argument
2961 tls = data; in nxt_router_tls_rpc_handler()
3101 void *data) in nxt_router_app_prefork_ready() argument
3108 rpc = data; in nxt_router_app_prefork_ready()
3163 void *data) in nxt_router_app_prefork_error() argument
3169 rpc = data; in nxt_router_app_prefork_error()
3367 job->work.data = joint; in nxt_router_engine_joints_create()
3405 job->work.data = NULL; in nxt_router_engine_quit()
3435 job->work.data = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_engine_joints_delete()
3485 link->work.data = link; in nxt_router_thread_create()
3566 .data = nxt_port_rpc_handler,
3573 nxt_router_thread_start(void *data) in nxt_router_thread_start() argument
3583 link = data; in nxt_router_thread_start()
3637 work->data = port; 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() argument
3653 port = 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() argument
3676 joint = data; in nxt_router_listen_socket_create()
3689 lev->socket.data = joint; 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() argument
3738 joint = data; in nxt_router_listen_socket_update()
3747 old = lev->socket.data; in nxt_router_listen_socket_update()
3748 lev->socket.data = joint; 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() argument
3773 skcf = data; in nxt_router_listen_socket_delete()
3784 joint = lev->socket.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() argument
3812 nxt_router_listen_socket_close(nxt_task_t *task, void *obj, void *data) in nxt_router_listen_socket_close() argument
3827 joint = lev->socket.data; in nxt_router_listen_socket_close()
3828 lev->socket.data = NULL; in nxt_router_listen_socket_close()
4005 nxt_router_thread_exit_handler(nxt_task_t *task, void *obj, void *data) in nxt_router_thread_exit_handler() argument
4013 link = data; in nxt_router_thread_exit_handler()
4040 void *data) in nxt_router_response_ready_handler() argument
4053 req_rpc_data = data; in nxt_router_response_ready_handler()
4374 nxt_http_request_send_body(nxt_task_t *task, void *obj, void *data) in nxt_http_request_send_body() argument
4392 void *data) in nxt_router_response_error_handler() argument
4396 req_rpc_data = data; in nxt_router_response_error_handler()
4414 void *data) in nxt_router_app_port_ready() argument
4423 nxt_assert(data != NULL); in nxt_router_app_port_ready()
4425 app_joint_rpc = data; in nxt_router_app_port_ready()
4533 void *data) in nxt_router_app_port_error() argument
4541 nxt_assert(data != NULL); in nxt_router_app_port_error()
4543 app_joint_rpc = data; in nxt_router_app_port_error()
4737 && app->adjust_idle_work.data == NULL) in nxt_router_app_port_release()
4740 app->adjust_idle_work.data = app; in nxt_router_app_port_release()
4878 nxt_router_adjust_idle_timer(nxt_task_t *task, void *obj, void *data) in nxt_router_adjust_idle_timer() argument
4888 queued = (data == app); in nxt_router_adjust_idle_timer()
4903 app->adjust_idle_work.data = NULL; 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() argument
4985 nxt_router_app_joint_release_handler(nxt_task_t *task, void *obj, void *data) in nxt_router_app_joint_release_handler() argument
4998 nxt_router_free_app(nxt_task_t *task, void *obj, void *data) in nxt_router_free_app() argument
5199 nxt_router_http_request_error(nxt_task_t *task, void *obj, void *data) in nxt_router_http_request_error() argument
5218 nxt_router_http_request_done(nxt_task_t *task, void *obj, void *data) in nxt_router_http_request_done() argument
5222 r = data; in nxt_router_http_request_done()
5667 nxt_router_app_timeout(nxt_task_t *task, void *obj, void *data) in nxt_router_app_timeout() argument
5695 nxt_router_http_request_release(nxt_task_t *task, void *obj, void *data) in nxt_router_http_request_release() argument