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: Change hive Healthy func to accept addresses

Browse source
This commit is contained in:
lash 2018-12-17 11:28:12 +01:00
parent 5bf8307719
commit 166f08403a
2 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
swarm/network/hive.go
View file

@ -244,7 +244,10 @@ func (h *Hive) savePeers() error {
} }
// Healthy is an api proxy to the underlying kademlia healthy function // Healthy is an api proxy to the underlying kademlia healthy function
func (h *Hive) Healthy(addr []byte, pp PeerPot) *Health { func (h *Hive) Healthy(addrs [][]byte) *Health {
pp.base = addr k := NewKademlia(h.BaseAddr(), NewKadParams())
return pp.Healthy() for _, a := range addrs {
k.On(a)
}
return pp.Healthy([]*Kademlia{k})
} }

3
swarm/network/simulations/discovery/discovery_test.go
View file

@ -412,7 +412,8 @@ func discoveryPersistenceSimulation(nodes, conns int, adapter adapters.NodeAdapt
addr := id.String() addr := id.String()
log.Error("before hive healthy call") log.Error("before hive healthy call")
pp := ppmap[addr] pp := ppmap[addr]
if err := client.Call(&healthy, "hive_healthy", pp.BaseAddr(), pp); err != nil { // if err := client.Call(&healthy, "hive_healthy", pp.BaseAddr(), pp); err != nil {
if err := client.Call(&healthy, "hive_healthy", pp.BaseAddr(), addrs); err != nil {
return fmt.Errorf("error getting node health: %s", err) return fmt.Errorf("error getting node health: %s", err)
} }