Lines Matching refs:router_port

57     nxt_unit_port_t *router_port, nxt_unit_port_t *read_port,
367 nxt_unit_port_t *router_port; member
434 nxt_unit_port_t ready_port, router_port, read_port, shared_port; in nxt_unit_init() local
454 router_port = init->router_port; in nxt_unit_init()
460 nxt_unit_port_id_init(&router_port.id, router_port.id.pid, in nxt_unit_init()
461 router_port.id.id); in nxt_unit_init()
469 rc = nxt_unit_read_env(&ready_port, &router_port, &read_port, in nxt_unit_init()
491 rc = nxt_unit_fd_blocking(router_port.out_fd); in nxt_unit_init()
496 lib->router_port = nxt_unit_add_port(ctx, &router_port, NULL); in nxt_unit_init()
497 if (nxt_slow_path(lib->router_port == NULL)) { in nxt_unit_init()
624 lib->router_port = NULL; in nxt_unit_create()
769 if (nxt_fast_path(lib->router_port != NULL)) { in nxt_unit_lib_release()
770 nxt_unit_port_release(lib->router_port); in nxt_unit_lib_release()
830 nxt_unit_read_env(nxt_unit_port_t *ready_port, nxt_unit_port_t *router_port, in nxt_unit_read_env() argument
909 nxt_unit_port_id_init(&router_port->id, (pid_t) router_pid, router_id); in nxt_unit_read_env()
911 router_port->in_fd = -1; in nxt_unit_read_env()
912 router_port->out_fd = router_fd; in nxt_unit_read_env()
913 router_port->data = NULL; in nxt_unit_read_env()
3620 res = nxt_unit_port_send(ctx, lib->router_port, &msg, sizeof(msg), NULL); in nxt_unit_send_oosm()
4319 res = nxt_unit_port_send(ctx, lib->router_port, &m, sizeof(m), NULL); in nxt_unit_get_mmap()
4388 res = nxt_unit_port_send(ctx, lib->router_port, &msg, sizeof(msg), NULL); in nxt_unit_send_shm_ack()
5143 rc = nxt_unit_send_port(&new_ctx->ctx, lib->router_port, port, queue_fd); in nxt_unit_ctx_alloc()
5878 res = nxt_unit_port_send(ctx, lib->router_port, &m, sizeof(m), NULL); in nxt_unit_get_port()