SQE items with this OP will take the specified amount of time (asynchronously) before completing. This allows to serve as an asynchronous delay in between SQE items (e.g: A sensor measurement requested, which requires 50-ms before having the result available). Signed-off-by: Luis Ubieda <luisf@croxel.com>
34 lines
996 B
C
34 lines
996 B
C
/*
|
|
* Copyright (c) 2025 Croxel Inc.
|
|
*
|
|
* SPDX-License-Identifier: Apache-2.0
|
|
*/
|
|
|
|
#include <zephyr/kernel.h>
|
|
#include <zephyr/rtio/rtio.h>
|
|
|
|
/** Required to access Timeout Queue APIs, which are used instead of the
|
|
* Timer APIs because of concerns on size on rtio_sqe (k_timer is more
|
|
* than double the size of _timeout). Users will have to instantiate a
|
|
* pool of SQE objects, thus its size directly impacts memory footprint
|
|
* of RTIO applications.
|
|
*/
|
|
#include <../kernel/include/timeout_q.h>
|
|
|
|
#include "rtio_sched.h"
|
|
|
|
static void rtio_sched_alarm_expired(struct _timeout *t)
|
|
{
|
|
struct rtio_sqe *sqe = CONTAINER_OF(t, struct rtio_sqe, delay.to);
|
|
struct rtio_iodev_sqe *iodev_sqe = CONTAINER_OF(sqe, struct rtio_iodev_sqe, sqe);
|
|
|
|
rtio_iodev_sqe_ok(iodev_sqe, 0);
|
|
}
|
|
|
|
void rtio_sched_alarm(struct rtio_iodev_sqe *iodev_sqe, k_timeout_t timeout)
|
|
{
|
|
struct rtio_sqe *sqe = &iodev_sqe->sqe;
|
|
|
|
z_init_timeout(&sqe->delay.to);
|
|
z_add_timeout(&sqe->delay.to, rtio_sched_alarm_expired, timeout);
|
|
}
|