Lines Matching refs:reply_port

742                                  msg->port_msg.reply_port);  in nxt_router_conf_data_handler()
830 nxt_port_t *reply_port, *shared_port, *old_shared_port; in nxt_router_app_restart_handler() local
834 reply_port = nxt_runtime_port_find(task->thread->runtime, in nxt_router_app_restart_handler()
836 msg->port_msg.reply_port); in nxt_router_app_restart_handler()
837 if (nxt_slow_path(reply_port == NULL)) { in nxt_router_app_restart_handler()
916 nxt_port_socket_write(task, reply_port, reply, -1, msg->port_msg.stream, in nxt_router_app_restart_handler()
3950 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_req_headers_ack_handler()
3971 msg->port_msg.reply_port); in nxt_router_req_headers_ack_handler()
4950 nxt_port_t *port, *reply_port; in nxt_router_app_prepare_request() local
4968 reply_port = task->thread->engine->port; in nxt_router_app_prepare_request()
5000 msg.pm.pid = reply_port->pid; in nxt_router_app_prepare_request()
5001 msg.pm.reply_port = reply_port->id; in nxt_router_app_prepare_request()
5023 reply_port->id, NULL); in nxt_router_app_prepare_request()
5479 msg->port_msg.reply_port); in nxt_router_get_mmap_handler()
5482 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_get_mmap_handler()
5542 nxt_port_t *port, *reply_port; in nxt_router_get_port_handler() local
5548 reply_port = nxt_runtime_port_find(rt, msg->port_msg.pid, in nxt_router_get_port_handler()
5549 msg->port_msg.reply_port); in nxt_router_get_port_handler()
5550 if (nxt_slow_path(reply_port == NULL)) { in nxt_router_get_port_handler()
5552 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_get_port_handler()
5579 (void) nxt_port_send_port(task, reply_port, port, msg->port_msg.stream); in nxt_router_get_port_handler()