summaryrefslogtreecommitdiffstats
path: root/runtime/queue.h
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2009-05-12 15:27:40 +0200
committerRainer Gerhards <rgerhards@adiscon.com>2009-05-12 15:27:40 +0200
commitbb79e96dc300fa5a2182e7c047afb3b15c5dc870 (patch)
tree85680d43b503648da48fafe1178b1cb1ce62cc86 /runtime/queue.h
parent21b7f7e603639fa8f354c954b0e467abb72b6c12 (diff)
downloadrsyslog-bb79e96dc300fa5a2182e7c047afb3b15c5dc870.tar.gz
rsyslog-bb79e96dc300fa5a2182e7c047afb3b15c5dc870.tar.xz
rsyslog-bb79e96dc300fa5a2182e7c047afb3b15c5dc870.zip
moving to a cleaner implementation of batches
... now that we know what we need from a theoretical POV.
Diffstat (limited to 'runtime/queue.h')
-rw-r--r--runtime/queue.h5
1 files changed, 3 insertions, 2 deletions
diff --git a/runtime/queue.h b/runtime/queue.h
index 8a60254b..4a5f16a1 100644
--- a/runtime/queue.h
+++ b/runtime/queue.h
@@ -27,6 +27,7 @@
#include <pthread.h>
#include "obj.h"
#include "wtp.h"
+#include "batch.h"
#include "stream.h"
/* queue types */
@@ -100,7 +101,7 @@ typedef struct queue_s {
* the user really wanted...). -- rgerhards, 2008-04-02
*/
/* end dequeue time window */
- rsRetVal (*pConsumer)(void *,aUsrp_t*); /* user-supplied consumer function for dequeued messages */
+ rsRetVal (*pConsumer)(void *,batch_t*); /* user-supplied consumer function for dequeued messages */
/* calling interface for pConsumer: arg1 is the global user pointer from this structure, arg2 is the
* user pointer array that was dequeued (actual sample: for actions, arg1 is the pAction and arg2
* is pointer to an array of message message pointers)
@@ -184,7 +185,7 @@ rsRetVal qqueueStart(qqueue_t *pThis);
rsRetVal qqueueSetMaxFileSize(qqueue_t *pThis, size_t iMaxFileSize);
rsRetVal qqueueSetFilePrefix(qqueue_t *pThis, uchar *pszPrefix, size_t iLenPrefix);
rsRetVal qqueueConstruct(qqueue_t **ppThis, queueType_t qType, int iWorkerThreads,
- int iMaxQueueSize, rsRetVal (*pConsumer)(void*,aUsrp_t*));
+ int iMaxQueueSize, rsRetVal (*pConsumer)(void*,batch_t*));
PROTOTYPEObjClassInit(qqueue);
PROTOTYPEpropSetMeth(qqueue, iPersistUpdCnt, int);
PROTOTYPEpropSetMeth(qqueue, iDeqtWinFromHr, int);