Add HttpUrlConnection backed implementation of CronetEngine.

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

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package org.chromium.net;
 
 import android.test.suitebuilder.annotation.SmallTest;
 
 import org.chromium.base.test.util.Feature;
+import org.chromium.net.CronetTestBase.OnlyRunNativeCronet;
 
 import java.util.Arrays;
 import java.util.List;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
 /**
  * Tests that directly drive {@code CronetUploadDataStream} and
  * {@code UploadDataProvider} to simulate different ordering of reset, init,
  * read, and rewind calls.
+ *

[pauljensen, 2015/12/29 16:35:53]

why'd you add an empty line?

[Charles, 2016/01/05 21:53:56]

Done.

  */
 public class CronetUploadTest extends CronetTestBase {
     private TestDrivenDataProvider mDataProvider;
     private CronetUploadDataStream mUploadDataStream;
     private TestUploadDataStreamHandler mHandler;
 
     @Override
     @SuppressWarnings("PrimitiveArrayPassedToVarargsMethod")
     protected void setUp() throws Exception {
         super.setUp();
@@ skipping 12 matching lines @@
         mHandler.destroyNativeObjects();
         super.tearDown();
     }
 
     /**
      * Tests that after some data is read, init triggers a rewind, and that
      * before the rewind completes, init blocks.
      */
     @SmallTest
     @Feature({"Cronet"})
-    public void testInitTriggersRewindAndInitBeforeRewindCompletes()
-            throws Exception {
+    @OnlyRunNativeCronet
+    public void testInitTriggersRewindAndInitBeforeRewindCompletes() throws Exception {
         // Init completes synchronously and read succeeds.
         assertTrue(mHandler.init());
         mHandler.read();
         mDataProvider.waitForReadRequest();
         mHandler.checkReadCallbackNotInvoked();
         mDataProvider.onReadSucceeded(mUploadDataStream);
         mHandler.waitForReadComplete();
         mDataProvider.assertReadNotPending();
         assertEquals(0, mDataProvider.getNumRewindCalls());
         assertEquals(1, mDataProvider.getNumReadCalls());
@@ skipping 27 matching lines @@
         assertEquals(2, mDataProvider.getNumReadCalls());
         assertEquals("hello", mHandler.getData());
     }
 
     /**
      * Tests that after some data is read, init triggers a rewind, and that
      * after the rewind completes, init does not block.
      */
     @SmallTest
     @Feature({"Cronet"})
-    public void testInitTriggersRewindAndInitAfterRewindCompletes()
-            throws Exception {
+    @OnlyRunNativeCronet
+    public void testInitTriggersRewindAndInitAfterRewindCompletes() throws Exception {
         // Init completes synchronously and read succeeds.
         assertTrue(mHandler.init());
         mHandler.read();
         mDataProvider.waitForReadRequest();
         mHandler.checkReadCallbackNotInvoked();
         mDataProvider.onReadSucceeded(mUploadDataStream);
         mHandler.waitForReadComplete();
         mDataProvider.assertReadNotPending();
         assertEquals(0, mDataProvider.getNumRewindCalls());
         assertEquals(1, mDataProvider.getNumReadCalls());
@@ skipping 26 matching lines @@
         assertEquals(2, mDataProvider.getNumReadCalls());
         assertEquals("hello", mHandler.getData());
     }
 
     /**
      * Tests that if init before read completes, a rewind is triggered when
      * read completes.
      */
     @SmallTest
     @Feature({"Cronet"})
+    @OnlyRunNativeCronet
     public void testReadCompleteTriggerRewind() throws Exception {
         // Reset and init before read completes.
         assertTrue(mHandler.init());
         mHandler.read();
         mDataProvider.waitForReadRequest();
         mHandler.checkReadCallbackNotInvoked();
         mHandler.reset();
         // Init should return asynchronously, since there is a pending read.
         assertFalse(mHandler.init());
         mDataProvider.assertRewindNotPending();
@@ skipping 14 matching lines @@
         assertEquals("", mHandler.getData());
     }
 
     /**
      * Tests that when init again after rewind completes, no additional rewind
      * is triggered. This test is the same as testReadCompleteTriggerRewind
      * except that this test invokes reset and init again in the end.
      */
     @SmallTest
     @Feature({"Cronet"})
+    @OnlyRunNativeCronet
     public void testReadCompleteTriggerRewindOnlyOneRewind() throws Exception {
         testReadCompleteTriggerRewind();
         // Reset and Init again, no rewind should happen.
         mHandler.reset();
         assertTrue(mHandler.init());
         mDataProvider.assertRewindNotPending();
         assertEquals(1, mDataProvider.getNumRewindCalls());
         assertEquals(1, mDataProvider.getNumReadCalls());
         assertEquals("", mHandler.getData());
     }
 
     /**
      * Tests that if reset before read completes, no rewind is triggered, and
      * that a following init triggers rewind.
      */
     @SmallTest
     @Feature({"Cronet"})
-    public void testResetBeforeReadCompleteAndInitTriggerRewind()
-            throws Exception {
+    @OnlyRunNativeCronet
+    public void testResetBeforeReadCompleteAndInitTriggerRewind() throws Exception {
         // Reset before read completes. Rewind is not triggered.
         assertTrue(mHandler.init());
         mHandler.read();
         mDataProvider.waitForReadRequest();
         mHandler.checkReadCallbackNotInvoked();
         mHandler.reset();
         mDataProvider.onReadSucceeded(mUploadDataStream);
         mDataProvider.assertRewindNotPending();
         assertEquals(0, mDataProvider.getNumRewindCalls());
         assertEquals(1, mDataProvider.getNumReadCalls());
@@ skipping 13 matching lines @@
 
     /**
      * Tests that there is no crash when native CronetUploadDataStream is
      * destroyed while read is pending. The test is racy since the read could
      * complete either before or after the Java CronetUploadDataStream's
      * onDestroyUploadDataStream() method is invoked. However, the test should
      * pass either way, though we are interested in the latter case.
      */
     @SmallTest
     @Feature({"Cronet"})
-    public void testDestroyNativeStreamBeforeReadComplete()
-            throws Exception {
+    @OnlyRunNativeCronet
+    public void testDestroyNativeStreamBeforeReadComplete() throws Exception {
         // Start a read and wait for it to be pending.
         assertTrue(mHandler.init());
         mHandler.read();
         mDataProvider.waitForReadRequest();
         mHandler.checkReadCallbackNotInvoked();
 
         // Destroy the C++ TestUploadDataStreamHandler. The handler will then
         // destroy the C++ CronetUploadDataStream it owns on the network thread.
         // That will result in calling the Java CronetUploadDataSteam's
         // onUploadDataStreamDestroyed() method on its executor thread, which
         // will then destroy the CronetUploadDataStreamAdapter.
         mHandler.destroyNativeObjects();
 
         // Make the read complete should not encounter a crash.
         mDataProvider.onReadSucceeded(mUploadDataStream);
 
         assertEquals(0, mDataProvider.getNumRewindCalls());
         assertEquals(1, mDataProvider.getNumReadCalls());
     }
 
     /**
      * Tests that there is no crash when native CronetUploadDataStream is
      * destroyed while rewind is pending. The test is racy since rewind could
      * complete either before or after the Java CronetUploadDataStream's
      * onDestroyUploadDataStream() method is invoked. However, the test should
      * pass either way, though we are interested in the latter case.
      */
     @SmallTest
     @Feature({"Cronet"})
-    public void testDestroyNativeStreamBeforeRewindComplete()
-            throws Exception {
+    @OnlyRunNativeCronet
+    public void testDestroyNativeStreamBeforeRewindComplete() throws Exception {
         // Start a read and wait for it to complete.
         assertTrue(mHandler.init());
         mHandler.read();
         mDataProvider.waitForReadRequest();
         mHandler.checkReadCallbackNotInvoked();
         mDataProvider.onReadSucceeded(mUploadDataStream);
         mHandler.waitForReadComplete();
         mDataProvider.assertReadNotPending();
         assertEquals(0, mDataProvider.getNumRewindCalls());
         assertEquals(1, mDataProvider.getNumReadCalls());
@@ skipping 13 matching lines @@
         // will then destroy the CronetUploadDataStreamAdapter.
         mHandler.destroyNativeObjects();
 
         // Signal rewind completes, and wait for init to complete.
         mDataProvider.onRewindSucceeded(mUploadDataStream);
 
         assertEquals(1, mDataProvider.getNumRewindCalls());
         assertEquals(1, mDataProvider.getNumReadCalls());
     }
 }