Home
last modified time | relevance | path

Searched refs:app_port (Results 1 – 3 of 3) sorted by relevance

/unit/src/
H A Dnxt_http_websocket.c101 res = nxt_port_socket_write(task, req_rpc_data->app_port, in nxt_http_websocket_client()
142 if (req_rpc_data->app_port == NULL) { in nxt_http_websocket_error_handler()
147 (void) nxt_port_socket_write(task, req_rpc_data->app_port, in nxt_http_websocket_error_handler()
H A Dnxt_router_request.h30 nxt_port_t *app_port; member
H A Dnxt_router.c544 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()
613 if (req_rpc_data->app_port != NULL) { in nxt_request_rpc_data_unlink()
617 req_rpc_data->app_port = NULL; in nxt_request_rpc_data_unlink()
4177 nxt_port_t *app_port; in nxt_router_response_ready_handler() local
4325 app_port = req_rpc_data->app_port; in nxt_router_response_ready_handler()
4446 nxt_port_inc_use(app_port); in nxt_router_req_headers_ack_handler()
4460 req_rpc_data->app_port = app_port; in nxt_router_req_headers_ack_handler()
5259 req_rpc_data->app_port = port; in nxt_router_app_port_get()
[all …]