Commit ead67de8 authored by David Wilson's avatar David Wilson

core: make Side.write() return None rather than crash if side already closed.

parent 74b31bbe
......@@ -483,6 +483,9 @@ class Side(object):
return s
def write(self, s):
if self.fd is None:
return None
written, disconnected = io_op(os.write, self.fd, s[:CHUNK_SIZE])
if disconnected:
return None
......@@ -613,7 +616,7 @@ class Stream(BasicStream):
written = self.transmit_side.write(self._output_buf)
if written is None:
LOG.debug('%r.on_transmit(): disconnection detected', self)
self.on_disconnect()
self.on_disconnect(broker)
return
IOLOG.debug('%r.on_transmit() -> len %d', self, written)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment