aboutsummaryrefslogtreecommitdiffstats
path: root/eth/downloader/downloader_test.go
diff options
context:
space:
mode:
authorPéter Szilágyi <peterke@gmail.com>2015-07-03 17:53:11 +0800
committerPéter Szilágyi <peterke@gmail.com>2015-07-03 18:01:22 +0800
commitf857fb7600f586ad9bfd037091420f77137c973f (patch)
tree2e2f02177488637b9ba202127ce962309cbe2636 /eth/downloader/downloader_test.go
parent9f6016e8773f951c5b81b30c0257350e2a9c8e5f (diff)
downloadgo-tangerine-f857fb7600f586ad9bfd037091420f77137c973f.tar
go-tangerine-f857fb7600f586ad9bfd037091420f77137c973f.tar.gz
go-tangerine-f857fb7600f586ad9bfd037091420f77137c973f.tar.bz2
go-tangerine-f857fb7600f586ad9bfd037091420f77137c973f.tar.lz
go-tangerine-f857fb7600f586ad9bfd037091420f77137c973f.tar.xz
go-tangerine-f857fb7600f586ad9bfd037091420f77137c973f.tar.zst
go-tangerine-f857fb7600f586ad9bfd037091420f77137c973f.zip
eth/downloader: fix a rare test race on the OSX CI
Diffstat (limited to 'eth/downloader/downloader_test.go')
-rw-r--r--eth/downloader/downloader_test.go8
1 files changed, 7 insertions, 1 deletions
diff --git a/eth/downloader/downloader_test.go b/eth/downloader/downloader_test.go
index c5fb00289..23549a9ba 100644
--- a/eth/downloader/downloader_test.go
+++ b/eth/downloader/downloader_test.go
@@ -83,7 +83,13 @@ func newTester() *downloadTester {
// sync starts synchronizing with a remote peer, blocking until it completes.
func (dl *downloadTester) sync(id string) error {
err := dl.downloader.synchronise(id, dl.peerHashes[id][0])
- for atomic.LoadInt32(&dl.downloader.processing) == 1 {
+ for {
+ // If the queue is empty and processing stopped, break
+ hashes, blocks := dl.downloader.queue.Size()
+ if hashes+blocks == 0 && atomic.LoadInt32(&dl.downloader.processing) == 0 {
+ break
+ }
+ // Otherwise sleep a bit and retry
time.Sleep(time.Millisecond)
}
return err