Lines Matching refs:pTxn
408 ETxnStatus txnQ_Transact (TI_HANDLE hTxnQ, TTxnStruct *pTxn)
411 TI_UINT32 uFuncId = TXN_PARAM_GET_FUNC_ID(pTxn);
414 if (TXN_PARAM_GET_SINGLE_STEP(pTxn))
416 pTxnQ->aFuncInfo[uFuncId].pSingleStep = pTxn;
421 TI_HANDLE hQueue = pTxnQ->aTxnQueues[uFuncId][TXN_PARAM_GET_PRIORITY(pTxn)];
423 que_Enqueue (hQueue, (TI_HANDLE)pTxn);
429 rc = txnQ_RunScheduler (pTxnQ, pTxn);
443 * \param pTxn - The completed transaction object
465 * \param pTxn - The completed transaction object
472 TTxnStruct *pTxn = (TTxnStruct *)hTxn;
473 TI_UINT32 uFuncId = TXN_PARAM_GET_FUNC_ID(pTxn);
477 if (pTxn != pTxnQ->pCurrTxn)
479 TRACE2(pTxnQ->hReport, REPORT_SEVERITY_ERROR, "txnQ_TxnDoneCb(): CB returned pTxn 0x%x while pCurrTxn is 0x%x !!\n", pTxn, pTxnQ->pCurrTxn);
492 TXN_PARAM_SET_STATUS(pTxn, TXN_PARAM_STATUS_RECOVERY);
493 pTxnQ->aFuncInfo[uFuncId].fTxnQueueDoneCb (pTxnQ->aFuncInfo[uFuncId].hCbHandle, pTxn);
500 que_Enqueue (pTxnQ->hTxnDoneQueue, (TI_HANDLE)pTxn);
762 TTxnStruct *pTxn;
774 pTxn = (TTxnStruct *) que_Dequeue (pTxnQ->aTxnQueues[uFuncId][uPrio]);
779 * do not call fTxnQueueDoneCb (hCbHandle, pTxn) callback
781 } while (pTxn != NULL);
