summaryrefslogtreecommitdiffstats
path: root/runtime/queue.c
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2013-11-19 18:18:10 +0100
committerRainer Gerhards <rgerhards@adiscon.com>2013-11-19 18:18:10 +0100
commit020fe0dcc4ae9eae05e36dcf54ac043c5ae856ae (patch)
tree46db18e05a61ec9b933bccaa12d7bcf0341e831c /runtime/queue.c
parentcdce0bde4b3b2f77ecdf8a9ba2e4772fb92ff20d (diff)
downloadrsyslog-020fe0dcc4ae9eae05e36dcf54ac043c5ae856ae.tar.gz
rsyslog-020fe0dcc4ae9eae05e36dcf54ac043c5ae856ae.tar.bz2
rsyslog-020fe0dcc4ae9eae05e36dcf54ac043c5ae856ae.zip
bugfix: legacy directive $ActionQueueWorkerThreads was not honored
Diffstat (limited to 'runtime/queue.c')
-rw-r--r--runtime/queue.c2
1 files changed, 2 insertions, 0 deletions
diff --git a/runtime/queue.c b/runtime/queue.c
index c9d064d6..78a7a79e 100644
--- a/runtime/queue.c
+++ b/runtime/queue.c
@@ -2123,6 +2123,7 @@ qqueueStart(qqueue_t *pThis) /* this is the ConstructionFinalizer */
"60%% (%d) if you have a good reason for this.",
obj.GetName((obj_t*) pThis), pThis->iHighWtrMrk, goodval);
}
+
if(pThis->iHighWtrMrk < 2 || pThis->iHighWtrMrk > pThis->iMaxQueueSize)
pThis->iHighWtrMrk = (pThis->iMaxQueueSize / 100) * 90;
if( pThis->iLowWtrMrk < 2
@@ -2937,6 +2938,7 @@ DEFpropSetMeth(qqueue, iFullDlyMrk, int)
DEFpropSetMeth(qqueue, iDiscardSeverity, int)
DEFpropSetMeth(qqueue, iLightDlyMrk, int)
DEFpropSetMeth(qqueue, bIsDA, int)
+DEFpropSetMeth(qqueue, iNumWorkerThreads, int)
DEFpropSetMeth(qqueue, iMinMsgsPerWrkr, int)
DEFpropSetMeth(qqueue, bSaveOnShutdown, int)
DEFpropSetMeth(qqueue, pAction, action_t*)