summaryrefslogtreecommitdiffstats
path: root/queue.h
Commit message (Collapse)AuthorAgeFilesLines
* some more 32 bit fun ;)Rainer Gerhards2008-01-311-1/+1
|
* bugfix: having fun with 32/64 bit portability - after 15 years, I finallyRainer Gerhards2008-01-311-4/+4
| | | | | was trapped again ;) -- now fixed, sizes > 2GB supported on 32bit platforms
* - implemented limiting disk space allocated to queuesRainer Gerhards2008-01-301-0/+4
| | | | | - addded $MainMsgQueueMaxDiskSpace config directive - addded $ActionQueueMaxDiskSpace config directive
* - implemented simple output rate limitingRainer Gerhards2008-01-301-0/+4
| | | | | | - addded $ActionQueueDequeueSlowdown config directive - addded $MainMsgQueueDequeueSlowdown config directive - bugfix: MsgDup() did not work with new base object data structure
* added ability to re-enqueue objects into the queue when a worker thread isRainer Gerhards2008-01-291-0/+6
| | | | cancelled
* - implemented the $ActionResumeRetryCount config directiveRainer Gerhards2008-01-281-2/+9
| | | | | | | | | | | | | | | | | | | | | - added queue between main queue and action executor (currently works in "direct" mode only, else crashes) - added $ActionQueueFilename config directive - added $ActionQueueSize config directive - added $ActionQueueHighWaterMark config directive - added $ActionQueueLowWaterMark config directive - added $ActionQueueDiscardMark config directive - added $ActionQueueDiscardSeverity config directive - added $ActionQueueCheckpointInterval config directive - added $ActionQueueType config directive - added $ActionQueueWorkerThreads config directive - added $ActionQueueTimeoutshutdown config directive - added $ActionQueueTimeoutActionCompletion config directive - added $ActionQueueTimeoutenQueue config directive - added $ActionQueueTimeoutworkerThreadShutdown config directive - added $ActionQueueWorkerThreadMinimumMessages config directive - added $ActionQueueMaxFileSize config directive - added $ActionQueueSaveonShutdown config directive
* cleanup to prepare for releaseRainer Gerhards2008-01-281-1/+0
|
* some more testing and cleanup with the queue class (pretty stable now)Rainer Gerhards2008-01-281-9/+1
|
* fixed a bug when shutting down DA queueRainer Gerhards2008-01-271-3/+3
|
* fixed the situation where message processing could be stalled for someRainer Gerhards2008-01-271-2/+4
| | | | period after DA mode turn off
* partially fixed bug that caused rsyslogd to stall processing enqueuedRainer Gerhards2008-01-261-0/+1
| | | | | | messages after turning off DA mode and before any new message were arrived (if a new message arrived, everything went back to normal, so it was a temporary halt)
* disk-assisted queue mode finally begins to look good ;)Rainer Gerhards2008-01-251-2/+3
|
* redesigned queue to utilize helper classes for threading support. This isRainer Gerhards2008-01-241-36/+4
| | | | | | finally in a running state for regular (non disk-assisted) queues, with a minor nit at shutdown. So I can finally commit the work again to CVS...
* some further cleanup on the mutexesRainer Gerhards2008-01-191-1/+1
|
* seperated mutex for queue size management from those for queue threadRainer Gerhards2008-01-191-1/+2
| | | | management
* saving stateRainer Gerhards2008-01-181-0/+2
|
* - created an in-depth description of DA assisted queue modeRainer Gerhards2008-01-181-0/+1
| | | | | - snapshot of new thread coding - DA mode still does not work, but need to save
* fixed sync issue on shutdown process if need to persist pure memory queueRainer Gerhards2008-01-171-0/+3
| | | | to disk
* worked on threadingRainer Gerhards2008-01-171-6/+26
|
* implemented dynamic startup and shutdown of worker threads based on currentRainer Gerhards2008-01-161-8/+13
| | | | activity
* queue is now able to restore persisted state on startup (but still someRainer Gerhards2008-01-161-1/+3
| | | | fine tuning to be done)
* changed startup of disk assisted mode to allow for higher concurrency, mostRainer Gerhards2008-01-151-4/+7
| | | | | | importantly allow the input to continue enqueue msgs while the disk queue is initialized. This may help somewhat with UDP and other lossy sources
* disk assisted queue works quite well, except for startup from disk queueRainer Gerhards2008-01-151-1/+4
|
* some more work on disk assisted mode (still not complete)Rainer Gerhards2008-01-141-0/+5
|
* begin disk assisted queue memory queue modes (not fully implemented yet)Rainer Gerhards2008-01-141-4/+9
|
* - implemented config file handlers forRainer Gerhards2008-01-141-0/+8
| | | | | | | | $MainMsgQueueHighWaterMark $MainMsgQueueLowWaterMark $MainMsgQueueDiscardMark $MainMsgQueueDiscardSeverity but did NOT yet implement the functionality behind these directives!
* removed $MainMsgQueueImmediateShutdown config directive and handling, thisRainer Gerhards2008-01-141-2/+0
| | | | | has been superseeded by the Timeout params. Backward compatibility is no concern, no version with that directive was ever released.
* - implemented $MainMsgQueueTimeoutActionCompletion config directiveRainer Gerhards2008-01-141-0/+6
| | | | | | - implemented $MainMsgQueueTimeoutEnqueue config directive - implemented $MainMsgQueueTimeoutShutdown config directive - some cleanup
* worker shutdown sequence enhanced to try different ways to shut down andRainer Gerhards2008-01-141-0/+2
| | | | | terminate workers if none helps (this protects against badly written output plugins which hold the queue for too long)
* added $MainMsgQueuePersistUpdateCount config file directiveRainer Gerhards2008-01-131-1/+3
|
* support for reading back persistet queue information completedRainer Gerhards2008-01-131-0/+2
|
* support for object property bags addedRainer Gerhards2008-01-111-0/+2
|
* file stream objects are now persistet on immediate queue shutdown (queueRainer Gerhards2008-01-111-1/+2
| | | | itself is not yet fully persisted)
* added $MainMsgQueueImmediateShutdown config directiveRainer Gerhards2008-01-111-0/+1
|
* - begun to permit queue to terminate without being drainedRainer Gerhards2008-01-111-2/+1
| | | | | | - fixed a starvation condition in queueWorker (pthread_yield() was needed) could not be seen with any previously released code, came up during new development
* - some cleanupRainer Gerhards2008-01-101-1/+14
| | | | | - implemented management function for worker thread 0 in order to change queue workers dynamically -- stage work
* changed queue class to use stream classRainer Gerhards2008-01-091-2/+3
|
* implemented $MainMsgQueueFilePrefix configuration directiveRainer Gerhards2008-01-091-0/+1
|
* implemented queue object method to set the file name prefixRainer Gerhards2008-01-091-6/+12
|
* - implemented new GetSize() handler for config filesRainer Gerhards2008-01-091-2/+3
| | | | - implemented $MainMsgQueueMaxFileSize configuration directive
* - first implementation of "disk" queue mode finished. It still needs someRainer Gerhards2008-01-081-0/+1
| | | | | | | work and the deserializer needs also to be expanded, but the queue at least performs well now. - fixed a race condition that could occur when input modules were terminated
* implemented queue disk reader to switch to multiple filesRainer Gerhards2008-01-081-0/+1
|
* - MsgSetProperty() implementedRainer Gerhards2008-01-071-1/+1
| | | | | - defined a property class - implemented deserializer (needs some more work)
* implemented buffered read calls for the queue fileRainer Gerhards2008-01-071-0/+4
|
* implemented disk queue as far as I could without an object de-serializerRainer Gerhards2008-01-071-4/+16
|
* - added multiple worker thread capability to queue classRainer Gerhards2008-01-051-2/+4
| | | | - implemented $MainMsgQueueWorkerThreads config directive
* added the "direct" queueing mode to queue class (no queing at all)Rainer Gerhards2008-01-051-1/+2
|
* changed queue object Construction/Startup interfaceRainer Gerhards2008-01-041-0/+1
|
* removed serialization pointer from queue; used new base class insteadRainer Gerhards2008-01-041-10/+2
|
* - begun some work on Msg Object serializiationRainer Gerhards2008-01-041-3/+10
| | | | - created a kind of general base class
generated by cgit (git 2.34.1) at 2024-04-25 16:55:52 +0000