aboutsummaryrefslogtreecommitdiffstats
path: root/eth/downloader/downloader_test.go
diff options
context:
space:
mode:
authorPéter Szilágyi <peterke@gmail.com>2016-05-30 17:01:50 +0800
committerPéter Szilágyi <peterke@gmail.com>2016-05-30 17:01:50 +0800
commit4496a44f68246bf128bb822c3f3a98f38adfdbdd (patch)
tree312922dbfc111fd3ef66c194dcdc6c87b96bba66 /eth/downloader/downloader_test.go
parentab664c7e17009729d1083d8d4f7c37eb387012d3 (diff)
downloaddexon-4496a44f68246bf128bb822c3f3a98f38adfdbdd.tar.gz
dexon-4496a44f68246bf128bb822c3f3a98f38adfdbdd.tar.zst
dexon-4496a44f68246bf128bb822c3f3a98f38adfdbdd.zip
eth/downloader: ensure cancel channel is closed post sync
Diffstat (limited to 'eth/downloader/downloader_test.go')
-rw-r--r--eth/downloader/downloader_test.go12
1 files changed, 11 insertions, 1 deletions
diff --git a/eth/downloader/downloader_test.go b/eth/downloader/downloader_test.go
index 4ea8a8abe..1cf0e7cd3 100644
--- a/eth/downloader/downloader_test.go
+++ b/eth/downloader/downloader_test.go
@@ -188,7 +188,17 @@ func (dl *downloadTester) sync(id string, td *big.Int, mode SyncMode) error {
}
}
dl.lock.RUnlock()
- return dl.downloader.synchronise(id, hash, td, mode)
+
+ // Synchronise with the chosen peer and ensure proper cleanup afterwards
+ err := dl.downloader.synchronise(id, hash, td, mode)
+ select {
+ case <-dl.downloader.cancelCh:
+ // Ok, downloader fully cancelled after sync cycle
+ default:
+ // Downloader is still accepting packets, can block a peer up
+ panic("downloader active post sync cycle") // panic will be caught by tester
+ }
+ return err
}
// hasHeader checks if a header is present in the testers canonical chain.