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/wtp.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/wtp.h')
| -rw-r--r-- | runtime/wtp.h | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/runtime/wtp.h b/runtime/wtp.h index 25992f7f..697722af 100644 --- a/runtime/wtp.h +++ b/runtime/wtp.h @@ -56,7 +56,7 @@ struct wtp_s { void *pUsr; /* pointer to user object (in this case, the queue the wtp belongs to) */ pthread_attr_t attrThrd;/* attribute for new threads (created just once and cached here) */ pthread_mutex_t *pmutUsr; - pthread_cond_t *pcondBusy; /* condition the user will signal "busy again, keep runing" on (awakes worker) */ + pthread_cond_t *pcondBusy; /* unused condition variable, was used to signal threads to wake up */ rsRetVal (*pfChkStopWrkr)(void *pUsr, int); rsRetVal (*pfGetDeqBatchSize)(void *pUsr, int*); /* obtains max dequeue count from queue config */ rsRetVal (*pfObjProcessed)(void *pUsr, wti_t *pWti); /* indicate user object is processed */ |