diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2010-12-16 14:23:38 +0100 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2010-12-16 14:23:38 +0100 |
commit | b9ba5013ad39dbf60a0a3bc06c38870a803451fd (patch) | |
tree | 731f063626eb09d199211b31e2e3b6415c59e614 /runtime/queue.c | |
parent | 189a26c0444178612bf6e4618ccd9c722b83c261 (diff) | |
download | rsyslog-b9ba5013ad39dbf60a0a3bc06c38870a803451fd.tar.gz rsyslog-b9ba5013ad39dbf60a0a3bc06c38870a803451fd.tar.xz rsyslog-b9ba5013ad39dbf60a0a3bc06c38870a803451fd.zip |
bugfix: batch processing flagged invalid message as "bad" under some circumstances
also fixed some cosmetic nits
Diffstat (limited to 'runtime/queue.c')
-rw-r--r-- | runtime/queue.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/runtime/queue.c b/runtime/queue.c index 60d17086..c2806ca1 100644 --- a/runtime/queue.c +++ b/runtime/queue.c @@ -1129,7 +1129,7 @@ cancelWorkers(qqueue_t *pThis) * done when *no* worker is running. So time for a shutdown... -- rgerhards, 2009-05-28 */ DBGOPRINT((obj_t*) pThis, "checking to see if main queue DA worker pool needs to be cancelled\n"); - iRetLocal = wtpCancelAll(pThis->pWtpDA); /* returns immediately if all threads already have terminated */ + wtpCancelAll(pThis->pWtpDA); /* returns immediately if all threads already have terminated */ } RETiRet; |