Lines Matching refs:pTxn
419 ETxnStatus txnQ_Transact (TI_HANDLE hTxnQ, TTxnStruct *pTxn)
422 TI_UINT32 uFuncId = TXN_PARAM_GET_FUNC_ID(pTxn);
425 if (TXN_PARAM_GET_SINGLE_STEP(pTxn))
427 pTxnQ->aFuncInfo[uFuncId].pSingleStep = pTxn;
433 TI_HANDLE hQueue = pTxnQ->aTxnQueues[uFuncId][TXN_PARAM_GET_PRIORITY(pTxn)];
435 eStatus = que_Enqueue (hQueue, (TI_HANDLE)pTxn);
439 TRACE3(pTxnQ->hReport, REPORT_SEVERITY_ERROR, "txnQ_Transact(): Enqueue failed, pTxn=0x%x, HwAddr=0x%x, Len0=%d\n", pTxn, pTxn->uHwAddr, pTxn->aLen[0]);
446 rc = txnQ_RunScheduler (pTxnQ, pTxn);
460 * \param pTxn - The completed transaction object
482 * \param pTxn - The completed transaction object
489 TTxnStruct *pTxn = (TTxnStruct *)hTxn;
490 TI_UINT32 uFuncId = TXN_PARAM_GET_FUNC_ID(pTxn);
494 if (pTxn != pTxnQ->pCurrTxn)
496 TRACE2(pTxnQ->hReport, REPORT_SEVERITY_ERROR, "txnQ_TxnDoneCb(): CB returned pTxn 0x%x while pCurrTxn is 0x%x !!\n", pTxn, pTxnQ->pCurrTxn);
509 TXN_PARAM_SET_STATUS(pTxn, TXN_PARAM_STATUS_RECOVERY);
510 pTxnQ->aFuncInfo[uFuncId].fTxnQueueDoneCb (pTxnQ->aFuncInfo[uFuncId].hCbHandle, pTxn);
519 eStatus = que_Enqueue (pTxnQ->hTxnDoneQueue, (TI_HANDLE)pTxn);
522 TRACE3(pTxnQ->hReport, REPORT_SEVERITY_ERROR, "txnQ_TxnDoneCb(): Enqueue failed, pTxn=0x%x, HwAddr=0x%x, Len0=%d\n", pTxn, pTxn->uHwAddr, pTxn->aLen[0]);
681 TRACE3(pTxnQ->hReport, REPORT_SEVERITY_ERROR, "txnQ_Scheduler(): Enqueue failed, pTxn=0x%x, HwAddr=0x%x, Len0=%d\n", pSelectedTxn, pSelectedTxn->uHwAddr, pSelectedTxn->aLen[0]);
822 TTxnStruct *pTxn;
835 pTxn = (TTxnStruct *) que_Dequeue (pTxnQ->aTxnQueues[uFuncId][uPrio]);
839 * do not call fTxnQueueDoneCb (hCbHandle, pTxn) callback
841 } while (pTxn != NULL);
