diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-05-28 11:57:30 +0200 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-05-28 11:57:30 +0200 |
commit | fc3e56941ca6dbf401bee2f9dc0f9e4c5cd87f40 (patch) | |
tree | 6e506d1a66615ffeb95b9960c54352ba2e6175a2 /runtime/wti.c | |
parent | 7405a3057003bab0361a111b0f9d013b881b6db0 (diff) | |
download | rsyslog-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.c | 1 |
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); |