diff options
| author | Péter Szilágyi <peterke@gmail.com> | 2015-07-03 17:53:11 +0800 |
|---|---|---|
| committer | Péter Szilágyi <peterke@gmail.com> | 2015-07-03 18:01:22 +0800 |
| commit | f857fb7600f586ad9bfd037091420f77137c973f (patch) | |
| tree | 2e2f02177488637b9ba202127ce962309cbe2636 /eth | |
| parent | 9f6016e8773f951c5b81b30c0257350e2a9c8e5f (diff) | |
| download | dexon-f857fb7600f586ad9bfd037091420f77137c973f.tar.gz dexon-f857fb7600f586ad9bfd037091420f77137c973f.tar.zst dexon-f857fb7600f586ad9bfd037091420f77137c973f.zip | |
eth/downloader: fix a rare test race on the OSX CI
Diffstat (limited to 'eth')
| -rw-r--r-- | eth/downloader/downloader_test.go | 8 |
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 |