queue: lightdelay config: keep default of 70% until mark is explicitely set
authorRainer Gerhards <rgerhards@adiscon.com>
Wed, 22 Feb 2012 08:43:25 +0000 (09:43 +0100)
committerRainer Gerhards <rgerhards@adiscon.com>
Wed, 22 Feb 2012 08:43:25 +0000 (09:43 +0100)
action.c
tools/syslogd.c

index f85b1c4..7de10d4 100644 (file)
--- a/action.c
+++ b/action.c
@@ -144,7 +144,7 @@ static queueType_t ActionQueType = QUEUETYPE_DIRECT;                /* type of the main messag
 static int iActionQueueSize = 1000;                            /* size of the main message queue above */
 static int iActionQueueDeqBatchSize = 16;                      /* batch size for action queues */
 static int iActionQHighWtrMark = 800;                          /* high water mark for disk-assisted queues */
-static int iActionQLightDlyMrk = 700;                          /* light delay mark for disk-assisted queues */
+static int iActionQLightDlyMrk = -1;                           /* light delay mark for disk-assisted queues */
 static int iActionQLowWtrMark = 200;                           /* low water mark for disk-assisted queues */
 static int iActionQDiscardMark = 9800;                         /* begin to discard messages */
 static int iActionQDiscardSeverity = 8;                                /* by default, discard nothing to prevent unintentional loss */
@@ -227,7 +227,7 @@ actionResetQueueParams(void)
        iActionQueueSize = 1000;                        /* size of the main message queue above */
        iActionQueueDeqBatchSize = 16;                  /* default batch size */
        iActionQHighWtrMark = 800;                      /* high water mark for disk-assisted queues */
-       iActionQLightDlyMrk = 700;
+       iActionQLightDlyMrk = -1;
        iActionQLowWtrMark = 200;                       /* low water mark for disk-assisted queues */
        iActionQDiscardMark = 9800;                     /* begin to discard messages */
        iActionQDiscardSeverity = 8;                    /* discard warning and above */
@@ -424,7 +424,9 @@ actionConstructFinalize(action_t *pThis)
        setQPROP(qqueueSettoWrkShutdown, "$ActionQueueWorkerTimeoutThreadShutdown", iActionQtoWrkShutdown);
        setQPROP(qqueueSettoEnq, "$ActionQueueTimeoutEnqueue", iActionQtoEnq);
        setQPROP(qqueueSetiHighWtrMrk, "$ActionQueueHighWaterMark", iActionQHighWtrMark);
-       setQPROP(qqueueSetiLightDlyMrk, "$ActionQueueLightDelayMark", iActionQLightDlyMrk);
+       if(iActionQLightDlyMrk > 0) {
+               setQPROP(qqueueSetiLightDlyMrk, "$ActionQueueLightDelayMark", iActionQLightDlyMrk);
+       }
        setQPROP(qqueueSetiLowWtrMrk, "$ActionQueueLowWaterMark", iActionQLowWtrMark);
        setQPROP(qqueueSetiDiscardMrk, "$ActionQueueDiscardMark", iActionQDiscardMark);
        setQPROP(qqueueSetiDiscardSeverity, "$ActionQueueDiscardSeverity", iActionQDiscardSeverity);
index 4c53757..c0e663d 100644 (file)
@@ -262,7 +262,7 @@ static uchar *pszConfDAGFile = NULL;                                /* name of config DAG file, non-NULL mea
 qqueue_t *pMsgQueue = NULL;                            /* the main message queue */
 static int iMainMsgQueueSize = 10000;                          /* size of the main message queue above */
 static int iMainMsgQHighWtrMark = 8000;                                /* high water mark for disk-assisted queues */
-static int iMainMsgQLightDlyMark = 7000;                       /* light delay mark for disk-assisted queues */
+static int iMainMsgQLightDlyMark = -1;                 /* light delay mark for disk-assisted queues */
 static int iMainMsgQLowWtrMark = 2000;                         /* low water mark for disk-assisted queues */
 static int iMainMsgQDiscardMark = 9800;                                /* begin to discard messages */
 static int iMainMsgQDiscardSeverity = 8;                       /* by default, discard nothing to prevent unintentional loss */
@@ -301,7 +301,7 @@ static rsRetVal resetConfigVariables(uchar __attribute__((unused)) *pp, void __a
        pszMainMsgQFName = NULL;
        iMainMsgQueueSize = 10000;
        iMainMsgQHighWtrMark = 8000;
-       iMainMsgQLightDlyMark = 7000;
+       iMainMsgQLightDlyMark = -1;
        iMainMsgQLowWtrMark = 2000;
        iMainMsgQDiscardMark = 9800;
        iMainMsgQDiscardSeverity = 8;
@@ -1576,7 +1576,9 @@ rsRetVal createMainQueue(qqueue_t **ppQueue, uchar *pszQueueName)
        setQPROP(qqueueSetiHighWtrMrk, "$MainMsgQueueHighWaterMark", iMainMsgQHighWtrMark);
        setQPROP(qqueueSetiLowWtrMrk, "$MainMsgQueueLowWaterMark", iMainMsgQLowWtrMark);
        setQPROP(qqueueSetiDiscardMrk, "$MainMsgQueueDiscardMark", iMainMsgQDiscardMark);
-       setQPROP(qqueueSetiLightDlyMrk, "$MainMsgQueueLightDelayMark", iMainMsgQLightDlyMark);
+       if(iMainMsgQLightDlyMark > 0) {
+               setQPROP(qqueueSetiLightDlyMrk, "$MainMsgQueueLightDelayMark", iMainMsgQLightDlyMark);
+       }
        setQPROP(qqueueSetiDiscardSeverity, "$MainMsgQueueDiscardSeverity", iMainMsgQDiscardSeverity);
        setQPROP(qqueueSetiMinMsgsPerWrkr, "$MainMsgQueueWorkerThreadMinimumMessages", iMainMsgQWrkMinMsgs);
        setQPROP(qqueueSetbSaveOnShutdown, "$MainMsgQueueSaveOnShutdown", bMainMsgQSaveOnShutdown);