diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2008-01-14 11:55:24 +0000 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2008-01-14 11:55:24 +0000 |
| commit | 77a338e180fd51811041363f615760a14a2dc889 (patch) | |
| tree | 8edab9c877db4c25e6291d68f833b5bd4e6feb57 /queue.h | |
| parent | dd36718bd11c85af49546ab589fa42bf512075ce (diff) | |
| download | rsyslog-77a338e180fd51811041363f615760a14a2dc889.tar.gz rsyslog-77a338e180fd51811041363f615760a14a2dc889.tar.xz rsyslog-77a338e180fd51811041363f615760a14a2dc889.zip | |
- implemented $MainMsgQueueTimeoutActionCompletion config directive
- implemented $MainMsgQueueTimeoutEnqueue config directive
- implemented $MainMsgQueueTimeoutShutdown config directive
- some cleanup
Diffstat (limited to 'queue.h')
| -rw-r--r-- | queue.h | 6 |
1 files changed, 6 insertions, 0 deletions
@@ -85,6 +85,9 @@ typedef struct queue_s { 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? */ + int toQShutdown; /* timeout for regular queue shutdown in ms */ + int toActShutdown; /* timeout for long-running action shutdown in ms */ + int toEnq; /* enqueue timeout */ rsRetVal (*pConsumer)(void *); /* user-supplied consumer function for dequeued messages */ /* type-specific handlers (set during construction) */ rsRetVal (*qConstruct)(struct queue_s *pThis); @@ -136,6 +139,9 @@ rsRetVal queueConstruct(queue_t **ppThis, queueType_t qType, int iWorkerThreads, PROTOTYPEObjClassInit(queue); PROTOTYPEpropSetMeth(queue, bImmediateShutdown, int); PROTOTYPEpropSetMeth(queue, iPersistUpdCnt, int); +PROTOTYPEpropSetMeth(queue, toQShutdown, long); +PROTOTYPEpropSetMeth(queue, toActShutdown, long); +PROTOTYPEpropSetMeth(queue, toEnq, long); #define queueGetID(pThis) ((unsigned long) pThis) #endif /* #ifndef QUEUE_H_INCLUDED */ |