diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2008-01-28 17:39:46 +0000 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2008-01-28 17:39:46 +0000 |
commit | c77519ab7b1fe246039bfdd99dbf6f17c44af449 (patch) | |
tree | 24029fe44f67badcddedbd8f37cdb68f72156479 /action.h | |
parent | 7ddc2511193930c1f9aa755904cef6f3b860a670 (diff) | |
download | rsyslog-c77519ab7b1fe246039bfdd99dbf6f17c44af449.tar.gz rsyslog-c77519ab7b1fe246039bfdd99dbf6f17c44af449.tar.xz rsyslog-c77519ab7b1fe246039bfdd99dbf6f17c44af449.zip |
- implemented the $ActionResumeRetryCount config directive
- added queue between main queue and action executor (currently works in
"direct" mode only, else crashes)
- added $ActionQueueFilename config directive
- added $ActionQueueSize config directive
- added $ActionQueueHighWaterMark config directive
- added $ActionQueueLowWaterMark config directive
- added $ActionQueueDiscardMark config directive
- added $ActionQueueDiscardSeverity config directive
- added $ActionQueueCheckpointInterval config directive
- added $ActionQueueType config directive
- added $ActionQueueWorkerThreads config directive
- added $ActionQueueTimeoutshutdown config directive
- added $ActionQueueTimeoutActionCompletion config directive
- added $ActionQueueTimeoutenQueue config directive
- added $ActionQueueTimeoutworkerThreadShutdown config directive
- added $ActionQueueWorkerThreadMinimumMessages config directive
- added $ActionQueueMaxFileSize config directive
- added $ActionQueueSaveonShutdown config directive
Diffstat (limited to 'action.h')
-rw-r--r-- | action.h | 6 |
1 files changed, 5 insertions, 1 deletions
@@ -27,6 +27,7 @@ #include "syslogd-types.h" #include "sync.h" +#include "queue.h" /* external data - this is to be removed when we change the action * object interface (will happen some time..., at latest when the @@ -60,6 +61,7 @@ struct action_s { * content later). This is preserved after the message has been * processed - it is also used to detect duplicates. */ + queue_t *pQueue; /* action queue */ SYNC_OBJ_TOOL; /* required for mutex support */ }; typedef struct action_s action_t; @@ -68,12 +70,14 @@ typedef struct action_s action_t; /* function prototypes */ rsRetVal actionConstruct(action_t **ppThis); +rsRetVal actionConstructFinalize(action_t *pThis); rsRetVal actionDestruct(action_t *pThis); +rsRetVal actionAddCfSysLineHdrl(void); rsRetVal actionTryResume(action_t *pThis); rsRetVal actionSuspend(action_t *pThis); rsRetVal actionDbgPrint(action_t *pThis); rsRetVal actionSetGlobalResumeInterval(int iNewVal); -rsRetVal actionCallDoAction(action_t *pAction); +rsRetVal actionDoAction(action_t *pAction); #if 1 #define actionIsSuspended(pThis) ((pThis)->bSuspended == 1) |