| /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...] |
| 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/dev/ |
| sequencervar.h | 93 pcq_t *pcq; member in struct:sequencer_softc
|
| sequencervar.h | 93 pcq_t *pcq; member in struct:sequencer_softc
|
| /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...] |
| 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/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;
|
| 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;
|
