Force close stale sessions that aren't closing

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)

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)