/Zephyr-latest/tests/kernel/fifo/fifo_timeout/src/ |
D | main.c | 90 void *packet = k_fifo_get(&scratch_fifo_packets_fifo, K_NO_WAIT); in get_scratch_packet() 131 packet = k_fifo_get(d->fifo, K_MSEC(d->timeout)); in test_thread_pend_and_timeout() 161 k_fifo_get(&timeout_order_fifo, K_FOREVER); in test_multiple_threads_pending() 205 packet = k_fifo_get(d->fifo, K_MSEC(d->timeout)); in test_thread_pend_and_get_data() 234 data = k_fifo_get(&timeout_order_fifo, K_FOREVER); in test_multiple_threads_get_data() 252 data = k_fifo_get(&timeout_order_fifo, K_FOREVER); in test_multiple_threads_get_data() 276 !!k_fifo_get(&fifo_timeout[0], K_NO_WAIT); in test_thread_timeout_reply_values() 286 !!k_fifo_get(&fifo_timeout[0], K_FOREVER); in test_thread_timeout_reply_values_wfe() 310 packet = k_fifo_get(&fifo_timeout[0], K_MSEC(timeout)); in ZTEST() 315 packet = k_fifo_get(&fifo_timeout[0], K_NO_WAIT); in ZTEST() [all …]
|
/Zephyr-latest/tests/benchmarks/sys_kernel/src/ |
D | mwfifo.c | 49 pelement = k_fifo_get(&fifo1, K_FOREVER); in fifo_thread1() 57 k_fifo_get(&sync_fifo, K_FOREVER); in fifo_thread1() 83 pelement = k_fifo_get(&fifo2, K_FOREVER); in fifo_thread2() 90 k_fifo_get(&sync_fifo, K_FOREVER); in fifo_thread2() 116 while ((pelement = k_fifo_get(&fifo2, K_NO_WAIT)) == NULL) { in fifo_thread3() 125 k_fifo_get(&sync_fifo, K_FOREVER); in fifo_thread3() 236 pelement = k_fifo_get(&fifo2, K_FOREVER); in fifo_test() 240 pelement = k_fifo_get(&fifo2, K_FOREVER); in fifo_test()
|
D | lifo.c | 62 k_fifo_get(&sync_fifo, K_FOREVER); in lifo_thread1() 93 k_fifo_get(&sync_fifo, K_FOREVER); in lifo_thread2() 125 k_fifo_get(&sync_fifo, K_FOREVER); in lifo_thread3()
|
/Zephyr-latest/tests/kernel/fifo/fifo_api/src/ |
D | test_fifo_fail.c | 28 zassert_is_null(k_fifo_get(&fifo, K_NO_WAIT), NULL); in ZTEST() 29 zassert_is_null(k_fifo_get(&fifo, TIMEOUT), NULL); in ZTEST()
|
D | test_fifo_contexts.c | 53 rx_data = k_fifo_get(pfifo, K_NO_WAIT); in tfifo_get() 58 rx_data = k_fifo_get(pfifo, K_NO_WAIT); in tfifo_get() 63 rx_data = k_fifo_get(pfifo, K_NO_WAIT); in tfifo_get()
|
D | test_fifo_cancel.c | 31 void *ret = k_fifo_get(pfifo, K_MSEC(500)); in tfifo_thread_thread()
|
D | test_fifo_loop.c | 34 rx_data = k_fifo_get(pfifo, K_NO_WAIT); in tfifo_get()
|
/Zephyr-latest/tests/kernel/fifo/fifo_usage/src/ |
D | main.c | 77 rx_data = k_fifo_get((struct k_fifo *)p, K_NO_WAIT); in tIsr_entry_get() 90 rx_data = k_fifo_get((struct k_fifo *)p1, K_NO_WAIT); in thread_entry_fn_single() 110 rx_data = k_fifo_get((struct k_fifo *)p2, K_FOREVER); in thread_entry_fn_dual() 166 rx_data = k_fifo_get(&fifo1, K_NO_WAIT); in ZTEST() 197 rx_data = k_fifo_get(&fifo1, K_FOREVER); in ZTEST()
|
/Zephyr-latest/subsys/net/ip/ |
D | promiscuous.c | 30 return k_fifo_get(&promiscuous_queue, timeout); in net_promisc_mode_wait_data() 54 pkt = k_fifo_get(&promiscuous_queue, K_NO_WAIT); in flush_queue()
|
/Zephyr-latest/subsys/mgmt/mcumgr/transport/src/ |
D | smp.c | 139 while ((nb = k_fifo_get(&smpt->fifo, K_NO_WAIT)) != NULL) { in smp_handle_reqs() 233 while ((nb = k_fifo_get(&zst->fifo, K_NO_WAIT)) != NULL) { in smp_rx_remove_invalid() 242 while ((nb = k_fifo_get(&temp_fifo, K_NO_WAIT)) != NULL) { in smp_rx_remove_invalid() 262 while ((nb = k_fifo_get(&zst->fifo, K_NO_WAIT)) != NULL) { in smp_rx_clear()
|
D | smp_uart.c | 66 while ((rx_buf = k_fifo_get(&smp_uart_rx_fifo, K_NO_WAIT)) != NULL) { in smp_uart_process_rx_queue()
|
/Zephyr-latest/tests/benchmarks/sys_kernel/ |
D | README.txt | 88 k_fifo_get(K_FOREVER) 98 k_fifo_get(K_FOREVER) 99 k_fifo_get(K_NO_WAIT) 110 k_fifo_get(K_FOREVER) 112 k_fifo_get(K_FOREVER)
|
/Zephyr-latest/samples/bluetooth/hci_uart_3wire/src/ |
D | main.c | 212 struct net_buf *buf = k_fifo_get(&h5.unack_queue, K_NO_WAIT); in process_unack() 348 while ((buf = k_fifo_get(&h5.tx_queue, K_NO_WAIT))) { in retx_timeout() 353 while ((buf = k_fifo_get(&h5.unack_queue, K_NO_WAIT))) { in retx_timeout() 362 while ((buf = k_fifo_get(&tmp_queue, K_NO_WAIT))) { in retx_timeout() 604 buf = k_fifo_get(&tx_queue, K_NO_WAIT); in process_events() 614 buf = k_fifo_get(&h5.tx_queue, K_FOREVER); in process_events() 691 buf = k_fifo_get(&h5.rx_queue, K_FOREVER); in rx_thread() 697 while ((cache = k_fifo_get(&h5.unack_queue, K_NO_WAIT))) { in rx_thread() 703 while ((cache = k_fifo_get(&h5.tx_queue, K_NO_WAIT))) { in rx_thread() 810 buf = k_fifo_get(&rx_queue, K_FOREVER); in main()
|
/Zephyr-latest/subsys/console/ |
D | getline.c | 29 cmd = k_fifo_get(&used_queue, K_FOREVER); in console_getline()
|
/Zephyr-latest/tests/bsim/bluetooth/ll/edtt/hci_test_app/src/ |
D | main.c | 277 struct net_buf *buf = k_fifo_get(&event_queue, K_FOREVER); in discard_event() 309 buf = k_fifo_get(&rx_queue, K_FOREVER); in service_events() 381 while ((buf = k_fifo_get(&event_queue, K_NO_WAIT))) { in flush_events() 404 buf = k_fifo_get(&event_queue, K_FOREVER); in get_event() 431 buf = k_fifo_get(&event_queue, K_FOREVER); in get_events() 470 while ((buf = k_fifo_get(&data_queue, K_NO_WAIT))) { in le_flush_data() 517 buf = k_fifo_get(&data_queue, K_FOREVER); in le_data_read() 587 while ((buf = k_fifo_get(&iso_data_queue, K_NO_WAIT))) { in le_flush_iso_data() 634 buf = k_fifo_get(&iso_data_queue, K_FOREVER); in le_iso_data_read()
|
/Zephyr-latest/tests/benchmarks/latency_measure/src/ |
D | fifo.c | 53 data = k_fifo_get(&fifo, K_NO_WAIT); in fifo_put_get_thread_entry() 78 data = k_fifo_get(&fifo, K_NO_WAIT); in fifo_put_get_thread_entry() 187 data = k_fifo_get(&fifo, K_FOREVER); in alt_thread_entry() 208 data = k_fifo_get(&fifo, K_FOREVER); in alt_thread_entry()
|
/Zephyr-latest/drivers/video/ |
D | video_mcux_smartdma.c | 76 data->queued_buf = k_fifo_get(&data->fifo_in, K_NO_WAIT); in nxp_video_sdma_callback() 117 data->queued_buf = k_fifo_get(&data->fifo_in, K_NO_WAIT); in nxp_video_sdma_stream_start() 189 *vbuf = k_fifo_get(&data->fifo_out, timeout); in nxp_video_sdma_dequeue() 212 while ((vbuf = k_fifo_get(&data->fifo_in, K_NO_WAIT))) { in nxp_video_sdma_flush()
|
D | video_emul_rx.c | 161 while ((vbuf = k_fifo_get(&data->fifo_in, K_NO_WAIT)) != NULL) { in emul_rx_worker() 214 *vbufp = k_fifo_get(&data->fifo_out, timeout); in emul_rx_dequeue() 245 while ((vbuf = k_fifo_get(&data->fifo_in, K_NO_WAIT))) { in emul_rx_flush()
|
D | video_sw_generator.c | 161 vbuf = k_fifo_get(&data->fifo_in, K_NO_WAIT); in __buffer_work() 204 *vbuf = k_fifo_get(&data->fifo_out, timeout); in video_sw_generator_dequeue() 224 while ((vbuf = k_fifo_get(&data->fifo_in, K_NO_WAIT))) { in video_sw_generator_flush()
|
/Zephyr-latest/samples/bluetooth/hci_uart/src/ |
D | main.c | 215 buf = k_fifo_get(&uart_tx_queue, K_NO_WAIT); in tx_isr() 258 buf = k_fifo_get(&tx_queue, K_FOREVER); in tx_thread() 408 buf = k_fifo_get(&rx_queue, K_FOREVER); in main()
|
/Zephyr-latest/tests/bluetooth/hci_uart_async/src/ |
D | test_hci_uart_async.c | 216 struct net_buf *buf = k_fifo_get(&drv_send_fifo, TIMEOUT_PRESUME_STUCK); in ZTEST() 244 struct net_buf *buf = k_fifo_get(&drv_send_fifo, TIMEOUT_PRESUME_STUCK); in ZTEST()
|
/Zephyr-latest/drivers/bluetooth/hci/ |
D | h5.c | 215 struct net_buf *buf = k_fifo_get(&h5->unack_queue, K_NO_WAIT); in process_unack() 352 while ((buf = k_fifo_get(&h5->tx_queue, K_NO_WAIT))) { in retx_timeout() 357 while ((buf = k_fifo_get(&h5->unack_queue, K_NO_WAIT))) { in retx_timeout() 366 while ((buf = k_fifo_get(&tmp_queue, K_NO_WAIT))) { in retx_timeout() 656 buf = k_fifo_get(&h5->tx_queue, K_FOREVER); in tx_thread() 692 buf = k_fifo_get(&h5->rx_queue, K_FOREVER); in rx_thread()
|
/Zephyr-latest/subsys/bluetooth/mesh/ |
D | adv.c | 184 return k_fifo_get(ev->fifo, K_NO_WAIT); in process_events() 228 return k_fifo_get(&bt_mesh_friend_queue, timeout); in bt_mesh_adv_get_by_tag() 233 return k_fifo_get(&bt_mesh_relay_queue, timeout); in bt_mesh_adv_get_by_tag()
|
/Zephyr-latest/samples/boards/st/bluetooth/interactive_gui/src/ |
D | main.c | 346 buf = k_fifo_get(&uart_tx_queue, K_NO_WAIT); in tx_isr() 387 buf = k_fifo_get(&tx_queue, K_FOREVER); in tx_thread() 453 buf = k_fifo_get(&rx_queue, K_FOREVER); in main()
|
/Zephyr-latest/tests/bluetooth/tester/src/ |
D | btp.c | 97 cmd = k_fifo_get(&cmds_queue, K_FOREVER); in cmd_handler() 163 new_buf = k_fifo_get(&avail_queue, K_NO_WAIT); in recv_cb() 239 buf = k_fifo_get(&avail_queue, K_NO_WAIT); in tester_init()
|