| /Zephyr-Core-3.5.0/subsys/usb/device/class/ |
| D | bt_h4.c | 25 static K_FIFO_DEFINE(tx_queue);
123 buf = net_buf_get(&tx_queue, K_FOREVER); in hci_tx_thread()
230 ret = bt_enable_raw(&tx_queue); in bt_h4_init()
|
| D | bluetooth.c | 31 static K_FIFO_DEFINE(tx_queue);
132 buf = net_buf_get(&tx_queue, K_FOREVER); in hci_tx_thread()
368 net_buf_put(&tx_queue, rsp); in vs_read_usb_transport_mode()
458 ret = bt_enable_raw(&tx_queue); in bluetooth_init()
|
| /Zephyr-Core-3.5.0/drivers/bluetooth/hci/ |
| D | h5.c | 92 struct k_fifo tx_queue; member
336 while ((buf = net_buf_get(&h5.tx_queue, K_NO_WAIT))) { in retx_timeout()
344 net_buf_put(&h5.tx_queue, buf); in retx_timeout()
351 net_buf_put(&h5.tx_queue, buf); in retx_timeout()
605 net_buf_put(&h5.tx_queue, buf); in h5_queue()
633 buf = net_buf_get(&h5.tx_queue, K_FOREVER); in tx_thread()
721 k_fifo_init(&h5.tx_queue); in h5_init()
|
| /Zephyr-Core-3.5.0/samples/net/wpan_serial/src/ |
| D | main.c | 50 static struct k_fifo tx_queue; variable
196 k_fifo_put(&tx_queue, pkt); in send_data()
398 pkt = k_fifo_get(&tx_queue, K_FOREVER); in tx_thread()
430 k_fifo_init(&tx_queue); in init_tx_queue()
519 k_fifo_put(&tx_queue, pkt); in net_recv_data()
|
| /Zephyr-Core-3.5.0/samples/net/wpanusb/src/ |
| D | wpanusb.c | 43 static struct k_fifo tx_queue; variable
162 k_fifo_put(&tx_queue, pkt); in wpanusb_vendor_handler()
307 pkt = k_fifo_get(&tx_queue, K_FOREVER); in tx_thread()
352 k_fifo_init(&tx_queue); in init_tx_queue()
|
| /Zephyr-Core-3.5.0/samples/bluetooth/hci_uart/src/ |
| D | main.c | 39 static K_FIFO_DEFINE(tx_queue);
182 net_buf_put(&tx_queue, buf); in rx_isr()
256 buf = net_buf_get(&tx_queue, K_FOREVER); in tx_thread()
|
| /Zephyr-Core-3.5.0/samples/bluetooth/hci_rpmsg/src/ |
| D | main.c | 36 static K_FIFO_DEFINE(tx_queue);
195 net_buf_put(&tx_queue, buf); in hci_rpmsg_rx()
208 buf = net_buf_get(&tx_queue, K_FOREVER); in tx_thread()
|
| /Zephyr-Core-3.5.0/include/zephyr/bluetooth/ |
| D | rfcomm.h | 80 struct k_fifo tx_queue; member
|
| D | l2cap.h | 197 struct k_fifo tx_queue; member
|
| /Zephyr-Core-3.5.0/subsys/net/l2/ppp/ |
| D | ppp_l2.c | 24 static K_FIFO_DEFINE(tx_queue);
344 k_fifo_put(&tx_queue, pkt); in ppp_queue_pkt()
357 pkt = k_fifo_get(&tx_queue, K_FOREVER); in tx_handler()
|
| /Zephyr-Core-3.5.0/drivers/i2s/ |
| D | i2s_nrfx.c | 27 struct k_msgq tx_queue; member
192 int ret = k_msgq_get(&drv_data->tx_queue, in get_next_tx_buffer()
383 while (k_msgq_get(&drv_data->tx_queue, in purge_queue()
605 ret = k_msgq_put(&drv_data->tx_queue, in i2s_nrfx_write()
937 k_msgq_init(&i2s_nrfx_data##idx.tx_queue, \
|
| /Zephyr-Core-3.5.0/subsys/bluetooth/host/ |
| D | rfcomm.c | 264 net_buf_put(&dlc->tx_queue, in rfcomm_dlc_disconnect()
550 buf = net_buf_get(&dlc->tx_queue, timeout); in rfcomm_dlc_tx_thread()
582 while ((buf = net_buf_get(&dlc->tx_queue, K_NO_WAIT))) { in rfcomm_dlc_tx_thread()
759 k_fifo_init(&dlc->tx_queue); in rfcomm_dlc_connected()
834 net_buf_put(&dlc->tx_queue, in rfcomm_dlc_close()
1448 net_buf_put(&dlc->tx_queue, buf); in bt_rfcomm_dlc_send()
1696 net_buf_put(&dlc->tx_queue, in bt_rfcomm_dlc_disconnect()
|
| D | att.c | 105 struct k_fifo tx_queue; member
137 struct k_fifo tx_queue; member
492 err = process_queue(chan, &chan->tx_queue); in bt_att_sent()
498 (void)process_queue(chan, &att->tx_queue); in bt_att_sent()
781 err = process_queue(chan, &att->tx_queue); in att_send_process()
798 net_buf_put(&chan->tx_queue, buf); in bt_att_chan_send_rsp()
3044 while ((buf = net_buf_get(&att->tx_queue, K_NO_WAIT))) { in att_reset()
3080 while ((buf = net_buf_get(&chan->tx_queue, K_NO_WAIT))) { in att_chan_detach()
3131 k_fifo_init(&att->tx_queue); in att_chan_attach()
3355 k_fifo_init(&chan->tx_queue); in att_chan_new()
[all …]
|
| D | conn_internal.h | 195 struct k_fifo tx_queue; member
|
| D | l2cap.c | 907 return net_buf_get(&ch->tx_queue, K_NO_WAIT); in l2cap_chan_le_get_tx_buf()
949 k_fifo_init(&chan->tx_queue); in l2cap_chan_tx_init()
992 while ((buf = net_buf_get(&le_chan->tx_queue, K_NO_WAIT))) { in l2cap_chan_destroy()
1883 (k_fifo_is_empty(&ch->tx_queue) && !ch->tx_buf)) { in l2cap_chan_tx_resume()
2265 while ((buf = net_buf_get(&le_chan->tx_queue, K_NO_WAIT))) { in l2cap_chan_shutdown()
3175 if (le_chan->tx_buf || !k_fifo_is_empty(&le_chan->tx_queue) || in bt_l2cap_chan_send_cb()
3178 net_buf_put(&le_chan->tx_queue, buf); in bt_l2cap_chan_send_cb()
3187 net_buf_put(&le_chan->tx_queue, buf); in bt_l2cap_chan_send_cb()
|
| D | conn.c | 486 net_buf_put(&conn->tx_queue, buf); in bt_conn_send_cb()
681 buf = net_buf_get(&conn->tx_queue, K_NO_WAIT); in send_frag()
774 while ((buf = net_buf_get(&conn->tx_queue, K_NO_WAIT))) { in conn_cleanup()
840 bool packets_waiting = !k_fifo_is_empty(&conn->tx_queue); in conn_prepare_events()
857 &conn->tx_queue); in conn_prepare_events()
919 buf = k_fifo_peek_head(&conn->tx_queue); in bt_conn_process_tx()
1052 k_fifo_init(&conn->tx_queue); in bt_conn_set_state()
|
| D | hci_core.c | 2732 tx_queue); in process_events()
|
