parent
c467cf0274
commit
2b44fac4ec
|
@ -359,6 +359,9 @@ class IOStream(object):
|
||||||
raise IOError("Stream is closed")
|
raise IOError("Stream is closed")
|
||||||
|
|
||||||
def _add_io_state(self, state):
|
def _add_io_state(self, state):
|
||||||
|
if socket is None:
|
||||||
|
# connection has been closed, so there can be no future events
|
||||||
|
return
|
||||||
if not self._state & state:
|
if not self._state & state:
|
||||||
self._state = self._state | state
|
self._state = self._state | state
|
||||||
self.io_loop.update_handler(self.socket.fileno(), self._state)
|
self.io_loop.update_handler(self.socket.fileno(), self._state)
|
||||||
|
|
Loading…
Reference in New Issue