Fix addr expiration

miguelangel-nubla · Jan 2, 2025 · 0d02bc2 · 0d02bc2
1 parent e7d1db1
commit 0d02bc2
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 1 deletion.
diff --git a/addr.go b/addr.go
@@ -41,7 +41,7 @@ func (a *Addr) resetTimers(resetExpirationTime bool) {
 	}
 }
 
-func (a *Addr) IsStillValid() bool {
+func (a *Addr) Valid() bool {
 	return a.expirationTime.After(time.Now())
 }
 

diff --git a/addr_collection.go b/addr_collection.go
@@ -136,6 +136,19 @@ func (c *AddrCollection) Filter4() *AddrCollection {
 	return result
 }
 
+func (c *AddrCollection) FilterValid() *AddrCollection {
+	c.addressesMutex.RLock()
+	defer c.addressesMutex.RUnlock()
+
+	result := NewAddrCollection()
+	for _, addr := range c.addresses {
+		if addr.Valid() {
+			result.Enlist(addr)
+		}
+	}
+	return result
+}
+
 func (c *AddrCollection) Get() []*Addr {
 	c.addressesMutex.RLock()
 	defer c.addressesMutex.RUnlock()
-Original file line number
+Diff line change
@@ Expand Up / @@ -41,7 +41,7 @@ func (a *Addr) resetTimers(resetExpirationTime bool) { @@
     	}
     }
-    func (a *Addr) IsStillValid() bool {
+    func (a *Addr) Valid() bool {
     	return a.expirationTime.After(time.Now())
     }
@@ Expand Down @@