close connections in parallel, more shutdown fixes

core/src/main/groovy/com/muwire/core/Core.groovy

@@ -234,9 +234,13 @@ public class Core {
     }
     
     public void shutdown() {
+        log.info("shutting down connection manager")
         connectionManager.shutdown()
+        log.info("shutting down download manageer")
         downloadManager.shutdown()
+        log.info("shutting down connection acceeptor")
         connectionAcceptor.stop()
+        log.info("shutting down connection establisher")
         connectionEstablisher.stop()
     }
 

core/src/main/groovy/com/muwire/core/connection/Connection.groovy

@@ -76,9 +76,9 @@ abstract class Connection implements Closeable {
 			return
 		}
         log.info("closing $name")
-        endpoint.close()
 		reader.interrupt()
 		writer.interrupt()
+		endpoint.close()
 		eventBus.publish(new DisconnectionEvent(destination: endpoint.destination))
 	}
 	

core/src/main/groovy/com/muwire/core/connection/UltrapeerConnectionManager.groovy

@@ -104,8 +104,8 @@ class UltrapeerConnectionManager extends ConnectionManager {
     
     @Override
     void shutdown() {
-        peerConnections.each {k,v -> v.close() }
+        peerConnections.values().stream().parallel().forEach({v -> v.close()})
-        leafConnections.each {k,v -> v.close() }
+        leafConnections.values().stream().parallel().forEach({v -> v.close()})
         peerConnections.clear()
         leafConnections.clear()
     }

core/src/main/groovy/com/muwire/core/download/DownloadManager.groovy

@@ -138,5 +138,6 @@ public class DownloadManager {
     
     public void shutdown() {
         downloaders.each { it.stop() }
+        Downloader.executorService.shutdownNow()
     }
 }