summaryrefslogtreecommitdiffstats
path: root/runtime/queue.c
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2009-06-22 18:32:21 +0200
committerRainer Gerhards <rgerhards@adiscon.com>2009-06-22 18:32:21 +0200
commitd61bcbbd0e99a8ffadfe1e0c5347dee9e04a0b1d (patch)
treed9ce3466432d04ec2dfdc77ae5af0fe012c4a37e /runtime/queue.c
parent55ead69efa550cbdff11656cb11c4a50439e7749 (diff)
downloadrsyslog-d61bcbbd0e99a8ffadfe1e0c5347dee9e04a0b1d.tar.gz
rsyslog-d61bcbbd0e99a8ffadfe1e0c5347dee9e04a0b1d.tar.xz
rsyslog-d61bcbbd0e99a8ffadfe1e0c5347dee9e04a0b1d.zip
adapted (and improved) input batching to v5 engine
Diffstat (limited to 'runtime/queue.c')
-rw-r--r--runtime/queue.c3
1 files changed, 2 insertions, 1 deletions
diff --git a/runtime/queue.c b/runtime/queue.c
index 9462f865..1ae386e7 100644
--- a/runtime/queue.c
+++ b/runtime/queue.c
@@ -2635,7 +2635,6 @@ doEnqSingleObj(qqueue_t *pThis, flowControl_t flowCtlType, void *pUsr)
/* and finally enqueue the message */
CHKiRet(qqueueAdd(pThis, pUsr));
- qqueueChkPersist(pThis, 1); // TODO: optimize, do in outer function! (but we need parts from v5?)
finalize_it:
RETiRet;
@@ -2669,6 +2668,8 @@ dbgprintf("queueMultiEnq: %d\n", i);
CHKiRet(doEnqSingleObj(pThis, pMultiSub->ppMsgs[i]->flowCtlType, (void*)pMultiSub->ppMsgs[i]));
}
+ qqueueChkPersist(pThis, pMultiSub->nElem);
+
finalize_it:
if(pThis->qType != QUEUETYPE_DIRECT) {
/* make sure at least one worker is running. */