summaryrefslogtreecommitdiffstats
path: root/queue.c
Commit message (Collapse)AuthorAgeFilesLines
...
* reduced number of unnecessary wakeups of DA worker thread when high waterRainer Gerhards2008-01-271-45/+67
| | | | mark is not yet reached
* fixed the situation where message processing could be stalled for someRainer Gerhards2008-01-271-6/+49
| | | | period after DA mode turn off
* partially fixed bug that caused rsyslogd to stall processing enqueuedRainer Gerhards2008-01-261-9/+53
| | | | | | 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)
* fixed worker timeout which was accidently not set (and thus 0)Rainer Gerhards2008-01-251-0/+2
|
* disk-assisted queue mode finally begins to look good ;)Rainer Gerhards2008-01-251-74/+146
|
* restructured queue shutdown so that the queue timeout is properly appliedRainer Gerhards2008-01-251-97/+159
| | | | before terminatiing the queue
* redesigned queue to utilize helper classes for threading support. This isRainer Gerhards2008-01-241-1161/+418
| | | | | | 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...
* Module OMSNMP intially added, not completed yet.Andre Lorbach2008-01-221-1/+1
|
* some further cleanup on the mutexesRainer Gerhards2008-01-191-116/+62
|
* seperated mutex for queue size management from those for queue threadRainer Gerhards2008-01-191-47/+179
| | | | management
* saving stateRainer Gerhards2008-01-181-72/+102
|
* - created an in-depth description of DA assisted queue modeRainer Gerhards2008-01-181-100/+214
| | | | | - 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-8/+32
| | | | to disk
* worked on threadingRainer Gerhards2008-01-171-87/+294
|
* some more cleanup and flagged places where we need to implementRainer Gerhards2008-01-161-35/+13
| | | | DA-input-only mode
* some cleanup and fixesRainer Gerhards2008-01-161-26/+19
|
* implemented dynamic startup and shutdown of worker threads based on currentRainer Gerhards2008-01-161-117/+207
| | | | activity
* cleaned up queue disk startupRainer Gerhards2008-01-161-28/+32
|
* queue is now able to restore persisted state on startup (but still someRainer Gerhards2008-01-161-42/+174
| | | | fine tuning to be done)
* first shot at queue restore on startup, but could not finish before I needRainer Gerhards2008-01-151-1/+62
| | | | to leave ;)
* improved shutdown processing - in-memory queue is now drained to diskRainer Gerhards2008-01-151-5/+31
|
* changed startup of disk assisted mode to allow for higher concurrency, mostRainer Gerhards2008-01-151-121/+155
| | | | | | 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-28/+204
|
* some more work on disk assisted mode (still not complete)Rainer Gerhards2008-01-141-2/+48
|
* begin disk assisted queue memory queue modes (not fully implemented yet)Rainer Gerhards2008-01-141-42/+256
|
* - implemented $MainMsgQueueDiscardMark == 0 --> disable Discard logicRainer Gerhards2008-01-141-3/+6
| | | | - implemented $MainMsgQueueSize == 0 --> no limit on queue size
* also implemented $MainMsgQueueDiscardMark logic on dequeue, changedRainer Gerhards2008-01-141-9/+19
| | | | defaults
* implemented $MainMsgQueueDiscardMar and $MainMsgQueueDiscardSeverity (butRainer Gerhards2008-01-141-2/+19
| | | | serverity needs to be specified numerically for the time being)
* optimized codeRainer Gerhards2008-01-141-3/+4
|
* - implemented config file handlers forRainer Gerhards2008-01-141-0/+4
| | | | | | | | $MainMsgQueueHighWaterMark $MainMsgQueueLowWaterMark $MainMsgQueueDiscardMark $MainMsgQueueDiscardSeverity but did NOT yet implement the functionality behind these directives!
* removed $MainMsgQueueImmediateShutdown config directive and handling, thisRainer Gerhards2008-01-141-1/+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-42/+82
| | | | | | - 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-31/+111
| | | | | terminate workers if none helps (this protects against badly written output plugins which hold the queue for too long)
* changed queue shutdown procedure a bit - stage work for queue shutdownRainer Gerhards2008-01-131-9/+6
| | | | timeout setting
* added $MainMsgQueuePersistUpdateCount config file directiveRainer Gerhards2008-01-131-4/+45
|
* support for reading back persistet queue information completedRainer Gerhards2008-01-131-99/+154
|
* partial ability to read a disk queue back in (not completed, but would likeRainer Gerhards2008-01-111-2/+69
| | | | to save source for the weekend)
* support for de-serializing strm objects addedRainer Gerhards2008-01-111-1/+27
|
* added function to de-serialize a property bag (untested as other code isRainer Gerhards2008-01-111-2/+0
| | | | yet missing)
* queue can now persist disk queue information on immediate shutdownRainer Gerhards2008-01-111-1/+15
|
* support for object property bags addedRainer Gerhards2008-01-111-0/+17
|
* file stream objects are now persistet on immediate queue shutdown (queueRainer Gerhards2008-01-111-2/+88
| | | | itself is not yet fully persisted)
* added $MainMsgQueueImmediateShutdown config directiveRainer Gerhards2008-01-111-9/+4
|
* - begun to permit queue to terminate without being drainedRainer Gerhards2008-01-111-46/+47
| | | | | | - 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-31/+97
| | | | | - implemented management function for worker thread 0 in order to change queue workers dynamically -- stage work
* - implemented strm object serializer (untested as the code required forRainer Gerhards2008-01-101-5/+0
| | | | test is not yet present - hen/egg problem...)
* - fixed a bug that caused a segfault on startup when no $WorkDir directivev3-10-1aRainer Gerhards2008-01-101-4/+13
| | | | | | was specified in rsyslog.conf - fixed a bug that caused a segfault on queues with types other than "disk" - removed the now longer needed thread TermSyncTool
* changed some config parameters and some cleanupRainer Gerhards2008-01-101-3/+3
|
* - added write functions for several types to stream classRainer Gerhards2008-01-101-4/+5
| | | | - changed objSerialize methods to work directly on the stream class
* added buffered output to stream classRainer Gerhards2008-01-101-1/+4
|
generated by cgit (git 2.34.1) at 2024-04-28 10:44:41 +0000