diff options
Diffstat (limited to 'runtime')
| -rw-r--r-- | runtime/ruleset.c | 6 |
1 files changed, 3 insertions, 3 deletions
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; |