Searched refs:reply_port (Results 1 – 8 of 8) sorted by relevance
| /unit/src/ |
| H A D | nxt_port.h | 176 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 D | nxt_router.c | 767 msg->port_msg.reply_port); in nxt_router_conf_data_handler()
859 reply_port = nxt_runtime_port_find(task->thread->runtime, in nxt_router_app_restart_handler()
862 if (nxt_slow_path(reply_port == NULL)) { in nxt_router_app_restart_handler()
961 msg->port_msg.reply_port); in nxt_router_status_handler()
4245 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_req_headers_ack_handler()
5245 nxt_port_t *port, *reply_port; in nxt_router_app_prepare_request() local
5263 reply_port = task->thread->engine->port; in nxt_router_app_prepare_request()
5295 msg.pm.pid = reply_port->pid; in nxt_router_app_prepare_request()
5296 msg.pm.reply_port = reply_port->id; in nxt_router_app_prepare_request()
5844 nxt_port_t *port, *reply_port; in nxt_router_get_port_handler() local
[all …]
|
| H A D | nxt_main_process.c | 594 msg->port_msg.reply_port); in nxt_main_start_process_handler()
621 msg->port_msg.reply_port); in nxt_main_process_created_handler()
688 nxt_assert(msg->port_msg.reply_port == 0); in nxt_main_process_whoami_handler()
1107 msg->port_msg.reply_port); in nxt_main_port_socket_handler()
1421 msg->port_msg.reply_port); in nxt_main_port_modules_handler()
1709 msg->port_msg.reply_port); in nxt_main_port_access_log_handler()
|
| H A D | nxt_script.c | 552 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 D | nxt_cert.c | 963 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 D | nxt_port_socket.c | 161 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 D | nxt_unit.c | 223 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 D | nxt_application.c | 662 msg->port_msg.reply_port); in nxt_proto_start_process_handler()
|