regmap.h

Go to the documentation of this file.

/*
 * Copyright (c) 2025 STMicroelectronics
 *
 * SPDX-License-Identifier: Apache-2.0
 */

 
#ifndef ZEPHYR_INCLUDE_RTIO_REGMAP_H_
#define ZEPHYR_INCLUDE_RTIO_REGMAP_H_
 
#include <zephyr/rtio/rtio.h>
 
#ifdef __cplusplus
extern "C" {
#endif

struct rtio_regs {
        size_t rtio_regs_num;

        struct rtio_regs_list {
                uint8_t reg_addr;

                uint8_t *bufp;

                size_t len;
        } *rtio_regs_list; 
};

typedef enum {
        RTIO_BUS_I2C, 
        RTIO_BUS_SPI, 
        RTIO_BUS_I3C, 
} rtio_bus_type;

static inline bool rtio_is_spi(rtio_bus_type bus_type)
{
        return (bus_type == RTIO_BUS_SPI);
}

static inline bool rtio_is_i2c(rtio_bus_type bus_type)
{
        return (bus_type == RTIO_BUS_I2C);
}

static inline bool rtio_is_i3c(rtio_bus_type bus_type)
{
        return (bus_type == RTIO_BUS_I3C);
}

static inline void rtio_read_regs_async(struct rtio *r, struct rtio_iodev *iodev,
                                        rtio_bus_type bus_type, struct rtio_regs *regs,
                                        struct rtio_iodev_sqe *iodev_sqe, const struct device *dev,
                                        rtio_callback_t complete_op_cb)
{
        struct rtio_sqe *write_addr;
        struct rtio_sqe *read_reg;
        struct rtio_sqe *complete_op;
 
        for (uint8_t i = 0; i < regs->rtio_regs_num; i++) {
 
                write_addr = rtio_sqe_acquire(r);
                read_reg = rtio_sqe_acquire(r);
 
                if (write_addr == NULL || read_reg == NULL) {
                        rtio_iodev_sqe_err(iodev_sqe, -ENOMEM);
                        rtio_sqe_drop_all(r);
                        return;
                }
 
                rtio_sqe_prep_tiny_write(write_addr, iodev, RTIO_PRIO_NORM,
                                         &regs->rtio_regs_list[i].reg_addr, 1, NULL);
                write_addr->flags = RTIO_SQE_TRANSACTION;
 
                rtio_sqe_prep_read(read_reg, iodev, RTIO_PRIO_NORM, regs->rtio_regs_list[i].bufp,
                                   regs->rtio_regs_list[i].len, NULL);
                read_reg->flags = RTIO_SQE_CHAINED;
 
                switch (bus_type) {
                case RTIO_BUS_I2C:
                        read_reg->iodev_flags |= RTIO_IODEV_I2C_STOP | RTIO_IODEV_I2C_RESTART;
                        break;
                case RTIO_BUS_I3C:
                        read_reg->iodev_flags |= RTIO_IODEV_I3C_STOP | RTIO_IODEV_I3C_RESTART;
                        break;
                case RTIO_BUS_SPI:
                default:
                        break;
                }
        }
 
        complete_op = rtio_sqe_acquire(r);
        if (complete_op == NULL) {
                rtio_iodev_sqe_err(iodev_sqe, -ENOMEM);
                rtio_sqe_drop_all(r);
                return;
        }
 
        rtio_sqe_prep_callback_no_cqe(complete_op, complete_op_cb, (void *)dev, iodev_sqe);
 
        rtio_submit(r, 0);
}
 
#ifdef __cplusplus
}
#endif
 
#endif /* ZEPHYR_INCLUDE_RTIO_REGMAP_H_ */