| /Zephyr-latest/tests/subsys/rtio/rtio_api/src/ |
| D | test_rtio_api.c | 52 struct rtio_cqe *cqe; in test_rtio_simple_() local
65 cqe = rtio_cqe_consume(r); in test_rtio_simple_()
66 zassert_not_null(cqe, "Expected a valid cqe"); in test_rtio_simple_()
67 zassert_ok(cqe->result, "Result should be ok"); in test_rtio_simple_()
68 zassert_equal_ptr(cqe->userdata, &userdata[0], "Expected userdata back"); in test_rtio_simple_()
69 rtio_cqe_release(r, cqe); in test_rtio_simple_()
85 struct rtio_cqe cqe; in ZTEST() local
97 res = rtio_cqe_copy_out(&r_simple, &cqe, 1, K_MSEC(500)); in ZTEST()
119 struct rtio_cqe *cqe; in test_rtio_chain_() local
142 cqe = rtio_cqe_consume(r); in test_rtio_chain_()
[all …]
|
| /Zephyr-latest/tests/subsys/rtio/rtio_i2c/src/ |
| D | main.cpp | 27 struct rtio_cqe *cqe; in rtio_i2c_before() local
29 while ((cqe = rtio_cqe_consume(&test_rtio_ctx)) != NULL) { in rtio_i2c_before()
30 rtio_cqe_release(&test_rtio_ctx, cqe); in rtio_i2c_before()
67 struct rtio_cqe *cqe = rtio_cqe_consume_block(&test_rtio_ctx); in ZTEST() local
69 zassert_ok(cqe->result); in ZTEST()
70 rtio_cqe_release(&test_rtio_ctx, cqe); in ZTEST()
86 struct rtio_cqe *cqe = rtio_cqe_consume_block(&test_rtio_ctx); in ZTEST() local
88 zassert_equal(-EIO, cqe->result); in ZTEST()
89 rtio_cqe_release(&test_rtio_ctx, cqe); in ZTEST()
113 struct rtio_cqe *cqe = rtio_cqe_consume_block(&test_rtio_ctx); in ZTEST() local
[all …]
|
| /Zephyr-latest/tests/subsys/rtio/workq/src/ |
| D | main.c | 72 struct rtio_cqe *cqe; in ZTEST() local
90 cqe = rtio_cqe_consume_block(&r_test); in ZTEST()
91 rtio_cqe_release(&r_test, cqe); in ZTEST()
99 struct rtio_cqe *cqe; in ZTEST() local
123 cqe = rtio_cqe_consume_block(&r_test); in ZTEST()
124 rtio_cqe_release(&r_test, cqe); in ZTEST()
125 cqe = rtio_cqe_consume_block(&r_test); in ZTEST()
126 rtio_cqe_release(&r_test, cqe); in ZTEST()
127 cqe = rtio_cqe_consume_block(&r_test); in ZTEST()
128 rtio_cqe_release(&r_test, cqe); in ZTEST()
[all …]
|
| /Zephyr-latest/tests/drivers/spi/spi_loopback/src/ |
| D | spi_rtio.c | 85 struct rtio_cqe *cqe; in spi_complete_multiple() local
98 cqe = rtio_cqe_consume(&r); in spi_complete_multiple()
99 ret = cqe->result; in spi_complete_multiple()
100 rtio_cqe_release(&r, cqe); in spi_complete_multiple()
134 struct rtio_cqe *cqe; in spi_complete_loop() local
144 cqe = rtio_cqe_consume(&r); in spi_complete_loop()
145 ret = cqe->result; in spi_complete_loop()
146 rtio_cqe_release(&r, cqe); in spi_complete_loop()
173 struct rtio_cqe *cqe; in spi_null_tx_buf() local
186 cqe = rtio_cqe_consume(&r); in spi_null_tx_buf()
[all …]
|
| /Zephyr-latest/drivers/i3c/ |
| D | i3c_rtio.c | 132 struct rtio_cqe *cqe = NULL; in i3c_rtio_transfer() local
148 cqe = rtio_cqe_consume(r); in i3c_rtio_transfer()
149 while (cqe != NULL) { in i3c_rtio_transfer()
150 res = cqe->result; in i3c_rtio_transfer()
151 rtio_cqe_release(r, cqe); in i3c_rtio_transfer()
152 cqe = rtio_cqe_consume(r); in i3c_rtio_transfer()
165 struct rtio_cqe *cqe = NULL; in i3c_rtio_configure() local
184 cqe = rtio_cqe_consume(r); in i3c_rtio_configure()
185 res = cqe->result; in i3c_rtio_configure()
186 rtio_cqe_release(r, cqe); in i3c_rtio_configure()
[all …]
|
| /Zephyr-latest/doc/hardware/peripherals/sensor/ |
| D | multiple_temp_polling.c | 36 struct rtio_cqe *cqe; in main() local
53 cqe = rtio_cqe_consume_block(&temp_ctx); in main()
55 if (cqe->result != 0) { in main()
56 printk("async read failed %d\n", cqe->result); in main()
61 rc = rtio_cqe_get_mempool_buffer(&temp_ctx, cqe, &buf, &buf_len); in main()
69 ((struct rtio_iodev *)cqe->userdata)->data)->sensor; in main()
72 rtio_cqe_release(&temp_ctx, cqe); in main()
|
| D | accel_stream.c | 36 struct rtio_cqe *cqe; in main() local
47 cqe = rtio_cqe_consume_block(&accel_ctx); in main()
49 if (cqe->result != 0) { in main()
50 printk("async read failed %d\n", cqe->result); in main()
54 rc = rtio_cqe_get_mempool_buffer(&accel_ctx, cqe, &buf, &buf_len); in main()
62 ((struct rtio_iodev *)cqe->userdata)->data)->sensor; in main()
64 rtio_cqe_release(&accel_ctx, cqe); in main()
|
| /Zephyr-latest/drivers/i2c/ |
| D | i2c_rtio.c | 129 struct rtio_cqe *cqe = NULL; in i2c_rtio_transfer() local
145 cqe = rtio_cqe_consume(r); in i2c_rtio_transfer()
146 while (cqe != NULL) { in i2c_rtio_transfer()
147 res = cqe->result; in i2c_rtio_transfer()
148 rtio_cqe_release(r, cqe); in i2c_rtio_transfer()
149 cqe = rtio_cqe_consume(r); in i2c_rtio_transfer()
162 struct rtio_cqe *cqe = NULL; in i2c_rtio_configure() local
180 cqe = rtio_cqe_consume(r); in i2c_rtio_configure()
181 res = cqe->result; in i2c_rtio_configure()
182 rtio_cqe_release(r, cqe); in i2c_rtio_configure()
[all …]
|
| /Zephyr-latest/subsys/sensing/ |
| D | dispatch.c | 94 struct rtio_cqe cqe; in dispatch_task() local
96 rc = rtio_cqe_copy_out(&sensing_rtio_ctx, &cqe, 1, K_FOREVER); in dispatch_task()
102 rc = cqe.result; in dispatch_task()
106 rtio_cqe_get_mempool_buffer(&sensing_rtio_ctx, &cqe, &data, &data_len); in dispatch_task()
111 if ((uintptr_t)cqe.userdata >= in dispatch_task()
113 (uintptr_t)cqe.userdata < (uintptr_t)STRUCT_SECTION_END(sensing_sensor)) { in dispatch_task()
114 struct sensing_sensor *sensor = cqe.userdata; in dispatch_task()
|
| /Zephyr-latest/samples/subsys/rtio/sensor_batch_processing/src/ |
| D | main.c | 50 struct rtio_cqe *cqe = rtio_cqe_consume(&ez_io); in main() local
52 if (cqe == NULL) { in main()
59 if (cqe->result < 0) { in main()
63 if (rtio_cqe_get_mempool_buffer(&ez_io, cqe, &userdata[m], &data_len[m])) { in main()
66 rtio_cqe_release(&ez_io, cqe); in main()
|
| /Zephyr-latest/include/zephyr/rtio/ |
| D | rtio.h | 750 struct rtio_cqe *cqe = CONTAINER_OF(node, struct rtio_cqe, q); in rtio_cqe_pool_alloc() local
752 memset(cqe, 0, sizeof(struct rtio_cqe)); in rtio_cqe_pool_alloc()
756 return cqe; in rtio_cqe_pool_alloc()
759 static inline void rtio_cqe_pool_free(struct rtio_cqe_pool *pool, struct rtio_cqe *cqe) in rtio_cqe_pool_free() argument
761 mpsc_push(&pool->free_q, &cqe->q); in rtio_cqe_pool_free()
1037 struct rtio_cqe *cqe = rtio_cqe_pool_alloc(r->cqe_pool); in rtio_cqe_acquire() local
1039 if (cqe == NULL) { in rtio_cqe_acquire()
1043 memset(cqe, 0, sizeof(struct rtio_cqe)); in rtio_cqe_acquire()
1045 return cqe; in rtio_cqe_acquire()
1051 static inline void rtio_cqe_produce(struct rtio *r, struct rtio_cqe *cqe) in rtio_cqe_produce() argument
[all …]
|
| /Zephyr-latest/drivers/sensor/adi/adxl345/ |
| D | adxl345_stream.c | 182 struct rtio_cqe *cqe; in adxl345_process_fifo_samples_cb() local
186 cqe = rtio_cqe_consume(data->rtio_ctx); in adxl345_process_fifo_samples_cb()
187 if (cqe != NULL) { in adxl345_process_fifo_samples_cb()
188 if ((cqe->result < 0 && res == 0)) { in adxl345_process_fifo_samples_cb()
189 LOG_ERR("Bus error: %d", cqe->result); in adxl345_process_fifo_samples_cb()
190 res = cqe->result; in adxl345_process_fifo_samples_cb()
192 rtio_cqe_release(data->rtio_ctx, cqe); in adxl345_process_fifo_samples_cb()
194 } while (cqe != NULL); in adxl345_process_fifo_samples_cb()
281 struct rtio_cqe *cqe; in adxl345_process_status1_cb() local
285 cqe = rtio_cqe_consume(data->rtio_ctx); in adxl345_process_status1_cb()
[all …]
|
| /Zephyr-latest/drivers/sensor/adi/adxl362/ |
| D | adxl362_stream.c | 211 struct rtio_cqe *cqe; in adxl362_process_fifo_samples_cb() local
215 cqe = rtio_cqe_consume(data->rtio_ctx); in adxl362_process_fifo_samples_cb()
216 if (cqe != NULL) { in adxl362_process_fifo_samples_cb()
217 if ((cqe->result < 0 && res == 0)) { in adxl362_process_fifo_samples_cb()
218 LOG_ERR("Bus error: %d", cqe->result); in adxl362_process_fifo_samples_cb()
219 res = cqe->result; in adxl362_process_fifo_samples_cb()
221 rtio_cqe_release(data->rtio_ctx, cqe); in adxl362_process_fifo_samples_cb()
223 } while (cqe != NULL); in adxl362_process_fifo_samples_cb()
306 struct rtio_cqe *cqe; in adxl362_process_status_cb() local
310 cqe = rtio_cqe_consume(data->rtio_ctx); in adxl362_process_status_cb()
[all …]
|
| /Zephyr-latest/samples/sensor/accel_polling/src/ |
| D | main.c | 51 struct rtio_cqe *cqe; in print_accels_stream() local
63 cqe = rtio_cqe_consume_block(&accel_ctx); in print_accels_stream()
65 if (cqe->result != 0) { in print_accels_stream()
66 printk("async read failed %d\n", cqe->result); in print_accels_stream()
67 return cqe->result; in print_accels_stream()
70 rc = rtio_cqe_get_mempool_buffer(&accel_ctx, cqe, &buf, &buf_len); in print_accels_stream()
79 rtio_cqe_release(&accel_ctx, cqe); in print_accels_stream()
|
| /Zephyr-latest/drivers/sensor/adi/adxl372/ |
| D | adxl372_stream.c | 256 struct rtio_cqe *cqe; in adxl372_process_fifo_samples_cb() local
260 cqe = rtio_cqe_consume(data->rtio_ctx); in adxl372_process_fifo_samples_cb()
261 if (cqe != NULL) { in adxl372_process_fifo_samples_cb()
262 if ((cqe->result < 0 && res == 0)) { in adxl372_process_fifo_samples_cb()
263 LOG_ERR("Bus error: %d", cqe->result); in adxl372_process_fifo_samples_cb()
264 res = cqe->result; in adxl372_process_fifo_samples_cb()
266 rtio_cqe_release(data->rtio_ctx, cqe); in adxl372_process_fifo_samples_cb()
268 } while (cqe != NULL); in adxl372_process_fifo_samples_cb()
346 struct rtio_cqe *cqe; in adxl372_process_status1_cb() local
350 cqe = rtio_cqe_consume(data->rtio_ctx); in adxl372_process_status1_cb()
[all …]
|
| /Zephyr-latest/drivers/sensor/tdk/icm42688/ |
| D | icm42688_rtio_stream.c | 138 struct rtio_cqe *cqe; in icm42688_fifo_count_cb() local
141 cqe = rtio_cqe_consume(r); in icm42688_fifo_count_cb()
142 if (cqe != NULL) { in icm42688_fifo_count_cb()
143 rtio_cqe_release(r, cqe); in icm42688_fifo_count_cb()
145 } while (cqe != NULL); in icm42688_fifo_count_cb()
215 struct rtio_cqe *cqe; in icm42688_int_status_cb() local
218 cqe = rtio_cqe_consume(r); in icm42688_int_status_cb()
219 if (cqe != NULL) { in icm42688_int_status_cb()
220 rtio_cqe_release(r, cqe); in icm42688_int_status_cb()
222 } while (cqe != NULL); in icm42688_int_status_cb()
|
| /Zephyr-latest/drivers/sensor/adi/adxl367/ |
| D | adxl367_stream.c | 371 struct rtio_cqe *cqe; in adxl367_process_fifo_samples_cb() local
375 cqe = rtio_cqe_consume(data->rtio_ctx); in adxl367_process_fifo_samples_cb()
376 if (cqe != NULL) { in adxl367_process_fifo_samples_cb()
377 if ((cqe->result < 0 && res == 0)) { in adxl367_process_fifo_samples_cb()
378 LOG_ERR("Bus error: %d", cqe->result); in adxl367_process_fifo_samples_cb()
379 res = cqe->result; in adxl367_process_fifo_samples_cb()
381 rtio_cqe_release(data->rtio_ctx, cqe); in adxl367_process_fifo_samples_cb()
383 } while (cqe != NULL); in adxl367_process_fifo_samples_cb()
461 struct rtio_cqe *cqe; in adxl367_process_status_cb() local
465 cqe = rtio_cqe_consume(data->rtio_ctx); in adxl367_process_status_cb()
[all …]
|
| /Zephyr-latest/subsys/rtio/ |
| D | rtio_handlers.c | 62 static inline int z_vrfy_rtio_cqe_get_mempool_buffer(const struct rtio *r, struct rtio_cqe *cqe, in z_vrfy_rtio_cqe_get_mempool_buffer() argument
66 K_OOPS(K_SYSCALL_MEMORY_READ(cqe, sizeof(struct rtio_cqe))); in z_vrfy_rtio_cqe_get_mempool_buffer()
69 return z_impl_rtio_cqe_get_mempool_buffer(r, cqe, buff, buff_len); in z_vrfy_rtio_cqe_get_mempool_buffer()
|
| /Zephyr-latest/tests/drivers/build_all/sensor/src/ |
| D | generic_test.c | 180 struct rtio_cqe *cqe = rtio_cqe_consume_block(&sensor_read_rtio_ctx); in run_generic_test() local
182 zassert_ok(cqe->result, "CQE has failed status (error %d, iteration %d/%d)", in run_generic_test()
183 cqe->result, iteration + 1, in run_generic_test()
190 rtio_cqe_get_mempool_buffer(&sensor_read_rtio_ctx, cqe, &buf, &buf_len); in run_generic_test()
193 rtio_cqe_release(&sensor_read_rtio_ctx, cqe); in run_generic_test()
|
| /Zephyr-latest/drivers/sensor/st/lsm6dsv16x/ |
| D | lsm6dsv16x_rtio_stream.c | 213 struct rtio_cqe *cqe; in lsm6dsv16x_read_fifo_cb() local
217 cqe = rtio_cqe_consume(lsm6dsv16x->rtio_ctx); in lsm6dsv16x_read_fifo_cb()
218 if (cqe != NULL) { in lsm6dsv16x_read_fifo_cb()
219 if ((cqe->result < 0) && (res == 0)) { in lsm6dsv16x_read_fifo_cb()
220 LOG_ERR("Bus error: %d", cqe->result); in lsm6dsv16x_read_fifo_cb()
221 res = cqe->result; in lsm6dsv16x_read_fifo_cb()
223 rtio_cqe_release(lsm6dsv16x->rtio_ctx, cqe); in lsm6dsv16x_read_fifo_cb()
225 } while (cqe != NULL); in lsm6dsv16x_read_fifo_cb()
|
| /Zephyr-latest/drivers/spi/ |
| D | spi_rtio.c | 377 struct rtio_cqe *cqe; in spi_rtio_transceive() local
392 cqe = rtio_cqe_consume(ctx->r); in spi_rtio_transceive()
393 if (cqe->result < 0) { in spi_rtio_transceive()
394 err = cqe->result; in spi_rtio_transceive()
397 rtio_cqe_release(ctx->r, cqe); in spi_rtio_transceive()
|
| /Zephyr-latest/drivers/sensor/ |
| D | default_rtio_sensor.c | 286 struct rtio_cqe *cqe = rtio_cqe_consume_block(ctx); in sensor_processing_with_callback() local
289 rc = cqe->result; in sensor_processing_with_callback()
290 userdata = cqe->userdata; in sensor_processing_with_callback()
291 rtio_cqe_get_mempool_buffer(ctx, cqe, &buf, &buf_len); in sensor_processing_with_callback()
294 rtio_cqe_release(ctx, cqe); in sensor_processing_with_callback()
|
| /Zephyr-latest/doc/services/rtio/ |
| D | index.rst | 95 queue (cq) with completion queue events (cqe). A sqe once completed results in
96 a cqe being pushed into the cq. The ordering of cqe may not be the same order of
115 Turning submission queue entries (sqe) into completion queue events (cqe) is the
187 int rc = rtio_cqe_get_mempool_buffer(&rtio_context, &cqe, &buf, &buf_len);
194 /* Release the cqe events (note that the buffer is not released yet */
|
| /Zephyr-latest/include/zephyr/drivers/ |
| D | sensor.h | 1094 struct rtio_cqe *cqe = rtio_cqe_consume_block(ctx); in sensor_read() local
1095 int res = cqe->result; in sensor_read()
1097 __ASSERT(cqe->userdata == buf, in sensor_read()
1100 rtio_cqe_release(ctx, cqe); in sensor_read()
|
| /Zephyr-latest/doc/releases/ |
| D | release-notes-3.4.rst | 1369 * Added policy that every ``sqe`` will generate a ``cqe`` (previously an RTIO_SQE_TRANSACTION
1370 entry would only trigger a ``cqe`` on the last ``sqe`` in the transaction.
|
