Lines Matching refs:shared_port
446 port_fd = app->shared_port->pair[0]; in nxt_router_start_app_process_handler()
447 queue_fd = app->shared_port->queue_fd; in nxt_router_start_app_process_handler()
855 nxt_port_t *reply_port, *shared_port, *old_shared_port; in nxt_router_app_restart_handler() local
875 shared_port = nxt_port_new(task, NXT_SHARED_PORT_ID, nxt_pid, in nxt_router_app_restart_handler()
877 if (nxt_slow_path(shared_port == NULL)) { in nxt_router_app_restart_handler()
881 ret = nxt_port_socket_init(task, shared_port, 0); in nxt_router_app_restart_handler()
883 nxt_port_use(task, shared_port, -1); in nxt_router_app_restart_handler()
887 ret = nxt_router_app_queue_init(task, shared_port); in nxt_router_app_restart_handler()
889 nxt_port_write_close(shared_port); in nxt_router_app_restart_handler()
890 nxt_port_read_close(shared_port); in nxt_router_app_restart_handler()
891 nxt_port_use(task, shared_port, -1); in nxt_router_app_restart_handler()
895 nxt_port_write_enable(task, shared_port); in nxt_router_app_restart_handler()
911 shared_port->app = app; in nxt_router_app_restart_handler()
913 old_shared_port = app->shared_port; in nxt_router_app_restart_handler()
916 app->shared_port = shared_port; in nxt_router_app_restart_handler()
1912 app->shared_port = port; in nxt_router_conf_create()
3055 port_fd = app->shared_port->pair[0]; in nxt_router_app_rpc_create()
3056 queue_fd = app->shared_port->queue_fd; in nxt_router_app_rpc_create()
5071 if (app->shared_port != NULL) { in nxt_router_free_app()
5072 app->shared_port->app = NULL; in nxt_router_free_app()
5073 nxt_port_close(task, app->shared_port); in nxt_router_free_app()
5074 nxt_port_use(task, app->shared_port, -1); in nxt_router_free_app()
5076 app->shared_port = NULL; in nxt_router_free_app()
5106 port = app->shared_port; in nxt_router_app_port_get()