antifix(backend-ender):use msg timestamp

This commit is contained in:
ShiKhu 2021-12-30 16:51:34 +01:00
parent c476e41bb0
commit 8f0524a2f6

View file

@ -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 {