Lines Matching refs:rt

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,
341 nxt_runtime_t *rt; in nxt_router_start() local
343 rt = task->thread->runtime; in nxt_router_start()
348 rt->tls = nxt_service_get(rt->services, "SSL/TLS", "OpenSSL"); in nxt_router_start()
349 if (nxt_slow_path(rt->tls == NULL)) { in nxt_router_start()
353 ret = rt->tls->library_init(task); in nxt_router_start()
375 controller_port = rt->port_by_type[NXT_PROCESS_CONTROLLER]; in nxt_router_start()
403 nxt_runtime_t *rt; in nxt_router_start_app_process_handler() local
433 rt = task->thread->runtime; in nxt_router_start_app_process_handler()
434 dport = rt->port_by_type[NXT_PROCESS_MAIN]; in nxt_router_start_app_process_handler()
511 nxt_runtime_t *rt; in nxt_router_start_app_process() local
515 rt = task->thread->runtime; in nxt_router_start_app_process()
516 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_start_app_process()
677 nxt_runtime_t *rt; in nxt_router_new_port_handler() local
727 rt = task->thread->runtime; in nxt_router_new_port_handler()
733 main_app_port = nxt_port_hash_find(&rt->ports, port->pid, 0); in nxt_router_new_port_handler()
1174 nxt_runtime_t *rt; in nxt_router_conf_apply() local
1251 rt = task->thread->runtime; in nxt_router_conf_apply()
1253 interface = nxt_service_get(rt->services, "engine", NULL); in nxt_router_conf_apply()
1262 ret = nxt_router_threads_create(task, rt, tmcf); in nxt_router_conf_apply()
2796 nxt_runtime_t *rt; in nxt_router_listen_socket_rpc_create() local
2818 rt = task->thread->runtime; in nxt_router_listen_socket_rpc_create()
2819 main_port = rt->port_by_type[NXT_PROCESS_MAIN]; in nxt_router_listen_socket_rpc_create()
2820 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_listen_socket_rpc_create()
3026 nxt_runtime_t *rt; in nxt_router_app_rpc_create() local
3029 rt = task->thread->runtime; in nxt_router_app_rpc_create()
3049 dport = rt->port_by_type[NXT_PROCESS_MAIN]; in nxt_router_app_rpc_create()
3062 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_router_app_rpc_create()
3446 nxt_router_threads_create(nxt_task_t *task, nxt_runtime_t *rt, in nxt_router_threads_create() argument
3457 ret = nxt_router_thread_create(task, rt, recf[i].engine); in nxt_router_threads_create()
3468 nxt_router_thread_create(nxt_task_t *task, nxt_runtime_t *rt, in nxt_router_thread_create() argument
3487 nxt_queue_insert_tail(&rt->engines, &engine->link); in nxt_router_thread_create()
3650 nxt_runtime_t *rt; in nxt_router_rt_add_port() local
3652 rt = task->thread->runtime; in nxt_router_rt_add_port()
3657 res = nxt_port_hash_add(&rt->ports, port); in nxt_router_rt_add_port()
3852 nxt_runtime_t *rt; in nxt_router_listen_socket_release() local
3895 rt = task->thread->runtime; in nxt_router_listen_socket_release()
3896 main_port = rt->port_by_type[NXT_PROCESS_MAIN]; in nxt_router_listen_socket_release()
5769 nxt_runtime_t *rt; in nxt_router_get_mmap_handler() local
5774 rt = task->thread->runtime; in nxt_router_get_mmap_handler()
5776 port = nxt_runtime_port_find(rt, msg->port_msg.pid, in nxt_router_get_mmap_handler()
5841 nxt_runtime_t *rt; in nxt_router_get_port_handler() local
5844 rt = task->thread->runtime; in nxt_router_get_port_handler()
5846 reply_port = nxt_runtime_port_find(rt, msg->port_msg.pid, in nxt_router_get_port_handler()
5866 port = nxt_runtime_port_find(rt, get_port_msg->pid, get_port_msg->id); in nxt_router_get_port_handler()