From bbf0aecbbd3d4adf2f952011418701dce0236234 Mon Sep 17 00:00:00 2001 From: Rainer Gerhards Date: Sun, 13 Jan 2008 17:16:59 +0000 Subject: added $MainMsgQueuePersistUpdateCount config file directive --- queue.h | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'queue.h') diff --git a/queue.h b/queue.h index 6593ce84..e5b64ff8 100644 --- a/queue.h +++ b/queue.h @@ -81,7 +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 iUpdsSincePersist;/* nbr of queue updates since the last persist call */ + int iPersistUpdCnt; /* persits queue info after this nbr of updates - 0 -> persist only on shutdown */ 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) */ @@ -132,6 +133,7 @@ rsRetVal queueConstruct(queue_t **ppThis, queueType_t qType, int iWorkerThreads, int iMaxQueueSize, rsRetVal (*pConsumer)(void*)); PROTOTYPEObjClassInit(queue); PROTOTYPEpropSetMeth(queue, bImmediateShutdown, int); +PROTOTYPEpropSetMeth(queue, iPersistUpdCnt, int); #define queueGetID(pThis) ((unsigned long) pThis) #endif /* #ifndef QUEUE_H_INCLUDED */ -- cgit