Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | - 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...). | ||||
* | utilized the new auto-destruction capability so that the queue can now | Rainer Gerhards | 2008-01-04 | 1 | -2/+11 |
| | | | | destruct user objects if needed | ||||
* | removed serialization pointer from queue; used new base class instead | Rainer Gerhards | 2008-01-04 | 1 | -8/+4 |
| | |||||
* | - begun some work on Msg Object serializiation | Rainer Gerhards | 2008-01-04 | 1 | -1/+9 |
| | | | | - created a kind of general base class | ||||
* | begun working on disk queueing (not completed, do not use this mode!) | Rainer Gerhards | 2008-01-03 | 1 | -8/+101 |
| | |||||
* | added $MainMsgQueueType config parameter | Rainer Gerhards | 2008-01-03 | 1 | -1/+2 |
| | |||||
* | simplified code and got rid of empty/full state variables | Rainer Gerhards | 2008-01-03 | 1 | -21/+5 |
| | |||||
* | added capability to use a linked list for queuing to the queue class | Rainer Gerhards | 2008-01-03 | 1 | -4/+135 |
| | |||||
* | queue is now a full object and handles threading by itself | Rainer Gerhards | 2008-01-03 | 1 | -26/+98 |
| | |||||
* | implemented queue type "drivers" | Rainer Gerhards | 2008-01-03 | 1 | -27/+90 |
| | |||||
* | restructured queue interface to use rsRetVal and instances, removed | Rainer Gerhards | 2008-01-03 | 1 | -51/+79 |
| | | | | dependency on globals - now more like a real class | ||||
* | moved queue code to its own module (finally) | Rainer Gerhards | 2008-01-03 | 1 | -0/+128 |