Expose RTT and throughput estimates from Cronet

components/cronet/android/test/javatests/src/org/chromium/net/CronetUrlRequestContextTest.java

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 1e433d90b421694647c8879178a37bb272a7adc3..a556100490ebe37ff07dd1be2f298d3c11686c2a 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
@@ -12,6 +12,8 @@ import android.os.Looper;
 import android.os.StrictMode;
 import android.test.suitebuilder.annotation.SmallTest;
 
+import org.json.JSONObject;
+
 import org.chromium.base.FileUtils;
 import org.chromium.base.PathUtils;
 import org.chromium.base.annotations.JNINamespace;
@@ -21,7 +23,6 @@ import org.chromium.net.TestUrlRequestCallback.ResponseStep;
 import org.chromium.net.impl.CronetLibraryLoader;
 import org.chromium.net.impl.CronetUrlRequestContext;
 import org.chromium.net.test.EmbeddedTestServer;
-import org.json.JSONObject;
 
 import java.io.BufferedReader;
 import java.io.File;
@@ -280,6 +281,12 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
     @Feature({"Cronet"})
     public void testRealTimeNetworkQualityObservationsQuicDisabled() throws Exception {
         CronetEngine.Builder mCronetEngineBuilder = new CronetEngine.Builder(getContext());
+        assert CronetEngine.INVALID_RTT_THROUGHPUT < 0;

[xunjieli, 2016/10/19 23:32:28]

Once you get rid of CronetEngine.INVALID_RTT_THROUGHPUT, these asserts wont be
necessary.

[tbansal1, 2016/10/20 00:29:18]

Done.

+
+        // The invalid value for the estimates used by Cronet should match the invalid value for
+        // the estimates used by the native.
+        assertEquals(CronetEngine.INVALID_RTT_THROUGHPUT,
+                RttThroughputValues.INVALID_RTT_THROUGHPUT_VALUE);
         Executor listenersExecutor = Executors.newSingleThreadExecutor(new ExecutorThreadFactory());
         ConditionVariable waitForThroughput = new ConditionVariable();
         TestNetworkQualityRttListener rttListener =
@@ -330,6 +337,22 @@ public class CronetUrlRequestContextTest extends CronetTestBase {
         assertTrue(testFramework.mCronetEngine.getEffectiveConnectionType()
                 != EffectiveConnectionType.TYPE_UNKNOWN);
 
+        // Verify that the HTTP RTT, transport RTT and downstream throughput
+        // estimates are available.
+        if (testFramework.mCronetEngine.getEffectiveConnectionType()
+                != EffectiveConnectionType.TYPE_OFFLINE) {
+            assertTrue(testFramework.mCronetEngine.getHttpRttMs() > 0);
+            assertTrue(testFramework.mCronetEngine.getTransportRttMs() > 0);
+            assertTrue(testFramework.mCronetEngine.getDownstreamThroughputKbps() > 0);
+        } else {
+            assertEquals(CronetEngine.INVALID_RTT_THROUGHPUT,
+                    testFramework.mCronetEngine.getHttpRttMs());
+            assertEquals(CronetEngine.INVALID_RTT_THROUGHPUT,
+                    testFramework.mCronetEngine.getTransportRttMs());
+            assertEquals(CronetEngine.INVALID_RTT_THROUGHPUT,
+                    testFramework.mCronetEngine.getDownstreamThroughputKbps());
+        }
+
         testFramework.mCronetEngine.shutdown();
     }