| /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/drivers/sensor/tdk/icm45686/ |
| D | icm45686_bus.h | 27 struct rtio_cqe *cqe; in icm45686_bus_read() local
46 cqe = rtio_cqe_consume(ctx); in icm45686_bus_read()
47 if (cqe != NULL) { in icm45686_bus_read()
48 err = cqe->result; in icm45686_bus_read()
49 rtio_cqe_release(ctx, cqe); in icm45686_bus_read()
51 } while (cqe != NULL); in icm45686_bus_read()
66 struct rtio_cqe *cqe; in icm45686_bus_write() local
83 cqe = rtio_cqe_consume(ctx); in icm45686_bus_write()
84 if (cqe != NULL) { in icm45686_bus_write()
85 err = cqe->result; in icm45686_bus_write()
[all …]
|
| /Zephyr-latest/drivers/sensor/pixart/paa3905/ |
| D | paa3905_bus.h | 27 struct rtio_cqe *cqe; in paa3905_bus_read() local
46 cqe = rtio_cqe_consume(ctx); in paa3905_bus_read()
47 if (cqe != NULL) { in paa3905_bus_read()
48 err = cqe->result; in paa3905_bus_read()
49 rtio_cqe_release(ctx, cqe); in paa3905_bus_read()
51 } while (cqe != NULL); in paa3905_bus_read()
66 struct rtio_cqe *cqe; in paa3905_bus_write() local
85 cqe = rtio_cqe_consume(ctx); in paa3905_bus_write()
86 if (cqe != NULL) { in paa3905_bus_write()
87 err = cqe->result; in paa3905_bus_write()
[all …]
|
| D | paa3905.c | 33 struct rtio_cqe *cqe; in paa3905_complete_result() local
37 cqe = rtio_cqe_consume(ctx); in paa3905_complete_result()
38 if (cqe != NULL) { in paa3905_complete_result()
39 err = cqe->result; in paa3905_complete_result()
40 rtio_cqe_release(ctx, cqe); in paa3905_complete_result()
42 } while (cqe != NULL); in paa3905_complete_result()
|
| /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/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/drivers/i2c/ |
| D | i2c_rtio.c | 170 struct rtio_cqe *cqe = NULL; in i2c_rtio_transfer() local
186 cqe = rtio_cqe_consume(r); in i2c_rtio_transfer()
187 while (cqe != NULL) { in i2c_rtio_transfer()
188 res = cqe->result; in i2c_rtio_transfer()
189 rtio_cqe_release(r, cqe); in i2c_rtio_transfer()
190 cqe = rtio_cqe_consume(r); in i2c_rtio_transfer()
203 struct rtio_cqe *cqe = NULL; in i2c_rtio_configure() local
221 cqe = rtio_cqe_consume(r); in i2c_rtio_configure()
222 res = cqe->result; in i2c_rtio_configure()
223 rtio_cqe_release(r, cqe); in i2c_rtio_configure()
[all …]
|
| /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/asahi_kasei/akm09918c/ |
| D | akm09918c_async.c | 21 struct rtio_cqe *cqe; in akm09918c_flush_cqes() local
25 cqe = rtio_cqe_consume(rtio_ctx); in akm09918c_flush_cqes()
26 if (cqe != NULL) { in akm09918c_flush_cqes()
27 if ((cqe->result < 0 && res == 0)) { in akm09918c_flush_cqes()
28 LOG_ERR("Bus error: %d", cqe->result); in akm09918c_flush_cqes()
29 res = cqe->result; in akm09918c_flush_cqes()
31 rtio_cqe_release(rtio_ctx, cqe); in akm09918c_flush_cqes()
33 } while (cqe != NULL); in akm09918c_flush_cqes()
|
| /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 | 257 struct rtio_cqe *cqe; in adxl372_process_fifo_samples_cb() local
261 cqe = rtio_cqe_consume(data->rtio_ctx); in adxl372_process_fifo_samples_cb()
262 if (cqe != NULL) { in adxl372_process_fifo_samples_cb()
263 if ((cqe->result < 0 && res == 0)) { in adxl372_process_fifo_samples_cb()
264 LOG_ERR("Bus error: %d", cqe->result); in adxl372_process_fifo_samples_cb()
265 res = cqe->result; in adxl372_process_fifo_samples_cb()
267 rtio_cqe_release(data->rtio_ctx, cqe); in adxl372_process_fifo_samples_cb()
269 } while (cqe != NULL); in adxl372_process_fifo_samples_cb()
347 struct rtio_cqe *cqe; in adxl372_process_status1_cb() local
351 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/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/samples/sensor/stream_fifo/src/ |
| D | main.c | 62 struct rtio_cqe *cqe; in print_stream() local
85 cqe = rtio_cqe_consume_block(&stream_ctx); in print_stream()
87 if (cqe->result != 0) { in print_stream()
88 printk("async read failed %d\n", cqe->result); in print_stream()
92 rc = rtio_cqe_get_mempool_buffer(&stream_ctx, cqe, &buf, &buf_len); in print_stream()
101 rtio_cqe_release(&stream_ctx, cqe); in print_stream()
|
| /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/drivers/sensor/st/lsm6dsv16x/ |
| D | lsm6dsv16x_rtio_stream.c | 214 struct rtio_cqe *cqe; in lsm6dsv16x_read_fifo_cb() local
218 cqe = rtio_cqe_consume(lsm6dsv16x->rtio_ctx); in lsm6dsv16x_read_fifo_cb()
219 if (cqe != NULL) { in lsm6dsv16x_read_fifo_cb()
220 if ((cqe->result < 0) && (res == 0)) { in lsm6dsv16x_read_fifo_cb()
221 LOG_ERR("Bus error: %d", cqe->result); in lsm6dsv16x_read_fifo_cb()
222 res = cqe->result; in lsm6dsv16x_read_fifo_cb()
224 rtio_cqe_release(lsm6dsv16x->rtio_ctx, cqe); in lsm6dsv16x_read_fifo_cb()
226 } while (cqe != NULL); in lsm6dsv16x_read_fifo_cb()
|
