Lines Matching refs:consumerIdx
251 OSSA_READ_LE_32(circularQ->agRoot, &circularQ->consumerIdx, circularQ->ciPointer, 0); in mpiMsgFreeGet()
256 if (((circularQ->producerIdx + bcCount) % circularQ->numElements) == circularQ->consumerIdx) in mpiMsgFreeGet()
259 …G_VERY_LOUD,"Za", (((circularQ->producerIdx & 0xFFF) << 16) | (circularQ->consumerIdx & 0xFFF) )); in mpiMsgFreeGet()
262 …iMsgFreeGet: %d + %d == %d AGSA_RC_BUSY\n",circularQ->producerIdx,bcCount,circularQ->consumerIdx)); in mpiMsgFreeGet()
267 …G_VERY_LOUD,"Zb", (((circularQ->producerIdx & 0xFFF) << 16) | (circularQ->consumerIdx & 0xFFF) )); in mpiMsgFreeGet()
316 if (((circularQ->producerIdx + bcCount) % circularQ->numElements) == circularQ->consumerIdx) in mpiMsgFreeGetOQ()
411 ((circularQ->producerIdx << 16 ) | circularQ->consumerIdx), in mpiMsgPrepare()
535 ((circularQ->producerIdx << 16 ) | circularQ->consumerIdx), in mpiMsgProduce()
680 if(circularQ->producerIdx != circularQ->consumerIdx) in mpiMsgConsume()
683 …iMsgHeader_t*) ((bit8 *)(circularQ->memoryRegion.virtPtr) + circularQ->consumerIdx * circularQ->el… in mpiMsgConsume()
702 …SA_DBG1(("mpiMsgConsume: CI=%d PI=%d msgHeader=%p\n", circularQ->consumerIdx, circularQ->producerI… in mpiMsgConsume()
703 circularQ->consumerIdx = (circularQ->consumerIdx + 1) % circularQ->numElements; in mpiMsgConsume()
708 circularQ->consumerIdx); in mpiMsgConsume()
715 …SA_ASSERT(circularQ->consumerIdx <= circularQ->numElements, "Multi-buffer messages cannot wrap aro… in mpiMsgConsume()
732 …SA_DBG3(("mpiMsgConsume: CI=%d PI=%d msgHeader=%p\n", circularQ->consumerIdx, circularQ->producerI… in mpiMsgConsume()
741 …circularQ->consumerIdx = (circularQ->consumerIdx + ((msgHeader_tmp >> SHIFT24) & BC_MASK)) % circu… in mpiMsgConsume()
752 circularQ->consumerIdx); in mpiMsgConsume()
763 … set, PI=%d CI=%d msgHeader=%p\n", circularQ->producerIdx, circularQ->consumerIdx,(void *)msgHead… in mpiMsgConsume()
767 ((circularQ->producerIdx << 16 ) | circularQ->consumerIdx), in mpiMsgConsume()
772 circularQ->consumerIdx = circularQ->consumerIdx % circularQ->numElements; in mpiMsgConsume()
773 circularQ->consumerIdx ++; in mpiMsgConsume()
778 circularQ->consumerIdx); in mpiMsgConsume()
791 …} while(circularQ->producerIdx != circularQ->consumerIdx); /* while we don't have any more not-yet… in mpiMsgConsume()
832 …if ( ((mpiMsgHeader_t*)((bit8*)circularQ->memoryRegion.virtPtr + circularQ->consumerIdx * circular… in mpiMsgFreeSet()
835 … %d ConsumeIdx = %d msgHeader 0x%08x\n",circularQ->qNumber, circularQ->consumerIdx ,msgHeader->Hea… in mpiMsgFreeSet()
836 …((mpiMsgHeader_t*)((bit8*)circularQ->memoryRegion.virtPtr + circularQ->consumerIdx * circularQ->el… in mpiMsgFreeSet()
851 circularQ->consumerIdx = (circularQ->consumerIdx + bc) % circularQ->numElements; in mpiMsgFreeSet()
856 …SA_ASSERT(circularQ->consumerIdx <= circularQ->numElements, "Multi-buffer messages cannot wrap arr… in mpiMsgFreeSet()
866 circularQ->consumerIdx); in mpiMsgFreeSet()
872 SA_DBG5(("mpiMsgFreeSet: CI=%d PI=%d\n", circularQ->consumerIdx, circularQ->producerIdx)); in mpiMsgFreeSet()
938 …%p opcode %d pi/ci %d / %d\n", msgHeader, opCode, circularQ->producerIdx, circularQ->consumerIdx)); in mpiMsgProduceOQ()
964 ((circularQ->producerIdx << 16 ) | circularQ->consumerIdx), in mpiMsgProduceOQ()