diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-05 12:03:08 +0100 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-05 12:03:08 +0100 |
commit | 28b174e73c0d70be1a285b8b54c8904c3670cc0b (patch) | |
tree | 74df580e1ca84b3e31fb52f807862367e87784fd /runtime/queue.c | |
parent | c4f14fa28cc24cc56104b4b89ad380ee0f0470d3 (diff) | |
download | rsyslog-28b174e73c0d70be1a285b8b54c8904c3670cc0b.tar.gz rsyslog-28b174e73c0d70be1a285b8b54c8904c3670cc0b.tar.bz2 rsyslog-28b174e73c0d70be1a285b8b54c8904c3670cc0b.zip |
remove no longer needed code
Diffstat (limited to 'runtime/queue.c')
-rw-r--r-- | runtime/queue.c | 24 |
1 files changed, 0 insertions, 24 deletions
diff --git a/runtime/queue.c b/runtime/queue.c index 18f62ffa..952edb0f 100644 --- a/runtime/queue.c +++ b/runtime/queue.c @@ -964,7 +964,6 @@ static rsRetVal qAddDirect(qqueue_t *pThis, msg_t* pMsg, wti_t *pWti) batch_t singleBatch; batch_obj_t batchObj; batch_state_t batchState = BATCH_STATE_RDY; - int i; DEFiRet; //TODO: init batchObj (states _OK and new fields -- CHECK) @@ -990,29 +989,6 @@ static rsRetVal qAddDirect(qqueue_t *pThis, msg_t* pMsg, wti_t *pWti) RETiRet; } -/* "enqueue" a batch in direct mode. This is a shortcut which saves all the overhead - * otherwise incured. -- rgerhards, ~2010-06-23 - */ -rsRetVal qqueueEnqObjDirectBatch(qqueue_t *pThis, batch_t *pBatch, wti_t *pWti) -{ - DEFiRet; - - ASSERT(pThis != NULL); - - /* calling the consumer is quite different here than it is from a worker thread */ - /* we need to provide the consumer's return value back to the caller because in direct - * mode the consumer probably has a lot to convey (which get's lost in the other modes - * because they are asynchronous. But direct mode is deliberately synchronous. - * rgerhards, 2008-02-12 - * We use our knowledge about the batch_t structure below, but without that, we - * pay a too-large performance toll... -- rgerhards, 2009-04-22 - */ - iRet = pThis->pConsumer(pThis->pAction, pBatch, pWti, NULL); - - RETiRet; -} - - static rsRetVal qDelDirect(qqueue_t __attribute__((unused)) *pThis) { return RS_RET_OK; |