Lines Matching refs:circularQ
1148 mpiOCQueue_t *circularQ = agNULL;
1166 circularQ = &saRoot->outboundQueue[queueNum];
1167 OSSA_READ_LE_32(circularQ->agRoot, &circularQ->producerIdx, circularQ->piPointer, 0);
1169 if (circularQ->producerIdx == circularQ->consumerIdx)
1181 ret = mpiMsgConsume(circularQ, &pMsg1, &category, &opcode, &bc);
1194 for (i=0; i<((bit32)bc*(circularQ->elementSize/4)); i++)
1202 MPI_DEBUG_TRACE( circularQ->qNumber,((circularQ->producerIdx << 16 ) | circularQ->consumerIdx),MPI_DEBUG_TRACE_OBQ, (void *)(((bit8*)pMsg1) - sizeof(mpiMsgHeader_t)), circularQ->elementSize);
1204 ossaLogIomb(circularQ->agRoot,
1205 circularQ->qNumber,
1208 bc*circularQ->elementSize);
1210 ossaQueueProcessed(agRoot, queueNum, circularQ->producerIdx, circularQ->consumerIdx);
1215 SA_DBG1(("siProcessOBMsg, Failed Q %2d PI 0x%03x CI 0x%03x\n", queueNum, circularQ->producerIdx, circularQ->consumerIdx));
1219 mpiMsgFreeSet(circularQ, pMsg1, bc);
1226 mpiMsgFreeSet(circularQ, pMsg1, bc);
1230 //if (AGSA_RC_BUSY == ret) // always (circularQ->producerIdx == circularQ->consumerIdx)