diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-03 10:59:34 +0100 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-03 10:59:34 +0100 |
| commit | 32b37ecd82b508e707cf1aa0b27acb4ac96a295c (patch) | |
| tree | ede66d3957acfe4354b57dd22e10917b0ef8f25e /action.c | |
| parent | 094ae94c861fe4f0ab36bfb35a7fb3a101fd667a (diff) | |
| download | rsyslog-32b37ecd82b508e707cf1aa0b27acb4ac96a295c.tar.gz rsyslog-32b37ecd82b508e707cf1aa0b27acb4ac96a295c.tar.bz2 rsyslog-32b37ecd82b508e707cf1aa0b27acb4ac96a295c.zip | |
fix async action queues
Diffstat (limited to 'action.c')
| -rw-r--r-- | action.c | 4 |
1 files changed, 3 insertions, 1 deletions
@@ -1082,7 +1082,7 @@ processBatchMain(void *pVoid, batch_t *pBatch, wti_t *pWti, int *pbShutdownImmed /* indicate we have not yet read the date */ ttNow.year = 0; - for(i = 0 ; i < batchNumMsgs(pBatch) && !*(pBatch->pbShutdownImmediate) ; ++i) { + for(i = 0 ; i < batchNumMsgs(pBatch) && !*pbShutdownImmediate ; ++i) { if(batchIsValidElem(pBatch, i)) { pMsg = pBatch->pElem[i].pMsg; dbgprintf("DDDD: processBatchMain[act %d], elt %d: %s\n", pAction->iActionNbr, i, pMsg->pszRawMsg); @@ -1092,6 +1092,8 @@ dbgprintf("DDDD: processBatchMain[act %d], elt %d: %s\n", pAction->iActionNbr, i pWti->actWrkrInfo[pAction->iActionNbr].staticActParams, pbShutdownImmediate, pWti); releaseDoActionParams(pAction, pWti); + // TODO: we must refactor this! flag messages as committed + batchSetElemState(pBatch, i, BATCH_STATE_COMM); } } |