Index: components/cronet/android/test/javatests/src/org/chromium/net/CronetUrlRequestContextTest.java |
diff --git a/components/cronet/android/test/javatests/src/org/chromium/net/CronetUrlRequestContextTest.java b/components/cronet/android/test/javatests/src/org/chromium/net/CronetUrlRequestContextTest.java |
index 176f8a7896952a5b9015238105d31a53ef5d7f08..a8e13f7ac3e9d8e30f0286ac83e356a3496b298f 100644 |
--- a/components/cronet/android/test/javatests/src/org/chromium/net/CronetUrlRequestContextTest.java |
+++ b/components/cronet/android/test/javatests/src/org/chromium/net/CronetUrlRequestContextTest.java |
@@ -79,6 +79,28 @@ public class CronetUrlRequestContextTest extends CronetTestBase { |
} |
} |
+ static class TestNetworkQualityObserver implements RTTObserver, |
+ BandwidthObserver { |
+ int mRTTObservationCount; |
+ int mBandwidthObservationCount; |
+ |
+ public void onRTTObservation(int value, int when, int source) { |
+ mRTTObservationCount++; |
+ } |
+ |
+ public void onBandwidthObservation(int value, int when, int source) { |
+ mBandwidthObservationCount++; |
+ } |
+ |
+ public int rttObservationCount() { |
+ return mRTTObservationCount; |
+ } |
+ |
+ public int bandwidthObservationCount() { |
+ return mBandwidthObservationCount; |
+ } |
+ } |
+ |
@SmallTest |
@Feature({"Cronet"}) |
public void testConfigUserAgent() throws Exception { |
@@ -154,6 +176,26 @@ public class CronetUrlRequestContextTest extends CronetTestBase { |
@SmallTest |
@Feature({"Cronet"}) |
+ public void testRealTimeNetworkQualityObservations() throws Exception { |
+ mActivity = launchCronetTestApp(); |
+ TestNetworkQualityObserver networkQualityObserver = |
+ new TestNetworkQualityObserver(); |
+ mActivity.mUrlRequestContext.configureNetworkQualityEstimator(true, |
mef
2015/08/11 17:16:27
What happens if you add observer without configuri
bengr
2015/08/25 23:43:34
Removed the configure method.
|
+ true); |
+ mActivity.mUrlRequestContext.addRTTObserver(networkQualityObserver); |
+ mActivity.mUrlRequestContext.addBandwidthObserver( |
+ networkQualityObserver); |
+ TestUrlRequestListener listener = new TestUrlRequestListener(); |
+ UrlRequest urlRequest = mActivity.mUrlRequestContext.createRequest( |
+ TEST_URL, listener, listener.getExecutor()); |
+ urlRequest.start(); |
+ listener.blockForDone(); |
+ assertTrue(networkQualityObserver.rttObservationCount() > 0); |
+ assertTrue(networkQualityObserver.bandwidthObservationCount() > 0); |
+ } |
+ |
+ @SmallTest |
+ @Feature({"Cronet"}) |
public void testShutdown() throws Exception { |
mActivity = launchCronetTestApp(); |
TestUrlRequestListener listener = new ShutdownTestUrlRequestListener(); |