diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-10-09 15:44:39 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-10-09 15:44:39 +0200 |
| commit | fccb97d4dcb905293b9b704b7647f59b95b1d1ae (patch) | |
| tree | 74dcad682834592e43fe918d649b81c1893fb7de /runtime/wtp.c | |
| parent | d85efd07e006d4d9031019aa9ac9757d303a8b36 (diff) | |
| parent | 98d1ed504ec001728955a5bcd7916f64cd85f39f (diff) | |
| download | rsyslog-fccb97d4dcb905293b9b704b7647f59b95b1d1ae.tar.gz rsyslog-fccb97d4dcb905293b9b704b7647f59b95b1d1ae.tar.bz2 rsyslog-fccb97d4dcb905293b9b704b7647f59b95b1d1ae.zip | |
Merge branch 'beta'
Diffstat (limited to 'runtime/wtp.c')
| -rw-r--r-- | runtime/wtp.c | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/runtime/wtp.c b/runtime/wtp.c index 4524e0c3..40d031dc 100644 --- a/runtime/wtp.c +++ b/runtime/wtp.c @@ -413,6 +413,7 @@ wtpAdviseMaxWorkers(wtp_t *pThis, int nMaxWrkr) ISOBJ_TYPE_assert(pThis, wtp); +int nMaxWrkrTmp = nMaxWrkr; if(nMaxWrkr == 0) FINALIZE; @@ -420,6 +421,7 @@ wtpAdviseMaxWorkers(wtp_t *pThis, int nMaxWrkr) nMaxWrkr = pThis->iNumWorkerThreads; nMissing = nMaxWrkr - ATOMIC_FETCH_32BIT(pThis->iCurNumWrkThrd); +dbgprintf("wtpAdviseMaxWorkers, nmax: %d, curr %d, missing %d\n", nMaxWrkrTmp, pThis->iNumWorkerThreads, nMissing); if(nMissing > 0) { DBGPRINTF("%s: high activity - starting %d additional worker thread(s).\n", wtpGetDbgHdr(pThis), nMissing); @@ -428,6 +430,7 @@ wtpAdviseMaxWorkers(wtp_t *pThis, int nMaxWrkr) CHKiRet(wtpStartWrkr(pThis)); } } else { +dbgprintf("YYY: adivse signal cond busy"); pthread_cond_signal(pThis->pcondBusy); } |