ready for integration in a better ASAPAndroid release.

Author: thsc42

src/net/sharksystem/asap/internals/ASAPConnectionHandler.java renamed to src/net/sharksystem/asap/ASAPConnectionHandler.java

@@ -1,4 +1,4 @@
-package net.sharksystem.asap.internals;
+package net.sharksystem.asap;
 
 import net.sharksystem.asap.ASAPException;
 import net.sharksystem.asap.protocol.ASAPConnection;

src/net/sharksystem/asap/ASAPInternalPeerWrapper.java

@@ -2,6 +2,7 @@
 
 import net.sharksystem.asap.internals.ASAPInternalOnlinePeersChangedListener;
 import net.sharksystem.asap.internals.ASAPInternalPeer;
+import net.sharksystem.asap.protocol.ASAPConnection;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -29,8 +30,8 @@ public CharSequence getPeerName() {
         return this.peer.getOwner();
     }
 
-    public void handleConnection(InputStream is, OutputStream os) throws IOException, ASAPException {
-        this.peer.handleConnection(is, os);
+    public ASAPConnection handleConnection(InputStream is, OutputStream os) throws IOException, ASAPException {
+        return this.peer.handleConnection(is, os);
     }
 
     @Override

src/net/sharksystem/asap/ASAPPeerService.java

@@ -7,10 +7,9 @@
 import java.io.InputStream;
 import java.io.OutputStream;
 
-public interface ASAPPeerService extends ASAPPeer {
-    long DEFAULT_MAX_PROCESSING_TIME = ASAPInternalPeer.DEFAULT_MAX_PROCESSING_TIME;
-
-    void handleConnection(InputStream is, OutputStream os) throws IOException, ASAPException;
+public interface ASAPPeerService extends ASAPPeer, ASAPConnectionHandler {
+    //    long DEFAULT_MAX_PROCESSING_TIME = 30000; // 30 seconds
+    long DEFAULT_MAX_PROCESSING_TIME = Long.MAX_VALUE; // eternity - debugging setting
 
     /**
      * Overwrite internal listener. This method is used e.g. in Androiud on service side. The asap peer is informed

src/net/sharksystem/asap/apps/testsupport/ASAPPeerWrapperMock.java

@@ -6,6 +6,7 @@
 import net.sharksystem.asap.internals.ASAPChunkReceivedListener;
 import net.sharksystem.asap.ASAPException;
 import net.sharksystem.asap.internals.ASAPMessages;
+import net.sharksystem.asap.protocol.ASAPConnection;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -125,7 +126,7 @@ public CharSequence getPeerName() {
     }
 
     @Override
-    public void handleConnection(InputStream is, OutputStream os) throws IOException, ASAPException {
+    public ASAPConnection handleConnection(InputStream is, OutputStream os) throws IOException, ASAPException {
         throw new ASAPException("that's a mock, no real peer");
     }
 

src/net/sharksystem/asap/internals/ASAPInternalPeer.java

@@ -1,5 +1,6 @@
 package net.sharksystem.asap.internals;
 
+import net.sharksystem.asap.ASAPConnectionHandler;
 import net.sharksystem.asap.ASAPException;
 import net.sharksystem.asap.ASAPSecurityException;
 import net.sharksystem.asap.protocol.*;

src/net/sharksystem/asap/util/ASAPPeerHandleConnectionThread.java

@@ -4,7 +4,7 @@
 import java.io.InputStream;
 import java.io.OutputStream;
 
-import net.sharksystem.asap.internals.ASAPConnectionHandler;
+import net.sharksystem.asap.ASAPConnectionHandler;
 import net.sharksystem.asap.ASAPException;
 
 /**