diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2011-03-30 12:13:14 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2011-03-30 12:13:14 +0200 |
| commit | 00e1f24187ee814801e6969629b82a7ae030beaf (patch) | |
| tree | 3ce277b2a3326dcadffe282fff977d5407c34cdb | |
| parent | b59f8fd65d4f464ce3673439725db1606ec31329 (diff) | |
| download | rsyslog-00e1f24187ee814801e6969629b82a7ae030beaf.tar.gz rsyslog-00e1f24187ee814801e6969629b82a7ae030beaf.tar.xz rsyslog-00e1f24187ee814801e6969629b82a7ae030beaf.zip | |
stop adding data to DA queue when low watermark has been reached
potentially closes: http://bugzilla.adiscon.com/show_bug.cgi?id=241
But needs more verification.
| -rw-r--r-- | runtime/queue.c | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/runtime/queue.c b/runtime/queue.c index ef6e843b..50ae307c 100644 --- a/runtime/queue.c +++ b/runtime/queue.c @@ -1774,9 +1774,13 @@ qqueueChkStopWrkrDA(qqueue_t *pThis) { DEFiRet; +//DBGPRINTF("XXXX: chkStopWrkrDA called, low watermark %d, phys Size %d\n", pThis->iLowWtrMrk, getPhysicalQueueSize(pThis)); if(pThis->bEnqOnly) { iRet = RS_RET_TERMINATE_WHEN_IDLE; } + if(getPhysicalQueueSize(pThis) <= pThis->iLowWtrMrk) { + iRet = RS_RET_TERMINATE_NOW; + } RETiRet; } |