| /Zephyr-4.2.1/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-4.2.1/samples/drivers/uart/async_api/src/ |
| D | main.c | 26 struct k_fifo tx_queue; variable
51 buf = k_fifo_get(&tx_queue, K_NO_WAIT); in uart_callback()
117 k_fifo_put(&tx_queue, tx_buf); in main()
|
| /Zephyr-4.2.1/samples/net/wpan_serial/src/ |
| D | main.c | 49 static struct k_fifo tx_queue; variable
195 k_fifo_put(&tx_queue, pkt); in send_data()
405 pkt = k_fifo_get(&tx_queue, K_FOREVER); in tx_thread()
437 k_fifo_init(&tx_queue); in init_tx_queue()
524 k_fifo_put(&tx_queue, pkt); in net_recv_data()
|
| /Zephyr-4.2.1/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()
604 k_fifo_put(&h5->tx_queue, buf); in h5_queue()
638 buf = k_fifo_get(&h5->tx_queue, K_FOREVER); in tx_thread()
736 k_fifo_init(&h5->tx_queue); in h5_init()
|
| /Zephyr-4.2.1/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-4.2.1/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-4.2.1/subsys/usb/device/class/ |
| D | bluetooth.c | 31 static K_FIFO_DEFINE(tx_queue);
138 buf = k_fifo_get(&tx_queue, K_FOREVER); in hci_tx_thread()
368 ret = bt_enable_raw(&tx_queue); in bluetooth_init()
|
| /Zephyr-4.2.1/drivers/i2s/ |
| D | i2s_renesas_ra_ssie.c | 60 struct k_msgq tx_queue; member
249 while (k_msgq_get(&dev_data->tx_queue, &msg_item, K_NO_WAIT) == 0) { in drop_queue()
293 ret = k_msgq_get(&dev_data->tx_queue, &msg_item, K_NO_WAIT); in renesas_ra_ssie_tx_start_transfer()
322 ret = k_msgq_get(&dev_data->tx_queue, &msg_item_tx, K_NO_WAIT); in renesas_ra_ssie_tx_rx_start_transfer()
360 if (k_msgq_num_used_get(&dev_data->tx_queue) == 0) { in renesas_ra_ssie_idle_dir_both_handle()
457 if (k_msgq_num_used_get(&dev_data->tx_queue) == 0) { in renesas_ra_ssie_tx_callback()
464 ret = k_msgq_get(&dev_data->tx_queue, &msg_item, K_NO_WAIT); in renesas_ra_ssie_tx_callback()
823 ret = k_msgq_put(&dev_data->tx_queue, &msg_item, K_MSEC(dev_data->tx_stream.cfg.timeout)); in i2s_renesas_ra_ssie_write()
918 if (k_msgq_num_used_get(&dev_data->tx_queue) > 0) { in i2s_renesas_ra_ssie_trigger()
977 k_msgq_init(&dev_data->tx_queue, (char *)dev_data->tx_msgs, sizeof(struct i2s_buf), in i2s_renesas_ra_ssie_init()
|
| D | i2s_nrfx.c | 35 struct k_msgq tx_queue; member
94 int ret = k_msgq_get(&drv_data->tx_queue, in get_next_tx_buffer()
302 while (k_msgq_get(&drv_data->tx_queue, in purge_queue()
527 ret = k_msgq_put(&drv_data->tx_queue, in i2s_nrfx_write()
858 k_msgq_init(&i2s_nrfx_data##inst.tx_queue, (char *)tx_msgs##inst, \
|
| D | i2s_nrf_tdm.c | 128 struct k_msgq tx_queue; member
284 int ret = k_msgq_get(&drv_data->tx_queue, &buf, K_NO_WAIT); in get_next_tx_buffer()
435 while (k_msgq_get(&drv_data->tx_queue, &buf, K_NO_WAIT) == 0) { in purge_queue()
704 ret = k_msgq_put(&drv_data->tx_queue, &buf, SYS_TIMEOUT_MS(drv_data->tx.cfg.timeout)); in tdm_nrf_write()
1228 k_msgq_init(&tdm_nrf_data##idx.tx_queue, (char *)tx_msgs##idx, \
|
| /Zephyr-4.2.1/samples/boards/st/bluetooth/interactive_gui/src/ |
| D | main.c | 40 static K_FIFO_DEFINE(tx_queue);
316 k_fifo_put(&tx_queue, buf); in rx_isr()
386 buf = k_fifo_get(&tx_queue, K_FOREVER); in tx_thread()
|
| /Zephyr-4.2.1/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()
443 net_buf_add(buf, ring_buf_get(&data->tx_queue, buf->data, buf->size)); in usbd_midi_tx_work()
458 ring_buf_init(&data->tx_queue, MIDI_QUEUE_SIZE, data->tx_queue_buf); in usbd_midi_preinit()
478 if (buflen > ring_buf_space_get(&data->tx_queue)) { in usbd_midi_send()
485 ring_buf_put(&data->tx_queue, (const uint8_t *)&word, 4); in usbd_midi_send()
|
| /Zephyr-4.2.1/include/zephyr/bluetooth/classic/ |
| D | rfcomm.h | 104 struct k_fifo tx_queue; member
|
| /Zephyr-4.2.1/subsys/net/l2/ppp/ |
| D | ppp_l2.c | 26 static K_FIFO_DEFINE(tx_queue);
460 k_fifo_put(&tx_queue, pkt); in ppp_queue_pkt()
477 pkt = k_fifo_get(&tx_queue, K_FOREVER); in tx_handler()
|
| /Zephyr-4.2.1/subsys/bluetooth/host/classic/ |
| D | rfcomm.c | 641 if (k_fifo_is_empty(&dlc->tx_queue) == true) { in rfcomm_dlc_tx_worker()
650 buf = k_fifo_get(&dlc->tx_queue, K_NO_WAIT); in rfcomm_dlc_tx_worker()
660 if (k_fifo_is_empty(&dlc->tx_queue) == false) { in rfcomm_dlc_tx_worker()
678 while ((buf = k_fifo_get(&dlc->tx_queue, K_NO_WAIT))) { in rfcomm_dlc_tx_worker()
888 k_fifo_init(&dlc->tx_queue); in rfcomm_dlc_connected()
1575 k_fifo_put(&dlc->tx_queue, buf); in bt_rfcomm_dlc_send()
|
| /Zephyr-4.2.1/include/zephyr/bluetooth/ |
| D | l2cap.h | 294 struct k_fifo tx_queue; member
|
| /Zephyr-4.2.1/subsys/bluetooth/host/ |
| D | att.c | 122 struct k_fifo tx_queue; member
152 struct k_fifo tx_queue; member
676 err = process_queue(chan, &chan->tx_queue); in bt_att_sent()
682 (void)process_queue(chan, &att->tx_queue); in bt_att_sent()
868 err = process_queue(chan, &att->tx_queue); in att_send_process()
885 k_fifo_put(&chan->tx_queue, buf); in bt_att_chan_send_rsp()
3148 while ((buf = k_fifo_get(&att->tx_queue, K_NO_WAIT))) { in att_reset()
3183 while ((buf = k_fifo_get(&chan->tx_queue, K_NO_WAIT))) { in att_chan_detach()
3238 k_fifo_init(&att->tx_queue); in att_chan_attach()
3461 k_fifo_init(&chan->tx_queue); in att_chan_new()
[all …]
|
| D | l2cap.c | 281 while ((buf = k_fifo_get(&le_chan->tx_queue, K_NO_WAIT))) { in l2cap_chan_del()
448 k_fifo_init(&le_chan->tx_queue); in bt_l2cap_connected()
802 k_fifo_put(&le_chan->tx_queue, pdu); in bt_l2cap_send_pdu()
812 return !k_fifo_is_empty(&lechan->tx_queue); in chan_has_data()
965 struct net_buf *fifo_pdu = k_fifo_peek_head(&lechan->tx_queue); in l2cap_data_pull()
1025 fifo_pdu = k_fifo_get(&lechan->tx_queue, K_NO_WAIT); in l2cap_data_pull()
1331 k_fifo_init(&chan->tx_queue); in l2cap_chan_tx_init()
2399 while ((buf = k_fifo_get(&le_chan->tx_queue, K_NO_WAIT))) { in l2cap_chan_shutdown()
3407 k_fifo_put(&le_chan->tx_queue, buf); in bt_l2cap_dyn_chan_send()
|
