[Cronet] Change interface APIs to abstract classes

components/cronet/android/java/src/org/chromium/net/urlconnection/CronetFixedModeOutputStream.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.base.VisibleForTesting;
+import org.chromium.net.UploadDataProvider;
 import org.chromium.net.UploadDataSink;
 
 import java.io.IOException;
 import java.net.HttpRetryException;
 import java.net.ProtocolException;
 import java.nio.ByteBuffer;
 
 /**
  * An implementation of {@link java.io.OutputStream} to send data to a server,
  * when {@link CronetHttpURLConnection#setFixedLengthStreamingMode} is used.
  * This implementation does not buffer the entire request body in memory.
  * It does not support rewind. Note that {@link #write} should only be called
  * from the thread on which the {@link #mConnection} is created.
  */
 final class CronetFixedModeOutputStream extends CronetOutputStream {
     // CronetFixedModeOutputStream buffers up to this value and wait for UploadDataStream
     // to consume the data. This field is non-final, so it can be changed for tests.
     // Using 2048 bytes is because the internal read buffer is 14520 for QUIC,
     // 2852 for SPDY, and 16384 for normal stream. If a large value is used
     // here, the buffer might not fit the internal buffer and compacting the buffer
     // will be costly, see #read method below.
     @VisibleForTesting
     private static int sDefaultBufferLength = 2048;
     private final CronetHttpURLConnection mConnection;
     private final MessageLoop mMessageLoop;
     private final long mContentLength;
     private final ByteBuffer mBuffer;
+    private final UploadDataProvider mUploadDataProvider = new UploadDataProviderImpl();
     private long mBytesWritten;
 
     /**
      * Package protected constructor.
      * @param connection The CronetHttpURLConnection object.
      * @param contentLength The content length of the request body. Non-zero for
      *            non-chunked upload.
      */
     CronetFixedModeOutputStream(CronetHttpURLConnection connection,
             long contentLength, MessageLoop messageLoop) {
@@ skipping 77 matching lines @@
     }
 
     @Override
     void checkReceivedEnoughContent() throws IOException {
         if (mBytesWritten < mContentLength) {
             throw new ProtocolException("Content received is less than Content-Length.");
         }
     }
 
     @Override
-    public long getLength() {
-        return mContentLength;
+    UploadDataProvider getUploadDataProvider() {
+        return mUploadDataProvider;
     }
 
-    @Override
-    public void read(final UploadDataSink uploadDataSink, final ByteBuffer byteBuffer) {
-        int availableSpace = byteBuffer.capacity() - byteBuffer.position();
-        if (availableSpace < mBuffer.position()) {
-            // byteBuffer does not have enough capacity, so only put a portion
-            // of mBuffer in it.
-            byteBuffer.put(mBuffer.array(), 0, availableSpace);
-            mBuffer.position(availableSpace);
-            // Move remaining buffer to the head of the buffer for use in the
-            // next read call.
-            mBuffer.compact();
-        } else {
-            // byteBuffer has enough capacity to hold the content of mBuffer.
-            mBuffer.flip();
-            byteBuffer.put(mBuffer);
-            // Reuse this buffer.
-            mBuffer.clear();
-            // Quit message loop so embedder can write more data.
-            mMessageLoop.quit();
+    private class UploadDataProviderImpl extends UploadDataProvider {
+        @Override
+        public long getLength() {
+            return mContentLength;
         }
-        uploadDataSink.onReadSucceeded(false);
-    }
 
-    @Override
-    public void rewind(UploadDataSink uploadDataSink) {
-        uploadDataSink.onRewindError(new HttpRetryException(
-                "Cannot retry streamed Http body", -1));
+        @Override
+        public void read(final UploadDataSink uploadDataSink, final ByteBuffer byteBuffer) {
+            int availableSpace = byteBuffer.capacity() - byteBuffer.position();
+            if (availableSpace < mBuffer.position()) {
+                // byteBuffer does not have enough capacity, so only put a portion
+                // of mBuffer in it.
+                byteBuffer.put(mBuffer.array(), 0, availableSpace);
+                mBuffer.position(availableSpace);
+                // Move remaining buffer to the head of the buffer for use in the
+                // next read call.
+                mBuffer.compact();
+            } else {
+                // byteBuffer has enough capacity to hold the content of mBuffer.
+                mBuffer.flip();
+                byteBuffer.put(mBuffer);
+                // Reuse this buffer.
+                mBuffer.clear();
+                // Quit message loop so embedder can write more data.
+                mMessageLoop.quit();
+            }
+            uploadDataSink.onReadSucceeded(false);
+        }
+
+        @Override
+        public void rewind(UploadDataSink uploadDataSink) {
+            uploadDataSink.onRewindError(
+                    new HttpRetryException("Cannot retry streamed Http body", -1));
+        }
     }
 
     /**
      * Sets the default buffer length for use in tests.
      */
     @VisibleForTesting
     static void setDefaultBufferLengthForTesting(int length) {
         sDefaultBufferLength = length;
     }
 }