|
@@ -220,6 +220,9 @@ class Supervisor:
|
|
|
'read event caused by %(dispatcher)r',
|
|
|
dispatcher=dispatcher)
|
|
|
dispatcher.handle_read_event()
|
|
|
+ if (not dispatcher.readable()
|
|
|
+ and not dispatcher.writable()):
|
|
|
+ self.options.poller.unregister(fd)
|
|
|
except asyncore.ExitNow:
|
|
|
raise
|
|
|
except:
|
|
@@ -233,6 +236,9 @@ class Supervisor:
|
|
|
'write event caused by %(dispatcher)r',
|
|
|
dispatcher=dispatcher)
|
|
|
dispatcher.handle_write_event()
|
|
|
+ if (not dispatcher.readable()
|
|
|
+ and not dispatcher.writable()):
|
|
|
+ self.options.poller.unregister(fd)
|
|
|
except asyncore.ExitNow:
|
|
|
raise
|
|
|
except:
|