|
|
@ -915,11 +915,11 @@ class Broker(object):
|
|
|
|
rsides, wsides, _ = select.select(self._readers, self._writers,
|
|
|
|
rsides, wsides, _ = select.select(self._readers, self._writers,
|
|
|
|
(), timeout)
|
|
|
|
(), timeout)
|
|
|
|
for side in rsides:
|
|
|
|
for side in rsides:
|
|
|
|
IOLOG.debug('%r: POLLIN for %r', self, side.stream)
|
|
|
|
IOLOG.debug('%r: POLLIN for %r', self, side)
|
|
|
|
self._call(side.stream, side.stream.on_receive)
|
|
|
|
self._call(side.stream, side.stream.on_receive)
|
|
|
|
|
|
|
|
|
|
|
|
for side in wsides:
|
|
|
|
for side in wsides:
|
|
|
|
IOLOG.debug('%r: POLLOUT for %r', self, side.stream)
|
|
|
|
IOLOG.debug('%r: POLLOUT for %r', self, side)
|
|
|
|
self._call(side.stream, side.stream.on_transmit)
|
|
|
|
self._call(side.stream, side.stream.on_transmit)
|
|
|
|
|
|
|
|
|
|
|
|
def keep_alive(self):
|
|
|
|
def keep_alive(self):
|
|
|
|