Lines Matching refs:queue_fd

62     int queue_fd);
152 nxt_unit_port_t *port, int queue_fd);
429 int rc, queue_fd, shared_queue_fd; in nxt_unit_init() local
443 queue_fd = -1; in nxt_unit_init()
503 queue_fd = nxt_unit_shm_open(ctx, sizeof(nxt_port_queue_t)); in nxt_unit_init()
504 if (nxt_slow_path(queue_fd == -1)) { in nxt_unit_init()
509 PROT_READ | PROT_WRITE, MAP_SHARED, queue_fd, 0); in nxt_unit_init()
511 nxt_unit_alert(ctx, "mmap(%d) failed: %s (%d)", queue_fd, in nxt_unit_init()
557 rc = nxt_unit_ready(ctx, ready_port.out_fd, ready_stream, queue_fd); in nxt_unit_init()
565 nxt_unit_close(queue_fd); in nxt_unit_init()
575 if (queue_fd != -1) { in nxt_unit_init()
576 nxt_unit_close(queue_fd); in nxt_unit_init()
942 nxt_unit_ready(nxt_unit_ctx_t *ctx, int ready_fd, uint32_t stream, int queue_fd) in nxt_unit_ready() argument
948 int fds[2] = {queue_fd, -1}; in nxt_unit_ready()
5105 int rc, queue_fd; in nxt_unit_ctx_alloc() local
5129 queue_fd = -1; in nxt_unit_ctx_alloc()
5138 queue_fd = nxt_unit_shm_open(&new_ctx->ctx, sizeof(nxt_port_queue_t)); in nxt_unit_ctx_alloc()
5139 if (nxt_slow_path(queue_fd == -1)) { in nxt_unit_ctx_alloc()
5144 PROT_READ | PROT_WRITE, MAP_SHARED, queue_fd, 0); in nxt_unit_ctx_alloc()
5146 nxt_unit_alert(ctx, "mmap(%d) failed: %s (%d)", queue_fd, in nxt_unit_ctx_alloc()
5157 rc = nxt_unit_send_port(&new_ctx->ctx, lib->router_port, port, queue_fd); in nxt_unit_ctx_alloc()
5162 nxt_unit_close(queue_fd); in nxt_unit_ctx_alloc()
5168 if (queue_fd != -1) { in nxt_unit_ctx_alloc()
5169 nxt_unit_close(queue_fd); in nxt_unit_ctx_alloc()
5344 nxt_unit_port_t *port, int queue_fd) in nxt_unit_send_port() argument
5349 int fds[2] = { port->out_fd, queue_fd }; in nxt_unit_send_port()