Lines Matching refs:reply_port

768                                  msg->port_msg.reply_port);  in nxt_router_conf_data_handler()
856 nxt_port_t *reply_port, *shared_port, *old_shared_port; in nxt_router_app_restart_handler() local
860 reply_port = nxt_runtime_port_find(task->thread->runtime, in nxt_router_app_restart_handler()
862 msg->port_msg.reply_port); in nxt_router_app_restart_handler()
863 if (nxt_slow_path(reply_port == NULL)) { in nxt_router_app_restart_handler()
942 nxt_port_socket_write(task, reply_port, reply, -1, msg->port_msg.stream, in nxt_router_app_restart_handler()
962 msg->port_msg.reply_port); in nxt_router_status_handler()
4241 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_req_headers_ack_handler()
4262 msg->port_msg.reply_port); in nxt_router_req_headers_ack_handler()
5241 nxt_port_t *port, *reply_port; in nxt_router_app_prepare_request() local
5259 reply_port = task->thread->engine->port; in nxt_router_app_prepare_request()
5291 msg.pm.pid = reply_port->pid; in nxt_router_app_prepare_request()
5292 msg.pm.reply_port = reply_port->id; in nxt_router_app_prepare_request()
5314 reply_port->id, NULL); in nxt_router_app_prepare_request()
5777 msg->port_msg.reply_port); in nxt_router_get_mmap_handler()
5780 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_get_mmap_handler()
5840 nxt_port_t *port, *reply_port; in nxt_router_get_port_handler() local
5846 reply_port = nxt_runtime_port_find(rt, msg->port_msg.pid, in nxt_router_get_port_handler()
5847 msg->port_msg.reply_port); in nxt_router_get_port_handler()
5848 if (nxt_slow_path(reply_port == NULL)) { in nxt_router_get_port_handler()
5850 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_get_port_handler()
5877 (void) nxt_port_send_port(task, reply_port, port, msg->port_msg.stream); in nxt_router_get_port_handler()