Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | 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 |
| | |||||
* | - added multiple worker thread capability to queue class | Rainer Gerhards | 2008-01-05 | 1 | -12/+30 |
| | | | | - implemented $MainMsgQueueWorkerThreads config directive | ||||
* | added the "direct" queueing mode to queue class (no queing at all) | Rainer Gerhards | 2008-01-05 | 1 | -18/+71 |
| | |||||
* | added capability for concurrent access to the msg class. Can be dynamically | Rainer Gerhards | 2008-01-05 | 1 | -6/+6 |
| | | | | activated. If active, locking is employed. | ||||
* | changed queue object Construction/Startup interface | Rainer Gerhards | 2008-01-04 | 1 | -9/+22 |
| | |||||
* | moved message destruction back to consumer - the consume should decide what | Rainer Gerhards | 2008-01-04 | 1 | -5/+0 |
| | | | | | to do with the object. It may pass it on to someone else. So this would have creatd some headache in the future (maybe...). |