Home
last modified time | relevance | path

Searched refs:queued (Results 1 – 25 of 133) sorted by relevance

123456

/src/sys/contrib/dev/mediatek/mt76/
H A Ddebugfs.c67 i, q->queued, q->head, q->tail); in mt76_queues_read()
77 int i, queued; in mt76_rx_queues_read() local
83 queued = mt76_is_usb(dev) ? q->ndesc - q->queued : q->queued; in mt76_rx_queues_read()
85 i, queued, q->head, q->tail); in mt76_rx_queues_read()
H A Dsdio.c317 q->queued = 0; in mt76s_alloc_rx_queue()
372 if (q->queued > 0) { in mt76s_get_next_rx_entry()
375 q->queued--; in mt76s_get_next_rx_entry()
439 while (q->queued > 0) { in mt76s_process_tx_queue()
455 if (!q->queued) in mt76s_process_tx_queue()
529 if (q->queued == q->ndesc) in mt76s_tx_queue_skb()
544 q->queued++; in mt76s_tx_queue_skb()
562 if (q->queued == q->ndesc) { in mt76s_tx_queue_skb_raw()
575 q->queued++; in mt76s_tx_queue_skb_raw()
H A Dusb.c450 if (q->queued > 0) { in mt76u_get_next_rx_entry()
453 q->queued--; in mt76u_get_next_rx_entry()
596 q->queued++; in mt76u_complete_rx()
668 q->queued = 0; in mt76u_submit_rx_buffers()
789 while (q->queued > 0) { in mt76u_status_worker()
799 if (!q->queued) in mt76u_status_worker()
878 if (q->queued == q->ndesc) in mt76u_tx_queue_skb()
896 q->queued++; in mt76u_tx_queue_skb()
1042 while (q->queued > 0) { in mt76u_stop_tx()
H A Ddma.c305 q->queued++; in mt76_dma_add_rx_buf()
369 q->queued++; in mt76_dma_add_buf()
425 while (q->queued > 0 && q->tail != last) { in mt76_dma_tx_cleanup()
447 if (!q->queued) in mt76_dma_tx_cleanup()
558 if (!q->queued) in mt76_dma_dequeue()
602 q->queued--; in mt76_dma_dequeue()
617 if (q->queued + 1 >= q->ndesc - 1) in mt76_dma_tx_queue_skb_raw()
700 if (q->queued + (tx_info.nbuf + 1) / 2 >= q->ndesc - 1) { in mt76_dma_tx_queue_skb()
757 while (q->queued < q->ndesc - 1) { in mt76_dma_rx_fill_buf()
H A Dwed.c139 q->queued = q->head; in mt76_wed_dma_setup()
146 q->queued = q->head; in mt76_wed_dma_setup()
/src/sys/cam/
H A Dcam_iosched.c262 int queued; /* number currently in the queue */ member
649 pending += !!(isc->read_stats.state_flags & IOP_RATE_LIMITED) * isc->read_stats.queued + in cam_iosched_ticker()
650 !!(isc->write_stats.state_flags & IOP_RATE_LIMITED) * isc->write_stats.queued /* + in cam_iosched_ticker()
788 printf("Queued reads %d writes %d\n", isc->read_stats.queued, isc->write_stats.queued); in cam_iosched_has_io()
862 ios->queued = 0; in cam_iosched_iop_stats_init()
1043 &ios->queued, 0, in cam_iosched_iop_stats_sysctl_init()
1382 isc->current_read_bias, isc->write_stats.queued, in cam_iosched_get_write()
1383 isc->read_stats.queued); in cam_iosched_get_write()
1406 isc->write_stats.queued--; in cam_iosched_get_write()
1428 isc->trim_stats.queued++; in cam_iosched_put_back_trim()
[all …]
/src/sys/kern/
H A Dkern_devctl.c67 int queued; member
277 devsoftc.queued--; in devread()
356 kn->kn_data = devsoftc.queued; in filt_devctl_read()
389 if (devsoftc.queued == 0) in devctl_alloc_dei()
393 devsoftc.queued--; in devctl_alloc_dei()
424 devsoftc.queued++; in devctl_queue()
/src/sys/dev/rtwn/pci/
H A Drtwn_pci_rx.c305 ring->queued--; in rtwn_pci_tx_done()
306 KASSERT(ring->queued >= 0, in rtwn_pci_tx_done()
314 if (ring->queued > 0) in rtwn_pci_tx_done()
322 ring->queued < (RTWN_PCI_TX_LIST_COUNT - 1)) { in rtwn_pci_tx_done()
333 if (sc->sc_ratectl != RTWN_RATECTL_NET80211 && ring->queued <= 1) { in rtwn_pci_tx_done()
H A Drtwn_pci_tx.c182 ring->queued++; in rtwn_pci_tx_start_frame()
183 if (ring->queued >= (RTWN_PCI_TX_LIST_COUNT - 1)) in rtwn_pci_tx_start_frame()
H A Drtwn_pci_var.h62 int queued; member
/src/sys/dev/firewire/
H A Dfwdev.c118 q->queued = 0; in fwdev_allocbuf()
234 ir->queued--; in fw_close()
344 ir->queued = 0; in fw_read()
364 ir->stproc->poffset + ir->queued); in fw_read()
373 ir->queued++; in fw_read()
374 if (ir->queued >= ir->bnpacket) { in fw_read()
477 it->queued = 0; in fw_write()
496 it->stproc->poffset + it->queued); in fw_write()
500 it->queued++; in fw_write()
501 if (it->queued >= it->bnpacket) { in fw_write()
H A Dfirewire.c242 if (!(xferq->queued < xferq->maxq)) { in fw_asyreq()
244 xferq->queued); in fw_asyreq()
305 xfer->q->queued++; in fw_asystart()
557 xferq->queued--; in fw_xferq_drain()
778 fc->arq->queued = 0; in fw_init()
779 fc->ars->queued = 0; in fw_init()
780 fc->atq->queued = 0; in fw_init()
781 fc->ats->queued = 0; in fw_init()
797 fc->it[i]->queued = 0; in fw_init()
798 fc->ir[i]->queued = 0; in fw_init()
[all …]
/src/lib/libopenbsd/
H A Dimsg-buffer.c190 msgbuf->queued = 0; in msgbuf_init()
294 msgbuf->queued++; in ibuf_enqueue()
305 msgbuf->queued--; in ibuf_dequeue()
H A Dimsg.h40 u_int32_t queued; member
/src/sys/netpfil/ipfw/
H A Ddn_sched_qfq.c242 NO(uint32_t queued;) /* debugging */
558 NO(if (q->queued) in qfq_dequeue()
573 NO(q->queued--;) in qfq_dequeue()
603 NO(if (!q->bitmaps[ER] && q->queued) in qfq_dequeue()
668 NO(q->queued++;) in qfq_enqueue()
878 D("loops %d queued %d V 0x%llx", q->loops, q->queued, (_P64)q->V); in dump_sched()
/src/contrib/ncurses/misc/
H A Dcmpdef.cmd77 do while queued() > 0
100 do while queued() > 0
131 do while queued() > 0
H A Dmakedef.cmd92 do while queued() > 0
147 end /* do while queued() */
176 do while queued() > 0
H A Dchkdef.cmd75 do while queued() > 0
112 do while queued() > 0
/src/sys/dev/iwi/
H A Dif_iwivar.h68 int queued; member
89 int queued; member
/src/sys/dev/ral/
H A Drt2560.c459 ring->queued = 0; in rt2560_alloc_tx_ring()
548 ring->queued = 0; in rt2560_reset_tx_ring()
989 sc->txq.queued--; in rt2560_tx_intr()
996 if (sc->prioq.queued == 0 && sc->txq.queued == 0) in rt2560_tx_intr()
999 if (sc->txq.queued < RT2560_TX_RING_COUNT - 1) in rt2560_tx_intr()
1060 sc->prioq.queued--; in rt2560_prio_intr()
1074 if (sc->prioq.queued == 0 && sc->txq.queued == 0) in rt2560_prio_intr()
1077 if (sc->prioq.queued < RT2560_PRIO_RING_COUNT) in rt2560_prio_intr()
1580 sc->prioq.queued++; in rt2560_tx_mgt()
1635 sc->txq.queued++; in rt2560_sendprot()
[all …]
/src/usr.sbin/diskinfo/
H A Ddiskinfo.c576 int error, i, queued, completed; in iops() local
601 queued = i; in iops()
622 queued++; in iops()
623 } else if (completed == queued) { in iops()
/src/tests/sys/netinet6/frag6/
H A Dfrag6.subr74 # be global fragments queued. (This still does not rule out that there
75 # are no other fragments queued anywhere else in the system).
/src/sys/dev/usb/wlan/
H A Dif_mtwvar.h152 int queued; member
196 int queued; member
/src/sys/netgraph/
H A DNOTES96 Every node has a queue, plus there is a list of nodes that have queued work.
102 be queued.
/src/sys/arm/allwinner/
H A Dif_awg.c171 u_int cur, next, queued; member
645 if (sc->tx.queued + nsegs > TX_DESC_COUNT) { in awg_encap()
687 ++sc->tx.queued; in awg_encap()
713 --sc->tx.queued; in awg_clean_txbuf()
851 sc->tx.queued = 0; in awg_setup_dma()
1072 for (i = sc->tx.next; sc->tx.queued > 0; i = TX_NEXT(i)) { in awg_stop()
1079 for (; sc->tx.queued > 0; i = TX_NEXT(i)) { in awg_stop()
1296 for (i = sc->tx.next; sc->tx.queued > 0; i = TX_NEXT(i)) { in awg_txeof()

123456