/Zephyr-latest/samples/bluetooth/hci_uart_3wire/src/ |
D | main.c | 95 struct k_fifo tx_queue; member 136 static K_FIFO_DEFINE(tx_queue); 348 while ((buf = k_fifo_get(&h5.tx_queue, K_NO_WAIT))) { in retx_timeout() 356 k_fifo_put(&h5.tx_queue, buf); in retx_timeout() 363 k_fifo_put(&h5.tx_queue, buf); in retx_timeout() 413 k_fifo_put(&tx_queue, buf); in h5_process_complete_packet() 570 k_fifo_put(&h5.tx_queue, buf); in h5_queue() 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() 643 &tx_queue, 0), in tx_thread() [all …]
|
/Zephyr-latest/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() 406 pkt = k_fifo_get(&tx_queue, K_FOREVER); in tx_thread() 438 k_fifo_init(&tx_queue); in init_tx_queue() 525 k_fifo_put(&tx_queue, pkt); in net_recv_data()
|
/Zephyr-latest/subsys/usb/device/class/ |
D | bluetooth.c | 31 static K_FIFO_DEFINE(tx_queue); 136 buf = k_fifo_get(&tx_queue, K_FOREVER); in hci_tx_thread() 376 k_fifo_put(&tx_queue, rsp); in vs_read_usb_transport_mode() 466 ret = bt_enable_raw(&tx_queue); in bluetooth_init()
|
/Zephyr-latest/drivers/bluetooth/hci/ |
D | h5.c | 92 struct k_fifo tx_queue; member 352 while ((buf = k_fifo_get(&h5->tx_queue, K_NO_WAIT))) { in retx_timeout() 360 k_fifo_put(&h5->tx_queue, buf); in retx_timeout() 367 k_fifo_put(&h5->tx_queue, buf); in retx_timeout() 622 k_fifo_put(&h5->tx_queue, buf); in h5_queue() 656 buf = k_fifo_get(&h5->tx_queue, K_FOREVER); in tx_thread() 754 k_fifo_init(&h5->tx_queue); in h5_init()
|
/Zephyr-latest/samples/bluetooth/hci_uart/src/ |
D | main.c | 39 static K_FIFO_DEFINE(tx_queue); 182 k_fifo_put(&tx_queue, buf); in rx_isr() 258 buf = k_fifo_get(&tx_queue, K_FOREVER); in tx_thread()
|
/Zephyr-latest/samples/bluetooth/hci_ipc/src/ |
D | main.c | 39 static K_FIFO_DEFINE(tx_queue); 198 k_fifo_put(&tx_queue, buf); in hci_ipc_rx() 211 buf = k_fifo_get(&tx_queue, K_FOREVER); in tx_thread()
|
/Zephyr-latest/include/zephyr/bluetooth/classic/ |
D | rfcomm.h | 104 struct k_fifo tx_queue; member
|
/Zephyr-latest/samples/boards/st/bluetooth/interactive_gui/src/ |
D | main.c | 40 static K_FIFO_DEFINE(tx_queue); 317 k_fifo_put(&tx_queue, buf); in rx_isr() 387 buf = k_fifo_get(&tx_queue, K_FOREVER); in tx_thread()
|
/Zephyr-latest/subsys/net/l2/ppp/ |
D | ppp_l2.c | 25 static K_FIFO_DEFINE(tx_queue); 435 k_fifo_put(&tx_queue, pkt); in ppp_queue_pkt() 452 pkt = k_fifo_get(&tx_queue, K_FOREVER); in tx_handler()
|
/Zephyr-latest/subsys/usb/device_next/class/ |
D | usbd_midi2.c | 154 struct ring_buf tx_queue; member 204 if (ring_buf_size_get(&data->tx_queue)) { in usbd_midi_class_request() 437 net_buf_add(buf, ring_buf_get(&data->tx_queue, buf->data, buf->size)); in usbd_midi_tx_work() 452 ring_buf_init(&data->tx_queue, MIDI_QUEUE_SIZE, data->tx_queue_buf); in usbd_midi_preinit() 472 if (buflen > ring_buf_space_get(&data->tx_queue)) { in usbd_midi_send() 479 ring_buf_put(&data->tx_queue, (const uint8_t *)&word, 4); in usbd_midi_send()
|
/Zephyr-latest/drivers/i2s/ |
D | i2s_nrfx.c | 32 struct k_msgq tx_queue; member 194 int ret = k_msgq_get(&drv_data->tx_queue, in get_next_tx_buffer() 402 while (k_msgq_get(&drv_data->tx_queue, in purge_queue() 628 ret = k_msgq_put(&drv_data->tx_queue, in i2s_nrfx_write() 965 k_msgq_init(&i2s_nrfx_data##idx.tx_queue, \
|
/Zephyr-latest/include/zephyr/bluetooth/ |
D | l2cap.h | 231 struct k_fifo tx_queue; member
|
/Zephyr-latest/subsys/bluetooth/host/classic/ |
D | rfcomm.c | 280 k_fifo_put(&dlc->tx_queue, net_buf_alloc(&dummy_pool, K_NO_WAIT)); in rfcomm_dlc_disconnect() 601 buf = k_fifo_get(&dlc->tx_queue, timeout); in rfcomm_dlc_tx_thread() 636 while ((buf = k_fifo_get(&dlc->tx_queue, K_NO_WAIT))) { in rfcomm_dlc_tx_thread() 814 k_fifo_init(&dlc->tx_queue); in rfcomm_dlc_connected() 896 k_fifo_put(&dlc->tx_queue, in rfcomm_dlc_close() 1514 k_fifo_put(&dlc->tx_queue, buf); in bt_rfcomm_dlc_send() 1773 k_fifo_put(&dlc->tx_queue, in bt_rfcomm_dlc_disconnect()
|
/Zephyr-latest/subsys/bluetooth/host/ |
D | att.c | 110 struct k_fifo tx_queue; member 145 struct k_fifo tx_queue; member 618 err = process_queue(chan, &chan->tx_queue); in bt_att_sent() 624 (void)process_queue(chan, &att->tx_queue); in bt_att_sent() 799 err = process_queue(chan, &att->tx_queue); in att_send_process() 816 k_fifo_put(&chan->tx_queue, buf); in bt_att_chan_send_rsp() 3126 while ((buf = k_fifo_get(&att->tx_queue, K_NO_WAIT))) { in att_reset() 3161 while ((buf = k_fifo_get(&chan->tx_queue, K_NO_WAIT))) { in att_chan_detach() 3216 k_fifo_init(&att->tx_queue); in att_chan_attach() 3438 k_fifo_init(&chan->tx_queue); in att_chan_new() [all …]
|
D | l2cap.c | 267 struct net_buf *buf = k_fifo_get(&le_chan->tx_queue, K_NO_WAIT); in bt_l2cap_chan_del() 423 k_fifo_init(&le_chan->tx_queue); in bt_l2cap_connected() 753 k_fifo_put(&le_chan->tx_queue, pdu); in bt_l2cap_send_pdu() 763 return !k_fifo_is_empty(&lechan->tx_queue); in chan_has_data() 916 struct net_buf *pdu = k_fifo_peek_head(&lechan->tx_queue); in l2cap_data_pull() 972 __maybe_unused struct net_buf *b = k_fifo_get(&lechan->tx_queue, K_NO_WAIT); in l2cap_data_pull() 1274 k_fifo_init(&chan->tx_queue); in l2cap_chan_tx_init() 2278 while ((buf = k_fifo_get(&le_chan->tx_queue, K_NO_WAIT))) { in l2cap_chan_shutdown() 3277 k_fifo_put(&le_chan->tx_queue, buf); in bt_l2cap_dyn_chan_send()
|