diff options
| author | Péter Szilágyi <peterke@gmail.com> | 2015-06-07 23:46:32 +0800 |
|---|---|---|
| committer | Péter Szilágyi <peterke@gmail.com> | 2015-06-08 18:23:58 +0800 |
| commit | 4b2dd44711a04c639ecde68806455ccf7244acce (patch) | |
| tree | 7ffc67ecb34c690eef9587fcc776b0fc5d198f2a | |
| parent | 2d627995cf22b9a1187e4b22d430f84541904d2c (diff) | |
| download | dexon-4b2dd44711a04c639ecde68806455ccf7244acce.tar.gz dexon-4b2dd44711a04c639ecde68806455ccf7244acce.tar.zst dexon-4b2dd44711a04c639ecde68806455ccf7244acce.zip | |
eth/downloader: fix throttling test to be less timing dependent
| -rw-r--r-- | eth/downloader/downloader_test.go | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/eth/downloader/downloader_test.go b/eth/downloader/downloader_test.go index 4e2d527b9..4219c2788 100644 --- a/eth/downloader/downloader_test.go +++ b/eth/downloader/downloader_test.go @@ -273,9 +273,13 @@ func TestThrottling(t *testing.T) { }() // Iteratively take some blocks, always checking the retrieval count for total := 0; total < targetBlocks; { - // Sleep a bit for sync to complete - time.Sleep(500 * time.Millisecond) - + // Wait a bit for sync to complete + for start := time.Now(); time.Since(start) < 3*time.Second; { + time.Sleep(25 * time.Millisecond) + if len(tester.downloader.queue.blockPool) == blockCacheLimit { + break + } + } // Fetch the next batch of blocks took := tester.downloader.TakeBlocks() if len(took) != blockCacheLimit { |