diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2008-01-04 16:52:56 +0000 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2008-01-04 16:52:56 +0000 |
| commit | e41c0854dac685047dba1107b097bf674e740131 (patch) | |
| tree | b0257b48b40e707b65a1c3ec02de42d95928b45d /queue.c | |
| parent | 3b8457d1da7f81f9d5c48ff9f1d84cb838942803 (diff) | |
| download | rsyslog-e41c0854dac685047dba1107b097bf674e740131.tar.gz rsyslog-e41c0854dac685047dba1107b097bf674e740131.tar.xz rsyslog-e41c0854dac685047dba1107b097bf674e740131.zip | |
moved message destruction back to consumer - the consume should decide what
to do with the object. It may pass it on to someone else. So this would
have creatd some headache in the future (maybe...).
Diffstat (limited to 'queue.c')
| -rw-r--r-- | queue.c | 5 |
1 files changed, 0 insertions, 5 deletions
@@ -343,11 +343,6 @@ queueWorker(void *arg) if(iRetLocal != RS_RET_OK) dbgprintf("Queue 0x%lx: Consumer returned iRet %d\n", (unsigned long) pThis, iRetLocal); -dbgprintf("QUEUE: consumer done\n"); - iRetLocal = objDestruct(pUsr); - if(iRetLocal != RS_RET_OK) - dbgprintf("Queue 0x%lx: Destructor returned iRet %d\n", - (unsigned long) pThis, iRetLocal); } else { dbgprintf("Queue 0x%lx: error %d dequeueing element - ignoring, but strange things " "may happen\n", (unsigned long) pThis, iRet); |