expose socket object.

fix readString on ByteBufferList.

Change-Id: I07993c7354432d32b25de1e7b9c097c16ac99a4a

Author: koush

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

@@ -1,10 +1,7 @@
 package com.koushikdutta.async;
 
-import android.util.Log;
-
 import java.io.IOException;
 import java.net.InetSocketAddress;
-import java.net.SocketAddress;
 import java.nio.ByteBuffer;
 
 public class AsyncDatagramSocket extends AsyncNetworkSocket {

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

@@ -1,6 +1,7 @@
 package com.koushikdutta.async;
 
 import android.util.Log;
+
 import com.koushikdutta.async.callback.CompletedCallback;
 import com.koushikdutta.async.callback.DataCallback;
 import com.koushikdutta.async.callback.WritableCallback;
@@ -350,4 +351,8 @@ public InetSocketAddress getRemoteAddress() {
     public int getLocalPort() {
         return mChannel.getLocalPort();
     }
+
+    public Object getSocket() {
+        return getChannel().getSocket();
+    }
 }

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

@@ -1,19 +1,29 @@
 package com.koushikdutta.async;
 
 import android.os.Build;
+
 import com.koushikdutta.async.callback.CompletedCallback;
 import com.koushikdutta.async.callback.DataCallback;
 import com.koushikdutta.async.callback.WritableCallback;
 import com.koushikdutta.async.wrapper.AsyncSocketWrapper;
+
 import org.apache.http.conn.ssl.StrictHostnameVerifier;
 
-import javax.net.ssl.*;
-import javax.net.ssl.SSLEngineResult.HandshakeStatus;
-import javax.net.ssl.SSLEngineResult.Status;
 import java.nio.ByteBuffer;
 import java.security.KeyStore;
 import java.security.cert.X509Certificate;
 
+import javax.net.ssl.HostnameVerifier;
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.SSLEngine;
+import javax.net.ssl.SSLEngineResult;
+import javax.net.ssl.SSLEngineResult.HandshakeStatus;
+import javax.net.ssl.SSLEngineResult.Status;
+import javax.net.ssl.SSLException;
+import javax.net.ssl.TrustManager;
+import javax.net.ssl.TrustManagerFactory;
+import javax.net.ssl.X509TrustManager;
+
 public class AsyncSSLSocketWrapper implements AsyncSocketWrapper, AsyncSSLSocket {
     AsyncSocket mSocket;
     BufferedDataEmitter mEmitter;

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

@@ -329,6 +329,7 @@ public String readString() {
             builder.append(new String(bb.array(), bb.arrayOffset() + bb.position(), bb.remaining()));
             reclaim(bb);
         }
+        remaining = 0;
         return builder.toString();
     }
 

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

@@ -47,4 +47,5 @@ public void close() throws IOException {
     }
 
     public abstract int getLocalPort();
+    public abstract Object getSocket();
 }

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

@@ -1,10 +1,7 @@
 package com.koushikdutta.async;
 
-import android.util.Log;
-
 import java.io.IOException;
 import java.net.InetSocketAddress;
-import java.net.SocketAddress;
 import java.nio.ByteBuffer;
 import java.nio.channels.ClosedChannelException;
 import java.nio.channels.DatagramChannel;
@@ -86,4 +83,9 @@ public long read(ByteBuffer[] byteBuffers) throws IOException {
     public long read(ByteBuffer[] byteBuffers, int i, int i2) throws IOException {
         return mChannel.read(byteBuffers, i, i2);
     }
+
+    @Override
+    public Object getSocket() {
+        return mChannel.socket();
+    }
 }

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

@@ -73,4 +73,9 @@ public long read(ByteBuffer[] byteBuffers, int i, int i2) throws IOException {
         assert false;
         throw new IOException(msg);
     }
+
+    @Override
+    public Object getSocket() {
+        return mChannel.socket();
+    }
 }

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

@@ -67,4 +67,9 @@ public long read(ByteBuffer[] byteBuffers) throws IOException {
     public long read(ByteBuffer[] byteBuffers, int i, int i2) throws IOException {
         return mChannel.read(byteBuffers, i, i2);
     }
+
+    @Override
+    public Object getSocket() {
+        return mChannel.socket();
+    }
 }