Initial implementation of CronetBidirectionalStream.

components/cronet/android/test/javatests/src/org/chromium/net/CronetTestBase.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.AndroidTestCase;
 
 import org.chromium.base.PathUtils;
 
@@ skipping 116 matching lines @@
                     // For all other tests.
                     super.runTest();
                 }
             } catch (Throwable e) {
                 throw new Throwable("CronetTestBase#runTest failed.", e);
             }
         } else if (packageName.equals("org.chromium.net")) {
             try {
                 Method method = getClass().getMethod(getName(), (Class[]) null);
                 super.runTest();
-                if (!method.isAnnotationPresent(OnlyRunNativeCronet.class)) {
+                if (!getClass().isAnnotationPresent(OnlyRunNativeCronet.class)

[pauljensen, 2016/01/19 16:03:41]

Charles wanted to avoid this as it makes it too easy to make changes just for
the native impl.  I somewhat agree with him, and accept that it will require
adding lots of annotations, one for each test in the case of this CL.

[mef, 2016/01/20 15:37:41]

Done. We'll also need another annotation 'RunQuicAndHttp2' at some point.

+                        && !method.isAnnotationPresent(OnlyRunNativeCronet.class)) {
                     if (mCronetTestFramework != null) {
                         mCronetTestFramework.mCronetEngine =
                                 new JavaCronetEngine(UserAgent.from(getContext()));
                     }
                     mTestingJavaImpl = true;
                     super.runTest();
                 }
             } catch (Throwable e) {
                 throw new Throwable("CronetTestBase#runTest failed.", e);
             }
@@ skipping 20 matching lines @@
             urlRequestContextAdapter = ((ChromiumUrlRequestFactory) framework.mRequestFactory)
                                                .getRequestContext()
                                                .getUrlRequestContextAdapter();
         } else {
             urlRequestContextAdapter = ((CronetUrlRequestContext) framework.mCronetEngine)
                                                .getUrlRequestContextAdapter();
         }
         NativeTestServer.registerHostResolverProc(urlRequestContextAdapter, isLegacyAPI);
     }
 
+    void assertResponseEquals(UrlResponseInfo expected, UrlResponseInfo actual) {
+        assertEquals(expected.getAllHeaders(), actual.getAllHeaders());
+        assertEquals(expected.getAllHeadersAsList(), actual.getAllHeadersAsList());
+        assertEquals(expected.getHttpStatusCode(), actual.getHttpStatusCode());
+        assertEquals(expected.getHttpStatusText(), actual.getHttpStatusText());
+        assertEquals(expected.getUrlChain(), actual.getUrlChain());
+        assertEquals(expected.getUrl(), actual.getUrl());
+        // Transferred bytes and proxy server are not supported in pure java
+        if (!(mCronetTestFramework.mCronetEngine instanceof JavaCronetEngine)) {
+            assertEquals(expected.getReceivedBytesCount(), actual.getReceivedBytesCount());
+            assertEquals(expected.getProxyServer(), actual.getProxyServer());
+            // This is a place where behavior intentionally differs between native and java
+            assertEquals(expected.getNegotiatedProtocol(), actual.getNegotiatedProtocol());
+        }
+    }
+
     @Target(ElementType.METHOD)
     @Retention(RetentionPolicy.RUNTIME)
     public @interface CompareDefaultWithCronet {
     }
 
     @Target(ElementType.METHOD)
     @Retention(RetentionPolicy.RUNTIME)
     public @interface OnlyRunCronetHttpURLConnection {
     }
 
-    @Target(ElementType.METHOD)
+    @Target({ElementType.TYPE, ElementType.METHOD})
     @Retention(RetentionPolicy.RUNTIME)
     public @interface OnlyRunNativeCronet {}
 }