diff --git a/server/controller.py b/server/controller.py
index dfc37d8..ce40e4a 100644
--- a/server/controller.py
+++ b/server/controller.py
@@ -369,7 +369,7 @@ class Controller(ServerBase):
         stale = []
         for session in self.sessions:
             if session.is_closing():
-                pass
+                session.abort()
             elif session.last_recv < stale_cutoff:
                 self.close_session(session)
                 stale.append(session.session_id)
diff --git a/server/peers.py b/server/peers.py
index c5fec84..c7a6a96 100644
--- a/server/peers.py
+++ b/server/peers.py
@@ -42,7 +42,6 @@ class PeerSession(ClientSession):
         self.logger = ConnectionLogger(self.logger, context)
 
     def connection_made(self, transport):
-        '''Handle an incoming client connection.'''
         super().connection_made(transport)
         self.sessions.add(self)