RefreshBuckets: Use self ID on bucket 0.

This commit is contained in:
Kleissner
2021-04-25 03:44:52 +02:00
parent 1c03afd63b
commit 611dfa3b1c

View File

@@ -241,6 +241,12 @@ func (dht *DHT) RefreshBuckets(target int) {
for bucket, total := range dht.ht.getTotalNodesPerBucket() {
if target == 0 || total < target {
nodeR := dht.ht.getRandomIDFromBucket(bucket)
// Refreshing closest bucket? Use self ID instead of random one.
if bucket == 0 {
nodeR = dht.ht.Self.ID
}
dht.FindNode(nodeR)
}
}