|
|
|
@ -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 { |
|
|
|
|