From f829ebcba0785a3e528624b8a90d8feb58020d73 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ren=C3=A9=20Canna=C3=B2?= Date: Tue, 5 Nov 2019 21:36:54 +1100 Subject: [PATCH] Allows max_lag_ms to be 0 --- lib/Query_Processor.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/Query_Processor.cpp b/lib/Query_Processor.cpp index 0e5010019..650942d01 100644 --- a/lib/Query_Processor.cpp +++ b/lib/Query_Processor.cpp @@ -2659,7 +2659,7 @@ bool Query_Processor::query_parser_first_comment(Query_Processor_Output *qpo, ch if (!strcasecmp(key,"max_lag_ms")) { if (c >= '0' && c <= '9') { // it is a digit int t=atoi(value); - if (t > 0 && t <= 600000) { + if (t >= 0 && t <= 600000) { qpo->max_lag_ms = t; } } @@ -2671,7 +2671,7 @@ bool Query_Processor::query_parser_first_comment(Query_Processor_Output *qpo, ch long long now_ms_s = (long long)now_ms; long long t=atoll(value); long long diff = now_ms_s - t; - if (diff > 0 && diff <= 600000) { + if (diff >= 0 && diff <= 600000) { qpo->max_lag_ms = diff; } }