network: Kademlia Load Balancing (#1774)

* network: initial implementation for the proposed solution for peers load balancing in Kademlia as per SWIP 28
ethersphere · Nov 12, 2019 · 868b945 · 868b945
1 parent 7c508c6
commit 868b945
Show file tree

Hide file tree

Showing 14 changed files with 1,555 additions and 103 deletions.
diff --git a/network/hive_test.go b/network/hive_test.go
@@ -254,7 +254,7 @@ func TestHiveStateConnections(t *testing.T) {
 
 	}
 	h1.Kademlia.lock.Lock()
-	numConns := h1.conns.Size()
+	numConns := h1.defaultIndex.conns.Size()
 	h1.Kademlia.lock.Unlock()
 	connAddresses := make(map[string]string)
 	h1.EachConn(h1.base, 255, func(peer *Peer, i int) bool {
@@ -271,12 +271,12 @@ func TestHiveStateConnections(t *testing.T) {
 	connsAfterLoading := 0
 	iterations := 0
 	h2.Kademlia.lock.Lock()
-	connsAfterLoading = h2.conns.Size()
+	connsAfterLoading = h2.defaultIndex.conns.Size()
 	h2.Kademlia.lock.Unlock()
 	for connsAfterLoading != numConns && iterations < 5 {
 		select {
 		case <-addedChan:
-			connsAfterLoading = h2.conns.Size()
+			connsAfterLoading = h2.defaultIndex.conns.Size()
 		case <-time.After(1 * time.Second):
 			iterations++
 		}