diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2008-01-13 15:47:41 +0000 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2008-01-13 15:47:41 +0000 |
commit | abdcea7d8f0eda058a6c6719cf24955878279d7c (patch) | |
tree | bab4f9dc61457f63e9a30516cf91eb8112fac1ef /queue.h | |
parent | 366060a51de60c717886636d6ef646bf1959972c (diff) | |
download | rsyslog-abdcea7d8f0eda058a6c6719cf24955878279d7c.tar.gz rsyslog-abdcea7d8f0eda058a6c6719cf24955878279d7c.tar.xz rsyslog-abdcea7d8f0eda058a6c6719cf24955878279d7c.zip |
support for reading back persistet queue information completed
Diffstat (limited to 'queue.h')
-rw-r--r-- | queue.h | 2 |
1 files changed, 2 insertions, 0 deletions
@@ -81,6 +81,8 @@ typedef struct queue_s { int iNumWorkerThreads;/* number of worker threads to use */ qWrkThrd_t *pWrkThrds;/* array with control structure for the worker thread(s) associated with this queue */ int bImmediateShutdown;/* on shutdown, drain the queue --> 0 / do NOT drain the queue --> 1 */ + //int bNeedPersist; /* does the queue need to be persisted on disk (updated since last persist?) */ + int bNeedDelQIF; /* does the QIF file need to be deleted when queue becomes empty? */ rsRetVal (*pConsumer)(void *); /* user-supplied consumer function for dequeued messages */ /* type-specific handlers (set during construction) */ rsRetVal (*qConstruct)(struct queue_s *pThis); |