| /Zephyr-Core-3.4.0/subsys/rtio/ |
| D | rtio_executor.c | 21 static inline void rtio_iodev_submit(struct rtio_iodev_sqe *iodev_sqe) in rtio_iodev_submit() argument
23 if (FIELD_GET(RTIO_SQE_CANCELED, iodev_sqe->sqe.flags)) { in rtio_iodev_submit()
25 rtio_iodev_sqe_err(iodev_sqe, -ECANCELED); in rtio_iodev_submit()
28 iodev_sqe->sqe.iodev->api->submit(iodev_sqe); in rtio_iodev_submit()
34 static void rtio_executor_op(struct rtio_iodev_sqe *iodev_sqe) in rtio_executor_op() argument
36 const struct rtio_sqe *sqe = &iodev_sqe->sqe; in rtio_executor_op()
40 sqe->callback(iodev_sqe->r, sqe, sqe->arg0); in rtio_executor_op()
41 rtio_iodev_sqe_ok(iodev_sqe, 0); in rtio_executor_op()
44 rtio_iodev_sqe_err(iodev_sqe, -EINVAL); in rtio_executor_op()
60 struct rtio_iodev_sqe *iodev_sqe = CONTAINER_OF(node, struct rtio_iodev_sqe, q); in rtio_executor_submit() local
[all …]
|
| /Zephyr-Core-3.4.0/tests/subsys/rtio/rtio_api/src/ |
| D | rtio_iodev_test.h | 65 struct rtio_iodev_sqe *iodev_sqe = data->txn_curr; in rtio_iodev_timer_fn() local
68 if (iodev_sqe == last_iodev_sqe) { in rtio_iodev_timer_fn()
73 last_iodev_sqe = iodev_sqe; in rtio_iodev_timer_fn()
75 if (iodev_sqe->sqe.op == RTIO_OP_RX) { in rtio_iodev_timer_fn()
79 int rc = rtio_sqe_rx_buf(iodev_sqe, 16, 16, &buf, &buf_len); in rtio_iodev_timer_fn()
82 iodev_sqe = data->txn_head; in rtio_iodev_timer_fn()
85 rtio_iodev_sqe_err(iodev_sqe, rc); in rtio_iodev_timer_fn()
91 buf[i] = ((uint8_t *)iodev_sqe->sqe.userdata)[i]; in rtio_iodev_timer_fn()
95 if (iodev_sqe->sqe.flags & RTIO_SQE_TRANSACTION) { in rtio_iodev_timer_fn()
97 TC_PRINT("iodev_sqe %p marked transaction, next %p\n", iodev_sqe, data->txn_curr); in rtio_iodev_timer_fn()
[all …]
|
| /Zephyr-Core-3.4.0/samples/subsys/rtio/sensor_batch_processing/src/ |
| D | vnd_sensor.c | 55 struct rtio_iodev_sqe *iodev_sqe) in vnd_sensor_iodev_execute() argument
62 if (iodev_sqe->sqe.op == RTIO_OP_RX) { in vnd_sensor_iodev_execute()
63 result = rtio_sqe_rx_buf(iodev_sqe, config->sample_size, config->sample_size, &buf, in vnd_sensor_iodev_execute()
76 rtio_iodev_sqe_err(iodev_sqe, result); in vnd_sensor_iodev_execute()
78 rtio_iodev_sqe_ok(iodev_sqe, result); in vnd_sensor_iodev_execute()
82 static void vnd_sensor_iodev_submit(struct rtio_iodev_sqe *iodev_sqe) in vnd_sensor_iodev_submit() argument
84 struct vnd_sensor_data *data = (struct vnd_sensor_data *) iodev_sqe->sqe.iodev; in vnd_sensor_iodev_submit()
86 rtio_mpsc_push(&data->iodev.iodev_sq, &iodev_sqe->q); in vnd_sensor_iodev_submit()
95 struct rtio_iodev_sqe *iodev_sqe = CONTAINER_OF(node, struct rtio_iodev_sqe, q); in vnd_sensor_handle_int() local
97 vnd_sensor_iodev_execute(dev, iodev_sqe); in vnd_sensor_handle_int()
|
| /Zephyr-Core-3.4.0/include/zephyr/rtio/ |
| D | rtio.h | 433 void (*submit)(struct rtio_iodev_sqe *iodev_sqe);
620 struct rtio_iodev_sqe *iodev_sqe = CONTAINER_OF(node, struct rtio_iodev_sqe, q); in rtio_sqe_pool_alloc() local
624 return iodev_sqe; in rtio_sqe_pool_alloc()
627 static inline void rtio_sqe_pool_free(struct rtio_sqe_pool *pool, struct rtio_iodev_sqe *iodev_sqe) in rtio_sqe_pool_free() argument
629 rtio_mpsc_push(&pool->free_q, &iodev_sqe->q); in rtio_sqe_pool_free()
835 static inline struct rtio_iodev_sqe *rtio_txn_next(const struct rtio_iodev_sqe *iodev_sqe) in rtio_txn_next() argument
837 if (iodev_sqe->sqe.flags & RTIO_SQE_TRANSACTION) { in rtio_txn_next()
838 return iodev_sqe->next; in rtio_txn_next()
853 static inline struct rtio_iodev_sqe *rtio_chain_next(const struct rtio_iodev_sqe *iodev_sqe) in rtio_chain_next() argument
855 if (iodev_sqe->sqe.flags & RTIO_SQE_CHAINED) { in rtio_chain_next()
[all …]
|
| /Zephyr-Core-3.4.0/drivers/sensor/ |
| D | default_rtio_sensor.c | 15 static void sensor_submit_fallback(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe);
17 static void sensor_iodev_submit(struct rtio_iodev_sqe *iodev_sqe) in sensor_iodev_submit() argument
19 const struct sensor_read_config *cfg = iodev_sqe->sqe.iodev->data; in sensor_iodev_submit()
24 api->submit(dev, iodev_sqe); in sensor_iodev_submit()
26 sensor_submit_fallback(dev, iodev_sqe); in sensor_iodev_submit()
91 static void sensor_submit_fallback(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe) in sensor_submit_fallback() argument
93 const struct sensor_read_config *cfg = iodev_sqe->sqe.iodev->data; in sensor_submit_fallback()
105 rtio_iodev_sqe_err(iodev_sqe, rc); in sensor_submit_fallback()
110 rc = rtio_sqe_rx_buf(iodev_sqe, min_buf_len, min_buf_len, &buf, &buf_len); in sensor_submit_fallback()
113 rtio_iodev_sqe_err(iodev_sqe, rc); in sensor_submit_fallback()
[all …]
|
| /Zephyr-Core-3.4.0/drivers/i2c/ |
| D | i2c_sam_twihs_rtio.c | 65 struct rtio_iodev_sqe *iodev_sqe; member
220 if (!completion && data->iodev_sqe != NULL) { in i2c_sam_twihs_next()
228 data->iodev_sqe = NULL; in i2c_sam_twihs_next()
234 data->iodev_sqe = CONTAINER_OF(next, struct rtio_iodev_sqe, q); in i2c_sam_twihs_next()
235 data->sqe = data->iodev_sqe->sqe; in i2c_sam_twihs_next()
246 struct rtio_iodev_sqe *iodev_sqe = dev_data->iodev_sqe; in i2c_sam_twihs_complete() local
252 rtio_iodev_sqe_err(iodev_sqe, status); in i2c_sam_twihs_complete()
258 dev_data->sqe = rtio_spsc_next(iodev_sqe->r->sq, dev_data->sqe); in i2c_sam_twihs_complete()
261 rtio_iodev_sqe_ok(iodev_sqe, status); in i2c_sam_twihs_complete()
266 static void i2c_sam_twihs_submit(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe) in i2c_sam_twihs_submit() argument
[all …]
|
| /Zephyr-Core-3.4.0/include/zephyr/drivers/ |
| D | spi.h | 615 struct rtio_iodev_sqe *iodev_sqe);
1062 static inline void spi_iodev_submit(struct rtio_iodev_sqe *iodev_sqe) in spi_iodev_submit() argument
1064 const struct spi_dt_spec *dt_spec = iodev_sqe->sqe.iodev->data; in spi_iodev_submit()
1068 api->iodev_submit(dt_spec->bus, iodev_sqe); in spi_iodev_submit()
|
| D | i2c.h | 237 struct rtio_iodev_sqe *iodev_sqe);
926 static inline void i2c_iodev_submit(struct rtio_iodev_sqe *iodev_sqe) in i2c_iodev_submit() argument
928 const struct i2c_dt_spec *dt_spec = iodev_sqe->sqe->iodev->data; in i2c_iodev_submit()
932 api->iodev_submit(dt_spec->bus, iodev_sqe); in i2c_iodev_submit()
|
| /Zephyr-Core-3.4.0/drivers/spi/ |
| D | spi_sam.c | 737 struct rtio_iodev_sqe *iodev_sqe) in spi_sam_iodev_submit() argument
741 rtio_mpsc_push(&data->iodev.iodev_sq, &iodev_sqe->q); in spi_sam_iodev_submit()
|
| /Zephyr-Core-3.4.0/doc/services/rtio/ |
| D | index.rst | 166 int rc = rtio_sqe_rx_buff(iodev_sqe, MIN_BUF_LEN, DESIRED_BUF_LEN, &buf, &buf_len);
|
