'Gives chance for agents to send a heartbeat.'

def wait_down_agents(self, agent_type, agent_dead_limit):

    tdelta = (timeutils.utcnow() - getattr(self, '_clock_jump_canary', timeutils.utcnow()))
    if (tdelta.total_seconds() > cfg.CONF.agent_down_time):
        LOG.warning(_LW('Time    since    last    %s    agent    reschedule    check    has    exceeded    the    interval    between    checks.    Waiting    before    check    to    allow    agents    to    send    a    heartbeat    in    case    there    was    a    clock    adjustment.'), agent_type)
        time.sleep(agent_dead_limit)
    self._clock_jump_canary = timeutils.utcnow()
