added $MainMsgQueuePersistUpdateCount config file directive

1 files changed, 3 insertions, 1 deletions

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 */