Lines Matching refs:node
722 struct mpsc_node *node = mpsc_pop(&pool->free_q); in rtio_sqe_pool_alloc() local
724 if (node == NULL) { in rtio_sqe_pool_alloc()
728 struct rtio_iodev_sqe *iodev_sqe = CONTAINER_OF(node, struct rtio_iodev_sqe, q); in rtio_sqe_pool_alloc()
744 struct mpsc_node *node = mpsc_pop(&pool->free_q); in rtio_cqe_pool_alloc() local
746 if (node == NULL) { in rtio_cqe_pool_alloc()
750 struct rtio_cqe *cqe = CONTAINER_OF(node, struct rtio_cqe, q); in rtio_cqe_pool_alloc()
1023 struct mpsc_node *node = mpsc_pop(&r->sq); in rtio_sqe_drop_all() local
1025 while (node != NULL) { in rtio_sqe_drop_all()
1026 iodev_sqe = CONTAINER_OF(node, struct rtio_iodev_sqe, q); in rtio_sqe_drop_all()
1028 node = mpsc_pop(&r->sq); in rtio_sqe_drop_all()
1069 struct mpsc_node *node; in rtio_cqe_consume() local
1078 node = mpsc_pop(&r->cq); in rtio_cqe_consume()
1079 if (node == NULL) { in rtio_cqe_consume()
1082 cqe = CONTAINER_OF(node, struct rtio_cqe, q); in rtio_cqe_consume()
1099 struct mpsc_node *node; in rtio_cqe_consume_block() local
1105 node = mpsc_pop(&r->cq); in rtio_cqe_consume_block()
1106 while (node == NULL) { in rtio_cqe_consume_block()
1108 node = mpsc_pop(&r->cq); in rtio_cqe_consume_block()
1110 cqe = CONTAINER_OF(node, struct rtio_cqe, q); in rtio_cqe_consume_block()