From 8f0524a2f6bd5f0dfd2d9edbcd073523e1206dd5 Mon Sep 17 00:00:00 2001 From: ShiKhu Date: Thu, 30 Dec 2021 16:51:34 +0100 Subject: [PATCH] antifix(backend-ender):use msg timestamp --- backend/services/ender/builder/builder.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/backend/services/ender/builder/builder.go b/backend/services/ender/builder/builder.go index fa27e1c82..c0690a3ad 100644 --- a/backend/services/ender/builder/builder.go +++ b/backend/services/ender/builder/builder.go @@ -299,7 +299,8 @@ func (b *builder) checkTimeouts(ts int64) bool { b.buildPerformanceTrackAggr() } - lastTsGap := ts - b.lastProcessedTimestamp + lastTsGap := ts - int64(b.timestamp) + //b.lastProcessedTimestamp //log.Printf("checking timeouts for sess %v: %v now, %v sesstime; gap %v",b.sid, ts, b.timestamp, lastTsGap) if lastTsGap > intervals.EVENTS_SESSION_END_TIMEOUT { if rm := b.ddDetector.Build(); rm != nil {