summaryrefslogtreecommitdiffstats
path: root/runtime/wti.c
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2009-05-28 11:57:30 +0200
committerRainer Gerhards <rgerhards@adiscon.com>2009-05-28 11:57:30 +0200
commitfc3e56941ca6dbf401bee2f9dc0f9e4c5cd87f40 (patch)
tree6e506d1a66615ffeb95b9960c54352ba2e6175a2 /runtime/wti.c
parent7405a3057003bab0361a111b0f9d013b881b6db0 (diff)
downloadrsyslog-fc3e56941ca6dbf401bee2f9dc0f9e4c5cd87f40.tar.gz
rsyslog-fc3e56941ca6dbf401bee2f9dc0f9e4c5cd87f40.tar.xz
rsyslog-fc3e56941ca6dbf401bee2f9dc0f9e4c5cd87f40.zip
fixing an issue during DA mode queue shutdown
also changed DA queue mode in that the regular workers now run concurrently.
Diffstat (limited to 'runtime/wti.c')
-rw-r--r--runtime/wti.c1
1 files changed, 1 insertions, 0 deletions
diff --git a/runtime/wti.c b/runtime/wti.c
index 2fb5eea2..9428cd47 100644
--- a/runtime/wti.c
+++ b/runtime/wti.c
@@ -392,6 +392,7 @@ wtiWorker(wti_t *pThis)
dbgSetThrdName(pThis->pszDbgHdr);
pthread_cleanup_push(wtiWorkerCancelCleanup, pThis);
+ pThis->batch.nElemDeq = 0; /* re-init dequeue count */
BEGIN_MTX_PROTECTED_OPERATIONS_UNCOND(pWtp->pmutUsr);
pWtp->pfOnWorkerStartup(pWtp->pUsr);
END_MTX_PROTECTED_OPERATIONS_UNCOND(pWtp->pmutUsr);