diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2009-05-19 11:03:09 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2009-05-19 11:03:09 +0200 |
| commit | a4dad2009992d436ba23c2d0a4a43b483aac40fc (patch) | |
| tree | 4971015a6e9d5cb45ae0742d6bd6c788bdc2985f /runtime/queue.h | |
| parent | cb0fa751b7e18ffe71aec84bccfeaf04fca7ff13 (diff) | |
| download | rsyslog-a4dad2009992d436ba23c2d0a4a43b483aac40fc.tar.gz rsyslog-a4dad2009992d436ba23c2d0a4a43b483aac40fc.tar.xz rsyslog-a4dad2009992d436ba23c2d0a4a43b483aac40fc.zip | |
queue size calculation now based on logical/physical dequeue
... needed to split the old single counter into two. I wouldn't bet that
I made some mistakes while doing so, but at least some ad-hoc tests plus
the testbench do no longer indicate errors.
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 e47b8762..92bf8ae5 100644 --- a/runtime/queue.h +++ b/runtime/queue.h @@ -74,7 +74,8 @@ typedef struct queue_s { int bSaveOnShutdown;/* persists everthing on shutdown (if DA!)? 1-yes, 0-no */ int bQueueStarted; /* has queueStart() been called on this queue? 1-yes, 0-no */ int bQueueInDestruction;/* 1 if queue is in destruction process, 0 otherwise */ - int iQueueSize; /* Current number of elements in the queue */ + int iQueueSize; /* Current number of elements in queue store (some are already logically dequeued!) */ + int nLogDeq; /* number of elements currently logically dequeued */ int iMaxQueueSize; /* how large can the queue grow? */ int iNumWorkerThreads;/* number of worker threads to use */ int iCurNumWrkThrd;/* current number of active worker threads */ |