Commit message (Collapse) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
* | 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 | |
| | ||||||
* | changed queue file name generation (to be more generic) | Rainer Gerhards | 2008-01-10 | 1 | -0/+9 | |
| | ||||||
* | some cleanup on object model | Rainer Gerhards | 2008-01-09 | 1 | -33/+5 | |
| | ||||||
* | changed queue class to use stream class | Rainer Gerhards | 2008-01-09 | 1 | -229/+18 | |
| | ||||||
* | created a generic stream class (for file access) | Rainer Gerhards | 2008-01-09 | 1 | -9/+2 | |
| | ||||||
* | implemented queue object method to set the file name prefix | Rainer Gerhards | 2008-01-09 | 1 | -15/+45 | |
| | ||||||
* | - implemented new GetSize() handler for config files | Rainer Gerhards | 2008-01-09 | 1 | -3/+29 | |
| | | | | - implemented $MainMsgQueueMaxFileSize configuration directive | |||||
* | - first implementation of "disk" queue mode finished. It still needs some | Rainer Gerhards | 2008-01-08 | 1 | -10/+27 | |
| | | | | | | | 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 files | Rainer Gerhards | 2008-01-08 | 1 | -29/+30 | |
| | ||||||
* | fixed some memory leaks in new code -- thanks to varmojfekoj for the patch | Rainer Gerhards | 2008-01-08 | 1 | -0/+1 | |
| | ||||||
* | worked a bit more on the queue, disk dequeing part (not complete yet) | Rainer Gerhards | 2008-01-07 | 1 | -3/+13 | |
| | ||||||
* | - MsgSetProperty() implemented | Rainer Gerhards | 2008-01-07 | 1 | -9/+41 | |
| | | | | | - defined a property class - implemented deserializer (needs some more work) | |||||
* | implemented class type registry | Rainer Gerhards | 2008-01-07 | 1 | -1/+0 | |
| | ||||||
* | implemented buffered read calls for the queue file | Rainer Gerhards | 2008-01-07 | 1 | -20/+104 | |
| | ||||||
* | implemented disk queue as far as I could without an object de-serializer | Rainer Gerhards | 2008-01-07 | 1 | -18/+111 | |
| | ||||||
* | worked on object header (now also contains the size) | Rainer Gerhards | 2008-01-06 | 1 | -4/+4 | |
| | ||||||
* | worked a bit on object serialization | Rainer Gerhards | 2008-01-06 | 1 | -3/+3 | |
| |