Home
last modified time | relevance | path

Searched refs:txq (Results 1 – 25 of 44) sorted by relevance

12

/netbsd/src/sys/dev/marvell/
Dif_gfe.c136 #define GE_TXDSYNC(sc, txq, n, ops) \ argument
137 bus_dmamap_sync((sc)->sc_dmat, (txq)->txq_desc_mem.gdm_map, \
138 (n) * sizeof((txq)->txq_descs[0]), sizeof((txq)->txq_descs[0]), \
140 #define GE_TXDPRESYNC(sc, txq, n) \ argument
141 GE_TXDSYNC(sc, txq, n, BUS_DMASYNC_PREREAD | BUS_DMASYNC_PREWRITE)
142 #define GE_TXDPOSTSYNC(sc, txq, n) \ argument
143 GE_TXDSYNC(sc, txq, n, BUS_DMASYNC_POSTREAD | BUS_DMASYNC_POSTWRITE)
731 struct gfe_txqueue * const txq = &sc->sc_txq[GE_TXPRIO_HI]; in gfe_ifwatchdog() local
738 curtxdnum = (GE_READ(sc, txq->txq_ectdp) - in gfe_ifwatchdog()
739 txq->txq_desc_busaddr) / sizeof(txq->txq_descs[0]); in gfe_ifwatchdog()
[all …]
/netbsd/src/sys/arch/arm/broadcom/
Dbcm53xx_eth.c614 struct bcmeth_txqueue * const txq = &sc->sc_txq; in bcmeth_ifstop() local
627 bcmeth_write_4(sc, txq->txq_reg_xmtctl, in bcmeth_ifstop()
628 bcmeth_read_4(sc, txq->txq_reg_xmtctl) & ~XMTCTL_ENABLE); in bcmeth_ifstop()
634 uint32_t tx0 = bcmeth_read_4(sc, txq->txq_reg_xmtsts0); in bcmeth_ifstop()
725 struct bcmeth_txqueue *txq, in bcmeth_txq_desc_presync() argument
729 bus_dmamap_sync(sc->sc_dmat, txq->txq_descmap, in bcmeth_txq_desc_presync()
730 (txdb - txq->txq_first) * sizeof(*txdb), count * sizeof(*txdb), in bcmeth_txq_desc_presync()
737 struct bcmeth_txqueue *txq, in bcmeth_txq_desc_postsync() argument
741 bus_dmamap_sync(sc->sc_dmat, txq->txq_descmap, in bcmeth_txq_desc_postsync()
742 (txdb - txq->txq_first) * sizeof(*txdb), count * sizeof(*txdb), in bcmeth_txq_desc_postsync()
[all …]
/netbsd/src/sys/dev/pci/cxgb/
Dcxgb_sge.c683 struct sge_txq *txq; in sge_timer_cb() local
690 txq = &qs->txq[0]; in sge_timer_cb()
691 reclaim_eth = txq[TXQ_ETH].processed - txq[TXQ_ETH].cleaned; in sge_timer_cb()
692 reclaim_ofl = txq[TXQ_OFLD].processed - txq[TXQ_OFLD].cleaned; in sge_timer_cb()
769 sge_txq_reclaim_(struct sge_txq *txq) in sge_txq_reclaim_() argument
775 p = txq->port; in sge_txq_reclaim_()
778 reclaimable = desc_reclaimable(txq); in sge_txq_reclaim_()
779 if (reclaimable > 0 && mtx_trylock(&txq->lock)) { in sge_txq_reclaim_()
780 n = reclaim_completed_tx(txq, TX_CLEAN_MAX_DESC, m_vec); in sge_txq_reclaim_()
781 mtx_unlock(&txq->lock); in sge_txq_reclaim_()
[all …]
Dcxgb_main.c1375 struct sge_txq *txq; in cxgb_start_tx() local
1391 txq = &qs->txq[TXQ_ETH]; in cxgb_start_tx()
1394 if (txq->flags & TXQ_TRANSMITTING) in cxgb_start_tx()
1399 mtx_lock(&txq->lock); in cxgb_start_tx()
1400 txq->flags |= TXQ_TRANSMITTING; in cxgb_start_tx()
1401 in_use_init = txq->in_use; in cxgb_start_tx()
1402 while ((txq->in_use - in_use_init < txmax) && in cxgb_start_tx()
1403 (txq->size > txq->in_use + TX_MAX_DESC)) { in cxgb_start_tx()
1435 txq->flags &= ~TXQ_TRANSMITTING; in cxgb_start_tx()
1436 mtx_unlock(&txq->lock); in cxgb_start_tx()
[all …]
/netbsd/src/sys/arch/powerpc/booke/dev/
Dpq3etsec.c1261 struct pq3etsec_txqueue *txq, in pq3etsec_txq_desc_presync() argument
1265 bus_dmamap_sync(sc->sc_dmat, txq->txq_descmap, in pq3etsec_txq_desc_presync()
1266 (txbd - txq->txq_first) * sizeof(*txbd), count * sizeof(*txbd), in pq3etsec_txq_desc_presync()
1273 struct pq3etsec_txqueue *txq, in pq3etsec_txq_desc_postsync() argument
1277 bus_dmamap_sync(sc->sc_dmat, txq->txq_descmap, in pq3etsec_txq_desc_postsync()
1278 (txbd - txq->txq_first) * sizeof(*txbd), count * sizeof(*txbd), in pq3etsec_txq_desc_postsync()
1820 struct pq3etsec_txqueue *txq) in pq3etsec_txq_active_p() argument
1822 return !IF_IS_EMPTY(&txq->txq_mbufs); in pq3etsec_txq_active_p()
1828 struct pq3etsec_txqueue *txq) in pq3etsec_txq_fillable_p() argument
1830 return txq->txq_free >= txq->txq_threshold; in pq3etsec_txq_fillable_p()
[all …]
/netbsd/src/sys/dev/pci/
Dif_vmx.c1077 struct vmxnet3_txqueue *txq; in vmxnet3_set_interrupt_idx() local
1087 txq = &vmxq->vxq_txqueue; in vmxnet3_set_interrupt_idx()
1088 txs = txq->vxtxq_ts; in vmxnet3_set_interrupt_idx()
1159 struct vmxnet3_txqueue *txq; in vmxnet3_init_txq() local
1162 txq = &sc->vmx_queue[q].vxq_txqueue; in vmxnet3_init_txq()
1163 txr = &txq->vxtxq_cmd_ring; in vmxnet3_init_txq()
1165 snprintf(txq->vxtxq_name, sizeof(txq->vxtxq_name), "%s-tx%d", in vmxnet3_init_txq()
1167 txq->vxtxq_mtx = mutex_obj_alloc(MUTEX_DEFAULT, IPL_NET /* XXX */); in vmxnet3_init_txq()
1169 txq->vxtxq_sc = sc; in vmxnet3_init_txq()
1171 txq->vxtxq_si = softint_establish(SOFTINT_NET | SOFTINT_MPSAFE, in vmxnet3_init_txq()
[all …]
Dif_wm.c214 #define WM_TXQUEUELEN(txq) ((txq)->txq_num) argument
215 #define WM_TXQUEUELEN_MASK(txq) (WM_TXQUEUELEN(txq) - 1) argument
216 #define WM_TXQUEUE_GC(txq) (WM_TXQUEUELEN(txq) / 8) argument
219 #define WM_NTXDESC(txq) ((txq)->txq_ndesc) argument
220 #define WM_NTXDESC_MASK(txq) (WM_NTXDESC(txq) - 1) argument
221 #define WM_TXDESCS_SIZE(txq) (WM_NTXDESC(txq) * (txq)->txq_descsize) argument
222 #define WM_NEXTTX(txq, x) (((x) + 1) & WM_NTXDESC_MASK(txq)) argument
223 #define WM_NEXTTXS(txq, x) (((x) + 1) & WM_TXQUEUELEN_MASK(txq)) argument
265 #define WM_CDTXOFF(txq, x) ((txq)->txq_descsize * (x)) argument
399 WM_Q_EVCNT_DEFINE(txq, txsstall); /* Stalled due to no txs */
[all …]
Dif_nfe.c357 if (nfe_alloc_tx_ring(sc, &sc->txq) != 0) { in nfe_attach()
366 nfe_free_tx_ring(sc, &sc->txq); in nfe_attach()
464 nfe_free_tx_ring(sc, &sc->txq); in nfe_detach()
727 bus_dmamap_sync(sc->sc_dmat, sc->txq.map, in nfe_txdesc32_sync()
728 (char *)desc32 - (char *)sc->txq.desc32, in nfe_txdesc32_sync()
735 bus_dmamap_sync(sc->sc_dmat, sc->txq.map, in nfe_txdesc64_sync()
736 (char *)desc64 - (char *)sc->txq.desc64, in nfe_txdesc64_sync()
744 bus_dmamap_sync(sc->sc_dmat, sc->txq.map, in nfe_txdesc32_rsync()
745 (char *)&sc->txq.desc32[start] - (char *)sc->txq.desc32, in nfe_txdesc32_rsync()
746 (char *)&sc->txq.desc32[end] - in nfe_txdesc32_rsync()
[all …]
Dif_iwi.c394 error = iwi_alloc_tx_ring(sc, &sc->txq[0], IWI_TX_RING_COUNT, in iwi_attach()
401 error = iwi_alloc_tx_ring(sc, &sc->txq[1], IWI_TX_RING_COUNT, in iwi_attach()
408 error = iwi_alloc_tx_ring(sc, &sc->txq[2], IWI_TX_RING_COUNT, in iwi_attach()
415 error = iwi_alloc_tx_ring(sc, &sc->txq[3], IWI_TX_RING_COUNT, in iwi_attach()
467 iwi_free_tx_ring(sc, &sc->txq[0]); in iwi_detach()
468 iwi_free_tx_ring(sc, &sc->txq[1]); in iwi_detach()
469 iwi_free_tx_ring(sc, &sc->txq[2]); in iwi_detach()
470 iwi_free_tx_ring(sc, &sc->txq[3]); in iwi_detach()
1433 iwi_tx_intr(struct iwi_softc *sc, struct iwi_tx_ring *txq) in iwi_tx_intr() argument
1442 hw = CSR_READ_4(sc, txq->csr_ridx); in iwi_tx_intr()
[all …]
Dif_rge.c463 struct rge_txq *txq; in rge_encap() local
484 txq = &sc->rge_ldata.rge_txq[idx]; in rge_encap()
485 txmap = txq->txq_dmamap; in rge_encap()
546 txq->txq_mbuf = m; in rge_encap()
547 txq->txq_descidx = last; in rge_encap()
1408 struct rge_txq *txq; in rge_txeof() local
1417 txq = &sc->rge_ldata.rge_txq[cons]; in rge_txeof()
1418 idx = txq->txq_descidx; in rge_txeof()
1432 bus_dmamap_sync(sc->sc_dmat, txq->txq_dmamap, 0, in rge_txeof()
1433 txq->txq_dmamap->dm_mapsize, BUS_DMASYNC_POSTWRITE); in rge_txeof()
[all …]
Dif_nfevar.h97 struct nfe_tx_ring txq; member
Dif_iwivar.h138 struct iwi_tx_ring txq[WME_NUM_AC]; member
/netbsd/src/sys/dev/ic/
Drt2661.c237 error = rt2661_alloc_tx_ring(sc, &sc->txq[0], RT2661_TX_RING_COUNT); in rt2661_attach()
243 error = rt2661_alloc_tx_ring(sc, &sc->txq[1], RT2661_TX_RING_COUNT); in rt2661_attach()
249 error = rt2661_alloc_tx_ring(sc, &sc->txq[2], RT2661_TX_RING_COUNT); in rt2661_attach()
255 error = rt2661_alloc_tx_ring(sc, &sc->txq[3], RT2661_TX_RING_COUNT); in rt2661_attach()
372 fail5: rt2661_free_tx_ring(sc, &sc->txq[3]); in rt2661_attach()
373 fail4: rt2661_free_tx_ring(sc, &sc->txq[2]); in rt2661_attach()
374 fail3: rt2661_free_tx_ring(sc, &sc->txq[1]); in rt2661_attach()
375 fail2: rt2661_free_tx_ring(sc, &sc->txq[0]); in rt2661_attach()
395 rt2661_free_tx_ring(sc, &sc->txq[0]); in rt2661_detach()
396 rt2661_free_tx_ring(sc, &sc->txq[1]); in rt2661_detach()
[all …]
Drt2560.c354 error = rt2560_alloc_tx_ring(sc, &sc->txq, RT2560_TX_RING_COUNT); in rt2560_attach()
486 fail2: rt2560_free_tx_ring(sc, &sc->txq); in rt2560_attach()
509 rt2560_free_tx_ring(sc, &sc->txq); in rt2560_detach()
1024 hw = (RAL_READ(sc, RT2560_SECCSR1) - sc->txq.physaddr) / in rt2560_encryption_intr()
1027 for (; sc->txq.next_encrypt != hw;) { in rt2560_encryption_intr()
1028 desc = &sc->txq.desc[sc->txq.next_encrypt]; in rt2560_encryption_intr()
1030 bus_dmamap_sync(sc->sc_dmat, sc->txq.map, in rt2560_encryption_intr()
1031 sc->txq.next_encrypt * RT2560_TX_DESC_SIZE, in rt2560_encryption_intr()
1046 bus_dmamap_sync(sc->sc_dmat, sc->txq.map, in rt2560_encryption_intr()
1047 sc->txq.next_encrypt * RT2560_TX_DESC_SIZE, in rt2560_encryption_intr()
[all …]
Dath.c3375 struct ath_txq *txq = &sc->sc_txq[qnum]; in ath_txq_setup() local
3377 txq->axq_qnum = qnum; in ath_txq_setup()
3378 txq->axq_depth = 0; in ath_txq_setup()
3379 txq->axq_intrcnt = 0; in ath_txq_setup()
3380 txq->axq_link = NULL; in ath_txq_setup()
3381 STAILQ_INIT(&txq->axq_q); in ath_txq_setup()
3382 ATH_TXQ_LOCK_INIT(sc, txq); in ath_txq_setup()
3402 struct ath_txq *txq; in ath_tx_setup() local
3409 txq = ath_txq_setup(sc, HAL_TX_QUEUE_DATA, haltype); in ath_tx_setup()
3410 if (txq != NULL) { in ath_tx_setup()
[all …]
Drtl8169.c1441 struct re_txq *txq; in re_txeof() local
1450 txq = &sc->re_ldata.re_txq[idx]; in re_txeof()
1451 KASSERT(txq->txq_mbuf != NULL); in re_txeof()
1453 descidx = txq->txq_descidx; in re_txeof()
1464 sc->re_ldata.re_tx_free += txq->txq_nsegs; in re_txeof()
1466 bus_dmamap_sync(sc->sc_dmat, txq->txq_dmamap, in re_txeof()
1467 0, txq->txq_dmamap->dm_mapsize, BUS_DMASYNC_POSTWRITE); in re_txeof()
1468 bus_dmamap_unload(sc->sc_dmat, txq->txq_dmamap); in re_txeof()
1469 m_freem(txq->txq_mbuf); in re_txeof()
1470 txq->txq_mbuf = NULL; in re_txeof()
[all …]
Darn9003.c1101 struct athn_txq *txq; in ar9003_tx_process() local
1121 txq = &sc->sc_txq[qid]; in ar9003_tx_process()
1123 bf = SIMPLEQ_FIRST(&txq->head); in ar9003_tx_process()
1124 if (bf == NULL || bf == txq->wait) { in ar9003_tx_process()
1128 SIMPLEQ_REMOVE_HEAD(&txq->head, bf_list); in ar9003_tx_process()
1178 if (--txq->queued < AR9003_TX_QDEPTH && txq->wait != NULL) { in ar9003_tx_process()
1179 AR_WRITE(sc, AR_QTXDP(qid), txq->wait->bf_daddr); in ar9003_tx_process()
1181 txq->wait = SIMPLEQ_NEXT(txq->wait, bf_list); in ar9003_tx_process()
1465 struct athn_txq *txq; in ar9003_tx() local
1536 txq = &sc->sc_txq[qid]; in ar9003_tx()
[all …]
Drt2560var.h129 struct rt2560_tx_ring txq; member
/netbsd/src/sys/arch/arm/at91/
Dat91emac.c193 bus_dmamap_sync(sc->sc_dmat, sc->txq[i].m_dmamap, 0, in emac_gctx()
194 sc->txq[i].m->m_pkthdr.len, BUS_DMASYNC_POSTWRITE); in emac_gctx()
195 bus_dmamap_unload(sc->sc_dmat, sc->txq[i].m_dmamap); in emac_gctx()
196 m_freem(sc->txq[i].m); in emac_gctx()
198 __FUNCTION__, i, sc->txq[i].m, sc->txqc)); in emac_gctx()
199 sc->txq[i].m = NULL; in emac_gctx()
444 &sc->txq[i].m_dmamap); in emac_init()
447 sc->txq[i].m = NULL; in emac_init()
629 if ((err = bus_dmamap_load_mbuf(sc->sc_dmat, sc->txq[bi].m_dmamap, m, in emac_ifstart()
631 sc->txq[bi].m_dmamap->dm_segs[0].ds_addr & 0x3 || in emac_ifstart()
[all …]
Dat91emacvar.h64 struct emac_qmeta txq[TX_QLEN]; member
/netbsd/src/sys/arch/arm/ep93xx/
Depe.c170 struct mbuf *m = sc->txq[tbi].m; in epe_gctx()
175 bus_dmamap_unload(sc->sc_dmat, sc->txq[tbi].m_dmamap); in epe_gctx()
178 sc->txq[tbi].m = NULL; in epe_gctx()
181 } while (sc->txq[tbi].m == m); in epe_gctx()
386 &sc->txq[i].m_dmamap); in epe_init()
387 sc->txq[i].m = NULL; in epe_init()
560 if ((err = bus_dmamap_load_mbuf(sc->sc_dmat, sc->txq[bi].m_dmamap, m, in epe_ifstart()
562 sc->txq[bi].m_dmamap->dm_segs[0].ds_addr & 0x3 || in epe_ifstart()
563 sc->txq[bi].m_dmamap->dm_nsegs > (sc->TXDQ_avail - ndq)) { in epe_ifstart()
568 bus_dmamap_unload(sc->sc_dmat, sc->txq[bi].m_dmamap); in epe_ifstart()
[all …]
Depevar.h61 struct epe_qmeta txq[TX_QLEN]; member
/netbsd/src/sys/arch/ews4800mips/dev/
Dewskbd.c107 uint8_t txq[EWSKBD_TXQ_LEN]; member
351 zs_write_data(cs, dc->txq[dc->txq_head]); in ewskbd_zsc_softint()
390 dc->txq[dc->txq_tail] = c[i]; in ewskbd_zsc_send()
/netbsd/src/sys/arch/sgimips/dev/
Dzs_kbd.c76 uint8_t txq[ZSKBD_TXQ_LEN]; member
313 zs_write_data(cs, dc->txq[dc->txq_head]); in zskbd_softint()
359 dc->txq[dc->txq_tail] = c[i]; in zskbd_send()
/netbsd/src/sys/dev/usb/
Dif_run.c617 sc->txq[ntx].pipe_no = ed->bEndpointAddress; in run_attach()
882 struct run_tx_ring *txq = &sc->txq[qid]; in run_alloc_tx_ring() local
890 txq->cur = txq->queued = 0; in run_alloc_tx_ring()
892 error = usbd_open_pipe(sc->sc_iface, txq->pipe_no, 0, &txq->pipeh); in run_alloc_tx_ring()
897 struct run_tx_data *data = &txq->data[i]; in run_alloc_tx_ring()
902 error = usbd_create_xfer(txq->pipeh, RUN_MAX_TXSZ, in run_alloc_tx_ring()
919 struct run_tx_ring *txq = &sc->txq[qid]; in run_free_tx_ring() local
922 if (txq->pipeh != NULL) { in run_free_tx_ring()
923 usbd_abort_pipe(txq->pipeh); in run_free_tx_ring()
924 usbd_close_pipe(txq->pipeh); in run_free_tx_ring()
[all …]

12