| /src/sys/kern/ |
| subr_pcq.c | 40 * P2. atomic_cas(&pcq->pcq_pc) loop to advance the producer
43 * P3. atomic_store_release(&pcq->pcq_items[c], item) to publish
50 * C1. atomic_load_relaxed(&pcq->pcq_pc) to get the consumer
55 * C2. atomic_load_consume(&pcq->pcq_items[c]) to get the next
59 * C3. pcq->pcq_items[c] = NULL to consume the next unconsumed but
64 * C5. atomic_cas(&pcq->pcq_pc) loop to advance the consumer
113 * - load/store C5 synchronizes with load/store P2 at &pcq->pcq_pc
128 #include <sys/pcq.h>
134 struct pcq { struct
166 pcq_advance(pcq_t *pcq, u_int pc
289 pcq_t *pcq; local in function:pcq_create
[all...] |
| /src/sys/sys/ |
| pcq.h | 1 /* $NetBSD: pcq.h,v 1.2 2014/06/09 12:44:06 rmind Exp $ */
37 typedef struct pcq pcq_t;
|
| /src/sys/net/ |
| pktqueue.c | 50 #include <sys/pcq.h>
87 struct percpu * pq_pcq; /* struct pcq * */
131 struct pcq **qp = vqp;
140 struct pcq **qp = vqp, *q = *qp;
147 static struct pcq *
150 struct pcq **qp, *q;
185 pq->pq_pcq = percpu_create(sizeof(struct pcq *),
205 percpu_free(pq->pq_pcq, sizeof(struct pcq *));
486 struct pcq *q;
562 struct pcq *q
[all...] |
| if_gre.h | 51 #include <sys/pcq.h>
|
| if_spppvar.h | 30 #include <sys/pcq.h>
|
| /src/sys/dev/ |
| sequencervar.h | 93 pcq_t *pcq; member in struct:sequencer_softc
|
| sequencer.c | 53 * can safely acquire the sequencer device's sc_lock. PCQ is lockless for
78 #include <sys/pcq.h>
212 if (sc->pcq)
213 pcq_destroy(sc->pcq);
230 sc->pcq = pcq_create(SEQ_MAXQ, KM_SLEEP);
231 if (sc->pcq == NULL) {
558 qi.qi_ptr = pcq_get(sc->pcq);
1431 pcq_put(sc->pcq, qi.qi_ptr);
|
| /src/sys/external/bsd/compiler_rt/dist/lib/tsan/rtl/ |
| tsan_interface_ann.cc | 331 char *f, int l, uptr pcq) {
336 char *f, int l, uptr pcq) {
341 char *f, int l, uptr pcq) {
346 char *f, int l, uptr pcq) {
|
| /src/sys/dev/pci/igc/ |
| if_igc.h | 43 #include <sys/pcq.h>
|
| /src/share/man/man9/ |
| Makefile | 50 pci_msi.9 pckbport.9 pcmcia.9 pcq.9 pcu.9 \
766 MLINKS+=pcq.9 pcq_create.9 \
767 pcq.9 pcq_destroy.9 \
768 pcq.9 pcq_get.9 \
769 pcq.9 pcq_peek.9 \
770 pcq.9 pcq_maxitems.9 \
771 pcq.9 pcq_put.9
|
| /src/lib/libperfuse/ |
| ops.c | 818 struct perfuse_cc_queue pcq; local in function:requeue_request
822 pcq.pcq_type = type;
823 pcq.pcq_cc = puffs_cc_getcc(pu);
824 TAILQ_INSERT_TAIL(&pnd->pnd_pcq, &pcq, pcq_next);
829 __func__, (void *)opc, pcq.pcq_cc,
833 puffs_cc_yield(pcq.pcq_cc);
834 TAILQ_REMOVE(&pnd->pnd_pcq, &pcq, pcq_next);
839 __func__, (void *)opc, pcq.pcq_cc,
849 struct perfuse_cc_queue *pcq; local in function:dequeue_requests
855 TAILQ_FOREACH(pcq, &pnd->pnd_pcq, pcq_next)
[all...] |
| /src/sys/dev/pci/ |
| if_enavar.h | 41 #include <sys/pcq.h>
|
| if_vioif.c | 52 #include <sys/pcq.h>
1064 "pcq full");
|
| if_vmx.c | 38 #include <sys/pcq.h>
1979 NULL, txq->vxtxq_name, "Dropped in pcq");
|
| if_aq.c | 79 #include <sys/pcq.h>
4918 "unable to allocate pcq for TXring[%d]\n",
|
| if_iavf.c | 93 #include <sys/pcq.h>
2262 txr->txr_name, "Dropped in pcq");
|
| if_ixl.c | 94 #include <sys/pcq.h>
6058 NULL, qp->qp_name, "Dropped in pcq");
|
| if_mcx.c | 44 #include <sys/pcq.h>
|
| if_wm.c | 103 #include <sys/pcq.h>
412 WM_Q_EVCNT_DEFINE(txq, pcqdrop); /* Pkt dropped in pcq */
3169 * because of wm_select_txqueue() and pcq(9) overhead.
|
| /src/sys/dev/pci/ixgbe/ |
| ixgbe.h | 75 #include <sys/pcq.h>
|
| /src/sys/dev/ic/ |
| mfi.c | 1366 struct mfi_prod_cons *pcq; local in function:mfi_intr
1374 pcq = MFIMEM_KVA(sc->sc_pcq);
1376 DNPRINTF(MFI_D_INTR, "%s: mfi_intr %p %p\n", DEVNAME(sc), sc, pcq);
1382 producer = pcq->mpc_producer;
1383 consumer = pcq->mpc_consumer;
1389 ctx = pcq->mpc_reply_q[consumer];
1390 pcq->mpc_reply_q[consumer] = MFI_INVALID_CTX;
1413 pcq->mpc_consumer = consumer;
|
| /src/sys/net/lagg/ |
| if_lagg_lacp.c | 45 #include <sys/pcq.h>
|
| /src/sys/dev/hyperv/ |
| if_hvn.c | 59 #include <sys/pcq.h>
1973 NULL, txr->txr_name, "dropped in pcq");
|
