summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2013-11-25 09:40:53 +0100
committerRainer Gerhards <rgerhards@adiscon.com>2013-11-25 09:40:53 +0100
commitf03431a834fa74326f43095c5b41b71014ea2e70 (patch)
tree3afbaaa4b20e89afe583107cd74af7382dd15d85
parent0df879fada6faed213ec32950ff17fe76396e438 (diff)
downloadrsyslog-7.5.7.tar.gz
rsyslog-7.5.7.tar.bz2
rsyslog-7.5.7.zip
regression fix: action queues with default settings did not start worker threadv7.5.7
-rw-r--r--runtime/queue.c8
1 files changed, 3 insertions, 5 deletions
diff --git a/runtime/queue.c b/runtime/queue.c
index e6dd6d69..8cbce011 100644
--- a/runtime/queue.c
+++ b/runtime/queue.c
@@ -2169,11 +2169,9 @@ qqueueStart(qqueue_t *pThis) /* this is the ConstructionFinalizer */
pThis->iLowWtrMrk = 1;
}
}
- if(pThis->iNumWorkerThreads > 1) {
- if( pThis->iMinMsgsPerWrkr < 1
- || pThis->iMinMsgsPerWrkr > pThis->iMaxQueueSize )
- pThis->iMinMsgsPerWrkr = pThis->iMaxQueueSize / pThis->iNumWorkerThreads;
- }
+ if( pThis->iMinMsgsPerWrkr < 1
+ || pThis->iMinMsgsPerWrkr > pThis->iMaxQueueSize )
+ pThis->iMinMsgsPerWrkr = pThis->iMaxQueueSize / pThis->iNumWorkerThreads;
if(pThis->iFullDlyMrk == -1 || pThis->iFullDlyMrk > pThis->iMaxQueueSize) {
pThis->iFullDlyMrk = (pThis->iMaxQueueSize / 100) * 97;
if(pThis->iFullDlyMrk == 0) {