diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-19 18:18:10 +0100 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-19 18:18:10 +0100 |
| commit | 020fe0dcc4ae9eae05e36dcf54ac043c5ae856ae (patch) | |
| tree | 46db18e05a61ec9b933bccaa12d7bcf0341e831c /runtime/queue.c | |
| parent | cdce0bde4b3b2f77ecdf8a9ba2e4772fb92ff20d (diff) | |
| download | rsyslog-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.c | 2 |
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*) |