Lines Matching refs:shared_port

421         port_fd = app->shared_port->pair[0];  in nxt_router_start_app_process_handler()
422 queue_fd = app->shared_port->queue_fd; in nxt_router_start_app_process_handler()
830 nxt_port_t *reply_port, *shared_port, *old_shared_port; in nxt_router_app_restart_handler() local
850 shared_port = nxt_port_new(task, NXT_SHARED_PORT_ID, nxt_pid, in nxt_router_app_restart_handler()
852 if (nxt_slow_path(shared_port == NULL)) { in nxt_router_app_restart_handler()
856 ret = nxt_port_socket_init(task, shared_port, 0); in nxt_router_app_restart_handler()
858 nxt_port_use(task, shared_port, -1); in nxt_router_app_restart_handler()
862 ret = nxt_router_app_queue_init(task, shared_port); in nxt_router_app_restart_handler()
864 nxt_port_write_close(shared_port); in nxt_router_app_restart_handler()
865 nxt_port_read_close(shared_port); in nxt_router_app_restart_handler()
866 nxt_port_use(task, shared_port, -1); in nxt_router_app_restart_handler()
870 nxt_port_write_enable(task, shared_port); in nxt_router_app_restart_handler()
886 shared_port->app = app; in nxt_router_app_restart_handler()
888 old_shared_port = app->shared_port; in nxt_router_app_restart_handler()
891 app->shared_port = shared_port; in nxt_router_app_restart_handler()
1757 app->shared_port = port; in nxt_router_conf_create()
2797 port_fd = app->shared_port->pair[0]; in nxt_router_app_rpc_create()
2798 queue_fd = app->shared_port->queue_fd; in nxt_router_app_rpc_create()
4776 if (app->shared_port != NULL) { in nxt_router_free_app()
4777 app->shared_port->app = NULL; in nxt_router_free_app()
4778 nxt_port_close(task, app->shared_port); in nxt_router_free_app()
4779 nxt_port_use(task, app->shared_port, -1); in nxt_router_free_app()
4781 app->shared_port = NULL; in nxt_router_free_app()
4811 port = app->shared_port; in nxt_router_app_port_get()