Home
last modified time | relevance | path

Searched refs:reply_port (Results 1 – 7 of 7) sorted by last modified time

/unit/src/
H A Dnxt_router.c742 msg->port_msg.reply_port); in nxt_router_conf_data_handler()
834 reply_port = nxt_runtime_port_find(task->thread->runtime, in nxt_router_app_restart_handler()
837 if (nxt_slow_path(reply_port == NULL)) { in nxt_router_app_restart_handler()
3950 msg->port_msg.pid, 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()
5479 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
[all …]
H A Dnxt_unit.c223 nxt_port_id_t reply_port; member
940 msg.reply_port = 0; in nxt_unit_ready()
1005 recv_msg.reply_port = port_msg->reply_port; in nxt_unit_process_msg()
1593 msg.reply_port = ctx_impl->read_port->id.id; in nxt_unit_send_req_headers_ack()
2641 m.msg.reply_port = 0; in nxt_unit_mmap_buf_send()
3290 msg.reply_port = 0; in nxt_unit_request_done()
3613 msg.reply_port = 0; in nxt_unit_send_oosm()
3897 msg.reply_port = 0; in nxt_unit_send_mmap()
4312 m.msg.reply_port = ctx_impl->read_port->id.id; in nxt_unit_get_mmap()
4381 msg.reply_port = 0; in nxt_unit_send_shm_ack()
[all …]
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_port.h162 nxt_port_id_t reply_port; member
324 nxt_port_id_t reply_port, nxt_buf_t *b);
328 nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_port_id_t reply_port, in nxt_port_socket_write() argument
331 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()
1303 msg->port_msg.reply_port); in nxt_main_port_modules_handler()
1591 msg->port_msg.reply_port); in nxt_main_port_access_log_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_application.c653 msg->port_msg.reply_port); in nxt_proto_start_process_handler()