diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-04-23 12:50:07 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-04-23 12:50:07 +0200 |
| commit | 5c0aeae8ab1f344a022d586dc26c5d78203f7e0b (patch) | |
| tree | b81b80018149907c1cbb1a81d2e04db067deccd3 /runtime/queue.h | |
| parent | 6feb86688546aff2d957e27d8516143b256371c3 (diff) | |
| download | rsyslog-5c0aeae8ab1f344a022d586dc26c5d78203f7e0b.tar.gz rsyslog-5c0aeae8ab1f344a022d586dc26c5d78203f7e0b.tar.xz rsyslog-5c0aeae8ab1f344a022d586dc26c5d78203f7e0b.zip | |
added $MainMsgQueueDequeueBatchSize and $ActionQueueDequeueBatchSize configuration directives
Diffstat (limited to 'runtime/queue.h')
| -rw-r--r-- | runtime/queue.h | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/runtime/queue.h b/runtime/queue.h index 4fb57d07..8a60254b 100644 --- a/runtime/queue.h +++ b/runtime/queue.h @@ -85,7 +85,7 @@ typedef struct queue_s { int toActShutdown; /* timeout for long-running action shutdown in ms */ int toWrkShutdown; /* timeout for idle workers in ms, -1 means indefinite (0 is immediate) */ int toEnq; /* enqueue timeout */ - int iDeqMaxAtOnce; /* max number of elements that shall be dequeued at once */ + int iDeqBatchSize; /* max number of elements that shall be dequeued at once */ /* rate limiting settings (will be expanded) */ int iDeqSlowdown; /* slow down dequeue by specified nbr of microseconds */ /* end rate limiting */ @@ -202,6 +202,7 @@ PROTOTYPEpropSetMeth(qqueue, bSaveOnShutdown, int); PROTOTYPEpropSetMeth(qqueue, pUsr, void*); PROTOTYPEpropSetMeth(qqueue, iDeqSlowdown, int); PROTOTYPEpropSetMeth(qqueue, sizeOnDiskMax, int64); +PROTOTYPEpropSetMeth(qqueue, iDeqBatchSize, int); #define qqueueGetID(pThis) ((unsigned long) pThis) #endif /* #ifndef QUEUE_H_INCLUDED */ |