lib/libperfuse/ops.c

818

struct perfuse_cc_queue pcq;

lib/libperfuse/ops.c

822

pcq.pcq_type = type;

lib/libperfuse/ops.c

823

pcq.pcq_cc = puffs_cc_getcc(pu);

lib/libperfuse/ops.c

824

TAILQ_INSERT_TAIL(&pnd->pnd_pcq, &pcq, pcq_next);

lib/libperfuse/ops.c

829

__func__, (void *)opc, pcq.pcq_cc,

lib/libperfuse/ops.c

833

puffs_cc_yield(pcq.pcq_cc);

lib/libperfuse/ops.c

834

TAILQ_REMOVE(&pnd->pnd_pcq, &pcq, pcq_next);

lib/libperfuse/ops.c

839

__func__, (void *)opc, pcq.pcq_cc,

lib/libperfuse/ops.c

849

struct perfuse_cc_queue *pcq;

lib/libperfuse/ops.c

855

TAILQ_FOREACH(pcq, &pnd->pnd_pcq, pcq_next) {

lib/libperfuse/ops.c

856

if (pcq->pcq_type != type)

lib/libperfuse/ops.c

862

__func__, (void *)opc, pcq->pcq_cc,

lib/libperfuse/ops.c

865

puffs_cc_schedule(pcq->pcq_cc);

sys/dev/ic/mfi.c

1366

struct mfi_prod_cons *pcq;

sys/dev/ic/mfi.c

1374

pcq = MFIMEM_KVA(sc->sc_pcq);

sys/dev/ic/mfi.c

1376

DNPRINTF(MFI_D_INTR, "%s: mfi_intr %p %p\n", DEVNAME(sc), sc, pcq);

sys/dev/ic/mfi.c

1382

producer = pcq->mpc_producer;

sys/dev/ic/mfi.c

1383

consumer = pcq->mpc_consumer;

sys/dev/ic/mfi.c

1389

ctx = pcq->mpc_reply_q[consumer];

sys/dev/ic/mfi.c

1390

pcq->mpc_reply_q[consumer] = MFI_INVALID_CTX;

sys/dev/ic/mfi.c

1413

pcq->mpc_consumer = consumer;

sys/dev/sequencer.c

1431

pcq_put(sc->pcq, qi.qi_ptr);

sys/dev/sequencer.c

212

if (sc->pcq)

sys/dev/sequencer.c

213

pcq_destroy(sc->pcq);

sys/dev/sequencer.c

230

sc->pcq = pcq_create(SEQ_MAXQ, KM_SLEEP);

sys/dev/sequencer.c

231

if (sc->pcq == NULL) {

sys/dev/sequencer.c

558

qi.qi_ptr = pcq_get(sc->pcq);

sys/dev/sequencervar.h

93

pcq_t *pcq;

sys/kern/subr_pcq.c

166

pcq_advance(pcq_t *pcq, u_int pc)

sys/kern/subr_pcq.c

169

if (__predict_false(++pc == pcq->pcq_nitems)) {

sys/kern/subr_pcq.c

179

pcq_put(pcq_t *pcq, void *item)

sys/kern/subr_pcq.c

187

v = atomic_load_relaxed(&pcq->pcq_pc);

sys/kern/subr_pcq.c

189

p = pcq_advance(pcq, op);

sys/kern/subr_pcq.c

195

} while (atomic_cas_32(&pcq->pcq_pc, v, nv) != v);

sys/kern/subr_pcq.c

203

atomic_store_release(&pcq->pcq_items[op], item);

sys/kern/subr_pcq.c

217

pcq_peek(pcq_t *pcq)

sys/kern/subr_pcq.c

219

const uint32_t v = atomic_load_relaxed(&pcq->pcq_pc);

sys/kern/subr_pcq.c

225

return (p == c) ? NULL : atomic_load_consume(&pcq->pcq_items[c]);

sys/kern/subr_pcq.c

234

pcq_get(pcq_t *pcq)

sys/kern/subr_pcq.c

240

v = atomic_load_relaxed(&pcq->pcq_pc);

sys/kern/subr_pcq.c

246

item = atomic_load_consume(&pcq->pcq_items[c]);

sys/kern/subr_pcq.c

259

pcq->pcq_items[c] = NULL;

sys/kern/subr_pcq.c

260

c = pcq_advance(pcq, c);

sys/kern/subr_pcq.c

277

while (__predict_false(atomic_cas_32(&pcq->pcq_pc, v, nv) != v)) {

sys/kern/subr_pcq.c

278

v = atomic_load_relaxed(&pcq->pcq_pc);

sys/kern/subr_pcq.c

280

c = pcq_advance(pcq, c);

sys/kern/subr_pcq.c

289

pcq_t *pcq;

sys/kern/subr_pcq.c

294

pcq = kmem_zalloc(offsetof(pcq_t, pcq_items[nitems]), kmflags);

sys/kern/subr_pcq.c

295

if (pcq != NULL) {

sys/kern/subr_pcq.c

296

pcq->pcq_nitems = nitems;

sys/kern/subr_pcq.c

298

return pcq;

sys/kern/subr_pcq.c

302

pcq_destroy(pcq_t *pcq)

sys/kern/subr_pcq.c

305

kmem_free(pcq, offsetof(pcq_t, pcq_items[pcq->pcq_nitems]));

sys/kern/subr_pcq.c

309

pcq_maxitems(pcq_t *pcq)

sys/kern/subr_pcq.c

312

return pcq->pcq_nitems;

sys/net/pktqueue.c

131

struct pcq **qp = vqp;

sys/net/pktqueue.c

140

struct pcq **qp = vqp, *q = *qp;

sys/net/pktqueue.c

147

static struct pcq *

sys/net/pktqueue.c

150

struct pcq **qp, *q;

sys/net/pktqueue.c

185

pq->pq_pcq = percpu_create(sizeof(struct pcq *),

sys/net/pktqueue.c

205

percpu_free(pq->pq_pcq, sizeof(struct pcq *));

sys/net/pktqueue.c

486

struct pcq *q;

sys/net/pktqueue.c

562

struct pcq *q;

sys/net/pktqueue.c

592

struct pcq **qp, *q, **qs = vqs;

sys/net/pktqueue.c

652

struct pcq *q;

sys/sys/pcq.h

37

typedef struct pcq pcq_t;