diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-05 17:53:52 +0100 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2013-11-05 17:53:52 +0100 |
commit | 962656afab5954259199e278aba0518fbedef89b (patch) | |
tree | 7c90fdf0eb85244b084f48fb1375208a407035fa | |
parent | e51de9f416b08e16b3a994596238a29c6bc06e7b (diff) | |
download | rsyslog-962656afab5954259199e278aba0518fbedef89b.tar.gz rsyslog-962656afab5954259199e278aba0518fbedef89b.tar.bz2 rsyslog-962656afab5954259199e278aba0518fbedef89b.zip |
cleanup no longer used code
-rw-r--r-- | runtime/queue.c | 21 | ||||
-rw-r--r-- | runtime/queue.h | 1 |
2 files changed, 0 insertions, 22 deletions
diff --git a/runtime/queue.c b/runtime/queue.c index a04e4f4d..db205fed 100644 --- a/runtime/queue.c +++ b/runtime/queue.c @@ -85,7 +85,6 @@ static rsRetVal qqueueMultiEnqObjDirect(qqueue_t *pThis, multi_submit_t *pMultiS static rsRetVal qAddDirect(qqueue_t *pThis, msg_t *pMsg); static rsRetVal qDestructDirect(qqueue_t __attribute__((unused)) *pThis); static rsRetVal qConstructDirect(qqueue_t __attribute__((unused)) *pThis); -static rsRetVal qDelDirect(qqueue_t __attribute__((unused)) *pThis); static rsRetVal qDestructDisk(qqueue_t *pThis); /* some constants for queuePersist () */ @@ -1009,11 +1008,6 @@ qAddDirect(qqueue_t *pThis, msg_t* pMsg) RETiRet; } -static rsRetVal qDelDirect(qqueue_t __attribute__((unused)) *pThis) -{ - return RS_RET_OK; -} - /* --------------- end type-specific handlers -------------------- */ @@ -2689,21 +2683,6 @@ finalize_it: /* ------------------------------ END multi-enqueue functions ------------------------------ */ -/* enqueue a new user data element in direct mode - * NOTE/TODO: This is a TESTER/EXPERIEMENTAL, to be changed to better - * code later on (like multi submit!) 2010-06-10 - * Enqueues the new element and awakes worker thread. - */ -rsRetVal -qqueueEnqMsgDirect(qqueue_t *pThis, msg_t *pMsg, wti_t *pWti) -{ - DEFiRet; - ISOBJ_TYPE_assert(pThis, qqueue); - iRet = qAddDirectWithWti(pThis, pMsg, pWti); - RETiRet; -} - - /* enqueue a new user data element * Enqueues the new element and awakes worker thread. */ diff --git a/runtime/queue.h b/runtime/queue.h index e5eef168..07491f21 100644 --- a/runtime/queue.h +++ b/runtime/queue.h @@ -194,7 +194,6 @@ struct queue_s { /* prototypes */ rsRetVal qqueueDestruct(qqueue_t **ppThis); -rsRetVal qqueueEnqMsgDirect(qqueue_t *pThis, msg_t *pMsg, wti_t *pWti); rsRetVal qqueueEnqMsg(qqueue_t *pThis, flowControl_t flwCtlType, msg_t *pMsg); rsRetVal qqueueStart(qqueue_t *pThis); rsRetVal qqueueSetMaxFileSize(qqueue_t *pThis, size_t iMaxFileSize); |