Commit message (Collapse) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
* | reduced number of unnecessary wakeups of DA worker thread when high water | Rainer Gerhards | 2008-01-27 | 1 | -45/+67 | |
| | | | | mark is not yet reached | |||||
* | fixed the situation where message processing could be stalled for some | Rainer Gerhards | 2008-01-27 | 1 | -6/+49 | |
| | | | | period after DA mode turn off | |||||
* | partially fixed bug that caused rsyslogd to stall processing enqueued | Rainer Gerhards | 2008-01-26 | 1 | -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 Gerhards | 2008-01-25 | 1 | -0/+2 | |
| | ||||||
* | disk-assisted queue mode finally begins to look good ;) | Rainer Gerhards | 2008-01-25 | 1 | -74/+146 | |
| | ||||||
* | restructured queue shutdown so that the queue timeout is properly applied | Rainer Gerhards | 2008-01-25 | 1 | -97/+159 | |
| | | | | before terminatiing the queue | |||||
* | redesigned queue to utilize helper classes for threading support. This is | Rainer Gerhards | 2008-01-24 | 1 | -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 Lorbach | 2008-01-22 | 1 | -1/+1 | |
| | ||||||
* | some further cleanup on the mutexes | Rainer Gerhards | 2008-01-19 | 1 | -116/+62 | |
| | ||||||
* | seperated mutex for queue size management from those for queue thread | Rainer Gerhards | 2008-01-19 | 1 | -47/+179 | |
| | | | | management | |||||
* | saving state | Rainer Gerhards | 2008-01-18 | 1 | -72/+102 | |
| | ||||||
* | - created an in-depth description of DA assisted queue mode | Rainer Gerhards | 2008-01-18 | 1 | -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 queue | Rainer Gerhards | 2008-01-17 | 1 | -8/+32 | |
| | | | | to disk | |||||
* | worked on threading | Rainer Gerhards | 2008-01-17 | 1 | -87/+294 | |
| | ||||||
* | some more cleanup and flagged places where we need to implement | Rainer Gerhards | 2008-01-16 | 1 | -35/+13 | |
| | | | | DA-input-only mode | |||||
* | some cleanup and fixes | Rainer Gerhards | 2008-01-16 | 1 | -26/+19 | |
| | ||||||
* | implemented dynamic startup and shutdown of worker threads based on current | Rainer Gerhards | 2008-01-16 | 1 | -117/+207 | |
| | | | | activity | |||||
* | cleaned up queue disk startup | Rainer Gerhards | 2008-01-16 | 1 | -28/+32 | |
| | ||||||
* | queue is now able to restore persisted state on startup (but still some | Rainer Gerhards | 2008-01-16 | 1 | -42/+174 | |
| | | | | fine tuning to be done) | |||||
* | first shot at queue restore on startup, but could not finish before I need | Rainer Gerhards | 2008-01-15 | 1 | -1/+62 | |
| | | | | to leave ;) | |||||
* | improved shutdown processing - in-memory queue is now drained to disk | Rainer Gerhards | 2008-01-15 | 1 | -5/+31 | |
| | ||||||
* | changed startup of disk assisted mode to allow for higher concurrency, most | Rainer Gerhards | 2008-01-15 | 1 | -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 queue | Rainer Gerhards | 2008-01-15 | 1 | -28/+204 | |
| | ||||||
* | some more work on disk assisted mode (still not complete) | Rainer Gerhards | 2008-01-14 | 1 | -2/+48 | |
| | ||||||
* | begin disk assisted queue memory queue modes (not fully implemented yet) | Rainer Gerhards | 2008-01-14 | 1 | -42/+256 | |
| | ||||||
* | - implemented $MainMsgQueueDiscardMark == 0 --> disable Discard logic | Rainer Gerhards | 2008-01-14 | 1 | -3/+6 | |
| | | | | - implemented $MainMsgQueueSize == 0 --> no limit on queue size | |||||
* | also implemented $MainMsgQueueDiscardMark logic on dequeue, changed | Rainer Gerhards | 2008-01-14 | 1 | -9/+19 | |
| | | | | defaults | |||||
* | implemented $MainMsgQueueDiscardMar and $MainMsgQueueDiscardSeverity (but | Rainer Gerhards | 2008-01-14 | 1 | -2/+19 | |
| | | | | serverity needs to be specified numerically for the time being) | |||||
* | optimized code | Rainer Gerhards | 2008-01-14 | 1 | -3/+4 | |
| | ||||||
* | - implemented config file handlers for | Rainer Gerhards | 2008-01-14 | 1 | -0/+4 | |
| | | | | | | | | $MainMsgQueueHighWaterMark $MainMsgQueueLowWaterMark $MainMsgQueueDiscardMark $MainMsgQueueDiscardSeverity but did NOT yet implement the functionality behind these directives! | |||||
* | removed $MainMsgQueueImmediateShutdown config directive and handling, this | Rainer Gerhards | 2008-01-14 | 1 | -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 directive | Rainer Gerhards | 2008-01-14 | 1 | -42/+82 | |
| | | | | | | - implemented $MainMsgQueueTimeoutEnqueue config directive - implemented $MainMsgQueueTimeoutShutdown config directive - some cleanup | |||||
* | worker shutdown sequence enhanced to try different ways to shut down and | Rainer Gerhards | 2008-01-14 | 1 | -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 shutdown | Rainer Gerhards | 2008-01-13 | 1 | -9/+6 | |
| | | | | timeout setting | |||||
* | added $MainMsgQueuePersistUpdateCount config file directive | Rainer Gerhards | 2008-01-13 | 1 | -4/+45 | |
| | ||||||
* | support for reading back persistet queue information completed | Rainer Gerhards | 2008-01-13 | 1 | -99/+154 | |
| | ||||||
* | partial ability to read a disk queue back in (not completed, but would like | Rainer Gerhards | 2008-01-11 | 1 | -2/+69 | |
| | | | | to save source for the weekend) | |||||
* | support for de-serializing strm objects added | Rainer Gerhards | 2008-01-11 | 1 | -1/+27 | |
| | ||||||
* | added function to de-serialize a property bag (untested as other code is | Rainer Gerhards | 2008-01-11 | 1 | -2/+0 | |
| | | | | yet missing) | |||||
* | queue can now persist disk queue information on immediate shutdown | Rainer Gerhards | 2008-01-11 | 1 | -1/+15 | |
| | ||||||
* | support for object property bags added | Rainer Gerhards | 2008-01-11 | 1 | -0/+17 | |
| | ||||||
* | file stream objects are now persistet on immediate queue shutdown (queue | Rainer Gerhards | 2008-01-11 | 1 | -2/+88 | |
| | | | | itself is not yet fully persisted) | |||||
* | added $MainMsgQueueImmediateShutdown config directive | Rainer Gerhards | 2008-01-11 | 1 | -9/+4 | |
| | ||||||
* | - begun to permit queue to terminate without being drained | Rainer Gerhards | 2008-01-11 | 1 | -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 cleanup | Rainer Gerhards | 2008-01-10 | 1 | -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 for | Rainer Gerhards | 2008-01-10 | 1 | -5/+0 | |
| | | | | test is not yet present - hen/egg problem...) | |||||
* | - fixed a bug that caused a segfault on startup when no $WorkDir directivev3-10-1a | Rainer Gerhards | 2008-01-10 | 1 | -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 cleanup | Rainer Gerhards | 2008-01-10 | 1 | -3/+3 | |
| | ||||||
* | - added write functions for several types to stream class | Rainer Gerhards | 2008-01-10 | 1 | -4/+5 | |
| | | | | - changed objSerialize methods to work directly on the stream class | |||||
* | added buffered output to stream class | Rainer Gerhards | 2008-01-10 | 1 | -1/+4 | |
| |