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

swarm/network/simulation: defer sim.Clsoe()

Browse source
This commit is contained in:
Fabio Barone 2019-02-24 21:04:14 -05:00
parent aa001605b9
commit 6ba8a5b65c
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
swarm/network/simulation/kademlia_test.go
View file

@ -50,6 +50,7 @@ func TestWaitTillHealthy(t *testing.T) {
// create the first simulation // create the first simulation
sim := New(simServiceMap) sim := New(simServiceMap)
defer sim.Close()
// connect and... // connect and...
_, err := sim.AddNodesAndConnectRing(testNodesNum) _, err := sim.AddNodesAndConnectRing(testNodesNum)
@ -77,7 +78,6 @@ func TestWaitTillHealthy(t *testing.T) {
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
sim.Close()
// create a control simulation // create a control simulation
controlSim := New(createSimServiceMap(false)) controlSim := New(createSimServiceMap(false))
@ -88,6 +88,10 @@ func TestWaitTillHealthy(t *testing.T) {
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
_, err = controlSim.WaitTillHealthy(ctx)
if err != nil {
t.Fatal(err)
}
// for each node... // for each node...
nodeIDs := controlSim.UpNodeIDs() nodeIDs := controlSim.UpNodeIDs()
if len(nodeIDs) != testNodesNum { if len(nodeIDs) != testNodesNum {
@ -122,6 +126,7 @@ func TestWaitTillHealthy(t *testing.T) {
healthy := info.Healthy() healthy := info.Healthy()
log.Trace("Node is healthy", "node", node, "healthy", healthy) log.Trace("Node is healthy", "node", node, "healthy", healthy)
if !healthy { if !healthy {
log.Trace("Unhealthy kademlia", "kad", kad.String())
t.Fatalf("Expected node %v of control simulation to be healthy, but it is not", node) t.Fatalf("Expected node %v of control simulation to be healthy, but it is not", node)
} }
} }