18 	const struct rtio_sqe *sqe = &iodev_sqe->sqe;  in rtio_executor_op()  local
20 	switch (sqe->op) {  in rtio_executor_op()
22 		sqe->callback.callback(iodev_sqe->r, sqe, sqe->callback.arg0);  in rtio_executor_op()
40 	if (FIELD_GET(RTIO_SQE_CANCELED, iodev_sqe->sqe.flags)) {  in rtio_iodev_submit()
46 	if (iodev_sqe->sqe.iodev == NULL) {  in rtio_iodev_submit()
51 	iodev_sqe->sqe.iodev->api->submit(iodev_sqe);  in rtio_iodev_submit()
70 		if (iodev_sqe->sqe.flags  & RTIO_SQE_CANCELED) {  in rtio_executor_submit()
71 			iodev_sqe->sqe.flags |= cancel_no_response;  in rtio_executor_submit()
78 		while (curr->sqe.flags & (RTIO_SQE_TRANSACTION | RTIO_SQE_CHAINED)) {  in rtio_executor_submit()
80 			bool transaction = iodev_sqe->sqe.flags & RTIO_SQE_TRANSACTION;  in rtio_executor_submit()
81 			bool chained = iodev_sqe->sqe.flags & RTIO_SQE_CHAINED;  in rtio_executor_submit()
96 			if (curr->sqe.flags  & RTIO_SQE_CANCELED) {  in rtio_executor_submit()
97 				next->sqe.flags |= cancel_no_response;  in rtio_executor_submit()
128 	if (curr->sqe.op == RTIO_OP_RX && FIELD_GET(RTIO_SQE_MEMPOOL_BUFFER, curr->sqe.flags)) {  in rtio_executor_handle_multishot()
131 			LOG_DBG("Releasing memory @%p size=%u", (void *)curr->sqe.rx.buf,  in rtio_executor_handle_multishot()
132 				curr->sqe.rx.buf_len);  in rtio_executor_handle_multishot()
133 			rtio_release_buffer(r, curr->sqe.rx.buf, curr->sqe.rx.buf_len);  in rtio_executor_handle_multishot()
136 		curr->sqe.rx.buf = NULL;  in rtio_executor_handle_multishot()
137 		curr->sqe.rx.buf_len = 0;  in rtio_executor_handle_multishot()
148 	const bool is_multishot = FIELD_GET(RTIO_SQE_MULTISHOT, iodev_sqe->sqe.flags) == 1;  in rtio_executor_done()
149 	const bool is_canceled = FIELD_GET(RTIO_SQE_CANCELED, iodev_sqe->sqe.flags) == 1;  in rtio_executor_done()
156 		userdata = curr->sqe.userdata;  in rtio_executor_done()
157 		sqe_flags = curr->sqe.flags;  in rtio_executor_done()