- 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

1 files changed, 5 insertions, 1 deletions

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)