Lines Matching refs:shared_port

368     nxt_unit_port_t          *shared_port;  member
434 nxt_unit_port_t ready_port, router_port, read_port, shared_port; in nxt_unit_init() local
445 shared_port.out_fd = -1; in nxt_unit_init()
446 shared_port.data = NULL; in nxt_unit_init()
465 shared_port.in_fd = init->shared_port_fd; in nxt_unit_init()
470 &shared_port.in_fd, &shared_queue_fd, in nxt_unit_init()
536 nxt_unit_port_id_init(&shared_port.id, read_port.id.pid, in nxt_unit_init()
550 lib->shared_port = nxt_unit_add_port(ctx, &shared_port, mem); in nxt_unit_init()
551 if (nxt_slow_path(lib->shared_port == NULL)) { in nxt_unit_init()
625 lib->shared_port = NULL; in nxt_unit_create()
773 if (nxt_fast_path(lib->shared_port != NULL)) { in nxt_unit_lib_release()
774 nxt_unit_port_release(lib->shared_port); in nxt_unit_lib_release()
1261 lib->callbacks.add_port(ctx, lib->shared_port); in nxt_unit_ctx_ready()
4640 res = nxt_unit_app_queue_recv(ctx, lib->shared_port, rbuf); in nxt_unit_read_buf()
4645 fds[1].fd = lib->shared_port->in_fd; in nxt_unit_read_buf()
4690 res = nxt_unit_shared_port_recv(ctx, lib->shared_port, rbuf); in nxt_unit_read_buf()
4959 rc = nxt_unit_shared_port_recv(ctx, lib->shared_port, rbuf); in nxt_unit_run_shared()
5004 rc = nxt_unit_app_queue_recv(ctx, lib->shared_port, rbuf); in nxt_unit_dequeue_request()
5044 if (port == lib->shared_port && !nxt_unit_chk_ready(ctx)) { in nxt_unit_process_port_msg_impl()
5053 if (port == lib->shared_port) { in nxt_unit_process_port_msg_impl()
5773 cb->remove_port(&lib->unit, ctx, lib->shared_port); in nxt_unit_quit()