Lines Matching refs:queue

157     nxt_unit_port_t *port, void *queue);
396 void *queue; member
1548 port_impl->queue = NULL; in nxt_unit_request_check_response_port()
5141 port_impl->queue = mem; in nxt_unit_ctx_alloc()
5405 if (port_impl->queue != NULL) { in nxt_unit_port_release()
5406 munmap(port_impl->queue, (port->id.id == NXT_UNIT_SHARED_PORT_ID) in nxt_unit_port_release()
5417 nxt_unit_add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, void *queue) in nxt_unit_add_port() argument
5436 port->in_fd, port->out_fd, queue); in nxt_unit_add_port()
5469 if (old_port_impl->queue == NULL) { in nxt_unit_add_port()
5470 old_port_impl->queue = queue; in nxt_unit_add_port()
5515 port->in_fd, port->out_fd, queue); in nxt_unit_add_port()
5554 new_port->queue = queue; in nxt_unit_add_port()
5901 if (port_impl->queue != NULL && (oob == NULL || oob->size == 0) in nxt_unit_port_send()
5904 rc = nxt_port_queue_send(port_impl->queue, buf, buf_size, &notify); in nxt_unit_port_send()
5943 if (port_impl->queue != NULL) { in nxt_unit_port_send()
5946 rc = nxt_port_queue_send(port_impl->queue, &msg.type, 1, &notify); in nxt_unit_port_send()
6162 nxt_app_queue_notification_received(port_impl->queue); in nxt_unit_shared_port_recv()
6246 rbuf->size = nxt_port_queue_recv(port_impl->queue, rbuf->buf); in nxt_unit_port_queue_recv()
6258 nxt_app_queue_t *queue; in nxt_unit_app_queue_recv() local
6268 queue = port_impl->queue; in nxt_unit_app_queue_recv()
6272 rbuf->size = nxt_app_queue_recv(queue, rbuf->buf, &cookie); in nxt_unit_app_queue_recv()
6279 if (nxt_app_queue_cancel(queue, cookie, port_msg->stream)) { in nxt_unit_app_queue_recv()