Skip to content

Commit 20e47d8

Browse files
committed
Merge pull request #589 from hathawsh/master
Unregister file descriptors when streams close.
2 parents ce75399 + 5e345e7 commit 20e47d8

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

supervisor/supervisord.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -220,6 +220,9 @@ def runforever(self):
220220
'read event caused by %(dispatcher)r',
221221
dispatcher=dispatcher)
222222
dispatcher.handle_read_event()
223+
if (not dispatcher.readable()
224+
and not dispatcher.writable()):
225+
self.options.poller.unregister(fd)
223226
except asyncore.ExitNow:
224227
raise
225228
except:
@@ -233,6 +236,9 @@ def runforever(self):
233236
'write event caused by %(dispatcher)r',
234237
dispatcher=dispatcher)
235238
dispatcher.handle_write_event()
239+
if (not dispatcher.readable()
240+
and not dispatcher.writable()):
241+
self.options.poller.unregister(fd)
236242
except asyncore.ExitNow:
237243
raise
238244
except:

0 commit comments

Comments
 (0)