diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-02 12:30:28 +0100 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-02 12:30:28 +0100 |
| commit | 8878a0b1cf11f417fb3f72ec5bc7fe13ddabd624 (patch) | |
| tree | 36a1cae2da4e1072282220863eacbea89283da1f | |
| parent | 08e96b620e67c576b5ad50a205a1ae941c990272 (diff) | |
| download | rsyslog-8878a0b1cf11f417fb3f72ec5bc7fe13ddabd624.tar.gz rsyslog-8878a0b1cf11f417fb3f72ec5bc7fe13ddabd624.tar.bz2 rsyslog-8878a0b1cf11f417fb3f72ec5bc7fe13ddabd624.zip | |
re-enable state handling after endTransaction()
| -rw-r--r-- | action.c | 8 |
1 files changed, 0 insertions, 8 deletions
@@ -1007,16 +1007,9 @@ for(i = 0 ; i < iActionNbr ; ++i) { if(getActionState(pWti, pThis) == ACT_STATE_ITX) { dbgprintf("DDDDD: calling endTransaction for action %d\n", pThis->iActionNbr); iRet = pThis->pMod->mod.om.endTransaction(pWti->actWrkrInfo[pThis->iActionNbr].actWrkrData); - setActionState(pWti, pThis, ACT_STATE_RDY); -#if 0 switch(iRet) { case RS_RET_OK: actionCommitted(pThis, pWti); - /* flag messages as committed */ - for(i = 0 ; i < pBatch->nElem ; ++i) { - batchSetElemState(pBatch, i, BATCH_STATE_COMM); - pBatch->pElem[i].bPrevWasSuspended = 0; /* we had success! */ - } break; case RS_RET_SUSPENDED: actionRetry(pThis, pWti); @@ -1039,7 +1032,6 @@ dbgprintf("DDDDD: calling endTransaction for action %d\n", pThis->iActionNbr); */ FINALIZE; } -#endif } iRet = getReturnCode(pThis, pWti); |