Lines Matching refs:read_port

57     nxt_unit_port_t *router_port, nxt_unit_port_t *read_port,
295 nxt_unit_port_t *read_port; member
434 nxt_unit_port_t ready_port, router_port, read_port, shared_port; in nxt_unit_init() local
450 && init->read_port.id.pid != 0) in nxt_unit_init()
455 read_port = init->read_port; in nxt_unit_init()
462 nxt_unit_port_id_init(&read_port.id, read_port.id.pid, in nxt_unit_init()
463 read_port.id.id); in nxt_unit_init()
469 rc = nxt_unit_read_env(&ready_port, &router_port, &read_port, in nxt_unit_init()
486 lib->pid = read_port.id.pid; in nxt_unit_init()
519 rc = nxt_unit_fd_blocking(read_port.in_fd); in nxt_unit_init()
524 lib->main_ctx.read_port = nxt_unit_add_port(ctx, &read_port, mem); in nxt_unit_init()
525 if (nxt_slow_path(lib->main_ctx.read_port == NULL)) { in nxt_unit_init()
536 nxt_unit_port_id_init(&shared_port.id, read_port.id.pid, in nxt_unit_init()
718 ctx_impl->read_port = NULL; in nxt_unit_ctx_init()
845 nxt_unit_port_t *read_port, int *shared_port_fd, int *shared_queue_fd, in nxt_unit_read_env() argument
929 nxt_unit_port_id_init(&read_port->id, (pid_t) read_pid, read_id); in nxt_unit_read_env()
931 read_port->in_fd = read_in_fd; in nxt_unit_read_env()
932 read_port->out_fd = read_out_fd; in nxt_unit_read_env()
933 read_port->data = NULL; in nxt_unit_read_env()
1607 msg.reply_port = ctx_impl->read_port->id.id; in nxt_unit_send_req_headers_ack()
3660 res = nxt_unit_ctx_port_recv(ctx, ctx_impl->read_port, rbuf); in nxt_unit_wait_shm_ack()
4098 if (nxt_slow_path(ctx_impl->read_port == NULL in nxt_unit_awake_ctx()
4099 || ctx_impl->read_port->out_fd == -1)) in nxt_unit_awake_ctx()
4110 (void) nxt_unit_port_send(ctx, ctx_impl->read_port, in nxt_unit_awake_ctx()
4327 m.msg.reply_port = ctx_impl->read_port->id.id; in nxt_unit_get_mmap()
4622 return nxt_unit_ctx_port_recv(ctx, ctx_impl->read_port, rbuf); in nxt_unit_read_buf()
4625 port_impl = nxt_container_of(ctx_impl->read_port, nxt_unit_port_impl_t, in nxt_unit_read_buf()
4633 res = nxt_unit_port_queue_recv(ctx_impl->read_port, rbuf); in nxt_unit_read_buf()
4639 (int) ctx_impl->read_port->id.pid, in nxt_unit_read_buf()
4640 (int) ctx_impl->read_port->id.id, in nxt_unit_read_buf()
4645 (int) ctx_impl->read_port->id.pid, in nxt_unit_read_buf()
4646 (int) ctx_impl->read_port->id.id, in nxt_unit_read_buf()
4669 fds[0].fd = ctx_impl->read_port->in_fd; in nxt_unit_read_buf()
4696 res = nxt_unit_ctx_port_recv(ctx, ctx_impl->read_port, rbuf); in nxt_unit_read_buf()
4872 rc = nxt_unit_ctx_port_recv(ctx, ctx_impl->read_port, rbuf); in nxt_unit_run_ctx()
5137 new_ctx->read_port = port; in nxt_unit_ctx_alloc()
5237 if (nxt_fast_path(ctx_impl->read_port != NULL)) { in nxt_unit_ctx_free()
5238 nxt_unit_remove_port(lib, NULL, &ctx_impl->read_port->id); in nxt_unit_ctx_free()
5239 nxt_unit_port_release(ctx_impl->read_port); in nxt_unit_ctx_free()
5831 if (nxt_fast_path(ctx_impl->read_port != NULL)) { in nxt_unit_quit()
5832 nxt_unit_remove_port(lib, ctx, &ctx_impl->read_port->id); in nxt_unit_quit()
5851 || ctx_impl->read_port == NULL in nxt_unit_quit()
5852 || ctx_impl->read_port->out_fd == -1) in nxt_unit_quit()
5857 (void) nxt_unit_port_send(ctx, ctx_impl->read_port, in nxt_unit_quit()
5884 m.msg.reply_port = ctx_impl->read_port->id.id; in nxt_unit_get_port()
6309 (void) nxt_unit_port_send(ctx, lib->main_ctx.read_port, in nxt_unit_app_queue_recv()