Home
last modified time | relevance | path

Searched refs:reply_port (Results 1 – 8 of 8) sorted by relevance

/unit/src/
H A Dnxt_port.h176 nxt_port_id_t reply_port; member
338 nxt_port_id_t reply_port, nxt_buf_t *b);
342 nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_port_id_t reply_port, in nxt_port_socket_write() argument
345 return nxt_port_socket_write2(task, port, type, fd, -1, stream, reply_port, in nxt_port_socket_write()
H A Dnxt_router.c768 msg->port_msg.reply_port); in nxt_router_conf_data_handler()
860 reply_port = nxt_runtime_port_find(task->thread->runtime, in nxt_router_app_restart_handler()
863 if (nxt_slow_path(reply_port == NULL)) { 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()
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()
5840 nxt_port_t *port, *reply_port; in nxt_router_get_port_handler() local
[all …]
H A Dnxt_main_process.c609 msg->port_msg.reply_port); in nxt_main_start_process_handler()
636 msg->port_msg.reply_port); in nxt_main_process_created_handler()
703 nxt_assert(msg->port_msg.reply_port == 0); in nxt_main_process_whoami_handler()
1122 msg->port_msg.reply_port); in nxt_main_port_socket_handler()
1436 msg->port_msg.reply_port); in nxt_main_port_modules_handler()
1724 msg->port_msg.reply_port); in nxt_main_port_access_log_handler()
H A Dnxt_script.c552 msg->port_msg.reply_port); in nxt_script_store_get_handler()
556 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_script_store_get_handler()
H A Dnxt_cert.c963 msg->port_msg.reply_port);
1135 msg->port_msg.reply_port); in nxt_cert_store_get_handler()
1139 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_cert_store_get_handler()
H A Dnxt_port_socket.c161 nxt_fd_t fd, nxt_fd_t fd2, uint32_t stream, nxt_port_id_t reply_port, in nxt_port_socket_write2() argument
185 msg.port_msg.reply_port = reply_port; in nxt_port_socket_write2()
H A Dnxt_unit.c223 nxt_port_id_t reply_port; member
954 msg.reply_port = 0; in nxt_unit_ready()
1019 recv_msg.reply_port = port_msg->reply_port; in nxt_unit_process_msg()
1607 msg.reply_port = ctx_impl->read_port->id.id; in nxt_unit_send_req_headers_ack()
2656 m.msg.reply_port = 0; in nxt_unit_mmap_buf_send()
3305 msg.reply_port = 0; in nxt_unit_request_done()
3628 msg.reply_port = 0; in nxt_unit_send_oosm()
3912 msg.reply_port = 0; in nxt_unit_send_mmap()
4327 m.msg.reply_port = ctx_impl->read_port->id.id; in nxt_unit_get_mmap()
4396 msg.reply_port = 0; in nxt_unit_send_shm_ack()
[all …]
H A Dnxt_application.c662 msg->port_msg.reply_port); in nxt_proto_start_process_handler()