Fix up leaky alloctions.

Author: koush

AndroidAsync/AndroidAsync-AndroidAsync.iml

@@ -37,22 +37,22 @@
       <sourceFolder url="file://$MODULE_DIR$/build/generated/res/rs/test/debug" type="java-test-resource" />
       <sourceFolder url="file://$MODULE_DIR$/src/debug/res" type="java-resource" />
       <sourceFolder url="file://$MODULE_DIR$/src/debug/resources" type="java-resource" />
+      <sourceFolder url="file://$MODULE_DIR$/src/debug/assets" type="java-resource" />
       <sourceFolder url="file://$MODULE_DIR$/src/debug/aidl" isTestSource="false" />
-      <sourceFolder url="file://$MODULE_DIR$/src/debug/assets" isTestSource="false" />
       <sourceFolder url="file://$MODULE_DIR$/src/debug/java" isTestSource="false" />
       <sourceFolder url="file://$MODULE_DIR$/src/debug/jni" isTestSource="false" />
       <sourceFolder url="file://$MODULE_DIR$/src/debug/rs" isTestSource="false" />
       <sourceFolder url="file://$MODULE_DIR$/src/main/res" type="java-resource" />
       <sourceFolder url="file://$MODULE_DIR$/src/main/resources" type="java-resource" />
+      <sourceFolder url="file://$MODULE_DIR$/src/main/assets" type="java-resource" />
       <sourceFolder url="file://$MODULE_DIR$/src/main/aidl" isTestSource="false" />
-      <sourceFolder url="file://$MODULE_DIR$/src/main/assets" isTestSource="false" />
       <sourceFolder url="file://$MODULE_DIR$/src" isTestSource="false" />
       <sourceFolder url="file://$MODULE_DIR$/src/main/jni" isTestSource="false" />
       <sourceFolder url="file://$MODULE_DIR$/src/main/rs" isTestSource="false" />
       <sourceFolder url="file://$MODULE_DIR$/test/res" type="java-test-resource" />
       <sourceFolder url="file://$MODULE_DIR$/src/androidTest/resources" type="java-test-resource" />
+      <sourceFolder url="file://$MODULE_DIR$/test/assets" type="java-test-resource" />
       <sourceFolder url="file://$MODULE_DIR$/src/androidTest/aidl" isTestSource="true" />
-      <sourceFolder url="file://$MODULE_DIR$/test/assets" isTestSource="true" />
       <sourceFolder url="file://$MODULE_DIR$/test/src" isTestSource="true" />
       <sourceFolder url="file://$MODULE_DIR$/src/androidTest/jni" isTestSource="true" />
       <sourceFolder url="file://$MODULE_DIR$/src/androidTest/rs" isTestSource="true" />

AndroidAsync/src/com/koushikdutta/async/AsyncNetworkSocket.java

@@ -174,6 +174,9 @@ int onReadable() {
                 pending.add(b);
                 Util.emitAllData(this, pending);
             }
+            else {
+                ByteBufferList.reclaim(b);
+            }
 
             if (closed) {
                 reportEndPending(null);

AndroidAsync/src/com/koushikdutta/async/AsyncSSLSocketWrapper.java

@@ -388,10 +388,8 @@ public void write(ByteBufferList bb) {
             // if the handshake is finished, don't send
             // 0 bytes of data, since that makes the ssl connection die.
             // it wraps a 0 byte package, and craps out.
-            if (finishedHandshake && bb.remaining() == 0) {
-                mWrapping = false;
-                return;
-            }
+            if (finishedHandshake && bb.remaining() == 0)
+                break;
             remaining = bb.remaining();
             try {
                 ByteBuffer[] arr = bb.getAllArray();
@@ -417,6 +415,7 @@ public void write(ByteBufferList bb) {
         while ((remaining != bb.remaining() || (res != null && res.getHandshakeStatus() == HandshakeStatus.NEED_WRAP)) && mSink.remaining() == 0);
         ByteBufferList.reclaim(mWriteTmp);
         mWrapping = false;
+        ByteBufferList.reclaim(writeBuf);
     }
 
     @Override

AndroidAsync/src/com/koushikdutta/async/http/ResponseCacheMiddleware.java

@@ -416,10 +416,12 @@ void spewInternal() {
                 FileInputStream din = cacheResponse.getBody();
                 int read = din.read(buffer.array(), buffer.arrayOffset(), buffer.capacity());
                 if (read == -1) {
+                    ByteBufferList.reclaim(buffer);
                     allowEnd = true;
                     report(null);
                     return;
                 }
+                allocator.track(read);
                 buffer.limit(read);
                 pending.add(buffer);
             }

AndroidAsync/src/com/koushikdutta/async/http/filter/InflaterInputFilter.java

@@ -36,8 +36,7 @@ public void onDataAvailable(DataEmitter emitter, ByteBufferList bb) {
                         int inflated = mInflater.inflate(output.array(), output.arrayOffset() + output.position(), output.remaining());
                         output.position(output.position() + inflated);
                         if (!output.hasRemaining()) {
-                            output.limit(output.position());
-                            output.position(0);
+                            output.flip();
                             transformed.add(output);
                             assert totalRead != 0;
                             int newSize = output.capacity() * 2;
@@ -48,8 +47,7 @@ public void onDataAvailable(DataEmitter emitter, ByteBufferList bb) {
                 }
                 ByteBufferList.reclaim(b);
             }
-            output.limit(output.position());
-            output.position(0);
+            output.flip();
             transformed.add(output);
 
             Util.emitAllData(this, transformed);