core: pending timers should keep broker alive.

pull/607/head
David Wilson 7 years ago
parent 237a3babaf
commit 4f0a946f30

@ -2973,7 +2973,7 @@ class Broker(object):
progress (e.g. log draining).
"""
it = (side.keep_alive for (_, (side, _)) in self.poller.readers)
return sum(it, 0)
return sum(it, 0) > 0 or self.timers.get_timeout() is not None
def defer_sync(self, func):
"""

Loading…
Cancel
Save