broadcast receive fix 3

server/src/main/java/com/usatiuk/dhfs/storage/objects/repository/distributed/peerdiscovery/LocalPeerDiscoveryBroadcaster.java

@@ -37,6 +37,7 @@ public class LocalPeerDiscoveryBroadcaster {
     }
 
     void shutdown(@Observes @Priority(10) ShutdownEvent event) {
+        _socket.close();
         _broadcasterThread.interrupt();
         while (_broadcasterThread.isAlive()) {
             try {
@@ -44,7 +45,6 @@ public class LocalPeerDiscoveryBroadcaster {
             } catch (InterruptedException ignored) {
             }
         }
-
     }
 
     private void broadcast() {

server/src/main/java/com/usatiuk/dhfs/storage/objects/repository/distributed/peerdiscovery/LocalPeerDiscoveryClient.java

@@ -36,8 +36,15 @@ public class LocalPeerDiscoveryClient {
     }
 
     void shutdown(@Observes @Priority(10) ShutdownEvent event) throws InterruptedException {
+        _socket.close();
         _clientThread.interrupt();
-        _clientThread.join();
+        _clientThread.interrupt();
+        while (_clientThread.isAlive()) {
+            try {
+                _clientThread.join();
+            } catch (InterruptedException ignored) {
+            }
+        }
     }
 
     private void client() {