consumer
void *consumer(void *arg);
CHECKr(pthread_create(&cons_th, NULL, consumer, &counter));
int consumer, producer, txidx;
consumer = CQCI_TxCompletionConsumerIndex_get(cqci);
if (consumer == producer)
while (consumer != producer) {
SF_CDTXCSYNC(sc, consumer, BUS_DMASYNC_POSTREAD);
tcd = letoh32(sc->sc_txcomp[consumer].tcd_word0);
consumer = SF_NEXTTCD(consumer);
CQCI_TxCompletionConsumerIndex(consumer));
int consumer, producer, bufproducer, rxidx, len;
consumer = CQCI_RxCompletionQ1ConsumerIndex_get(cqci);
if (consumer == producer)
while (consumer != producer) {
rcd = &sc->sc_rxcomp[consumer];
SF_CDRXCSYNC(sc, consumer,
SF_CDRXCSYNC(sc, consumer,
consumer = SF_NEXTRCD(consumer);
CQCI_RxCompletionQ1ConsumerIndex(consumer));
consumer = 0;
pcq->mpc_consumer = htole32(consumer);
uint32_t producer, consumer, ctx;
consumer = letoh32(pcq->mpc_consumer);
while (consumer != producer) {
DEVNAME(sc), producer, consumer);
ctx = pcq->mpc_reply_q[consumer];
pcq->mpc_reply_q[consumer] = MFI_INVALID_CTX;
DEVNAME(sc), producer, consumer);
consumer++;
if (consumer == (sc->sc_max_cmds + 1))
pwm_get(struct device *dev, const char *consumer)
nxe_ring_writeable(struct nxe_ring *nr, int consumer)
nr->nr_ready = consumer - nr->nr_slot;