diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-04 14:42:15 +0100 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-04 14:42:15 +0100 |
| commit | 9718fbbf0bae7fb1f9617b08d65087e433abe766 (patch) | |
| tree | 5d48924d73baba121585ebfb33a66d03e8f14472 /runtime/ruleset.c | |
| parent | 30aece94a64eb2564e6bb3067a98ec9405daebfb (diff) | |
| download | rsyslog-9718fbbf0bae7fb1f9617b08d65087e433abe766.tar.gz rsyslog-9718fbbf0bae7fb1f9617b08d65087e433abe766.tar.bz2 rsyslog-9718fbbf0bae7fb1f9617b08d65087e433abe766.zip | |
push bShutdownImmediate ptr down to commit process
Diffstat (limited to 'runtime/ruleset.c')
| -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; |