Home
last modified time | relevance | path

Searched refs:iodev_sqe (Results 1 – 25 of 62) sorted by relevance

123

/Zephyr-latest/subsys/rtio/
Drtio_executor.c16 static void rtio_executor_op(struct rtio_iodev_sqe *iodev_sqe) in rtio_executor_op() argument
18 const struct rtio_sqe *sqe = &iodev_sqe->sqe; in rtio_executor_op()
22 sqe->callback.callback(iodev_sqe->r, sqe, sqe->callback.arg0); in rtio_executor_op()
23 rtio_iodev_sqe_ok(iodev_sqe, 0); in rtio_executor_op()
26 rtio_iodev_sqe_err(iodev_sqe, -EINVAL); in rtio_executor_op()
38 static inline void rtio_iodev_submit(struct rtio_iodev_sqe *iodev_sqe) in rtio_iodev_submit() argument
40 if (FIELD_GET(RTIO_SQE_CANCELED, iodev_sqe->sqe.flags)) { in rtio_iodev_submit()
41 rtio_iodev_sqe_err(iodev_sqe, -ECANCELED); in rtio_iodev_submit()
46 if (iodev_sqe->sqe.iodev == NULL) { in rtio_iodev_submit()
47 rtio_executor_op(iodev_sqe); in rtio_iodev_submit()
[all …]
Drtio_workq.c37 struct rtio_iodev_sqe *iodev_sqe = req->iodev_sqe; in rtio_work_handler() local
39 req->handler(iodev_sqe); in rtio_work_handler()
62 struct rtio_iodev_sqe *iodev_sqe, in rtio_work_req_submit() argument
69 if (!iodev_sqe || !handler) { in rtio_work_req_submit()
75 struct rtio_sqe *sqe = &iodev_sqe->sqe; in rtio_work_req_submit()
79 req->iodev_sqe = iodev_sqe; in rtio_work_req_submit()
/Zephyr-latest/drivers/i3c/
Di3c_rtio_default.c16 static inline void i3c_msg_from_rx(const struct rtio_iodev_sqe *iodev_sqe, struct i3c_msg *msg) in i3c_msg_from_rx() argument
18 __ASSERT_NO_MSG(iodev_sqe->sqe.op == RTIO_OP_RX); in i3c_msg_from_rx()
20 msg->buf = iodev_sqe->sqe.rx.buf; in i3c_msg_from_rx()
21 msg->len = iodev_sqe->sqe.rx.buf_len; in i3c_msg_from_rx()
23 ((iodev_sqe->sqe.iodev_flags & RTIO_IODEV_I3C_STOP) ? I3C_MSG_STOP : 0) | in i3c_msg_from_rx()
24 ((iodev_sqe->sqe.iodev_flags & RTIO_IODEV_I3C_RESTART) ? I3C_MSG_RESTART : 0) | in i3c_msg_from_rx()
25 ((iodev_sqe->sqe.iodev_flags & RTIO_IODEV_I3C_HDR) ? I3C_MSG_HDR : 0) | in i3c_msg_from_rx()
26 ((iodev_sqe->sqe.iodev_flags & RTIO_IODEV_I3C_NBCH) ? I3C_MSG_NBCH : 0) | in i3c_msg_from_rx()
30 static inline void i3c_msg_from_tx(const struct rtio_iodev_sqe *iodev_sqe, struct i3c_msg *msg) in i3c_msg_from_tx() argument
32 __ASSERT_NO_MSG(iodev_sqe->sqe.op == RTIO_OP_TX); in i3c_msg_from_tx()
[all …]
/Zephyr-latest/drivers/i2c/
Di2c_rtio_default.c15 static inline void i2c_msg_from_rx(const struct rtio_iodev_sqe *iodev_sqe, struct i2c_msg *msg) in i2c_msg_from_rx() argument
17 __ASSERT_NO_MSG(iodev_sqe->sqe.op == RTIO_OP_RX); in i2c_msg_from_rx()
19 msg->buf = iodev_sqe->sqe.rx.buf; in i2c_msg_from_rx()
20 msg->len = iodev_sqe->sqe.rx.buf_len; in i2c_msg_from_rx()
22 ((iodev_sqe->sqe.iodev_flags & RTIO_IODEV_I2C_STOP) ? I2C_MSG_STOP : 0) | in i2c_msg_from_rx()
23 ((iodev_sqe->sqe.iodev_flags & RTIO_IODEV_I2C_RESTART) ? I2C_MSG_RESTART : 0) | in i2c_msg_from_rx()
24 ((iodev_sqe->sqe.iodev_flags & RTIO_IODEV_I2C_10_BITS) ? I2C_MSG_ADDR_10_BITS : 0) | in i2c_msg_from_rx()
28 static inline void i2c_msg_from_tx(const struct rtio_iodev_sqe *iodev_sqe, struct i2c_msg *msg) in i2c_msg_from_tx() argument
30 __ASSERT_NO_MSG(iodev_sqe->sqe.op == RTIO_OP_TX); in i2c_msg_from_tx()
32 msg->buf = (uint8_t *)iodev_sqe->sqe.tx.buf; in i2c_msg_from_tx()
[all …]
/Zephyr-latest/drivers/sensor/adi/adxl345/
Dadxl345_rtio.c15 static void adxl345_submit_fetch(struct rtio_iodev_sqe *iodev_sqe) in adxl345_submit_fetch() argument
18 (const struct sensor_read_config *) iodev_sqe->sqe.iodev->data; in adxl345_submit_fetch()
25 rc = rtio_sqe_rx_buf(iodev_sqe, min_buffer_len, min_buffer_len, &buffer, &buffer_len); in adxl345_submit_fetch()
28 rtio_iodev_sqe_err(iodev_sqe, rc); in adxl345_submit_fetch()
37 rtio_iodev_sqe_err(iodev_sqe, rc); in adxl345_submit_fetch()
41 rtio_iodev_sqe_ok(iodev_sqe, 0); in adxl345_submit_fetch()
44 void adxl345_submit(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe) in adxl345_submit() argument
47 (const struct sensor_read_config *) iodev_sqe->sqe.iodev->data; in adxl345_submit()
54 rtio_work_req_submit(req, iodev_sqe, adxl345_submit_fetch); in adxl345_submit()
56 adxl345_submit_stream(dev, iodev_sqe); in adxl345_submit()
[all …]
/Zephyr-latest/drivers/sensor/adi/adxl362/
Dadxl362_rtio.c15 static void adxl362_submit_fetch(struct rtio_iodev_sqe *iodev_sqe) in adxl362_submit_fetch() argument
18 (const struct sensor_read_config *) iodev_sqe->sqe.iodev->data; in adxl362_submit_fetch()
25 rc = rtio_sqe_rx_buf(iodev_sqe, min_buffer_len, min_buffer_len, &buffer, &buffer_len); in adxl362_submit_fetch()
28 rtio_iodev_sqe_err(iodev_sqe, rc); in adxl362_submit_fetch()
37 rtio_iodev_sqe_err(iodev_sqe, rc); in adxl362_submit_fetch()
41 rtio_iodev_sqe_ok(iodev_sqe, 0); in adxl362_submit_fetch()
44 void adxl362_submit(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe) in adxl362_submit() argument
47 (const struct sensor_read_config *) iodev_sqe->sqe.iodev->data; in adxl362_submit()
54 rtio_work_req_submit(req, iodev_sqe, adxl362_submit_fetch); in adxl362_submit()
56 adxl362_submit_stream(dev, iodev_sqe); in adxl362_submit()
[all …]
/Zephyr-latest/drivers/sensor/adi/adxl372/
Dadxl372_rtio.c15 static void adxl372_submit_fetch(struct rtio_iodev_sqe *iodev_sqe) in adxl372_submit_fetch() argument
18 (const struct sensor_read_config *)iodev_sqe->sqe.iodev->data; in adxl372_submit_fetch()
27 rc = rtio_sqe_rx_buf(iodev_sqe, min_buffer_len, min_buffer_len, &buffer, &buffer_len); in adxl372_submit_fetch()
30 rtio_iodev_sqe_err(iodev_sqe, rc); in adxl372_submit_fetch()
39 rtio_iodev_sqe_err(iodev_sqe, rc); in adxl372_submit_fetch()
43 rtio_iodev_sqe_ok(iodev_sqe, 0); in adxl372_submit_fetch()
46 void adxl372_submit(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe) in adxl372_submit() argument
49 (const struct sensor_read_config *)iodev_sqe->sqe.iodev->data; in adxl372_submit()
56 rtio_work_req_submit(req, iodev_sqe, adxl372_submit_fetch); in adxl372_submit()
58 adxl372_submit_stream(dev, iodev_sqe); in adxl372_submit()
[all …]
/Zephyr-latest/drivers/sensor/adi/adxl367/
Dadxl367_rtio.c15 static void adxl367_submit_fetch(struct rtio_iodev_sqe *iodev_sqe) in adxl367_submit_fetch() argument
18 (const struct sensor_read_config *) iodev_sqe->sqe.iodev->data; in adxl367_submit_fetch()
26 rc = rtio_sqe_rx_buf(iodev_sqe, min_buffer_len, min_buffer_len, &buffer, &buffer_len); in adxl367_submit_fetch()
29 rtio_iodev_sqe_err(iodev_sqe, rc); in adxl367_submit_fetch()
42 rtio_iodev_sqe_err(iodev_sqe, rc); in adxl367_submit_fetch()
51 rtio_iodev_sqe_err(iodev_sqe, rc); in adxl367_submit_fetch()
55 rtio_iodev_sqe_ok(iodev_sqe, 0); in adxl367_submit_fetch()
58 void adxl367_submit(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe) in adxl367_submit() argument
61 (const struct sensor_read_config *) iodev_sqe->sqe.iodev->data; in adxl367_submit()
68 rtio_work_req_submit(req, iodev_sqe, adxl367_submit_fetch); in adxl367_submit()
[all …]
/Zephyr-latest/drivers/sensor/tdk/icm42688/
Dicm42688_rtio.c48 static void icm42688_submit_one_shot(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe) in icm42688_submit_one_shot() argument
50 const struct sensor_read_config *cfg = iodev_sqe->sqe.iodev->data; in icm42688_submit_one_shot()
60 rc = rtio_sqe_rx_buf(iodev_sqe, min_buf_len, min_buf_len, &buf, &buf_len); in icm42688_submit_one_shot()
63 rtio_iodev_sqe_err(iodev_sqe, rc); in icm42688_submit_one_shot()
72 rtio_iodev_sqe_err(iodev_sqe, rc); in icm42688_submit_one_shot()
80 rtio_iodev_sqe_err(iodev_sqe, rc); in icm42688_submit_one_shot()
84 rtio_iodev_sqe_ok(iodev_sqe, 0); in icm42688_submit_one_shot()
87 void icm42688_submit_sync(struct rtio_iodev_sqe *iodev_sqe) in icm42688_submit_sync() argument
89 const struct sensor_read_config *cfg = iodev_sqe->sqe.iodev->data; in icm42688_submit_sync()
93 icm42688_submit_one_shot(dev, iodev_sqe); in icm42688_submit_sync()
[all …]
Dicm42688_rtio.h13 void icm42688_submit(const struct device *sensor, struct rtio_iodev_sqe *iodev_sqe);
15 void icm42688_submit_stream(const struct device *sensor, struct rtio_iodev_sqe *iodev_sqe);
/Zephyr-latest/drivers/sensor/bosch/bme280/
Dbme280_async.c16 void bme280_submit_sync(struct rtio_iodev_sqe *iodev_sqe) in bme280_submit_sync() argument
24 const struct sensor_read_config *cfg = iodev_sqe->sqe.iodev->data; in bme280_submit_sync()
29 rc = rtio_sqe_rx_buf(iodev_sqe, min_buf_len, min_buf_len, &buf, &buf_len); in bme280_submit_sync()
32 rtio_iodev_sqe_err(iodev_sqe, rc); in bme280_submit_sync()
39 rtio_iodev_sqe_err(iodev_sqe, rc); in bme280_submit_sync()
77 rtio_iodev_sqe_err(iodev_sqe, rc); in bme280_submit_sync()
81 rtio_iodev_sqe_ok(iodev_sqe, 0); in bme280_submit_sync()
84 void bme280_submit(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe) in bme280_submit() argument
91 rtio_iodev_sqe_err(iodev_sqe, -ENOMEM); in bme280_submit()
95 rtio_work_req_submit(req, iodev_sqe, bme280_submit_sync); in bme280_submit()
/Zephyr-latest/drivers/sensor/st/lsm6dsv16x/
Dlsm6dsv16x_rtio.c19 static void lsm6dsv16x_submit_sample(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe) in lsm6dsv16x_submit_sample() argument
21 const struct sensor_read_config *cfg = iodev_sqe->sqe.iodev->data; in lsm6dsv16x_submit_sample()
36 rc = rtio_sqe_rx_buf(iodev_sqe, min_buf_len, min_buf_len, &buf, &buf_len); in lsm6dsv16x_submit_sample()
120 rtio_iodev_sqe_err(iodev_sqe, rc); in lsm6dsv16x_submit_sample()
129 rtio_iodev_sqe_ok(iodev_sqe, 0); in lsm6dsv16x_submit_sample()
135 rtio_iodev_sqe_err(iodev_sqe, rc); in lsm6dsv16x_submit_sample()
140 void lsm6dsv16x_submit_sync(struct rtio_iodev_sqe *iodev_sqe) in lsm6dsv16x_submit_sync() argument
142 const struct sensor_read_config *cfg = iodev_sqe->sqe.iodev->data; in lsm6dsv16x_submit_sync()
146 lsm6dsv16x_submit_sample(dev, iodev_sqe); in lsm6dsv16x_submit_sync()
148 lsm6dsv16x_submit_stream(dev, iodev_sqe); in lsm6dsv16x_submit_sync()
[all …]
Dlsm6dsv16x_rtio.h15 void lsm6dsv16x_submit(const struct device *sensor, struct rtio_iodev_sqe *iodev_sqe);
17 void lsm6dsv16x_submit_stream(const struct device *sensor, struct rtio_iodev_sqe *iodev_sqe);
/Zephyr-latest/drivers/sensor/memsic/mmc56x3/
Dmmc56x3_async.c14 void mmc56x3_submit_sync(struct rtio_iodev_sqe *iodev_sqe) in mmc56x3_submit_sync() argument
22 const struct sensor_read_config *cfg = iodev_sqe->sqe.iodev->data; in mmc56x3_submit_sync()
27 rc = rtio_sqe_rx_buf(iodev_sqe, min_buf_len, min_buf_len, &buf, &buf_len); in mmc56x3_submit_sync()
30 rtio_iodev_sqe_err(iodev_sqe, rc); in mmc56x3_submit_sync()
37 rtio_iodev_sqe_err(iodev_sqe, rc); in mmc56x3_submit_sync()
85 rtio_iodev_sqe_err(iodev_sqe, rc); in mmc56x3_submit_sync()
89 rtio_iodev_sqe_ok(iodev_sqe, 0); in mmc56x3_submit_sync()
92 void mmc56x3_submit(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe) in mmc56x3_submit() argument
99 rtio_iodev_sqe_err(iodev_sqe, -ENOMEM); in mmc56x3_submit()
103 rtio_work_req_submit(req, iodev_sqe, mmc56x3_submit_sync); in mmc56x3_submit()
/Zephyr-latest/drivers/sensor/tdk/icm45686/
Dicm45686_stream.c98 struct rtio_iodev_sqe *iodev_sqe = data->stream.iodev_sqe; in icm45686_complete_result() local
102 rtio_iodev_sqe_ok(iodev_sqe, 0); in icm45686_complete_result()
111 const struct sensor_read_config *read_cfg = data->stream.iodev_sqe->sqe.iodev->data; in icm45686_handle_event_actions()
137 err = rtio_sqe_rx_buf(data->stream.iodev_sqe, in icm45686_handle_event_actions()
149 struct rtio_iodev_sqe *iodev_sqe = data->stream.iodev_sqe; in icm45686_handle_event_actions() local
153 data->stream.iodev_sqe = NULL; in icm45686_handle_event_actions()
154 rtio_iodev_sqe_err(iodev_sqe, err); in icm45686_handle_event_actions()
174 struct rtio_iodev_sqe *iodev_sqe = data->stream.iodev_sqe; in icm45686_handle_event_actions() local
178 data->stream.iodev_sqe = NULL; in icm45686_handle_event_actions()
179 rtio_iodev_sqe_err(iodev_sqe, -ENOMEM); in icm45686_handle_event_actions()
[all …]
/Zephyr-latest/drivers/sensor/pixart/paa3905/
Dpaa3905_stream.c24 static void paa3905_chip_recovery_handler(struct rtio_iodev_sqe *iodev_sqe) in paa3905_chip_recovery_handler() argument
26 const struct sensor_read_config *cfg = iodev_sqe->sqe.iodev->data; in paa3905_chip_recovery_handler()
33 rtio_iodev_sqe_err(iodev_sqe, err); in paa3905_chip_recovery_handler()
35 rtio_iodev_sqe_ok(iodev_sqe, 0); in paa3905_chip_recovery_handler()
55 struct rtio_iodev_sqe *iodev_sqe = data->stream.iodev_sqe; in paa3905_complete_result() local
85 rtio_iodev_sqe_err(iodev_sqe, -ENOMEM); in paa3905_complete_result()
89 rtio_work_req_submit(req, iodev_sqe, paa3905_chip_recovery_handler); in paa3905_complete_result()
91 rtio_iodev_sqe_ok(iodev_sqe, 0); in paa3905_complete_result()
110 CHECKIF(!data->stream.iodev_sqe) { in paa3905_stream_get_data()
119 err = rtio_sqe_rx_buf(data->stream.iodev_sqe, in paa3905_stream_get_data()
[all …]
Dpaa3905.c32 struct rtio_iodev_sqe *iodev_sqe = (struct rtio_iodev_sqe *)sqe->userdata; in paa3905_complete_result() local
45 rtio_iodev_sqe_err(iodev_sqe, err); in paa3905_complete_result()
47 rtio_iodev_sqe_ok(iodev_sqe, 0); in paa3905_complete_result()
53 static void paa3905_submit_one_shot(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe) in paa3905_submit_one_shot() argument
55 const struct sensor_read_config *cfg = iodev_sqe->sqe.iodev->data; in paa3905_submit_one_shot()
65 err = rtio_sqe_rx_buf(iodev_sqe, min_buf_len, min_buf_len, &buf, &buf_len); in paa3905_submit_one_shot()
68 rtio_iodev_sqe_err(iodev_sqe, err); in paa3905_submit_one_shot()
77 rtio_iodev_sqe_err(iodev_sqe, err); in paa3905_submit_one_shot()
87 rtio_iodev_sqe_err(iodev_sqe, -ENOMEM); in paa3905_submit_one_shot()
112 iodev_sqe); in paa3905_submit_one_shot()
[all …]
/Zephyr-latest/drivers/sensor/asahi_kasei/akm09918c/
Dakm09918c_async.c37 void akm09918c_submit(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe) in akm09918c_submit() argument
39 const struct sensor_read_config *cfg = iodev_sqe->sqe.iodev->data; in akm09918c_submit()
55 rtio_iodev_sqe_err(iodev_sqe, -ENOTSUP); in akm09918c_submit()
64 rtio_sqe_prep_callback_no_cqe(cb_sqe, akm09918_after_start_cb, (void *)iodev_sqe, NULL); in akm09918c_submit()
70 rtio_iodev_sqe_err(iodev_sqe, -ENOMEM); in akm09918c_submit()
80 struct rtio_iodev_sqe *iodev_sqe = (struct rtio_iodev_sqe *)arg0; in akm09918_after_start_cb() local
87 rtio_iodev_sqe_err(iodev_sqe, rc); in akm09918_after_start_cb()
93 data->work_ctx.iodev_sqe = iodev_sqe; in akm09918_after_start_cb()
97 rtio_iodev_sqe_err(iodev_sqe, rc); in akm09918_after_start_cb()
105 rtio_iodev_sqe_err(iodev_sqe, -EBUSY); in akm09918_after_start_cb()
[all …]
/Zephyr-latest/drivers/sensor/melexis/mlx90394/
Dmlx90394_async.c28 data->work_ctx.iodev_sqe->sqe.iodev->data; in mlx90394_async_fetch()
36 rtio_iodev_sqe_err(data->work_ctx.iodev_sqe, rc); in mlx90394_async_fetch()
40 rc = rtio_sqe_rx_buf(data->work_ctx.iodev_sqe, buf_len, buf_len, &buf, &buf_len); in mlx90394_async_fetch()
43 rtio_iodev_sqe_err(data->work_ctx.iodev_sqe, rc); in mlx90394_async_fetch()
90 rtio_iodev_sqe_err(data->work_ctx.iodev_sqe, -ENOTSUP); in mlx90394_async_fetch()
94 rtio_iodev_sqe_ok(data->work_ctx.iodev_sqe, 0); in mlx90394_async_fetch()
97 void mlx90394_submit(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe) in mlx90394_submit() argument
100 const struct sensor_read_config *cfg = iodev_sqe->sqe.iodev->data; in mlx90394_submit()
107 rtio_iodev_sqe_err(iodev_sqe, rc); in mlx90394_submit()
114 rtio_iodev_sqe_err(iodev_sqe, rc); in mlx90394_submit()
[all …]
/Zephyr-latest/samples/subsys/rtio/sensor_batch_processing/src/
Dvnd_sensor.c56 struct rtio_iodev_sqe *iodev_sqe) in vnd_sensor_iodev_execute() argument
63 if (iodev_sqe->sqe.op == RTIO_OP_RX) { in vnd_sensor_iodev_execute()
64 result = rtio_sqe_rx_buf(iodev_sqe, config->sample_size, config->sample_size, &buf, in vnd_sensor_iodev_execute()
77 rtio_iodev_sqe_err(iodev_sqe, result); in vnd_sensor_iodev_execute()
79 rtio_iodev_sqe_ok(iodev_sqe, result); in vnd_sensor_iodev_execute()
83 static void vnd_sensor_iodev_submit(struct rtio_iodev_sqe *iodev_sqe) in vnd_sensor_iodev_submit() argument
85 struct vnd_sensor_data *data = (struct vnd_sensor_data *) iodev_sqe->sqe.iodev; in vnd_sensor_iodev_submit()
87 mpsc_push(&data->io_q, &iodev_sqe->q); in vnd_sensor_iodev_submit()
96 struct rtio_iodev_sqe *iodev_sqe = CONTAINER_OF(node, struct rtio_iodev_sqe, q); in vnd_sensor_handle_int() local
98 vnd_sensor_iodev_execute(dev, iodev_sqe); in vnd_sensor_handle_int()
/Zephyr-latest/include/zephyr/rtio/
Dwork.h24 typedef void (*rtio_work_submit_t)(struct rtio_iodev_sqe *iodev_sqe);
39 struct rtio_iodev_sqe *iodev_sqe; member
66 struct rtio_iodev_sqe *iodev_sqe,
Drtio.h511 void (*submit)(struct rtio_iodev_sqe *iodev_sqe);
728 struct rtio_iodev_sqe *iodev_sqe = CONTAINER_OF(node, struct rtio_iodev_sqe, q); in rtio_sqe_pool_alloc() local
732 return iodev_sqe; in rtio_sqe_pool_alloc()
735 static inline void rtio_sqe_pool_free(struct rtio_sqe_pool *pool, struct rtio_iodev_sqe *iodev_sqe) in rtio_sqe_pool_free() argument
737 mpsc_push(&pool->free_q, &iodev_sqe->q); in rtio_sqe_pool_free()
954 static inline struct rtio_iodev_sqe *rtio_txn_next(const struct rtio_iodev_sqe *iodev_sqe) in rtio_txn_next() argument
956 if (iodev_sqe->sqe.flags & RTIO_SQE_TRANSACTION) { in rtio_txn_next()
957 return iodev_sqe->next; in rtio_txn_next()
972 static inline struct rtio_iodev_sqe *rtio_chain_next(const struct rtio_iodev_sqe *iodev_sqe) in rtio_chain_next() argument
974 if (iodev_sqe->sqe.flags & RTIO_SQE_CHAINED) { in rtio_chain_next()
[all …]
/Zephyr-latest/tests/subsys/rtio/rtio_api/src/
Drtio_iodev_test.h82 struct rtio_iodev_sqe *iodev_sqe = data->txn_curr; in rtio_iodev_timer_fn() local
87 switch (iodev_sqe->sqe.op) { in rtio_iodev_timer_fn()
92 rc = rtio_sqe_rx_buf(iodev_sqe, 16, 16, &buf, &buf_len); in rtio_iodev_timer_fn()
98 memcpy(buf, ((uint8_t *)iodev_sqe->sqe.userdata), 16); in rtio_iodev_timer_fn()
106 static void rtio_iodev_test_submit(struct rtio_iodev_sqe *iodev_sqe) in rtio_iodev_test_submit() argument
108 struct rtio_iodev *iodev = (struct rtio_iodev *)iodev_sqe->sqe.iodev; in rtio_iodev_test_submit()
114 mpsc_push(&data->io_q, &iodev_sqe->q); in rtio_iodev_test_submit()
/Zephyr-latest/drivers/sensor/maxim/ds3231/
Dds3231.c107 void sensor_ds3231_submit_sync(struct rtio_iodev_sqe *iodev_sqe) in sensor_ds3231_submit_sync() argument
114 const struct sensor_read_config *cfg = iodev_sqe->sqe.iodev->data; in sensor_ds3231_submit_sync()
118 rc = rtio_sqe_rx_buf(iodev_sqe, min_buf_len, min_buf_len, &buf, &buf_len); in sensor_ds3231_submit_sync()
121 rtio_iodev_sqe_err(iodev_sqe, rc); in sensor_ds3231_submit_sync()
138 rtio_iodev_sqe_err(iodev_sqe, rc); in sensor_ds3231_submit_sync()
144 rtio_iodev_sqe_ok(iodev_sqe, 0); in sensor_ds3231_submit_sync()
147 void sensor_ds3231_submit(const struct device *dev, struct rtio_iodev_sqe *iodev_sqe) in sensor_ds3231_submit() argument
154 rtio_iodev_sqe_err(iodev_sqe, -ENOMEM); in sensor_ds3231_submit()
162 rtio_work_req_submit(req, iodev_sqe, sensor_ds3231_submit_sync); in sensor_ds3231_submit()
/Zephyr-latest/subsys/sensing/
Dsensing_sensor.c16 static void sensing_iodev_submit(struct rtio_iodev_sqe *iodev_sqe) in sensing_iodev_submit() argument
18 struct sensing_sensor *sensor = (struct sensing_sensor *)iodev_sqe->sqe.userdata; in sensing_iodev_submit()
23 api->submit(dev, iodev_sqe); in sensing_iodev_submit()
26 rtio_iodev_sqe_err(iodev_sqe, -ENOTSUP); in sensing_iodev_submit()

123