From c77519ab7b1fe246039bfdd99dbf6f17c44af449 Mon Sep 17 00:00:00 2001 From: Rainer Gerhards Date: Mon, 28 Jan 2008 17:39:46 +0000 Subject: - 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 --- action.h | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'action.h') diff --git a/action.h b/action.h index 0355b834..e725ae19 100644 --- a/action.h +++ b/action.h @@ -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) -- cgit