diff options
author | Pavel Levshin <pavel@levshin.spb.ru> | 2013-11-06 18:37:47 +0100 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-06 18:37:47 +0100 |
commit | 772cba6f2e34660fa74a7e2f5ec2823a2cdb6b04 (patch) | |
tree | dd485659f80ef4cc00b28b1194a73fef0f35f5d6 /runtime/wti.h | |
parent | 6b0e236cdf3d55299de70cf41dafdefec286f103 (diff) | |
download | rsyslog-772cba6f2e34660fa74a7e2f5ec2823a2cdb6b04.tar.gz rsyslog-772cba6f2e34660fa74a7e2f5ec2823a2cdb6b04.tar.bz2 rsyslog-772cba6f2e34660fa74a7e2f5ec2823a2cdb6b04.zip |
improve worker thread pool handling
among others, make possible that workers really timeout and the pool
thus shrinks
Diffstat (limited to 'runtime/wti.h')
-rw-r--r-- | runtime/wti.h | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/runtime/wti.h b/runtime/wti.h index 014251f0..b0dc6c96 100644 --- a/runtime/wti.h +++ b/runtime/wti.h @@ -37,6 +37,7 @@ struct wti_s { wtp_t *pWtp; /* my worker thread pool (important if only the work thread instance is passed! */ batch_t batch; /* pointer to an object array meaningful for current user pointer (e.g. queue pUsr data elemt) */ uchar *pszDbgHdr; /* header string for debug messages */ + pthread_cond_t pcondBusy; /* condition to wake up the worker, protected by pmutUsr in wtp */ DEF_ATOMIC_HELPER_MUT(mutIsRunning); }; |