From 9718fbbf0bae7fb1f9617b08d65087e433abe766 Mon Sep 17 00:00:00 2001
From: Rainer Gerhards <rgerhards@adiscon.com>
Date: Mon, 4 Nov 2013 14:42:15 +0100
Subject: push bShutdownImmediate ptr down to commit process

---
 runtime/ruleset.c | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

(limited to 'runtime/ruleset.c')

diff --git a/runtime/ruleset.c b/runtime/ruleset.c
index 654c6e55..57694bf7 100644
--- a/runtime/ruleset.c
+++ b/runtime/ruleset.c
@@ -589,9 +589,9 @@ scriptExec(struct cnfstmt *root, batch_t *pBatch, sbool *active, wti_t *pWti)
 
 
 static void
-commitBatch(wti_t *pWti)
+commitBatch(batch_t *pBatch, wti_t *pWti)
 {
-	actionCommitAll(pWti);
+	actionCommitAllDirect(pWti, pBatch->pbShutdownImmediate);
 }
 
 /* Process (consume) a batch of messages. Calls the actions configured.
@@ -621,7 +621,7 @@ processBatch(batch_t *pBatch, wti_t *pWti)
 	}
 
 	/* commit phase */
-	commitBatch(pWti);
+	commitBatch(pBatch, pWti);
 finalize_it:
 	DBGPRINTF("ruleset.ProcessMsg() returns %d\n", iRet);
 	RETiRet;
-- 
cgit v1.2.3