Home
last modified time | relevance | path

Searched refs:k_fifo_get (Results 1 – 25 of 106) sorted by relevance

12345

/Zephyr-latest/tests/kernel/fifo/fifo_timeout/src/
Dmain.c90 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/
Dmwfifo.c49 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()
Dlifo.c62 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/
Dtest_fifo_fail.c28 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()
Dtest_fifo_contexts.c53 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()
Dtest_fifo_cancel.c31 void *ret = k_fifo_get(pfifo, K_MSEC(500)); in tfifo_thread_thread()
Dtest_fifo_loop.c34 rx_data = k_fifo_get(pfifo, K_NO_WAIT); in tfifo_get()
/Zephyr-latest/tests/kernel/fifo/fifo_usage/src/
Dmain.c77 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/
Dpromiscuous.c30 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/
Dsmp.c139 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()
Dsmp_uart.c66 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/
DREADME.txt88 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/
Dmain.c212 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/
Dgetline.c29 cmd = k_fifo_get(&used_queue, K_FOREVER); in console_getline()
/Zephyr-latest/tests/bsim/bluetooth/ll/edtt/hci_test_app/src/
Dmain.c277 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/
Dfifo.c53 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/
Dvideo_mcux_smartdma.c76 data->queued_buf = k_fifo_get(&data->fifo_in, K_NO_WAIT); in nxp_video_sdma_callback()
121 data->queued_buf = k_fifo_get(&data->fifo_in, K_NO_WAIT); in nxp_video_sdma_set_stream()
185 *vbuf = k_fifo_get(&data->fifo_out, timeout); in nxp_video_sdma_dequeue()
208 while ((vbuf = k_fifo_get(&data->fifo_in, K_NO_WAIT))) { in nxp_video_sdma_flush()
Dvideo_emul_rx.c153 while ((vbuf = k_fifo_get(&data->fifo_in, K_NO_WAIT)) != NULL) { in emul_rx_worker()
206 *vbufp = k_fifo_get(&data->fifo_out, timeout); in emul_rx_dequeue()
234 while ((vbuf = k_fifo_get(&data->fifo_in, K_NO_WAIT))) { in emul_rx_flush()
Dvideo_esp32_dvp.c126 data->active_vbuf = k_fifo_get(&data->fifo_in, K_NO_WAIT); in video_esp32_dma_rx_done()
183 data->active_vbuf = k_fifo_get(&data->fifo_in, K_NO_WAIT); in video_esp32_set_stream()
319 *vbuf = k_fifo_get(&data->fifo_out, timeout); in video_esp32_dequeue()
355 while ((vbuf = k_fifo_get(&data->fifo_in, K_NO_WAIT)) != NULL) { in video_esp32_flush()
Dvideo_sw_generator.c156 vbuf = k_fifo_get(&data->fifo_in, K_NO_WAIT); in __buffer_work()
199 *vbuf = k_fifo_get(&data->fifo_out, timeout); in video_sw_generator_dequeue()
219 while ((vbuf = k_fifo_get(&data->fifo_in, K_NO_WAIT))) { in video_sw_generator_flush()
/Zephyr-latest/samples/bluetooth/hci_uart/src/
Dmain.c215 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/
Dtest_hci_uart_async.c216 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/
Dh5.c215 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/
Dadv.c184 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/tests/bluetooth/tester/src/
Dbtp.c94 cmd = k_fifo_get(&cmds_queue, K_FOREVER); in cmd_handler()
164 new_buf = k_fifo_get(&avail_queue, K_NO_WAIT); in recv_cb()
240 buf = k_fifo_get(&avail_queue, K_NO_WAIT); in tester_init()

12345