forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 02:42:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm/network: Rename health test functions

Browse source
This commit is contained in:
lash 2018-12-14 17:15:15 +01:00
parent 957c8cced7
commit af9b98c7f8
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
swarm/network/kademlia.go
View file

@ -676,7 +676,7 @@ func (k *Kademlia) saturation() int {
// are found among the peers known to the kademlia // are found among the peers known to the kademlia
// It is used in Healthy function for testing only // It is used in Healthy function for testing only
// TODO move to separate testing tools file // TODO move to separate testing tools file
func (o *PeerPot) knowNearestNeighbours() (got bool, n int, missing [][]byte) { func (o *PeerPot) knownNeighbours() (got bool, n int, missing [][]byte) {
pm := make(map[string]bool) pm := make(map[string]bool)
// create a map with all peers at depth and deeper known in the kademlia // create a map with all peers at depth and deeper known in the kademlia
@ -713,7 +713,7 @@ func (o *PeerPot) knowNearestNeighbours() (got bool, n int, missing [][]byte) {
// gotNearestNeighbours tests if all neighbours in the peerpot // gotNearestNeighbours tests if all neighbours in the peerpot
// are currently connected in the kademlia // are currently connected in the kademlia
// It is used in Healthy function for testing only // It is used in Healthy function for testing only
func (o *PeerPot) gotNearestNeighbours() (got bool, n int, missing [][]byte) { func (o *PeerPot) connectedNeighbours() (got bool, n int, missing [][]byte) {
pm := make(map[string]bool) pm := make(map[string]bool)
// create a map with all peers at depth and deeper that are connected in the kademlia // create a map with all peers at depth and deeper that are connected in the kademlia
@ -765,8 +765,8 @@ type Health struct {
func (o *PeerPot) Healthy() *Health { func (o *PeerPot) Healthy() *Health {
o.Kademlia.lock.RLock() o.Kademlia.lock.RLock()
defer o.Kademlia.lock.RUnlock() defer o.Kademlia.lock.RUnlock()
gotnn, countgotnn, culpritsgotnn := o.gotNearestNeighbours() gotnn, countgotnn, culpritsgotnn := o.connectedNeighbours()
knownn, countknownn, culpritsknownn := o.knowNearestNeighbours() knownn, countknownn, culpritsknownn := o.knownNeighbours()
depth := depthForPot(o.conns, o.MinProxBinSize, o.base) depth := depthForPot(o.conns, o.MinProxBinSize, o.base)
saturated := o.saturation() < depth saturated := o.saturation() < depth
log.Trace(fmt.Sprintf("%08x: healthy: knowNNs: %v, gotNNs: %v, saturated: %v\n", o.base, knownn, gotnn, saturated)) log.Trace(fmt.Sprintf("%08x: healthy: knowNNs: %v, gotNNs: %v, saturated: %v\n", o.base, knownn, gotnn, saturated))