forked from cerc-io/plugeth
p2p/discv5, p2p/testing: add missing Timer.Stop calls in tests (#20869)
This commit is contained in:
parent
37d6357806
commit
0c359e4b9a
@ -43,6 +43,7 @@ func TestSimRandomResolve(t *testing.T) {
|
||||
|
||||
// A new node joins every 10s.
|
||||
launcher := time.NewTicker(10 * time.Second)
|
||||
defer launcher.Stop()
|
||||
go func() {
|
||||
for range launcher.C {
|
||||
net := sim.launchNode(false)
|
||||
@ -55,7 +56,6 @@ func TestSimRandomResolve(t *testing.T) {
|
||||
}()
|
||||
|
||||
time.Sleep(3 * time.Hour)
|
||||
launcher.Stop()
|
||||
sim.shutdown()
|
||||
sim.printStats()
|
||||
}
|
||||
@ -196,6 +196,7 @@ func randomResolves(t *testing.T, s *simulation, net *Network) {
|
||||
}
|
||||
|
||||
timer := time.NewTimer(randtime())
|
||||
defer timer.Stop()
|
||||
for {
|
||||
select {
|
||||
case <-timer.C:
|
||||
|
@ -242,6 +242,7 @@ func (s *ProtocolSession) testExchange(e Exchange) error {
|
||||
t = 2000 * time.Millisecond
|
||||
}
|
||||
alarm := time.NewTimer(t)
|
||||
defer alarm.Stop()
|
||||
select {
|
||||
case err := <-errc:
|
||||
return err
|
||||
|
Loading…
Reference in New Issue
Block a user