Lines Matching refs:app_port

544     nxt_port_t      *app_port;  in nxt_router_msg_cancel()  local
553 app_port = req_rpc_data->app_port; in nxt_router_msg_cancel()
555 if (app_port != NULL && app_port->id == NXT_SHARED_PORT_ID) { in nxt_router_msg_cancel()
556 cancelled = nxt_app_queue_cancel(app_port->queue, in nxt_router_msg_cancel()
613 if (req_rpc_data->app_port != NULL) { in nxt_request_rpc_data_unlink()
614 nxt_router_app_port_release(task, app, req_rpc_data->app_port, in nxt_request_rpc_data_unlink()
617 req_rpc_data->app_port = NULL; in nxt_request_rpc_data_unlink()
4046 nxt_port_t *app_port; in nxt_router_response_ready_handler() local
4194 app_port = req_rpc_data->app_port; in nxt_router_response_ready_handler()
4195 if (nxt_slow_path(app_port == NULL)) { in nxt_router_response_ready_handler()
4201 app_port->main_app_port->active_websockets++; in nxt_router_response_ready_handler()
4205 nxt_router_app_port_release(task, app, app_port, NXT_APR_UPGRADE); in nxt_router_response_ready_handler()
4235 nxt_port_t *app_port, *main_app_port, *idle_port; in nxt_router_req_headers_ack_handler() local
4261 app_port = nxt_port_hash_find(&app->port_hash, msg->port_msg.pid, in nxt_router_req_headers_ack_handler()
4263 if (nxt_slow_path(app_port == NULL)) { in nxt_router_req_headers_ack_handler()
4275 main_app_port = app_port->main_app_port; in nxt_router_req_headers_ack_handler()
4315 nxt_port_inc_use(app_port); in nxt_router_req_headers_ack_handler()
4327 nxt_port_use(task, req_rpc_data->app_port, -1); in nxt_router_req_headers_ack_handler()
4329 req_rpc_data->app_port = app_port; in nxt_router_req_headers_ack_handler()
4348 res = nxt_port_socket_write(task, app_port, NXT_PORT_MSG_REQ_BODY, in nxt_router_req_headers_ack_handler()
5128 req_rpc_data->app_port = port; in nxt_router_app_port_get()
5254 port = req_rpc_data->app_port; in nxt_router_app_prepare_request()