| /Zephyr-latest/subsys/rtio/ |
| D | rtio_handlers.c | 20 static inline bool rtio_vrfy_sqe(struct rtio_sqe *sqe) in rtio_vrfy_sqe() argument 22 if (sqe->iodev != NULL && K_SYSCALL_OBJ(sqe->iodev, K_OBJ_RTIO_IODEV)) { in rtio_vrfy_sqe() 28 switch (sqe->op) { in rtio_vrfy_sqe() 32 valid_sqe &= K_SYSCALL_MEMORY(sqe->tx.buf, sqe->tx.buf_len, false); in rtio_vrfy_sqe() 35 if ((sqe->flags & RTIO_SQE_MEMPOOL_BUFFER) == 0) { in rtio_vrfy_sqe() 36 valid_sqe &= K_SYSCALL_MEMORY(sqe->rx.buf, sqe->rx.buf_len, true); in rtio_vrfy_sqe() 42 valid_sqe &= K_SYSCALL_MEMORY(sqe->txrx.tx_buf, sqe->txrx.buf_len, true); in rtio_vrfy_sqe() 43 valid_sqe &= K_SYSCALL_MEMORY(sqe->txrx.rx_buf, sqe->txrx.buf_len, true); in rtio_vrfy_sqe() 73 static inline int z_vrfy_rtio_sqe_cancel(struct rtio_sqe *sqe) in z_vrfy_rtio_sqe_cancel() argument 75 return z_impl_rtio_sqe_cancel(sqe); in z_vrfy_rtio_sqe_cancel() [all …]
|
| D | rtio_executor.c | 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() [all …]
|
| D | rtio_workq.c | 75 struct rtio_sqe *sqe = &iodev_sqe->sqe; in rtio_work_req_submit() local 86 if (sqe->prio == RTIO_PRIO_LOW) { in rtio_work_req_submit() 88 } else if (sqe->prio == RTIO_PRIO_HIGH) { in rtio_work_req_submit()
|
| /Zephyr-latest/drivers/i3c/ |
| D | i3c_rtio_default.c | 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() 32 __ASSERT_NO_MSG(iodev_sqe->sqe.op == RTIO_OP_TX); in i3c_msg_from_tx() 34 msg->buf = (uint8_t *)iodev_sqe->sqe.tx.buf; in i3c_msg_from_tx() 35 msg->len = iodev_sqe->sqe.tx.buf_len; in i3c_msg_from_tx() [all …]
|
| D | i3c_rtio.c | 27 struct rtio_sqe *sqe = NULL; in i3c_rtio_copy() local 30 sqe = rtio_sqe_acquire(r); in i3c_rtio_copy() 32 if (sqe == NULL) { in i3c_rtio_copy() 38 rtio_sqe_prep_read(sqe, iodev, RTIO_PRIO_NORM, msgs[i].buf, msgs[i].len, in i3c_rtio_copy() 41 rtio_sqe_prep_write(sqe, iodev, RTIO_PRIO_NORM, msgs[i].buf, msgs[i].len, in i3c_rtio_copy() 44 sqe->flags |= RTIO_SQE_TRANSACTION; in i3c_rtio_copy() 45 sqe->iodev_flags = in i3c_rtio_copy() 54 sqe->flags &= ~RTIO_SQE_TRANSACTION; in i3c_rtio_copy() 56 return sqe; in i3c_rtio_copy() 131 struct rtio_sqe *sqe = NULL; in i3c_rtio_transfer() local [all …]
|
| /Zephyr-latest/tests/subsys/rtio/rtio_api/src/ |
| D | test_rtio_api.c | 51 struct rtio_sqe *sqe; in test_rtio_simple_() local 57 sqe = rtio_sqe_acquire(r); in test_rtio_simple_() 58 zassert_not_null(sqe, "Expected a valid sqe"); in test_rtio_simple_() 59 rtio_sqe_prep_nop(sqe, (struct rtio_iodev *)&iodev_test_simple, &userdata[0]); in test_rtio_simple_() 84 struct rtio_sqe *sqe; in ZTEST() local 89 sqe = rtio_sqe_acquire(&r_simple); in ZTEST() 90 zassert_not_null(sqe, "Expected a valid sqe"); in ZTEST() 91 rtio_sqe_prep_nop(sqe, (struct rtio_iodev *)&iodev_test_simple, &userdata[0]); in ZTEST() 92 sqe->flags |= RTIO_SQE_NO_RESPONSE; in ZTEST() 118 struct rtio_sqe *sqe; in test_rtio_chain_() local [all …]
|
| /Zephyr-latest/drivers/i2c/ |
| D | i2c_rtio_default.c | 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() 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() 33 msg->len = iodev_sqe->sqe.tx.buf_len; in i2c_msg_from_tx() 35 ((iodev_sqe->sqe.iodev_flags & RTIO_IODEV_I2C_STOP) ? I2C_MSG_STOP : 0) | in i2c_msg_from_tx() [all …]
|
| D | i2c_rtio.c | 26 struct rtio_sqe *sqe = NULL; in i2c_rtio_copy() local 29 sqe = rtio_sqe_acquire(r); in i2c_rtio_copy() 31 if (sqe == NULL) { in i2c_rtio_copy() 37 rtio_sqe_prep_read(sqe, iodev, RTIO_PRIO_NORM, msgs[i].buf, msgs[i].len, in i2c_rtio_copy() 40 rtio_sqe_prep_write(sqe, iodev, RTIO_PRIO_NORM, msgs[i].buf, msgs[i].len, in i2c_rtio_copy() 43 sqe->flags |= RTIO_SQE_TRANSACTION; in i2c_rtio_copy() 44 sqe->iodev_flags = in i2c_rtio_copy() 50 sqe->flags &= ~RTIO_SQE_TRANSACTION; in i2c_rtio_copy() 52 return sqe; in i2c_rtio_copy() 60 struct rtio_sqe *sqe = rtio_sqe_acquire(r); in i2c_rtio_copy_reg_write_byte() local [all …]
|
| D | i2c_nrfx_twim_rtio.c | 54 struct rtio_sqe *sqe = &ctx->txn_curr->sqe; in i2c_nrfx_twim_rtio_start() local 55 struct i2c_dt_spec *dt_spec = sqe->iodev->data; in i2c_nrfx_twim_rtio_start() 57 switch (sqe->op) { in i2c_nrfx_twim_rtio_start() 59 if (!nrf_dma_accessible_check(&config->common.twim, sqe->rx.buf)) { in i2c_nrfx_twim_rtio_start() 60 if (sqe->rx.buf_len > config->common.msg_buf_size) { in i2c_nrfx_twim_rtio_start() 64 data->user_rx_buf = sqe->rx.buf; in i2c_nrfx_twim_rtio_start() 65 data->user_rx_buf_size = sqe->rx.buf_len; in i2c_nrfx_twim_rtio_start() 67 I2C_MSG_READ | sqe->iodev_flags, in i2c_nrfx_twim_rtio_start() 74 return i2c_nrfx_twim_rtio_msg_start(dev, I2C_MSG_READ | sqe->iodev_flags, in i2c_nrfx_twim_rtio_start() 75 sqe->rx.buf, sqe->rx.buf_len, dt_spec->addr); in i2c_nrfx_twim_rtio_start() [all …]
|
| D | i2c_nrfx_twi_rtio.c | 66 struct rtio_sqe *sqe = &ctx->txn_curr->sqe; in i2c_nrfx_twi_rtio_start() local 67 struct i2c_dt_spec *dt_spec = sqe->iodev->data; in i2c_nrfx_twi_rtio_start() 69 switch (sqe->op) { in i2c_nrfx_twi_rtio_start() 71 return i2c_nrfx_twi_rtio_msg_start(dev, I2C_MSG_READ | sqe->iodev_flags, in i2c_nrfx_twi_rtio_start() 72 sqe->rx.buf, sqe->rx.buf_len, dt_spec->addr); in i2c_nrfx_twi_rtio_start() 74 return i2c_nrfx_twi_rtio_msg_start(dev, I2C_MSG_WRITE | sqe->iodev_flags, in i2c_nrfx_twi_rtio_start() 75 (uint8_t *)sqe->tiny_tx.buf, in i2c_nrfx_twi_rtio_start() 76 sqe->tiny_tx.buf_len, dt_spec->addr); in i2c_nrfx_twi_rtio_start() 78 return i2c_nrfx_twi_rtio_msg_start(dev, I2C_MSG_WRITE | sqe->iodev_flags, in i2c_nrfx_twi_rtio_start() 79 (uint8_t *)sqe->tx.buf, in i2c_nrfx_twi_rtio_start() [all …]
|
| D | i2c_sam_twihs_rtio.c | 176 struct rtio_sqe *sqe = &dev_data->ctx->txn_curr->sqe; in i2c_sam_twihs_start() local 177 struct i2c_dt_spec *dt_spec = sqe->iodev->data; in i2c_sam_twihs_start() 188 switch (sqe->op) { in i2c_sam_twihs_start() 190 read_msg_start(twihs, sqe->rx.buf_len, dt_spec->addr); in i2c_sam_twihs_start() 194 write_msg_start(twihs, sqe->tx.buf, 0, dt_spec->addr); in i2c_sam_twihs_start() 197 LOG_ERR("Invalid op code %d for submission %p\n", sqe->op, (void *)sqe); in i2c_sam_twihs_start() 232 struct rtio_sqe *sqe = &dev_data->ctx->txn_curr->sqe; in i2c_sam_twihs_isr() local 246 sqe->rx.buf[dev_data->buf_idx] = twihs->TWIHS_RHR; in i2c_sam_twihs_isr() 249 if (dev_data->buf_idx == sqe->rx.buf_len - 1U) { in i2c_sam_twihs_isr() 257 if (dev_data->buf_idx == sqe->tx.buf_len) { in i2c_sam_twihs_isr() [all …]
|
| D | i2c_mcux_lpi2c_rtio.c | 187 struct rtio_sqe *sqe = &ctx->txn_curr->sqe; in mcux_lpi2c_start() local 188 struct i2c_dt_spec *dt_spec = sqe->iodev->data; in mcux_lpi2c_start() 192 switch (sqe->op) { in mcux_lpi2c_start() 194 return mcux_lpi2c_msg_start(dev, I2C_MSG_READ | sqe->iodev_flags, in mcux_lpi2c_start() 195 sqe->rx.buf, sqe->rx.buf_len, dt_spec->addr); in mcux_lpi2c_start() 197 return mcux_lpi2c_msg_start(dev, I2C_MSG_WRITE | sqe->iodev_flags, in mcux_lpi2c_start() 198 (uint8_t *)sqe->tiny_tx.buf, sqe->tiny_tx.buf_len, in mcux_lpi2c_start() 201 return mcux_lpi2c_msg_start(dev, I2C_MSG_WRITE | sqe->iodev_flags, in mcux_lpi2c_start() 202 (uint8_t *)sqe->tx.buf, sqe->tx.buf_len, in mcux_lpi2c_start() 205 res = mcux_lpi2c_do_configure(dev, sqe->i2c_config); in mcux_lpi2c_start() [all …]
|
| D | i2c_max32_rtio.c | 275 struct rtio_sqe *sqe = &ctx->txn_curr->sqe; in max32_start() local 276 struct i2c_dt_spec *dt_spec = sqe->iodev->data; in max32_start() 279 switch (sqe->op) { in max32_start() 281 return max32_msg_start(dev, I2C_MSG_READ | sqe->iodev_flags, in max32_start() 282 sqe->rx.buf, sqe->rx.buf_len, dt_spec->addr); in max32_start() 285 return max32_msg_start(dev, I2C_MSG_WRITE | sqe->iodev_flags, in max32_start() 286 (uint8_t *)sqe->tiny_tx.buf, sqe->tiny_tx.buf_len, in max32_start() 289 return max32_msg_start(dev, I2C_MSG_WRITE | sqe->iodev_flags, in max32_start() 290 (uint8_t *)sqe->tx.buf, sqe->tx.buf_len, in max32_start() 293 res = max32_do_configure(dev, sqe->i2c_config); in max32_start() [all …]
|
| /Zephyr-latest/tests/drivers/spi/spi_loopback/src/ |
| D | spi_rtio.c | 84 struct rtio_sqe *sqe; in spi_complete_multiple() local 88 sqe = rtio_sqe_acquire(&r); in spi_complete_multiple() 89 rtio_sqe_prep_transceive(sqe, spi_iodev, RTIO_PRIO_NORM, in spi_complete_multiple() 91 sqe->flags |= RTIO_SQE_TRANSACTION; in spi_complete_multiple() 92 sqe = rtio_sqe_acquire(&r); in spi_complete_multiple() 93 rtio_sqe_prep_transceive(sqe, spi_iodev, RTIO_PRIO_NORM, in spi_complete_multiple() 133 struct rtio_sqe *sqe; in spi_complete_loop() local 137 sqe = rtio_sqe_acquire(&r); in spi_complete_loop() 138 rtio_sqe_prep_transceive(sqe, spi_iodev, RTIO_PRIO_NORM, in spi_complete_loop() 172 struct rtio_sqe *sqe; in spi_null_tx_buf() local [all …]
|
| /Zephyr-latest/include/zephyr/rtio/ |
| D | rtio.h | 281 typedef void (*rtio_callback_t)(struct rtio *r, const struct rtio_sqe *sqe, void *arg0); 493 struct rtio_sqe sqe; member 561 static inline void rtio_sqe_prep_nop(struct rtio_sqe *sqe, in rtio_sqe_prep_nop() argument 565 memset(sqe, 0, sizeof(struct rtio_sqe)); in rtio_sqe_prep_nop() 566 sqe->op = RTIO_OP_NOP; in rtio_sqe_prep_nop() 567 sqe->iodev = iodev; in rtio_sqe_prep_nop() 568 sqe->userdata = userdata; in rtio_sqe_prep_nop() 574 static inline void rtio_sqe_prep_read(struct rtio_sqe *sqe, in rtio_sqe_prep_read() argument 581 memset(sqe, 0, sizeof(struct rtio_sqe)); in rtio_sqe_prep_read() 582 sqe->op = RTIO_OP_RX; in rtio_sqe_prep_read() [all …]
|
| /Zephyr-latest/drivers/spi/ |
| D | spi_rtio.c | 23 struct spi_dt_spec *dt_spec = iodev_sqe->sqe.iodev->data; in spi_rtio_iodev_default_submit_sync() 42 switch (txn_curr->sqe.op) { in spi_rtio_iodev_default_submit_sync() 50 LOG_ERR("Invalid op code %d for submission %p", txn_curr->sqe.op, in spi_rtio_iodev_default_submit_sync() 51 (void *)&txn_curr->sqe); in spi_rtio_iodev_default_submit_sync() 90 struct rtio_sqe *sqe = &txn_curr->sqe; in spi_rtio_iodev_default_submit_sync() local 92 switch (sqe->op) { in spi_rtio_iodev_default_submit_sync() 94 rx_bufs[i].buf = sqe->rx.buf; in spi_rtio_iodev_default_submit_sync() 95 rx_bufs[i].len = sqe->rx.buf_len; in spi_rtio_iodev_default_submit_sync() 97 tx_bufs[i].len = sqe->rx.buf_len; in spi_rtio_iodev_default_submit_sync() 101 rx_bufs[i].len = sqe->tx.buf_len; in spi_rtio_iodev_default_submit_sync() [all …]
|
| /Zephyr-latest/subsys/sensing/sensor/hinge_angle/ |
| D | hinge_angle.c | 25 struct rtio_iodev_sqe *sqe; member 83 struct rtio_iodev_sqe *sqe) in hinge_submit() argument 87 if (data->sqe) { in hinge_submit() 88 rtio_iodev_sqe_err(sqe, -EBUSY); in hinge_submit() 90 data->sqe = sqe; in hinge_submit() 139 ret = rtio_sqe_rx_buf(data->sqe, sizeof(*sample), sizeof(*sample), in hinge_reporter_on_data_event() 142 rtio_iodev_sqe_err(data->sqe, ret); in hinge_reporter_on_data_event() 148 struct rtio_iodev_sqe *sqe = data->sqe; in hinge_reporter_on_data_event() local 150 data->sqe = NULL; in hinge_reporter_on_data_event() 151 rtio_iodev_sqe_ok(sqe, 0); in hinge_reporter_on_data_event()
|
| /Zephyr-latest/drivers/sensor/adi/adxl372/ |
| D | adxl372_stream.c | 33 struct rtio_sqe *sqe = rtio_sqe_acquire(data->rtio_ctx); in adxl372_fifo_flush_rtio() local 36 rtio_sqe_prep_tiny_write(sqe, data->iodev, RTIO_PRIO_NORM, reg_addr_w, 2, NULL); in adxl372_fifo_flush_rtio() 42 sqe = rtio_sqe_acquire(data->rtio_ctx); in adxl372_fifo_flush_rtio() 45 rtio_sqe_prep_tiny_write(sqe, data->iodev, RTIO_PRIO_NORM, reg_addr_w2, 2, NULL); in adxl372_fifo_flush_rtio() 51 sqe = rtio_sqe_acquire(data->rtio_ctx); in adxl372_fifo_flush_rtio() 54 rtio_sqe_prep_tiny_write(sqe, data->iodev, RTIO_PRIO_NORM, reg_addr_w3, 2, NULL); in adxl372_fifo_flush_rtio() 61 sqe = rtio_sqe_acquire(data->rtio_ctx); in adxl372_fifo_flush_rtio() 65 rtio_sqe_prep_tiny_write(sqe, data->iodev, RTIO_PRIO_NORM, reg_addr_w4, 2, NULL); in adxl372_fifo_flush_rtio() 66 sqe->flags |= RTIO_SQE_CHAINED; in adxl372_fifo_flush_rtio() 74 (const struct sensor_read_config *)iodev_sqe->sqe.iodev->data; in adxl372_submit_stream() [all …]
|
| /Zephyr-latest/tests/subsys/rtio/rtio_i2c/src/ |
| D | main.cpp | 61 struct rtio_sqe *sqe = i2c_rtio_copy(&test_rtio_ctx, &blocking_emul_iodev, &msg, 1); in ZTEST() local 63 zassert_not_null(sqe); in ZTEST() 75 struct rtio_sqe *sqe = rtio_sqe_acquire(&test_rtio_ctx); in ZTEST() local 77 zassert_not_null(sqe); in ZTEST() 78 sqe->op = UINT8_MAX; in ZTEST() 79 sqe->prio = RTIO_PRIO_NORM; in ZTEST() 80 sqe->iodev = &blocking_emul_iodev; in ZTEST() 81 sqe->userdata = NULL; in ZTEST() 95 struct rtio_sqe *sqe = rtio_sqe_acquire(&test_rtio_ctx); in ZTEST() local 106 zassert_not_null(sqe); in ZTEST() [all …]
|
| /Zephyr-latest/samples/subsys/rtio/sensor_batch_processing/src/ |
| D | main.c | 32 struct rtio_sqe *sqe = rtio_sqe_acquire(&ez_io); in main() local 34 rtio_sqe_prep_read_with_pool(sqe, iodev, RTIO_PRIO_HIGH, NULL); in main() 87 struct rtio_sqe *sqe = rtio_sqe_acquire(&ez_io); in main() local 90 rtio_sqe_prep_read_with_pool(sqe, iodev, RTIO_PRIO_HIGH, NULL); in main()
|
| /Zephyr-latest/drivers/sensor/adi/adxl367/ |
| D | adxl367_stream.c | 42 struct rtio_sqe *sqe = rtio_sqe_acquire(data->rtio_ctx); in adxl367_fifo_flush_rtio() local 45 rtio_sqe_prep_tiny_write(sqe, data->iodev, RTIO_PRIO_NORM, reg_addr_w, 3, NULL); in adxl367_fifo_flush_rtio() 47 sqe = rtio_sqe_acquire(data->rtio_ctx); in adxl367_fifo_flush_rtio() 51 rtio_sqe_prep_tiny_write(sqe, data->iodev, RTIO_PRIO_NORM, reg_addr_w2, 3, NULL); in adxl367_fifo_flush_rtio() 53 sqe = rtio_sqe_acquire(data->rtio_ctx); in adxl367_fifo_flush_rtio() 57 rtio_sqe_prep_tiny_write(sqe, data->iodev, RTIO_PRIO_NORM, reg_addr_w3, 3, NULL); in adxl367_fifo_flush_rtio() 64 sqe = rtio_sqe_acquire(data->rtio_ctx); in adxl367_fifo_flush_rtio() 68 rtio_sqe_prep_tiny_write(sqe, data->iodev, RTIO_PRIO_NORM, reg_addr_w4, 3, NULL); in adxl367_fifo_flush_rtio() 69 sqe->flags |= RTIO_SQE_CHAINED; in adxl367_fifo_flush_rtio() 77 (const struct sensor_read_config *)iodev_sqe->sqe.iodev->data; in adxl367_submit_stream() [all …]
|
| /Zephyr-latest/tests/subsys/rtio/workq/src/ |
| D | main.c | 20 struct rtio_sqe *sqe = &iodev_sqe->sqe; in work_handler() local 21 struct k_sem *sem = (struct k_sem *)sqe->userdata; in work_handler() 71 struct rtio_sqe *sqe; in ZTEST() local 74 sqe = rtio_sqe_acquire(&r_test); in ZTEST() 75 rtio_sqe_prep_nop(sqe, &dummy_iodev, &work_handler_sem_1); in ZTEST() 76 sqe->prio = RTIO_PRIO_NORM; in ZTEST()
|
| /Zephyr-latest/subsys/sensing/sensor/phy_3d_sensor/ |
| D | phy_3d_sensor.c | 163 struct rtio_iodev_sqe *sqe) in phy_3d_sensor_submit() argument 165 struct sensing_submit_config *config = (struct sensing_submit_config *)sqe->sqe.iodev->data; in phy_3d_sensor_submit() 174 ret = rtio_sqe_rx_buf(sqe, sizeof(*sample), sizeof(*sample), in phy_3d_sensor_submit() 177 rtio_iodev_sqe_err(sqe, ret); in phy_3d_sensor_submit() 184 rtio_iodev_sqe_err(sqe, ret); in phy_3d_sensor_submit() 191 rtio_iodev_sqe_err(sqe, ret); in phy_3d_sensor_submit() 208 rtio_iodev_sqe_ok(sqe, 0); in phy_3d_sensor_submit()
|
| /Zephyr-latest/drivers/sensor/adi/adxl345/ |
| D | adxl345_stream.c | 17 (const struct sensor_read_config *) iodev_sqe->sqe.iodev->data; in adxl345_submit_stream() 62 data->sqe = iodev_sqe; in adxl345_submit_stream() 105 static void adxl345_fifo_read_cb(struct rtio *rtio_ctx, const struct rtio_sqe *sqe, void *arg) in adxl345_fifo_read_cb() argument 110 struct rtio_iodev_sqe *iodev_sqe = sqe->userdata; in adxl345_fifo_read_cb() 125 struct rtio_iodev_sqe *current_sqe = data->sqe; in adxl345_process_fifo_samples_cb() 130 data->sqe = NULL; in adxl345_process_fifo_samples_cb() 239 struct rtio_iodev_sqe *current_sqe = data->sqe; in adxl345_process_status1_cb() 243 if (data->sqe == NULL) { in adxl345_process_status1_cb() 247 read_config = (struct sensor_read_config *)data->sqe->sqe.iodev->data; in adxl345_process_status1_cb() 312 data->sqe = NULL; in adxl345_process_status1_cb() [all …]
|
| /Zephyr-latest/drivers/sensor/adi/adxl362/ |
| D | adxl362_stream.c | 53 (const struct sensor_read_config *)iodev_sqe->sqe.iodev->data; in adxl362_submit_stream() 133 data->sqe = iodev_sqe; in adxl362_submit_stream() 136 static void adxl362_fifo_read_cb(struct rtio *rtio_ctx, const struct rtio_sqe *sqe, void *arg) in adxl362_fifo_read_cb() argument 140 struct rtio_iodev_sqe *iodev_sqe = sqe->userdata; in adxl362_fifo_read_cb() 152 struct rtio_iodev_sqe *current_sqe = data->sqe; in adxl362_process_fifo_samples_cb() 162 data->sqe = NULL; in adxl362_process_fifo_samples_cb() 254 struct rtio_iodev_sqe *current_sqe = data->sqe; in adxl362_process_status_cb() 258 if (data->sqe == NULL) { in adxl362_process_status_cb() 262 read_config = (struct sensor_read_config *)data->sqe->sqe.iodev->data; in adxl362_process_status_cb() 341 data->sqe = NULL; in adxl362_process_status_cb() [all …]
|