add trivial implementation of ServerConnector#close

core/src/main/java/net/luminis/quic/QuicConnection.java

@@ -21,8 +21,7 @@
 import java.time.Duration;
 import java.util.function.Consumer;
 
-
-public interface QuicConnection {
+public interface QuicConnection extends AutoCloseable {
 
     enum QuicVersion {
         V1,

core/src/main/java/net/luminis/quic/cid/ConnectionIdManager.java

@@ -133,6 +133,9 @@ public void registerAdditionalConnectionId(byte[] currentConnectionId, byte[] ne
 
             @Override
             public void deregisterConnectionId(byte[] connectionId) {}
+
+            @Override
+            public void close() {}
         };
     }
 

core/src/main/java/net/luminis/quic/server/ServerConnectionRegistry.java

@@ -20,7 +20,7 @@
 
 import net.luminis.quic.server.impl.ServerConnectionProxy;
 
-public interface ServerConnectionRegistry {
+public interface ServerConnectionRegistry extends AutoCloseable {
 
     void registerConnection(ServerConnectionProxy connection, byte[] connectionId);
 

core/src/main/java/net/luminis/quic/server/ServerConnector.java

@@ -33,7 +33,7 @@
 /**
  * Listens for QUIC connections on a given port. Requires server certificate and corresponding private key.
  */
-public interface ServerConnector {
+public interface ServerConnector extends AutoCloseable {
 
     void registerApplicationProtocol(String protocol, ApplicationProtocolConnectionFactory protocolConnectionFactory);
 

core/src/main/java/net/luminis/quic/server/impl/ServerConnectionProxy.java

@@ -22,7 +22,6 @@
 import java.nio.ByteBuffer;
 import java.time.Instant;
 
-
 public interface ServerConnectionProxy {
 
     byte[] getOriginalDestinationConnectionId();

core/src/main/java/net/luminis/quic/server/impl/ServerConnectionRegistryImpl.java

@@ -99,7 +99,7 @@ boolean isEmpty() {
     }
 
     /**
-     * Logs the entire connection table. For debugging purposed only.
+     * Logs the entire connection table. For debugging purposes only.
      */
     void logConnectionTable() {
         log.info("Connection table: \n" +
@@ -114,4 +114,11 @@ public int compare(Map.Entry<ConnectionSource, ServerConnectionProxy> o1, Map.En
                         .collect(Collectors.joining("\n")));
 
     }
+
+    @Override
+    public void close() {
+        for (ServerConnectionProxy proxy : currentConnections.values()) {
+            proxy.dispose();
+        }
+    }
 }

core/src/main/java/net/luminis/quic/server/impl/ServerConnectorImpl.java

@@ -53,6 +53,7 @@
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 /**
@@ -323,12 +324,28 @@ private void sendVersionNegotiationPacket(InetSocketAddress clientAddress, ByteB
             }
         }
     }
-
+
+    @Override
+    public void close() throws InterruptedException {
+        sharedScheduledExecutor.shutdown();
+        sharedExecutor.shutdown();
+
+        connectionRegistry.close();
+        serverSocket.close();
+
+        if (!sharedScheduledExecutor.awaitTermination(10, TimeUnit.SECONDS)) {
+            sharedScheduledExecutor.shutdownNow();
+        }
+        if (!sharedExecutor.awaitTermination(10, TimeUnit.SECONDS)) {
+            sharedExecutor.shutdownNow();
+        }
+    }
+
     private void closed(ServerConnectionImpl connection) {
         ServerConnectionProxy removedConnection = connectionRegistry.removeConnection(connection);
         removedConnection.dispose();
     }
-
+    
     private class ServerConnectorContext implements Context {
 
         @Override