diff --git a/src/yggdrasil/dht.go b/src/yggdrasil/dht.go index f4c8578..f722662 100644 --- a/src/yggdrasil/dht.go +++ b/src/yggdrasil/dht.go @@ -485,3 +485,9 @@ func dht_firstCloserThanThird(first *NodeID, } return false } + +func (t *dht) resetPeers() { + for _, b := range t.buckets_hidden { + b.peers = b.peers[:0] + } +} diff --git a/src/yggdrasil/router.go b/src/yggdrasil/router.go index a9de966..5028b49 100644 --- a/src/yggdrasil/router.go +++ b/src/yggdrasil/router.go @@ -80,6 +80,7 @@ func (r *router) mainLoop() { r.core.dht.insertIfNew(info, true) case <-r.reset: r.core.sessions.resetInits() + r.core.dht.resetPeers() case <-ticker.C: { // Any periodic maintenance stuff goes here