diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2008-01-03 13:28:45 +0000 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2008-01-03 13:28:45 +0000 |
| commit | 8951958ff6d8241df9ffe048e2c0d0766a9d383b (patch) | |
| tree | f667f9ec334d959d8afbf068553e7a1cf1bdcdde /queue.h | |
| parent | 9e67ae041d964748755e5c9c45ebe55ff612391e (diff) | |
| download | rsyslog-8951958ff6d8241df9ffe048e2c0d0766a9d383b.tar.gz rsyslog-8951958ff6d8241df9ffe048e2c0d0766a9d383b.tar.xz rsyslog-8951958ff6d8241df9ffe048e2c0d0766a9d383b.zip | |
queue is now a full object and handles threading by itself
Diffstat (limited to 'queue.h')
| -rw-r--r-- | queue.h | 9 |
1 files changed, 6 insertions, 3 deletions
@@ -23,6 +23,7 @@ #ifndef QUEUE_H_INCLUDED #define QUEUE_H_INCLUDED +#include <pthread.h> /* queue types */ typedef enum { @@ -34,6 +35,9 @@ typedef enum { typedef struct queue_s { queueType_t qType; int iMaxQueueSize; /* how large can the queue grow? */ + pthread_t thrdWorker; /* ID of the worker thread associated with this queue */ + int bDoRun; /* 1 - run queue, 0 - shutdown of queue requested */ + rsRetVal (*pConsumer)(void *); /* user-supplied consumer function for dequeued messages */ /* type-specific handlers (set during construction) */ rsRetVal (*qConstruct)(struct queue_s *pThis); rsRetVal (*qDestruct)(struct queue_s *pThis); @@ -55,9 +59,8 @@ typedef struct queue_s { /* prototypes */ -rsRetVal queueConstruct(queue_t **ppThis, queueType_t qType, int iMaxQueueSize); +rsRetVal queueConstruct(queue_t **ppThis, queueType_t qType, int iMaxQueueSize, rsRetVal (*pConsumer)(void*)); rsRetVal queueDestruct(queue_t *pThis); -rsRetVal queueAdd(queue_t *pThis, void* in); -rsRetVal queueDel(queue_t *pThis, void **out); +rsRetVal queueEnqObj(queue_t *pThis, void *pUsr); #endif /* #ifndef QUEUE_H_INCLUDED */ |