diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-10-22 14:57:34 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-10-22 14:57:34 +0200 |
| commit | 33e216daf7f89542cc6c91f1e97da6fdb71eecf8 (patch) | |
| tree | f4b74d404f66234121cdd1f7fe1bba029975ce61 /action.c | |
| parent | e04e1b50025f5fa9c26abd946190dce8f797d08f (diff) | |
| download | rsyslog-33e216daf7f89542cc6c91f1e97da6fdb71eecf8.tar.gz rsyslog-33e216daf7f89542cc6c91f1e97da6fdb71eecf8.tar.xz rsyslog-33e216daf7f89542cc6c91f1e97da6fdb71eecf8.zip | |
Begun to work on partial batch deletes...
... but this brings a lot of problems with it. The issue is that
we still have a sequential store and we do not know how we could
delete the one entry right in the middle of processing. I keep this
branch if we intend to move on with it - but for now I look into a
different solution...
Diffstat (limited to 'action.c')
| -rw-r--r-- | action.c | 4 |
1 files changed, 2 insertions, 2 deletions
@@ -936,8 +936,8 @@ processAction(action_t *pAction, batch_t *pBatch, int *pbShutdownImmediate) CHKiRet(localRet); /* this must be moved away - up into the dequeue part of the queue, I guess, but that's for another day */ - //for(i = 0 ; i < pBatch->nElem && !*pbShutdownImmediate ; i++) { - for(i = 0 ; i < pBatch->nElem ; i++) { + for(i = 0 ; i < pBatch->nElem && !*pbShutdownImmediate ; i++) { + //for(i = 0 ; i < pBatch->nElem ; i++) { pMsg = (msg_t*) pBatch->pElem[i].pUsrp; } iRet = finishBatch(pAction); |