'In testing, the pool.waitall() call very occasionally failed to return.
This is an attempt to make sure the reconstructor finishes its
reconstruction pass in some eventuality.'

def detect_lockups(self):

    while True:
        sleep(self.lockup_timeout)
        if (self.reconstruction_count == self.last_reconstruction_count):
            self.logger.error(_('Lockup    detected..    killing    live    coros.'))
            self.kill_coros()
        self.last_reconstruction_count = self.reconstruction_count
