diff options
Diffstat (limited to 'runtime')
| -rw-r--r-- | runtime/datetime.c | 4 | ||||
| -rw-r--r-- | runtime/queue.c | 2 |
2 files changed, 4 insertions, 2 deletions
diff --git a/runtime/datetime.c b/runtime/datetime.c index b047bcf3..0b9b1ae2 100644 --- a/runtime/datetime.c +++ b/runtime/datetime.c @@ -303,8 +303,10 @@ ParseTIMESTAMP3339(struct syslogTime *pTime, uchar** ppszTS, int *pLenStr) if(OffsetHour < 0 || OffsetHour > 23) ABORT_FINALIZE(RS_RET_INVLD_TIME); - if(lenStr == 0 || *pszTS++ != ':') + if(lenStr == 0 || *pszTS != ':') ABORT_FINALIZE(RS_RET_INVLD_TIME); + --lenStr; + pszTS++; OffsetMinute = srSLMGParseInt32(&pszTS, &lenStr); if(OffsetMinute < 0 || OffsetMinute > 59) ABORT_FINALIZE(RS_RET_INVLD_TIME); diff --git a/runtime/queue.c b/runtime/queue.c index bb9ea060..09ba7e67 100644 --- a/runtime/queue.c +++ b/runtime/queue.c @@ -1389,7 +1389,7 @@ qqueueSetDefaultsActionQueue(qqueue_t *pThis) pThis->iDeqBatchSize = 128; /* default batch size */ pThis->iHighWtrMrk = 800; /* high water mark for disk-assisted queues */ pThis->iLowWtrMrk = 200; /* low water mark for disk-assisted queues */ - pThis->iDiscardMrk = 9800; /* begin to discard messages */ + pThis->iDiscardMrk = 980; /* begin to discard messages */ pThis->iDiscardSeverity = 8; /* turn off */ pThis->iNumWorkerThreads = 1; /* number of worker threads for the mm queue above */ pThis->iMaxFileSize = 1024*1024; |