Home
last modified time | relevance | path

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

/unit/src/
H A Dnxt_port.h167 nxt_port_id_t reply_port; member
329 nxt_port_id_t reply_port, nxt_buf_t *b);
333 nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_port_id_t reply_port, in nxt_port_socket_write() argument
336 return nxt_port_socket_write2(task, port, type, fd, -1, stream, reply_port, in nxt_port_socket_write()
H A Dnxt_main_process.c534 msg->port_msg.reply_port); in nxt_main_start_process_handler()
561 msg->port_msg.reply_port); in nxt_main_process_created_handler()
623 nxt_assert(msg->port_msg.reply_port == 0); in nxt_main_process_whoami_handler()
1038 msg->port_msg.reply_port); in nxt_main_port_socket_handler()
1305 msg->port_msg.reply_port); in nxt_main_port_modules_handler()
1593 msg->port_msg.reply_port); in nxt_main_port_access_log_handler()
H A Dnxt_router.c746 msg->port_msg.reply_port); in nxt_router_conf_data_handler()
838 reply_port = nxt_runtime_port_find(task->thread->runtime, in nxt_router_app_restart_handler()
841 if (nxt_slow_path(reply_port == NULL)) { in nxt_router_app_restart_handler()
940 msg->port_msg.reply_port); in nxt_router_status_handler()
4032 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_req_headers_ack_handler()
5032 nxt_port_t *port, *reply_port; in nxt_router_app_prepare_request() local
5050 reply_port = task->thread->engine->port; in nxt_router_app_prepare_request()
5082 msg.pm.pid = reply_port->pid; in nxt_router_app_prepare_request()
5083 msg.pm.reply_port = reply_port->id; in nxt_router_app_prepare_request()
5624 nxt_port_t *port, *reply_port; in nxt_router_get_port_handler() local
[all …]
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
936 msg.reply_port = 0; in nxt_unit_ready()
1001 recv_msg.reply_port = port_msg->reply_port; in nxt_unit_process_msg()
1589 msg.reply_port = ctx_impl->read_port->id.id; in nxt_unit_send_req_headers_ack()
2637 m.msg.reply_port = 0; in nxt_unit_mmap_buf_send()
3286 msg.reply_port = 0; in nxt_unit_request_done()
3609 msg.reply_port = 0; in nxt_unit_send_oosm()
3893 msg.reply_port = 0; in nxt_unit_send_mmap()
4308 m.msg.reply_port = ctx_impl->read_port->id.id; in nxt_unit_get_mmap()
4377 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()