| /freebsd-14.2/sys/dev/netmap/ |
| H A D | netmap_generic.c | 244 mbq_safe_purge(&kring->rx_queue); in generic_netmap_unregister()
269 mbq_safe_fini(&kring->rx_queue); in generic_netmap_unregister()
338 mbq_safe_init(&kring->rx_queue); in generic_netmap_register()
421 mbq_safe_fini(&kring->rx_queue); in generic_netmap_register()
876 } else if (unlikely(mbq_len(&kring->rx_queue) > na->num_rx_desc)) { in generic_rx_handler()
880 mbq_safe_enqueue(&kring->rx_queue, m); in generic_rx_handler()
974 mbq_lock(&kring->rx_queue); in generic_netmap_rxsync()
976 m = mbq_peek(&kring->rx_queue); in generic_netmap_rxsync()
988 mbq_dequeue(&kring->rx_queue); in generic_netmap_rxsync()
1005 mbq_unlock(&kring->rx_queue); in generic_netmap_rxsync()
|
| H A D | netmap.c | 979 struct mbq *q = &NMR(na, NR_RX)[i]->rx_queue; in netmap_hw_krings_delete()
1387 struct mbq *q = &kring->rx_queue, fq; in netmap_rxsync_from_host()
4201 mbq_safe_init(&NMR(na, NR_RX)[i]->rx_queue); in netmap_hw_krings_create()
4297 q = &kring->rx_queue; in netmap_transmit()
|
| H A D | netmap_kern.h | 507 struct mbq rx_queue; /* intercepted rx mbufs. */ member
|
| /freebsd-14.2/sys/netlink/ |
| H A D | netlink_io.c | 267 if (queue_empty(&nlp->rx_queue)) { in nl_process_received_one()
279 queue_push(&nlp->rx_queue, sbcut_locked(sb, avail)); in nl_process_received_one()
290 while (!queue_empty(&nlp->rx_queue)) { in nl_process_received_one()
291 struct mbuf *m = queue_pop(&nlp->rx_queue); in nl_process_received_one()
295 queue_push_head(&nlp->rx_queue, m); in nl_process_received_one()
327 STAILQ_INIT(&nlp->rx_queue.head); in nl_init_io()
334 queue_free(&nlp->rx_queue); in nl_free_io()
|
| H A D | netlink_var.h | 68 struct nl_io_queue rx_queue; member
|
| /freebsd-14.2/sys/dev/qlnx/qlnxe/ |
| H A D | ecore_ll2.c | 475 p_rx = &p_ll2_conn->rx_queue; in ecore_ll2_rxq_flush()
1058 &p_ll2_info->rx_queue.rxq_chain, OSAL_NULL); in ecore_ll2_acquire_connection_rx()
1074 p_ll2_info->rx_queue.descq_array = p_descq; in ecore_ll2_acquire_connection_rx()
1082 &p_ll2_info->rx_queue.rcq_chain, OSAL_NULL); in ecore_ll2_acquire_connection_rx()
1344 &p_ll2_info->rx_queue.rx_sb_index, in ecore_ll2_acquire_connection()
1345 &p_ll2_info->rx_queue.p_fw_cons); in ecore_ll2_acquire_connection()
1346 p_ll2_info->rx_queue.b_cb_registred = true; in ecore_ll2_acquire_connection()
1426 p_rx = &p_ll2_conn->rx_queue; in ecore_ll2_establish_connection()
1588 p_rx = &p_ll2_conn->rx_queue; in ecore_ll2_post_rx_buffer()
1972 p_ll2_conn->rx_queue.b_cb_registred = false; in ecore_ll2_release_connection()
[all …]
|
| H A D | ecore_ll2.h | 123 struct ecore_ll2_rx_queue rx_queue; member
|
| /freebsd-14.2/sys/arm64/broadcom/genet/ |
| H A D | if_genet.c | 160 struct rx_queue { struct
199 struct rx_queue rx_queue[NRXQUEUE]; member
222 static int gen_rxintr(struct gen_softc *sc, struct rx_queue *q);
744 struct rx_queue *q; in gen_init_rxring()
748 q = &sc->rx_queue[queue]; in gen_init_rxring()
777 gen_newbuf_rx(sc, &sc->rx_queue[DEF_RXQUEUE], i); in gen_init_rxring()
819 sc->rx_queue[i].queue = i; in gen_init_rxrings()
829 sc->rx_queue[DEF_RXQUEUE].hwindex = GENET_DMA_DEFAULT_QUEUE; in gen_init_rxrings()
1329 gen_rxintr(sc, &sc->rx_queue[DEF_RXQUEUE]); in gen_intr()
1341 gen_rxintr(struct gen_softc *sc, struct rx_queue *q) in gen_rxintr()
[all …]
|
| /freebsd-14.2/sys/contrib/dev/rtw88/ |
| H A D | usb.h | 83 struct sk_buff_head rx_queue; member
|
| H A D | usb.c | 511 skb = skb_dequeue(&rtwusb->rx_queue); in rtw_usb_rx_handler()
527 if (skb_queue_len(&rtwusb->rx_queue) >= RTW_USB_MAX_RXQ_LEN) { in rtw_usb_rx_handler()
580 skb_queue_tail(&rtwusb->rx_queue, skb); in rtw_usb_read_port_complete()
714 skb_queue_head_init(&rtwusb->rx_queue); in rtw_usb_init_rx()
731 skb_queue_purge(&rtwusb->rx_queue); in rtw_usb_deinit_rx()
|
| /freebsd-14.2/sys/ofed/drivers/infiniband/ulp/sdp/ |
| H A D | sdp_proc.c | 129 __u32 rx_queue, tx_queue; in sdp_seq_show() local
146 rx_queue = rcv_nxt(sdp_sk(sk)) - sdp_sk(sk)->copied_seq; in sdp_seq_show()
151 rx_queue, tx_queue, sk->sk_state); in sdp_seq_show()
|
| /freebsd-14.2/sys/dev/enetc/ |
| H A D | if_enetc.c | 1000 struct enetc_rx_queue *rx_queue; in enetc_msix_intr_assign() local
1011 rx_queue = &sc->rx_queues[i]; in enetc_msix_intr_assign()
1014 &rx_queue->irq, vector + 1, IFLIB_INTR_RXTX, in enetc_msix_intr_assign()
1015 NULL, rx_queue, i, irq_name); in enetc_msix_intr_assign()
1037 rx_queue = &sc->rx_queues[i]; in enetc_msix_intr_assign()
1038 iflib_irq_free(ctx, &rx_queue->irq); in enetc_msix_intr_assign()
|
| /freebsd-14.2/sys/contrib/dev/rtw89/ |
| H A D | core.c | 1777 skb_queue_walk_safe(&rtwdev->ppdu_sts.rx_queue[band], skb_ppdu, tmp) { in rtw89_core_rx_pending_skb()
1778 skb_unlink(skb_ppdu, &rtwdev->ppdu_sts.rx_queue[band]); in rtw89_core_rx_pending_skb()
2023 skb_queue_walk_safe(&ppdu_sts->rx_queue[band], skb_ppdu, tmp) { in rtw89_core_flush_ppdu_rx_queue()
2024 skb_unlink(skb_ppdu, &ppdu_sts->rx_queue[band]); in rtw89_core_flush_ppdu_rx_queue()
2054 skb_queue_tail(&ppdu_sts->rx_queue[band], skb); in rtw89_core_rx()
3441 skb_queue_head_init(&rtwdev->ppdu_sts.rx_queue[i]); in rtw89_core_ppdu_sts_init()
|
| H A D | core.h | 4194 struct sk_buff_head rx_queue[RTW89_PHY_MAX]; member
|
| /freebsd-14.2/sys/contrib/dev/iwlwifi/pcie/ |
| H A D | trans.c | 3055 DEBUGFS_READ_FILE_OPS(rx_queue);
3079 DEBUGFS_ADD_FILE(rx_queue, dir, 0400); in iwl_trans_pcie_dbgfs_register()
|