| /freebsd-src/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()
340 mbq_safe_init(&kring->rx_queue); in generic_netmap_register()
423 mbq_safe_fini(&kring->rx_queue); in generic_netmap_register()
891 } else if (unlikely(mbq_len(&kring->rx_queue) > na->num_rx_desc)) { in generic_rx_handler()
895 mbq_safe_enqueue(&kring->rx_queue, m); in generic_rx_handler()
989 mbq_lock(&kring->rx_queue); in generic_netmap_rxsync()
991 m = mbq_peek(&kring->rx_queue); in generic_netmap_rxsync()
1003 mbq_dequeue(&kring->rx_queue); in generic_netmap_rxsync()
1020 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()
1283 * Called under kring->rx_queue.lock on the sw rx ring.
1371 * They have been put in kring->rx_queue by netmap_transmit().
1372 * We protect access to the kring using kring->rx_queue.lock
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 | 404 * RX rings attached to the host stack use an mbq (rx_queue) on both
508 struct mbq rx_queue; /* intercepted rx mbufs. */
507 struct mbq rx_queue; /* intercepted rx mbufs. */ global() member
|
| /freebsd-src/sys/dev/qlnx/qlnxe/ |
| H A D | ecore_ll2.c | 50 #define ECORE_LL2_RX_REGISTERED(ll2) ((ll2)->rx_queue.b_cb_registred)
336 struct ecore_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue; in ecore_ll2_handle_slowpath()
372 struct ecore_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue; in ecore_ll2_rxq_handle_completion()
423 struct ecore_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue; in ecore_ll2_rxq_completion()
475 p_rx = &p_ll2_conn->rx_queue; in ecore_ll2_rxq_flush()
540 struct ecore_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue; in ecore_ll2_lb_rxq_handler()
831 struct ecore_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue; in ecore_sp_ll2_rx_queue_start()
1058 &p_ll2_info->rx_queue.rxq_chain, OSAL_NULL); in ecore_ll2_acquire_connection_rx()
1065 capacity = ecore_chain_get_capacity(&p_ll2_info->rx_queue.rxq_chain); in ecore_ll2_acquire_connection_rx()
1074 p_ll2_info->rx_queue.descq_array = p_descq; in ecore_ll2_acquire_connection_rx()
[all …]
|
| H A D | ecore_ll2.h | 123 struct ecore_ll2_rx_queue rx_queue; member
|
| /freebsd-src/sys/arm64/broadcom/genet/ |
| H A D | if_genet.c | 159 struct rx_queue { struct
198 struct rx_queue rx_queue[NRXQUEUE]; member
221 static int gen_rxintr(struct gen_softc *sc, struct rx_queue *q);
224 static int gen_newbuf_rx(struct gen_softc *sc, struct rx_queue *q, int index);
225 static int gen_mapbuf_rx(struct gen_softc *sc, struct rx_queue *q, int index,
740 struct rx_queue *q; in gen_init_rxring()
744 q = &sc->rx_queue[queue]; in gen_init_rxring()
773 gen_newbuf_rx(sc, &sc->rx_queue[DEF_RXQUEUE], i); in gen_init_rxring()
815 sc->rx_queue[ in gen_init_rxrings()
160 hwindexrx_queue global() argument
161 nentriesrx_queue global() argument
162 currx_queue global() argument
163 prod_idxrx_queue global() argument
164 cons_idxrx_queue global() argument
165 entriesrx_queue global() argument
[all...] |
| /freebsd-src/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-src/sys/contrib/dev/rtw88/ |
| H A D | usb.h | 83 struct sk_buff_head rx_queue; member
|
| H A D | usb.c | 553 skb = skb_dequeue(&rtwusb->rx_queue); in rtw_usb_rx_resubmit()
569 if (skb_queue_len(&rtwusb->rx_queue) >= RTW_USB_MAX_RXQ_LEN) { in rtw_usb_read_port_complete()
570 dev_dbg_ratelimited(rtwdev->dev, "failed to get rx_queue, overflow\n"); in rtw_usb_read_port_complete()
622 skb_queue_tail(&rtwusb->rx_queue, skb); in rtw_usb_free_rx_bufs()
752 skb_queue_head_init(&rtwusb->rx_queue); in rtw_usb_init_tx()
775 skb_queue_purge(&rtwusb->rx_queue); in rtw_usb_intf_init()
|
| /freebsd-src/sys/dev/enetc/ |
| H A D | if_enetc.c | 998 struct enetc_rx_queue *rx_queue; in enetc_msix_intr_assign()
1009 rx_queue = &sc->rx_queues[i]; in enetc_msix_intr_assign()
1012 &rx_queue->irq, vector + 1, IFLIB_INTR_RXTX, in enetc_msix_intr_assign()
1013 NULL, rx_queue, i, irq_name); in enetc_msix_intr_assign()
1035 rx_queue = &sc->rx_queues[i]; in enetc_msix_intr_assign()
1036 iflib_irq_free(ctx, &rx_queue->irq); in enetc_msix_intr_assign()
999 struct enetc_rx_queue *rx_queue; enetc_msix_intr_assign() local
|
| /freebsd-src/sys/contrib/dev/rtw89/ |
| H A D | core.c | 2174 skb_queue_walk_safe(&rtwdev->ppdu_sts.rx_queue[band], skb_ppdu, tmp) { in rtw89_core_free_sta_pending_roc_tx()
2175 skb_unlink(skb_ppdu, &rtwdev->ppdu_sts.rx_queue[band]); in rtw89_core_free_sta_pending_roc_tx()
2502 skb_queue_walk_safe(&ppdu_sts->rx_queue[band], skb_ppdu, tmp) { in rtw89_roc_start()
2503 skb_unlink(skb_ppdu, &ppdu_sts->rx_queue[band]); in rtw89_roc_start()
2533 skb_queue_tail(&ppdu_sts->rx_queue[band], skb); in rtw89_roc_end()
4073 skb_queue_head_init(&rtwdev->ppdu_sts.rx_queue[i]);
|
| H A D | core.h | 5116 struct sk_buff_head rx_queue[RTW89_PHY_MAX]; in rtw89_chip_cfg_ctrl_path()
4194 struct sk_buff_head rx_queue[RTW89_PHY_MAX]; global() member
|
| /freebsd-src/sys/contrib/dev/iwlwifi/pcie/ |
| H A D | trans.c | 3098 DEBUGFS_READ_FILE_OPS(rx_queue);
3122 DEBUGFS_ADD_FILE(rx_queue, dir, 0400); in iwl_trans_pcie_dump_rbs()
|