Lines Matching refs:shared_port

447         port_fd = app->shared_port->pair[0];  in nxt_router_start_app_process_handler()
448 queue_fd = app->shared_port->queue_fd; in nxt_router_start_app_process_handler()
856 nxt_port_t *reply_port, *shared_port, *old_shared_port; in nxt_router_app_restart_handler() local
876 shared_port = nxt_port_new(task, NXT_SHARED_PORT_ID, nxt_pid, in nxt_router_app_restart_handler()
878 if (nxt_slow_path(shared_port == NULL)) { in nxt_router_app_restart_handler()
882 ret = nxt_port_socket_init(task, shared_port, 0); in nxt_router_app_restart_handler()
884 nxt_port_use(task, shared_port, -1); in nxt_router_app_restart_handler()
888 ret = nxt_router_app_queue_init(task, shared_port); in nxt_router_app_restart_handler()
890 nxt_port_write_close(shared_port); in nxt_router_app_restart_handler()
891 nxt_port_read_close(shared_port); in nxt_router_app_restart_handler()
892 nxt_port_use(task, shared_port, -1); in nxt_router_app_restart_handler()
896 nxt_port_write_enable(task, shared_port); in nxt_router_app_restart_handler()
912 shared_port->app = app; in nxt_router_app_restart_handler()
914 old_shared_port = app->shared_port; in nxt_router_app_restart_handler()
917 app->shared_port = shared_port; in nxt_router_app_restart_handler()
1913 app->shared_port = port; in nxt_router_conf_create()
3051 port_fd = app->shared_port->pair[0]; in nxt_router_app_rpc_create()
3052 queue_fd = app->shared_port->queue_fd; in nxt_router_app_rpc_create()
5067 if (app->shared_port != NULL) { in nxt_router_free_app()
5068 app->shared_port->app = NULL; in nxt_router_free_app()
5069 nxt_port_close(task, app->shared_port); in nxt_router_free_app()
5070 nxt_port_use(task, app->shared_port, -1); in nxt_router_free_app()
5072 app->shared_port = NULL; in nxt_router_free_app()
5102 port = app->shared_port; in nxt_router_app_port_get()