[Cronet] Check whether request is done before spinning up message loop

components/cronet/android/java/src/org/chromium/net/urlconnection/CronetBufferedOutputStream.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.urlconnection;
 
 import org.chromium.net.UploadDataProvider;
 import org.chromium.net.UploadDataSink;
 
 import java.io.IOException;
@@ skipping 53 matching lines @@
         }
 
         mConnection = connection;
         mInitialContentLength = -1;
         // Buffering without knowing content-length.
         mBuffer = ByteBuffer.allocate(INITIAL_BUFFER_SIZE);
     }
 
     @Override
     public void write(int oneByte) throws IOException {
+        checkNotClosed();
         ensureCanWrite(1);
         mBuffer.put((byte) oneByte);
     }
 
     @Override
     public void write(byte[] buffer, int offset, int count) throws IOException {
+        checkNotClosed();
         ensureCanWrite(count);
         mBuffer.put(buffer, offset, count);
     }
 
-    // TODO(xunjieli): implement close().
-
     /**
      * Ensures that {@code count} bytes can be written to the internal buffer.
      */
     private void ensureCanWrite(int count) throws IOException {
         if (mInitialContentLength != -1
                 && mBuffer.position() + count > mInitialContentLength) {
             // Error message is to match that of the default implementation.
             throw new ProtocolException("exceeded content-length limit of "
                     + mInitialContentLength + " bytes");
         }
@@ skipping 68 matching lines @@
             uploadDataSink.onReadSucceeded(false);
         }
 
         @Override
         public void rewind(UploadDataSink uploadDataSink) {
             mBuffer.position(0);
             uploadDataSink.onRewindSucceeded();
         }
     }
 }