Searched refs:currIParam (Results 1 – 3 of 3) sorted by relevance
/dports/sysutils/rsyslog8/rsyslog-8.2112.0/runtime/ |
H A D | wti.c | 216 if(wrkrInfo->p.tx.currIParam == wrkrInfo->p.tx.maxIParams) { in wtiNewIParam() 222 memset(iparams + (wrkrInfo->p.tx.currIParam * pAction->iNumTpls), 0, in wtiNewIParam() 227 *piparams = wrkrInfo->p.tx.iparams + wrkrInfo->p.tx.currIParam * pAction->iNumTpls; in wtiNewIParam() 228 ++wrkrInfo->p.tx.currIParam; in wtiNewIParam() 465 wrkrInfo->p.tx.currIParam = 0; in wtiWorker()
|
H A D | wti.h | 57 int currIParam; member
|
/dports/sysutils/rsyslog8/rsyslog-8.2112.0/ |
H A D | action.c | 1330 pThis->pszName, wrkrInfo->p.tx.currIParam); in doTransaction() 1487 const unsigned nMsgs = wrkrInfo->p.tx.currIParam; in actionTryRemoveHardErrorsFromBatch() 1525 if(!pThis->isTransactional || pWti->actWrkrInfo[pThis->iActionNbr].p.tx.currIParam == 0) { in ATTR_NONNULL() 1531 actionWriteErrorFile(pThis, iRet, wrkrInfo->p.tx.iparams, wrkrInfo->p.tx.currIParam); in ATTR_NONNULL() 1543 iRet = actionTryCommit(pThis, pWti, wrkrInfo->p.tx.iparams, wrkrInfo->p.tx.currIParam); in ATTR_NONNULL() 1553 if(wrkrInfo->p.tx.currIParam == 1) { in ATTR_NONNULL() 1556 nMsgs = wrkrInfo->p.tx.currIParam; in ATTR_NONNULL() 1563 pThis->pszName, wrkrInfo->p.tx.currIParam, iRet); in ATTR_NONNULL() 1565 * wrkrInfo->p.tx.currIParam)); in ATTR_NONNULL() 1612 wrkrInfo->p.tx.currIParam = 0; /* reset to beginning */ in ATTR_NONNULL() [all …]
|