Home
last modified time | relevance | path

Searched refs:circularQ (Results 1 – 13 of 13) sorted by relevance

/freebsd/sys/dev/pms/RefTisa/sallsdk/spc/
H A Dmpi.c228 mpiICQueue_t *circularQ, in mpiMsgFreeGet() argument
234 agsaRoot_t *agRoot=circularQ->agRoot; in mpiMsgFreeGet()
239 SA_ASSERT(NULL != circularQ, "circularQ cannot be null"); in mpiMsgFreeGet()
241 SA_ASSERT(0 != circularQ->numElements, "The number of elements in this queue is 0"); in mpiMsgFreeGet()
244 if(messageSize > circularQ->elementSize) in mpiMsgFreeGet()
246 …eGet: Message Size (%d) is larger than Q element size (%d)\n",messageSize,circularQ->elementSize)); in mpiMsgFreeGet()
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 …smTrace(hpDBG_VERY_LOUD,"Za", (((circularQ->producerIdx & 0xFFF) << 16) | (circularQ->consumerIdx… in mpiMsgFreeGet()
262 …SA_DBG1(("mpiMsgFreeGet: %d + %d == %d AGSA_RC_BUSY\n",circularQ->producerIdx,bcCount,circularQ->c… in mpiMsgFreeGet()
[all …]
H A Dsatimer.c126 mpiOCQueue_t *circularQ; in saTimerTick() local
131 circularQ = &saRoot->outboundQueue[i]; in saTimerTick()
132 OSSA_READ_LE_32(circularQ->agRoot, &circularQ->producerIdx, circularQ->piPointer, 0); in saTimerTick()
133 if(circularQ->producerIdx != circularQ->consumerIdx) in saTimerTick()
135 … if( saRoot->OldCi[i] == circularQ->consumerIdx && saRoot->OldPi[i] >= circularQ->producerIdx) in saTimerTick()
146 circularQ->producerIdx, in saTimerTick()
147 circularQ->consumerIdx, in saTimerTick()
148 …circularQ->producerIdx > circularQ->consumerIdx ? (circularQ->producerIdx - circularQ->consumerIdx… in saTimerTick()
185 saRoot->OldPi[i] = circularQ->producerIdx; in saTimerTick()
186 saRoot->OldCi[i] = circularQ->consumerIdx; in saTimerTick()
H A Dmpi.h446 FORCEINLINE bit32 mpiMsgFreeGet(mpiICQueue_t *circularQ, bit16 messageSize, void** messagePtr);
447 FORCEINLINE bit32 mpiMsgProduce(mpiICQueue_t *circularQ, void* messagePtr,
451 GLOBAL bit32 mpiMsgProduceOQ(mpiOCQueue_t *circularQ, void *messagePtr,
454 GLOBAL bit32 mpiMsgFreeGetOQ(mpiOCQueue_t *circularQ, bit16 messageSize,
459 bit32 mpiMsgPrepare(mpiICQueue_t *circularQ, void* messagePtr,
463 bit32 mpiMsgProduceSend(mpiICQueue_t *circularQ, void* messagePtr,
466 GLOBAL void mpiIBQMsgSend(mpiICQueue_t *circularQ);
471 FORCEINLINE bit32 mpiMsgConsume(mpiOCQueue_t *circularQ, void** messagePtr1, mpiMsgCategory_t *pCat…
472 FORCEINLINE bit32 mpiMsgFreeSet(mpiOCQueue_t *circularQ, void* messagePtr1, bit8 bc);
H A Dsassp.c57 mpiICQueue_t *circularQ; in saGetIBQPI() local
61 circularQ = &saRoot->inboundQueue[inq]; in saGetIBQPI()
62 return circularQ->producerIdx; in saGetIBQPI()
70 mpiICQueue_t *circularQ; in saSetIBQPI() local
74 circularQ = &saRoot->inboundQueue[inq]; in saSetIBQPI()
75 circularQ->producerIdx = pi; in saSetIBQPI()
143 mpiICQueue_t *circularQ; in siFastSSPResAlloc() local
177 circularQ = &saRoot->inboundQueue[inq]; in siFastSSPResAlloc()
178 retVal = mpiMsgFreeGet(circularQ, size, pPayload); in siFastSSPResAlloc()
284 mpiICQueue_t *circularQ; in saFastSSPPrepare() local
[all …]
H A Dsautil.c137 mpiOCQueue_t *circularQ; in siDumpActiveIORequests() local
166 circularQ = &saRoot->outboundQueue[i]; in siDumpActiveIORequests()
167 OSSA_READ_LE_32(circularQ->agRoot, &circularQ->producerIdx, circularQ->piPointer, 0); in siDumpActiveIORequests()
168 if(circularQ->producerIdx != circularQ->consumerIdx) in siDumpActiveIORequests()
170 …G1(("siDumpActiveIORequests:OBQ%d PI 0x%03x CI 0x%03x\n", i,circularQ->producerIdx, circularQ->con… in siDumpActiveIORequests()
H A Dsasata.c71 mpiICQueue_t *circularQ = agNULL; in saSATAStart() local
167 circularQ = &saRoot->inboundQueue[inq]; in saSATAStart()
168 retVal = mpiMsgFreeGet(circularQ, size, &pMessage); in saSATAStart()
551 ret = mpiMsgProduce(circularQ, in saSATAStart()
556 (bit8)circularQ->priority); in saSATAStart()
608 mpiICQueue_t *circularQ; in saSATAAbort() local
736 circularQ = &saRoot->inboundQueue[inq]; in saSATAAbort()
737 retVal = mpiMsgFreeGet(circularQ, IOMB_SIZE64, &pMessage); in saSATAAbort()
824 …ret = mpiMsgProduce(circularQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, OPC_INB_SATA_ABORT, outq, … in saSATAAbort()
H A Dsaphy.c203 mpiOCQueue_t *circularQ; in saPhyStop() local
208 circularQ = &saRoot->outboundQueue[i]; in saPhyStop()
209 OSSA_READ_LE_32(circularQ->agRoot, &circularQ->producerIdx, circularQ->piPointer, 0); in saPhyStop()
210 if(circularQ->producerIdx != circularQ->consumerIdx) in saPhyStop()
212 … SA_DBG1(("saPhyStop: PI 0x%03x CI 0x%03x\n",circularQ->producerIdx, circularQ->consumerIdx )); in saPhyStop()
H A Dsaint.c1147 mpiOCQueue_t *circularQ = agNULL; in siProcessOBMsg() local
1165 circularQ = &saRoot->outboundQueue[queueNum]; in siProcessOBMsg()
1166 OSSA_READ_LE_32(circularQ->agRoot, &circularQ->producerIdx, circularQ->piPointer, 0); in siProcessOBMsg()
1168 if (circularQ->producerIdx == circularQ->consumerIdx) in siProcessOBMsg()
1180 ret = mpiMsgConsume(circularQ, &pMsg1, &category, &opcode, &bc); in siProcessOBMsg()
1193 for (i=0; i<((bit32)bc*(circularQ->elementSize/4)); i++) in siProcessOBMsg()
1201 …circularQ->qNumber,((circularQ->producerIdx << 16 ) | circularQ->consumerIdx),MPI_DEBUG_TRACE_OBQ,… in siProcessOBMsg()
1203 ossaLogIomb(circularQ->agRoot, in siProcessOBMsg()
1204 circularQ->qNumber, in siProcessOBMsg()
1207 bc*circularQ->elementSize); in siProcessOBMsg()
[all …]
H A Dsaioctlcmd.c79 mpiICQueue_t *circularQ; in saFwProfile() local
120 circularQ = &saRoot->inboundQueue[inq]; in saFwProfile()
121 retVal = mpiMsgFreeGet(circularQ, IOMB_SIZE64, &pMessage); in saFwProfile()
183 …ret = mpiMsgProduce(circularQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, OPC_INB_FW_PROFILE, outq, … in saFwProfile()
232 mpiICQueue_t *circularQ; in saFwFlashUpdate() local
284 circularQ = &saRoot->inboundQueue[inq]; in saFwFlashUpdate()
285 retVal = mpiMsgFreeGet(circularQ, IOMB_SIZE64, &pMessage); in saFwFlashUpdate()
346 ret = mpiMsgProduce( circularQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, in saFwFlashUpdate()
347 OPC_INB_FW_FLASH_UPDATE, outq, (bit8)circularQ->priority); in saFwFlashUpdate()
379 mpiICQueue_t *circularQ; in saFlashExtExecute() local
[all …]
H A Dsasmp.c73 mpiICQueue_t *circularQ; in saSMPStart() local
183 circularQ = &saRoot->inboundQueue[inq]; in saSMPStart()
184 retVal = mpiMsgFreeGet(circularQ, IOMB_SIZE64, &pMessage); in saSMPStart()
H A Dsahw.c429 mpiOCQueue_t *circularQ; in saHwShutdown() local
434 circularQ = &saRoot->outboundQueue[i]; in saHwShutdown()
435 OSSA_READ_LE_32(circularQ->agRoot, &circularQ->producerIdx, circularQ->piPointer, 0); in saHwShutdown()
436 if(circularQ->producerIdx != circularQ->consumerIdx) in saHwShutdown()
438 … SA_DBG1(("saHwShutdown: PI 0x%03x CI 0x%03x\n",circularQ->producerIdx, circularQ->consumerIdx )); in saHwShutdown()
H A Dsainit.c1442 mpiOCQueue_t *circularQ; in saInitialize() local
1445 circularQ = &saRoot->outboundQueue[0]; in saInitialize()
1446 OSSA_READ_LE_32(circularQ->agRoot, &circularQ->producerIdx, circularQ->piPointer, 0); in saInitialize()
1447 … SA_DBG1(("saInitialize: PI 0x%03x CI 0x%03x\n",circularQ->producerIdx, circularQ->consumerIdx)); in saInitialize()
1519 mpiOCQueue_t *circularQ; in siReadControllerStatus() local
1522 circularQ = &saRoot->outboundQueue[0]; in siReadControllerStatus()
1523 OSSA_READ_LE_32(circularQ->agRoot, &circularQ->producerIdx, circularQ->piPointer, 0); in siReadControllerStatus()
1524 if(circularQ->producerIdx != circularQ->consumerIdx) in siReadControllerStatus()
1527 …SA_DBG1(("siReadControllerStatus: PI 0x%03x CI 0x%03x\n",circularQ->producerIdx, circularQ->consum… in siReadControllerStatus()
H A Dsampicmd.c103 mpiICQueue_t *circularQ; in mpiBuildCmd() local
126 circularQ = &saRoot->inboundQueue[inq]; in mpiBuildCmd()
127 retVal = mpiMsgFreeGet(circularQ, size, &pMessage); in mpiBuildCmd()
157 …if (AGSA_RC_FAILURE == mpiMsgProduce(circularQ, (void *)pMessage, category, opcode, outq, (bit8)ci… in mpiBuildCmd()
910 mpiICQueue_t *circularQ; in mpiSMPCmd() local
935 circularQ = &saRoot->inboundQueue[inq]; in mpiSMPCmd()
936 …if (AGSA_RC_FAILURE == mpiMsgProduce(circularQ, (void *)pIomb, MPI_CATEGORY_SAS_SATA, opcode, outq… in mpiSMPCmd()