summaryrefslogtreecommitdiffstats
path: root/queue.c
Commit message (Collapse)AuthorAgeFilesLines
* 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
|
* changed queue file name generation (to be more generic)Rainer Gerhards2008-01-101-0/+9
|
* some cleanup on object modelRainer Gerhards2008-01-091-33/+5
|
* changed queue class to use stream classRainer Gerhards2008-01-091-229/+18
|
* created a generic stream class (for file access)Rainer Gerhards2008-01-091-9/+2
|
* implemented queue object method to set the file name prefixRainer Gerhards2008-01-091-15/+45
|
* - implemented new GetSize() handler for config filesRainer Gerhards2008-01-091-3/+29
| | | | - implemented $MainMsgQueueMaxFileSize configuration directive
* - first implementation of "disk" queue mode finished. It still needs someRainer Gerhards2008-01-081-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 filesRainer Gerhards2008-01-081-29/+30
|
* fixed some memory leaks in new code -- thanks to varmojfekoj for the patchRainer Gerhards2008-01-081-0/+1
|
* worked a bit more on the queue, disk dequeing part (not complete yet)Rainer Gerhards2008-01-071-3/+13
|
* - MsgSetProperty() implementedRainer Gerhards2008-01-071-9/+41
| | | | | - defined a property class - implemented deserializer (needs some more work)
* implemented class type registryRainer Gerhards2008-01-071-1/+0
|
* implemented buffered read calls for the queue fileRainer Gerhards2008-01-071-20/+104
|
* implemented disk queue as far as I could without an object de-serializerRainer Gerhards2008-01-071-18/+111
|
* worked on object header (now also contains the size)Rainer Gerhards2008-01-061-4/+4
|
* worked a bit on object serializationRainer Gerhards2008-01-061-3/+3
|
* - added multiple worker thread capability to queue classRainer Gerhards2008-01-051-12/+30
| | | | - implemented $MainMsgQueueWorkerThreads config directive
* added the "direct" queueing mode to queue class (no queing at all)Rainer Gerhards2008-01-051-18/+71
|
* added capability for concurrent access to the msg class. Can be dynamicallyRainer Gerhards2008-01-051-6/+6
| | | | activated. If active, locking is employed.
* changed queue object Construction/Startup interfaceRainer Gerhards2008-01-041-9/+22
|
* moved message destruction back to consumer - the consume should decide whatRainer Gerhards2008-01-041-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...).
* utilized the new auto-destruction capability so that the queue can nowRainer Gerhards2008-01-041-2/+11
| | | | destruct user objects if needed
* removed serialization pointer from queue; used new base class insteadRainer Gerhards2008-01-041-8/+4
|
* - begun some work on Msg Object serializiationRainer Gerhards2008-01-041-1/+9
| | | | - created a kind of general base class
* begun working on disk queueing (not completed, do not use this mode!)Rainer Gerhards2008-01-031-8/+101
|
* added $MainMsgQueueType config parameterRainer Gerhards2008-01-031-1/+2
|
* simplified code and got rid of empty/full state variablesRainer Gerhards2008-01-031-21/+5
|
* added capability to use a linked list for queuing to the queue classRainer Gerhards2008-01-031-4/+135
|
* queue is now a full object and handles threading by itselfRainer Gerhards2008-01-031-26/+98
|
* implemented queue type "drivers"Rainer Gerhards2008-01-031-27/+90
|
generated by cgit (git 2.34.1) at 2024-11-11 16:48:06 +0000