Lines Matching defs:consumer

1044 	struct gmac_rxdb *consumer = rxq->rxq_consumer;
1049 		if (consumer == rxq->rxq_producer) {
1056 		if (consumer == rxq->rxq_first + currdscr) {
1059 		bcmeth_rxq_desc_postsync(sc, rxq, consumer, 1);
1074 		KASSERTMSG(rxsts != BCMETH_RCVMAGIC, "currdscr=%u consumer=%zd",
1075 		    currdscr, consumer - rxq->rxq_first);
1091 			if (++consumer == rxq->rxq_last) {
1092 				consumer = rxq->rxq_first;
1094 			KASSERTMSG(consumer != rxq->rxq_first + currdscr,
1096 			    "consumer=%zd", i, rxsts, desc_count, currdscr,
1097 			    consumer - rxq->rxq_first);
1123 			    consumer - rxq->rxq_first, desc_count, rxsts);
1150 			if (++consumer == rxq->rxq_last) {
1151 				KASSERT(consumer[-1].rxdb_flags
1155 				rxq->rxq_consumer = consumer;
1170 			consumer = rxq->rxq_consumer;
1179 		if (++consumer == rxq->rxq_last) {
1180 			KASSERT(consumer[-1].rxdb_flags & htole32(RXDB_FLAG_ET));
1181 			consumer = rxq->rxq_first;
1188 	rxq->rxq_consumer = consumer;
1249 	 * Reset the producer consumer indexes.
1602 	struct gmac_txdb *consumer = txq->txq_consumer;
1610 		if (consumer == txq->txq_producer) {
1611 			txq->txq_consumer = consumer;
1624 		bcmeth_txq_desc_postsync(sc, txq, consumer, 1);
1626 		if (consumer == txq->txq_first + __SHIFTOUT(s0, XMT_CURRDSCR)) {
1627 			txq->txq_consumer = consumer;
1641 		const uint32_t txdb_flags = le32toh(consumer->txdb_flags);
1669 			consumer->txdb_flags = htole32(TXDB_FLAG_ET);
1670 			KASSERT(consumer + 1 == txq->txq_last);
1671 			consumer = txq->txq_first;
1673 			consumer->txdb_flags = 0;
1674 			consumer++;
1675 			KASSERT(consumer < txq->txq_last);
1727 	 * Reset the producer consumer indexes.