diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-07-30 11:09:15 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-07-30 11:09:15 +0200 |
| commit | a6bda9b93f21cdbec1d7312078535eb092f32cb0 (patch) | |
| tree | e1b62c000eea2b81e0e67694b2d8129e252f830c /runtime/queue.c | |
| parent | feeb622c4e0c622559df803f8df6da39bf3015e7 (diff) | |
| download | rsyslog-a6bda9b93f21cdbec1d7312078535eb092f32cb0.tar.gz rsyslog-a6bda9b93f21cdbec1d7312078535eb092f32cb0.tar.xz rsyslog-a6bda9b93f21cdbec1d7312078535eb092f32cb0.zip | |
bugfix: discard action did not work (did not discard messages)
Diffstat (limited to 'runtime/queue.c')
| -rw-r--r-- | runtime/queue.c | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/runtime/queue.c b/runtime/queue.c index cb14b58d..8388d00e 100644 --- a/runtime/queue.c +++ b/runtime/queue.c @@ -1044,6 +1044,7 @@ static rsRetVal qAddDirect(qqueue_t *pThis, void* pUsr) iRet = pThis->pConsumer(pThis->pUsr, &singleBatch); objDestruct(pUsr); +dbgprintf("XXXX: qAddDirect returns %d\n", iRet); RETiRet; } @@ -2442,6 +2443,7 @@ doEnqSingleObj(qqueue_t *pThis, flowControl_t flowCtlType, void *pUsr) CHKiRet(qqueueAdd(pThis, pUsr)); finalize_it: +dbgprintf("XXXX: queueEnqObj returns %d\n", iRet); RETiRet; } |