HDFS-9772. TestBlockReplacement#testThrottler doesn't work as expected. Contributed by Lin Yiqun.
This commit is contained in:
parent
35f0770555
commit
903428bf94
|
@ -81,7 +81,6 @@ public class TestBlockReplacement {
|
||||||
long bytesToSend = TOTAL_BYTES;
|
long bytesToSend = TOTAL_BYTES;
|
||||||
long start = Time.monotonicNow();
|
long start = Time.monotonicNow();
|
||||||
DataTransferThrottler throttler = new DataTransferThrottler(bandwidthPerSec);
|
DataTransferThrottler throttler = new DataTransferThrottler(bandwidthPerSec);
|
||||||
long totalBytes = 0L;
|
|
||||||
long bytesSent = 1024*512L; // 0.5MB
|
long bytesSent = 1024*512L; // 0.5MB
|
||||||
throttler.throttle(bytesSent);
|
throttler.throttle(bytesSent);
|
||||||
bytesToSend -= bytesSent;
|
bytesToSend -= bytesSent;
|
||||||
|
@ -93,7 +92,7 @@ public class TestBlockReplacement {
|
||||||
} catch (InterruptedException ignored) {}
|
} catch (InterruptedException ignored) {}
|
||||||
throttler.throttle(bytesToSend);
|
throttler.throttle(bytesToSend);
|
||||||
long end = Time.monotonicNow();
|
long end = Time.monotonicNow();
|
||||||
assertTrue(totalBytes*1000/(end-start)<=bandwidthPerSec);
|
assertTrue(TOTAL_BYTES * 1000 / (end - start) <= bandwidthPerSec);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
|
|
Loading…
Reference in New Issue