Cronet Fix Channel Write after Close when request is canceled after success.

components/cronet/android/test/javatests/src/org/chromium/cronet_test_apk/TestHttpUrlRequestListener.java

Index: components/cronet/android/test/javatests/src/org/chromium/cronet_test_apk/TestHttpUrlRequestListener.java
diff --git a/components/cronet/android/test/javatests/src/org/chromium/cronet_test_apk/TestHttpUrlRequestListener.java b/components/cronet/android/test/javatests/src/org/chromium/cronet_test_apk/TestHttpUrlRequestListener.java
index de41031af9d1b76722f750b22e2a7483ad5faeda..3e1e6b13880d43fbcdb9ecd5fe2f677c197ddc5e 100644
--- a/components/cronet/android/test/javatests/src/org/chromium/cronet_test_apk/TestHttpUrlRequestListener.java
+++ b/components/cronet/android/test/javatests/src/org/chromium/cronet_test_apk/TestHttpUrlRequestListener.java
@@ -30,6 +30,7 @@ public class TestHttpUrlRequestListener implements HttpUrlRequestListener {
     public Exception mException;
     public Map<String, List<String>> mResponseHeaders;
 
+    private ConditionVariable mStarted = new ConditionVariable();
     private ConditionVariable mComplete = new ConditionVariable();
 
     public TestHttpUrlRequestListener() {
@@ -43,6 +44,7 @@ public class TestHttpUrlRequestListener implements HttpUrlRequestListener {
         mHttpStatusCode = request.getHttpStatusCode();
         mNegotiatedProtocol = request.getNegotiatedProtocol();
         mHttpStatusText = request.getHttpStatusText();
+        mStarted.open();
     }
 
     @Override
@@ -62,8 +64,15 @@ public class TestHttpUrlRequestListener implements HttpUrlRequestListener {
         mResponseAsString = new String(mResponseAsBytes);
         mException = request.getException();
         mComplete.open();
-        Log.i(TAG, "****** Request Complete, status code is "
-                + request.getHttpStatusCode());
+        Log.i(TAG, "****** Request Complete over " + mNegotiatedProtocol
+                + ", status code is " + mHttpStatusCode);
+    }
+
+    /**
+     * Blocks until the request starts.
+     */
+    public void blockForStarted() {
+        mStarted.block();
     }
 
     /**