[Cronet] Test the libcronet that's shipped, not libcronet_test

components/cronet/android/test/src/org/chromium/net/CronetTestUtil.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.os.ConditionVariable;
-
 import org.json.JSONException;
 import org.json.JSONObject;
 
 import org.chromium.base.annotations.JNINamespace;
 import org.chromium.net.impl.CronetEngineBuilderImpl;
 import org.chromium.net.impl.CronetUrlRequest;
+import org.chromium.net.impl.CronetUrlRequestContext;
 
 /**
  * Utilities for Cronet testing
  */
 @JNINamespace("cronet")
 public class CronetTestUtil {
-    private static final ConditionVariable sHostResolverBlock = new ConditionVariable();
-
     static final String SDCH_FAKE_HOST = "fake.sdch.domain";
     // QUIC test domain must match the certificate used
     // (quic_test.example.com.crt and quic_test.example.com.key.pkcs8), and
     // the file served (
     // components/cronet/android/test/assets/test/quic_data/simple.txt).
     static final String QUIC_FAKE_HOST = "test.example.com";
     private static final String[] TEST_DOMAINS = {SDCH_FAKE_HOST, QUIC_FAKE_HOST};
     private static final String LOOPBACK_ADDRESS = "127.0.0.1";
 
     /**
@@ skipping 20 matching lines @@
      */
     public static JSONObject generateHostResolverRules(String destination) throws JSONException {
         StringBuilder rules = new StringBuilder();
         for (String domain : TEST_DOMAINS) {
             rules.append("MAP " + domain + " " + destination + ",");
         }
         return new JSONObject().put("host_resolver_rules", rules);
     }
 
     /**
+     * Prepare {@code cronetEngine}'s network thread so libcronet_test code can run on it.
+     */
+    public static class NetworkThreadTestConnector {
+        private final CronetUrlRequestContext mRequestContext;
+
+        public NetworkThreadTestConnector(CronetEngine cronetEngine) {
+            mRequestContext = (CronetUrlRequestContext) cronetEngine;
+            nativePrepareNetworkThread(mRequestContext.getUrlRequestContextAdapter());
+        }
+
+        public void shutdown() {
+            nativeCleanupNetworkThread(mRequestContext.getUrlRequestContextAdapter());
+        }
+    }
+
+    /**
      * Returns the value of load flags in |urlRequest|.
      * @param urlRequest is the UrlRequest object of interest.
      */
     public static int getLoadFlags(UrlRequest urlRequest) {
         return nativeGetLoadFlags(((CronetUrlRequest) urlRequest).getUrlRequestAdapterForTesting());
     }
 
     public static void setMockCertVerifierForTesting(
             ExperimentalCronetEngine.Builder builder, long mockCertVerifier) {
         getCronetEngineBuilderImpl(builder).setMockCertVerifierForTesting(mockCertVerifier);
     }
 
-    public static void setLibraryName(ExperimentalCronetEngine.Builder builder, String libName) {
-        getCronetEngineBuilderImpl(builder).setLibraryName(libName);
-    }
-
     public static CronetEngineBuilderImpl getCronetEngineBuilderImpl(
             ExperimentalCronetEngine.Builder builder) {
         return (CronetEngineBuilderImpl) builder.getBuilderDelegate();
     }
 
-    private static native int nativeGetLoadFlags(long urlRequest);
+    private static native int nativeGetLoadFlags(long urlRequestAdapter);
+
+    private static native void nativePrepareNetworkThread(long contextAdapter);
+    private static native void nativeCleanupNetworkThread(long contextAdapter);
 }