diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-04-23 16:02:42 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-04-23 16:02:42 +0200 |
| commit | 8159d0a117837ed573e80cf86f4f013bf9534ab2 (patch) | |
| tree | 3c3ef9a4b32a1165d379c71de3abe497b3abc1e2 /runtime/queue.c | |
| parent | 6c5264159c099ddc4d06590508980ee53a83b67b (diff) | |
| download | rsyslog-8159d0a117837ed573e80cf86f4f013bf9534ab2.tar.gz rsyslog-8159d0a117837ed573e80cf86f4f013bf9534ab2.tar.xz rsyslog-8159d0a117837ed573e80cf86f4f013bf9534ab2.zip | |
fixed abort condition in DA mode
Diffstat (limited to 'runtime/queue.c')
| -rw-r--r-- | runtime/queue.c | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/runtime/queue.c b/runtime/queue.c index a5feef3d..c2df928b 100644 --- a/runtime/queue.c +++ b/runtime/queue.c @@ -374,8 +374,7 @@ qqueueInitDA(qqueue_t *pThis, int bEnqOnly, int bLockMutex) CHKiRet(wtpConstruct (&pThis->pWtpDA)); CHKiRet(wtpSetDbgHdr (pThis->pWtpDA, pszBuf, lenBuf)); CHKiRet(wtpSetpfChkStopWrkr (pThis->pWtpDA, (rsRetVal (*)(void *pUsr, int)) qqueueChkStopWrkrDA)); - // MULTIQUEUE: TODO: this should be DA-specific! - CHKiRet(wtpSetpfGetDeqBatchSize (pThis->pWtpReg, (rsRetVal (*)(void *pUsr, int*)) GetDeqBatchSize)); + CHKiRet(wtpSetpfGetDeqBatchSize (pThis->pWtpDA, (rsRetVal (*)(void *pUsr, int*)) GetDeqBatchSize)); CHKiRet(wtpSetpfIsIdle (pThis->pWtpDA, (rsRetVal (*)(void *pUsr, int)) qqueueIsIdleDA)); CHKiRet(wtpSetpfDoWork (pThis->pWtpDA, (rsRetVal (*)(void *pUsr, void *pWti, int)) ConsumerDA)); CHKiRet(wtpSetpfOnWorkerCancel (pThis->pWtpDA, (rsRetVal (*)(void *pUsr, void*pWti)) ConsumerCancelCleanup)); |