[Cronet] Switch from InstrumentationTest to junit

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

 // Copyright 2014 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.LargeTest;
 import android.test.suitebuilder.annotation.SmallTest;
 
 import org.chromium.base.annotations.SuppressFBWarnings;
 import org.chromium.base.test.util.Feature;
 import org.chromium.net.test.FailurePhase;
 
 import java.io.IOException;
 import java.nio.ByteBuffer;
 import java.util.HashMap;
 import java.util.List;
 import java.util.concurrent.Executors;
 
 /**
  * Tests making requests using {@link ChromiumUrlRequest}.
  */
 public class ChromiumUrlRequestTest extends CronetTestBase {
-    private CronetTestActivity mActivity;
+    private CronetTestFramework mTestFramework;
     private TestHttpUrlRequestListener mListener;
     private HttpUrlRequest mRequest;
 
     @Override
     protected void setUp() throws Exception {
         super.setUp();
-        mActivity = launchCronetTestApp();
-        assertTrue(NativeTestServer.startNativeTestServer(
-                getInstrumentation().getTargetContext()));
+        mTestFramework = startCronetTestFramework();
+        assertTrue(NativeTestServer.startNativeTestServer(getContext()));
         MockUrlRequestJobFactory.setUp();
     }
 
     @Override
     protected void tearDown() throws Exception {
         NativeTestServer.shutdownNativeTestServer();
         super.tearDown();
     }
 
     // Helper function to create a HttpUrlRequest with the specified url.
     private void createRequestAndWaitForComplete(
             String url, boolean disableRedirects) {
         HashMap<String, String> headers = new HashMap<String, String>();
         mListener = new TestHttpUrlRequestListener();
-        mRequest = mActivity.mRequestFactory.createRequest(
-                url,
-                HttpUrlRequest.REQUEST_PRIORITY_MEDIUM,
-                headers,
-                mListener);
+        mRequest = mTestFramework.mRequestFactory.createRequest(
+                url, HttpUrlRequest.REQUEST_PRIORITY_MEDIUM, headers, mListener);
         if (disableRedirects) {
             mRequest.disableRedirects();
         }
         mRequest.start();
         mListener.blockForComplete();
     }
 
     /**
      * Helper method to check that we are not calling methods on the native
      * adapter after it has been destroyed.
@@ skipping 170 matching lines @@
         // WritableByteChannel.close if request is canceled from another
         // thread.
         for (int i = 0; i < 100; ++i) {
             HashMap<String, String> headers = new HashMap<String, String>();
             TestByteChannel channel = new TestByteChannel();
             TestHttpUrlRequestListener listener =
                     new TestHttpUrlRequestListener();
 
             // Create request.
             final HttpUrlRequest request =
-                    mActivity.mRequestFactory.createRequest(
-                            NativeTestServer.getSuccessURL(),
-                            HttpUrlRequest.REQUEST_PRIORITY_LOW, headers,
-                            channel, listener);
+                    mTestFramework.mRequestFactory.createRequest(NativeTestServer.getSuccessURL(),
+                            HttpUrlRequest.REQUEST_PRIORITY_LOW, headers, channel, listener);
             request.start();
             listener.blockForStart();
             Runnable cancelTask = new Runnable() {
                 public void run() {
                     request.cancel();
                 }
             };
             Executors.newCachedThreadPool().execute(cancelTask);
             listener.blockForComplete();
             assertFalse(channel.isOpen());
@@ skipping 12 matching lines @@
         TestByteChannel channel = new TestByteChannel();
         TestHttpUrlRequestListener listener = new TestHttpUrlRequestListener();
 
         String data = "MyBigFunkyData";
         int dataLength = data.length();
         int repeatCount = 10000;
         String mockUrl = MockUrlRequestJobFactory.getMockUrlForData(data,
                 repeatCount);
 
         // Create request.
-        final HttpUrlRequest request =
-                mActivity.mRequestFactory.createRequest(
-                        mockUrl,
-                        HttpUrlRequest.REQUEST_PRIORITY_LOW, headers,
-                        channel, listener);
+        final HttpUrlRequest request = mTestFramework.mRequestFactory.createRequest(
+                mockUrl, HttpUrlRequest.REQUEST_PRIORITY_LOW, headers, channel, listener);
         // Channel will cancel the request from the network thread during the
         // first write.
         channel.setRequestToCancelOnWrite(request);
         request.start();
         listener.blockForComplete();
         assertTrue(request.isCanceled());
         assertFalse(channel.isOpen());
         // Test that ChromiumUrlRequest caches information which is available
         // after the native request adapter has been destroyed.
         // Since the request is canceled after onResponseStarted, status code
@@ skipping 12 matching lines @@
         String mockUrl = MockUrlRequestJobFactory.getMockUrlForData(data,
                 repeatCount);
         createRequestAndWaitForComplete(mockUrl, false);
         assertEquals(mockUrl, mListener.mUrl);
         for (int i = 0; i < repeatCount; ++i) {
             assertEquals(data, mListener.mResponseAsString.substring(
                     dataLength * i, dataLength * (i + 1)));
         }
     }
 }