From ec2565679a41a9e071ddebb48c3113227aa1bc89 Mon Sep 17 00:00:00 2001
From: Neil Booth <kyuupichan@gmail.com>
Date: Thu, 12 Apr 2018 21:43:25 +0800
Subject: [PATCH] Force close stale sessions that aren't closing

---
 server/controller.py | 2 +-
 server/peers.py      | 1 -
 2 files changed, 1 insertion(+), 2 deletions(-)

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)