|
|
@ -2801,7 +2801,7 @@ class Waker(Protocol):
|
|
|
|
self.stream.transmit_side.write(b(' '))
|
|
|
|
self.stream.transmit_side.write(b(' '))
|
|
|
|
except OSError:
|
|
|
|
except OSError:
|
|
|
|
e = sys.exc_info()[1]
|
|
|
|
e = sys.exc_info()[1]
|
|
|
|
if e.args[0] in (errno.EBADF, errno.EWOULDBLOCK):
|
|
|
|
if e.args[0] not in (errno.EBADF, errno.EWOULDBLOCK):
|
|
|
|
raise
|
|
|
|
raise
|
|
|
|
|
|
|
|
|
|
|
|
broker_shutdown_msg = (
|
|
|
|
broker_shutdown_msg = (
|
|
|
|