From 00e1f24187ee814801e6969629b82a7ae030beaf Mon Sep 17 00:00:00 2001
From: Rainer Gerhards <rgerhards@adiscon.com>
Date: Wed, 30 Mar 2011 12:13:14 +0200
Subject: 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.
---
 runtime/queue.c | 4 ++++
 1 file changed, 4 insertions(+)

(limited to 'runtime/queue.c')

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;
 }
-- 
cgit v1.2.3