working on Bluetooth problem: Switching off BT doesn't kill BT sockets - quite weird

Author: thsc42

app/libs/ASAP_Engine_0.5.0.jar

@@ -322,9 +322,11 @@ public void setOnlinePeersList(List<CharSequence> peerList) {
 
         Log.d(this.getLogStart(), sb.toString());
         if(onlinePeerList.size() < peerList.size()) {
-            Toast.makeText(this.getActivity(), "new online connections", Toast.LENGTH_SHORT);
+            Toast.makeText(this.getActivity(),
+                    "new online connections", Toast.LENGTH_SHORT).show();
         } else {
-            Toast.makeText(this.getActivity(), "online connections changed", Toast.LENGTH_SHORT);
+            Toast.makeText(this.getActivity(),
+                    "online connections changed", Toast.LENGTH_SHORT).show();
         }
 
         this.onlinePeerList = peerList;

app/src/main/java/net/sharksystem/asap/android/apps/ASAPApplication.java

@@ -10,7 +10,6 @@
 import android.util.Log;
 
 import net.sharksystem.asap.ASAPException;
-import net.sharksystem.asap.android.service.ASAPConnectionLauncher;
 import net.sharksystem.asap.android.service.MacLayerEngine;
 import net.sharksystem.asap.android.service.ASAPService;
 import net.sharksystem.asap.android.Util;
@@ -165,6 +164,44 @@ private void setup() {
                         ASAPServiceRequestNotifyIntent.ASAP_NOTIFY_BT_ENVIRONMENT_STARTED));
     }
 
+
+    void acceptServerSocketKilled() {
+        Log.d(this.getLogStart(), "was told accept socket died - shutdown");
+        // server socket was killed - that most probably because BT was switched off by users
+        try {
+            this.shutdown();
+        } catch (ASAPException e) {
+            Log.d(this.getLogStart(), "problems with shutdown: " + e.getLocalizedMessage());
+        }
+
+        /* BT on Android shows that weired behaviour that process can write into a BT socket
+        even when BT is off. That's impossible - but kill all sockets they are only zombies
+         */
+
+        for(BluetoothSocket socket : this.openSockets.values()) {
+            String name = "no remote Device";
+            String address = name;
+            BluetoothDevice remoteDevice = socket.getRemoteDevice();
+            if( remoteDevice != null) {
+                name = remoteDevice.getName();
+                address = remoteDevice.getAddress();
+            }
+
+            Log.d(this.getLogStart(), "kill zombie socket "
+                    + "name: " + name
+                    + " | address: " + address
+                    + " | isConnected: " + socket.isConnected());
+            try {
+                socket.getInputStream().close();
+                socket.getOutputStream().close();
+            } catch (IOException e) {
+                Log.d(this.getLogStart(), "could not close");
+            }
+        }
+
+        this.openSockets = new HashMap<>();
+    }
+
     public void startDiscoverable() {
         this.startDiscoverable(BluetoothEngine.DEFAULT_VISIBILITY_TIME);
     }
@@ -301,9 +338,7 @@ synchronized void handleBTSocket(BluetoothSocket socket) throws IOException {
         // remember that new connection
         this.openSockets.put(address, socket);
 
-        // set up new ASAP Session on that connection
-        new ASAPConnectionLauncher(socket.getInputStream(), socket.getOutputStream(),
-                this.getAsapService().getASAPEngine()).start();
+        this.launchASAPConnection(address, socket.getInputStream(), socket.getOutputStream());
     }
 
     public void propagateStatus(Context ctx) throws ASAPException {

app/src/main/java/net/sharksystem/asap/android/bluetooth/BluetoothEngine.java

@@ -51,6 +51,8 @@ public void run() {
                 this.btEngine.handleBTSocket(socket);
             } catch (IOException e) {
                 Log.d(this.getLogStart(), "Socket's accept() method failed", e);
+                // tell engine
+                this.btEngine.acceptServerSocketKilled();
                 break;
             }
         }

app/src/main/java/net/sharksystem/asap/android/bluetooth/BluetoothServerSocketThread.java

@@ -3,6 +3,10 @@
 import android.content.Context;
 import android.util.Log;
 
+import net.sharksystem.asap.MultiASAPEngineFS;
+
+import java.io.InputStream;
+import java.io.OutputStream;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
@@ -96,4 +100,15 @@ public boolean shouldConnectToMACPeer(String macAddress) {
     private String getLogStart() {
         return "ASAPMacLayerEngine";
     }
+
+    protected void launchASAPConnection(
+            String address, InputStream inputStream, OutputStream outputStream) {
+
+        // set up new ASAP Session on that connection
+        ASAPConnectionLauncher asapConnectionLauncher =
+                new ASAPConnectionLauncher(
+                        inputStream, outputStream, this.getAsapService().getASAPEngine());
+
+        asapConnectionLauncher.start();
+    }
 }