diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-06-22 18:32:21 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-06-22 18:32:21 +0200 |
| commit | d61bcbbd0e99a8ffadfe1e0c5347dee9e04a0b1d (patch) | |
| tree | d9ce3466432d04ec2dfdc77ae5af0fe012c4a37e /runtime/queue.c | |
| parent | 55ead69efa550cbdff11656cb11c4a50439e7749 (diff) | |
| download | rsyslog-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.c | 3 |
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. */ |