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()
704 ctx_impl->read_port = NULL; in nxt_unit_ctx_init()
831 nxt_unit_port_t *read_port, int *shared_port_fd, int *shared_queue_fd, in nxt_unit_read_env() argument
915 nxt_unit_port_id_init(&read_port->id, (pid_t) read_pid, read_id); in nxt_unit_read_env()
917 read_port->in_fd = read_in_fd; in nxt_unit_read_env()
918 read_port->out_fd = read_out_fd; in nxt_unit_read_env()
919 read_port->data = NULL; in nxt_unit_read_env()
1593 msg.reply_port = ctx_impl->read_port->id.id; in nxt_unit_send_req_headers_ack()
3645 res = nxt_unit_ctx_port_recv(ctx, ctx_impl->read_port, rbuf); in nxt_unit_wait_shm_ack()
4083 if (nxt_slow_path(ctx_impl->read_port == NULL in nxt_unit_awake_ctx()
4084 || ctx_impl->read_port->out_fd == -1)) in nxt_unit_awake_ctx()
4095 (void) nxt_unit_port_send(ctx, ctx_impl->read_port, in nxt_unit_awake_ctx()
4312 m.msg.reply_port = ctx_impl->read_port->id.id; in nxt_unit_get_mmap()
4607 return nxt_unit_ctx_port_recv(ctx, ctx_impl->read_port, rbuf); in nxt_unit_read_buf()
4610 port_impl = nxt_container_of(ctx_impl->read_port, nxt_unit_port_impl_t, in nxt_unit_read_buf()
4618 res = nxt_unit_port_queue_recv(ctx_impl->read_port, rbuf); in nxt_unit_read_buf()
4624 (int) ctx_impl->read_port->id.pid, in nxt_unit_read_buf()
4625 (int) ctx_impl->read_port->id.id, in nxt_unit_read_buf()
4630 (int) ctx_impl->read_port->id.pid, in nxt_unit_read_buf()
4631 (int) ctx_impl->read_port->id.id, in nxt_unit_read_buf()
4654 fds[0].fd = ctx_impl->read_port->in_fd; in nxt_unit_read_buf()
4681 res = nxt_unit_ctx_port_recv(ctx, ctx_impl->read_port, rbuf); in nxt_unit_read_buf()
4857 rc = nxt_unit_ctx_port_recv(ctx, ctx_impl->read_port, rbuf); in nxt_unit_run_ctx()
5122 new_ctx->read_port = port; in nxt_unit_ctx_alloc()
5222 if (nxt_fast_path(ctx_impl->read_port != NULL)) { in nxt_unit_ctx_free()
5223 nxt_unit_remove_port(lib, NULL, &ctx_impl->read_port->id); in nxt_unit_ctx_free()
5224 nxt_unit_port_release(ctx_impl->read_port); in nxt_unit_ctx_free()
5816 if (nxt_fast_path(ctx_impl->read_port != NULL)) { in nxt_unit_quit()
5817 nxt_unit_remove_port(lib, ctx, &ctx_impl->read_port->id); in nxt_unit_quit()
5836 || ctx_impl->read_port == NULL in nxt_unit_quit()
5837 || ctx_impl->read_port->out_fd == -1) in nxt_unit_quit()
5842 (void) nxt_unit_port_send(ctx, ctx_impl->read_port, in nxt_unit_quit()
5869 m.msg.reply_port = ctx_impl->read_port->id.id; in nxt_unit_get_port()
6294 (void) nxt_unit_port_send(ctx, lib->main_ctx.read_port, in nxt_unit_app_queue_recv()