Home
last modified time | relevance | path

Searched refs:rx_queue (Results 1 – 25 of 32) sorted by relevance

12

/Zephyr-4.3.0/include/zephyr/bluetooth/
Dhci_raw.h51 int bt_enable_raw(struct k_fifo *rx_queue);
/Zephyr-4.3.0/drivers/ieee802154/
Dieee802154_cc13xx_cc26xx_subg.h46 dataQueue_t rx_queue; member
Dieee802154_cc13xx_cc26xx.h72 dataQueue_t rx_queue; member
/Zephyr-4.3.0/subsys/usb/device/class/
Dbluetooth.c30 static K_FIFO_DEFINE(rx_queue);
188 buf = k_fifo_get(&rx_queue, K_FOREVER); in hci_rx_thread()
254 k_fifo_put(&rx_queue, buf); in acl_read_cb()
335 k_fifo_put(&rx_queue, buf); in bluetooth_class_handler()
/Zephyr-4.3.0/samples/bluetooth/hci_spi/src/
Dmain.c271 static K_FIFO_DEFINE(rx_queue); in main()
279 err = bt_enable_raw(&rx_queue); in main()
306 buf = k_fifo_get(&rx_queue, K_FOREVER); in main()
/Zephyr-4.3.0/samples/bluetooth/hci_uart_3wire/src/
Dmain.c96 struct k_fifo rx_queue; member
407 k_fifo_put(&h5.rx_queue, buf); in h5_process_complete_packet()
691 buf = k_fifo_get(&h5.rx_queue, K_FOREVER); in rx_thread()
772 static K_FIFO_DEFINE(rx_queue); in main()
779 bt_enable_raw(&rx_queue); in main()
790 k_fifo_init(&h5.rx_queue); in main()
810 buf = k_fifo_get(&rx_queue, K_FOREVER); in main()
/Zephyr-4.3.0/subsys/modem/backends/
Dmodem_backend_uart_async_hwfc.c181 err = k_msgq_put(&backend->async.rx_queue, &rx_event, K_NO_WAIT); in modem_backend_uart_async_hwfc_event_handler()
318 for (int i = 0; i < k_msgq_num_used_get(&backend->async.rx_queue); i++) { in modem_backend_uart_async_hwfc_receive()
319 if (k_msgq_peek_at(&backend->async.rx_queue, &rx_event, i)) { in modem_backend_uart_async_hwfc_receive()
331 if (k_msgq_get(&backend->async.rx_queue, &backend->async.rx_event, in modem_backend_uart_async_hwfc_receive()
349 k_msgq_num_used_get(&backend->async.rx_queue) != 0) { in modem_backend_uart_async_hwfc_receive()
452 k_msgq_init(&backend->async.rx_queue, (char *)&backend->async.rx_queue_buf, in modem_backend_uart_async_init()
/Zephyr-4.3.0/subsys/bluetooth/host/
Dhci_raw.c188 int bt_enable_raw(struct k_fifo *rx_queue) in bt_enable_raw() argument
194 raw_rx = rx_queue; in bt_enable_raw()
/Zephyr-4.3.0/samples/bluetooth/hci_ipc/src/
Dmain.c380 static K_FIFO_DEFINE(rx_queue); in main()
385 bt_enable_raw(&rx_queue); in main()
411 buf = k_fifo_get(&rx_queue, K_FOREVER); in main()
/Zephyr-4.3.0/samples/net/wpan_serial/src/
Dmain.c44 static struct k_fifo rx_queue; variable
163 k_fifo_put(&rx_queue, pkt_curr); in interrupt_handler()
314 pkt = k_fifo_get(&rx_queue, K_FOREVER); in rx_thread()
427 k_fifo_init(&rx_queue); in init_rx_queue()
/Zephyr-4.3.0/samples/bluetooth/hci_uart/src/
Dmain.c404 static K_FIFO_DEFINE(rx_queue); in main()
411 bt_enable_raw(&rx_queue); in main()
450 buf = k_fifo_get(&rx_queue, K_FOREVER); in main()
/Zephyr-4.3.0/include/zephyr/modem/backend/
Duart.h50 struct k_msgq rx_queue; member
/Zephyr-4.3.0/samples/boards/st/bluetooth/interactive_gui/src/
Dmain.c436 static K_FIFO_DEFINE(rx_queue); in main()
443 bt_enable_raw(&rx_queue); in main()
453 buf = k_fifo_get(&rx_queue, K_FOREVER); in main()
/Zephyr-4.3.0/drivers/audio/
Ddmic_mcux.c39 struct k_msgq *rx_queue; member
190 k_msgq_purge(drv_data->rx_queue); in dmic_mcux_stop()
250 ret = k_msgq_put(drv_data->rx_queue, &done_buffer, K_NO_WAIT); in dmic_mcux_dma_cb()
651 ret = k_msgq_get(drv_data->rx_queue, buffer, SYS_TIMEOUT_MS(timeout)); in dmic_mcux_read()
714 .rx_queue = &dmic_msgq##idx, \
Ddmic_nrfx_pdm.c54 struct k_msgq rx_queue; member
193 ret = k_msgq_put(&drv_data->rx_queue, in event_handler()
456 ret = k_msgq_get(&drv_data->rx_queue, buffer, SYS_TIMEOUT_MS(timeout)); in dmic_nrfx_pdm_read()
519 k_msgq_init(&dmic_nrfx_pdm_data##inst.rx_queue, (char *)rx_msgs##inst, \
/Zephyr-4.3.0/drivers/i2s/
Di2s_nrfx.c37 struct k_msgq rx_queue; member
214 int ret = k_msgq_put(&drv_data->rx_queue, in data_handler()
310 while (k_msgq_get(&drv_data->rx_queue, in purge_queue()
484 ret = k_msgq_get(&drv_data->rx_queue, in i2s_nrfx_read()
860 k_msgq_init(&i2s_nrfx_data##inst.rx_queue, (char *)rx_msgs##inst, \
Di2s_renesas_ra_ssie.c59 struct k_msgq rx_queue; member
255 while (k_msgq_get(&dev_data->rx_queue, &msg_item, K_NO_WAIT) == 0) { in drop_queue()
405 ret = k_msgq_put(&dev_data->rx_queue, &msg_item_rx, K_NO_WAIT); in renesas_ra_ssie_rx_callback()
848 ret = k_msgq_get(&dev_data->rx_queue, &msg_item, in i2s_renesas_ra_ssie_read()
979 k_msgq_init(&dev_data->rx_queue, (char *)dev_data->rx_msgs, sizeof(struct i2s_buf), in i2s_renesas_ra_ssie_init()
/Zephyr-4.3.0/drivers/bluetooth/hci/
Dh5.c93 struct k_fifo rx_queue; member
411 k_fifo_put(&h5->rx_queue, buf); in h5_process_complete_packet()
674 buf = k_fifo_get(&h5->rx_queue, K_FOREVER); in rx_thread()
743 k_fifo_init(&h5->rx_queue); in h5_init()
/Zephyr-4.3.0/tests/bsim/bluetooth/host/l2cap/reassembly/peer/src/
Dpeer.c46 static K_FIFO_DEFINE(rx_queue);
333 buf = k_fifo_get(&rx_queue, K_FOREVER); in rx_thread()
508 bt_enable_raw(&rx_queue); in init_tinyhost()
/Zephyr-4.3.0/tests/bsim/bluetooth/host/misc/disconnect/tester/src/
Dmain.c49 static K_FIFO_DEFINE(rx_queue);
346 buf = k_fifo_get(&rx_queue, K_FOREVER); in rx_thread()
534 bt_enable_raw(&rx_queue); in init_tinyhost()
/Zephyr-4.3.0/tests/bsim/bluetooth/host/l2cap/split/tester/src/
Dmain.c37 static K_FIFO_DEFINE(rx_queue);
349 buf = k_fifo_get(&rx_queue, K_FOREVER); in rx_thread()
598 bt_enable_raw(&rx_queue); in test_procedure_0()
/Zephyr-4.3.0/tests/bsim/bluetooth/host/att/pipeline/tester/src/
Dmain.c56 static K_FIFO_DEFINE(rx_queue);
392 buf = k_fifo_get(&rx_queue, K_FOREVER); in rx_thread()
582 bt_enable_raw(&rx_queue); in init_tinyhost()
/Zephyr-4.3.0/tests/bsim/bluetooth/host/att/sequential/tester/src/
Dmain.c51 static K_FIFO_DEFINE(rx_queue);
369 buf = k_fifo_get(&rx_queue, K_FOREVER); in rx_thread()
588 bt_enable_raw(&rx_queue); in init_tinyhost()
/Zephyr-4.3.0/tests/bsim/bluetooth/host/misc/hfc_multilink/tester/src/
Dtester.c39 static K_FIFO_DEFINE(rx_queue);
360 buf = k_fifo_get(&rx_queue, K_FOREVER); in rx_thread()
625 bt_enable_raw(&rx_queue); in entrypoint_tester()
/Zephyr-4.3.0/tests/bsim/bluetooth/ll/edtt/hci_test_app/src/
Dmain.c197 static K_FIFO_DEFINE(rx_queue);
309 buf = k_fifo_get(&rx_queue, K_FOREVER); in service_events()
770 err = bt_enable_raw(&rx_queue); in main()

12