summaryrefslogtreecommitdiffstats
path: root/stream.c
Commit message (Collapse)AuthorAgeFilesLines
* changed rsCStrObj name to cstr_t, which is more inline with the rest ofRainer Gerhards2008-02-211-2/+2
| | | | rsyslog (now) and also much easier to type
* changed rsCStrDestruct() to use the new interface conventionsRainer Gerhards2008-02-201-1/+1
|
* created var class out of property_tRainer Gerhards2008-02-201-1/+1
|
* - added doc on how expressions will workRainer Gerhards2008-02-191-2/+1
| | | | | | - cleaned up the stringbuf Construct interface - did some cleanup on stringbuf calls - we now have much better interfaces and macros
* - improved file polling algorithm for more rapid file data deliveryRainer Gerhards2008-02-141-1/+1
| | | | - some more cleanup
* some cleanupRainer Gerhards2008-02-131-1/+0
|
* - fixed a race condition in DoDie() - cosmetic issue in debugging mode,Rainer Gerhards2008-02-131-4/+8
| | | | | could not happen in production - added the ability to persist current read location for the file monitor
* added ability to monitor file accross rotationRainer Gerhards2008-02-131-74/+161
|
* - introduced a new, more powerful, message submission interface submitMsg()Rainer Gerhards2008-02-131-9/+3
| | | | | | in additon to logmsg() - a first, rough implementation of imfile that is able to read files (but does not persist or handle rotation or whatever)
* bugfix: having fun with 32/64 bit portability - after 15 years, I finallyRainer Gerhards2008-01-311-1/+1
| | | | | was trapped again ;) -- now fixed, sizes > 2GB supported on 32bit platforms
* - implemented limiting disk space allocated to queuesRainer Gerhards2008-01-301-0/+19
| | | | | - addded $MainMsgQueueMaxDiskSpace config directive - addded $ActionQueueMaxDiskSpace config directive
* - renamed Msg object to usual all-lowercase object name (else we ran intoRainer Gerhards2008-01-301-16/+3
| | | | | | troubles with the framework, also it was somewhat ugly...) - fixed a memory leak in object destruction (was recently introduced by object naming, not present in any released version)
* redesigned queue to utilize helper classes for threading support. This isRainer Gerhards2008-01-241-23/+23
| | | | | | 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...
* worked on threadingRainer Gerhards2008-01-171-1/+5
|
* changed startup of disk assisted mode to allow for higher concurrency, mostRainer Gerhards2008-01-151-1/+1
| | | | | | 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 queueRainer Gerhards2008-01-151-7/+7
|
* begin disk assisted queue memory queue modes (not fully implemented yet)Rainer Gerhards2008-01-141-1/+0
|
* - implemented $MainMsgQueueTimeoutActionCompletion config directiveRainer Gerhards2008-01-141-8/+17
| | | | | | - implemented $MainMsgQueueTimeoutEnqueue config directive - implemented $MainMsgQueueTimeoutShutdown config directive - some cleanup
* changed queue shutdown procedure a bit - stage work for queue shutdownRainer Gerhards2008-01-131-0/+1
| | | | timeout setting
* support for reading back persistet queue information completedRainer Gerhards2008-01-131-8/+56
|
* partial ability to read a disk queue back in (not completed, but would likeRainer Gerhards2008-01-111-10/+32
| | | | to save source for the weekend)
* support for de-serializing strm objects addedRainer Gerhards2008-01-111-1/+39
|
* queue can now persist disk queue information on immediate shutdownRainer Gerhards2008-01-111-4/+1
|
* file stream objects are now persistet on immediate queue shutdown (queueRainer Gerhards2008-01-111-15/+28
| | | | itself is not yet fully persisted)
* - some cleanupRainer Gerhards2008-01-101-5/+0
| | | | | - implemented management function for worker thread 0 in order to change queue workers dynamically -- stage work
* some cleanupRainer Gerhards2008-01-101-2/+2
|
* - implemented strm object serializer (untested as the code required forRainer Gerhards2008-01-101-5/+45
| | | | test is not yet present - hen/egg problem...)
* - added write functions for several types to stream classRainer Gerhards2008-01-101-29/+103
| | | | - changed objSerialize methods to work directly on the stream class
* data record support added to stream output writerRainer Gerhards2008-01-101-19/+71
|
* added buffered output to stream classRainer Gerhards2008-01-101-20/+96
|
* made queue file names better readableRainer Gerhards2008-01-101-28/+21
|
* changed queue file name generation (to be more generic)Rainer Gerhards2008-01-101-6/+16
|
* some cleanup on object modelRainer Gerhards2008-01-091-8/+51
|
* changed queue class to use stream classRainer Gerhards2008-01-091-7/+44
|
* created a generic stream class (for file access)Rainer Gerhards2008-01-091-0/+332