asyncore: introduce a new 'closed' attribute to make sure that dispatcher gets closed only once.
In different occasions close() might be called more than once, causing problems with already disconnected sockets/dispatchers.
diff --git a/Lib/asyncore.py b/Lib/asyncore.py
index f0712e2..91c629b 100644
--- a/Lib/asyncore.py
+++ b/Lib/asyncore.py
@@ -220,7 +220,7 @@
connected = False
accepting = False
- closing = False
+ closed = False
addr = None
ignore_log_types = frozenset(['warning'])
@@ -393,14 +393,16 @@
raise
def close(self):
- self.connected = False
- self.accepting = False
- self.del_channel()
- try:
- self.socket.close()
- except socket.error as why:
- if why.args[0] not in (ENOTCONN, EBADF):
- raise
+ if not self.closed:
+ self.closed = True
+ self.connected = False
+ self.accepting = False
+ self.del_channel()
+ try:
+ self.socket.close()
+ except socket.error as why:
+ if why.args[0] not in (ENOTCONN, EBADF):
+ raise
# cheap inheritance, used to pass all other attribute
# references to the underlying socket object.