Home
last modified time | relevance | path

Searched refs:rx_queue (Results 1 – 18 of 18) sorted by relevance

/freebsd/sys/dev/netmap/
H A Dnetmap_generic.c244 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 Dnetmap.c979 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 Dnetmap_kern.h508 struct mbq rx_queue; /* intercepted rx mbufs. */ member
/freebsd/sys/dev/qlnx/qlnxe/
H A Decore_ll2.c50 #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 Decore_ll2.h123 struct ecore_ll2_rx_queue rx_queue; member
/freebsd/sys/arm64/broadcom/genet/
H A Dif_genet.c159 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[i].queue = i; in gen_init_rxrings()
825 sc->rx_queue[DEF_RXQUEUE].hwindex = GENET_DMA_DEFAULT_QUEUE; in gen_init_rxrings()
[all …]
/freebsd/sys/dev/qcom_ess_edma/
H A Dqcom_ess_edma_gmac.h43 int rx_queue,
H A Dqcom_ess_edma_hw.c285 qcom_ess_edma_hw_intr_rx_ack(struct qcom_ess_edma_softc *sc, int rx_queue) in qcom_ess_edma_hw_intr_rx_ack() argument
288 EDMA_RING_LOCK_ASSERT(&sc->sc_rx_ring[rx_queue]); in qcom_ess_edma_hw_intr_rx_ack()
289 EDMA_REG_WRITE(sc, EDMA_REG_RX_ISR, (1U << rx_queue)); in qcom_ess_edma_hw_intr_rx_ack()
H A Dqcom_ess_edma_hw.h51 int rx_queue);
H A Dqcom_ess_edma.c441 int rx_queue = intr->irq_rid - QCOM_ESS_EDMA_NUM_TX_IRQS; in qcom_ess_edma_filter() local
448 (void) qcom_ess_edma_hw_intr_rx_intr_set_enable(sc, rx_queue, in qcom_ess_edma_filter()
454 taskqueue_enqueue(sc->sc_rx_state[rx_queue].completion_tq, in qcom_ess_edma_filter()
455 &sc->sc_rx_state[rx_queue].completion_task); in qcom_ess_edma_filter()
H A Dqcom_ess_edma_gmac.c439 int rx_queue, struct mbufq *mq) in qcom_ess_edma_gmac_receive_frames() argument
446 ring = &sc->sc_rx_ring[rx_queue]; in qcom_ess_edma_gmac_receive_frames()
/freebsd/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp_proc.c129 __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/sys/contrib/dev/rtw88/
H A Dusb.c553 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()
H A Dusb.h83 struct sk_buff_head rx_queue; member
/freebsd/sys/dev/enetc/
H A Dif_enetc.c998 struct enetc_rx_queue *rx_queue; in enetc_msix_intr_assign() local
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()
/freebsd/sys/contrib/dev/rtw89/
H A Dcore.c2189 skb_queue_walk_safe(&rtwdev->ppdu_sts.rx_queue[band], skb_ppdu, tmp) { in rtw89_core_rx_pending_skb()
2190 skb_unlink(skb_ppdu, &rtwdev->ppdu_sts.rx_queue[band]); in rtw89_core_rx_pending_skb()
2517 skb_queue_walk_safe(&ppdu_sts->rx_queue[band], skb_ppdu, tmp) { in rtw89_core_flush_ppdu_rx_queue()
2518 skb_unlink(skb_ppdu, &ppdu_sts->rx_queue[band]); in rtw89_core_flush_ppdu_rx_queue()
2548 skb_queue_tail(&ppdu_sts->rx_queue[band], skb); in rtw89_core_rx()
4103 skb_queue_head_init(&rtwdev->ppdu_sts.rx_queue[i]); in rtw89_core_ppdu_sts_init()
H A Dcore.h5116 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/sys/contrib/dev/iwlwifi/pcie/
H A Dtrans.c3098 DEBUGFS_READ_FILE_OPS(rx_queue);
3122 DEBUGFS_ADD_FILE(rx_queue, dir, 0400); in iwl_trans_pcie_dump_rbs()