diff --git a/subsys/rtio/rtio_executor_simple.c b/subsys/rtio/rtio_executor_simple.c index 926a63cdcf0..ace34db72b0 100644 --- a/subsys/rtio/rtio_executor_simple.c +++ b/subsys/rtio/rtio_executor_simple.c @@ -41,8 +41,10 @@ int rtio_simple_submit(struct rtio *r) */ void rtio_simple_ok(struct rtio *r, const struct rtio_sqe *sqe, int result) { - rtio_cqe_submit(r, result, sqe->userdata); + void *userdata = sqe->userdata; + rtio_spsc_release(r->sq); + rtio_cqe_submit(r, result, userdata); rtio_simple_submit(r); } @@ -52,18 +54,19 @@ void rtio_simple_ok(struct rtio *r, const struct rtio_sqe *sqe, int result) void rtio_simple_err(struct rtio *r, const struct rtio_sqe *sqe, int result) { struct rtio_sqe *nsqe; - bool chained; + void *userdata = sqe->userdata; + bool chained = sqe->flags & RTIO_SQE_CHAINED; - rtio_cqe_submit(r, result, sqe->userdata); - chained = sqe->flags & RTIO_SQE_CHAINED; rtio_spsc_release(r->sq); + rtio_cqe_submit(r, result, sqe->userdata); if (chained) { nsqe = rtio_spsc_consume(r->sq); while (nsqe != NULL && nsqe->flags & RTIO_SQE_CHAINED) { - rtio_cqe_submit(r, -ECANCELED, nsqe->userdata); + userdata = nsqe->userdata; rtio_spsc_release(r->sq); + rtio_cqe_submit(r, -ECANCELED, userdata); nsqe = rtio_spsc_consume(r->sq); }