From 32b37ecd82b508e707cf1aa0b27acb4ac96a295c Mon Sep 17 00:00:00 2001 From: Rainer Gerhards Date: Sun, 3 Nov 2013 10:59:34 +0100 Subject: fix async action queues --- action.c | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/action.c b/action.c index eaa993da..5d2fab68 100644 --- a/action.c +++ b/action.c @@ -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); } } -- cgit v1.2.3