From f4a60bd27851b69ce3227f8ecfa722593dbb9b0b Mon Sep 17 00:00:00 2001 From: Vladislav Yarmak Date: Fri, 23 Feb 2024 14:46:49 +0200 Subject: [PATCH] fix TTL --- listener/group.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/listener/group.go b/listener/group.go index c4c1445..de7cc24 100644 --- a/listener/group.go +++ b/listener/group.go @@ -11,6 +11,7 @@ import ( "github.com/SenseUnit/rgap/iface" "github.com/SenseUnit/rgap/protocol" "github.com/SenseUnit/rgap/psk" + "github.com/SenseUnit/rgap/util" "github.com/jellydator/ttlcache/v3" ) @@ -104,7 +105,7 @@ func (g *Group) Ingest(a *protocol.Announcement) error { expireAt := announceTime.Add(g.expire) setItem := g.addrSet.Get(address) if setItem == nil || setItem.ExpiresAt().Before(expireAt) { - g.addrSet.Set(address, struct{}{}, expireAt.Sub(now)) + g.addrSet.Set(address, struct{}{}, util.Max(expireAt.Sub(now), 1)) } return nil }