Synnefo » snf-ganeti

# Delete any record that is older than 8 hours; this value is based on

# the fact that the current retry counter is 5, and watcher runs every

# 5 minutes, so it takes around half an hour to exceed the retry

# counter, so 8 hours (16*1/2h) seems like a reasonable reset time

RETRY_EXPIRATION = 8 * 3600

  def MaintainInstanceList(self, instances):

    """Perform maintenance on the recorded instances.

    @type instances: list of string

    @param instances: the list of currently existing instances

    """

    idict = self._data["instance"]

    # First, delete obsolete instances

    obsolete_instances = set(idict).difference(instances)

    for inst in obsolete_instances:

      logging.debug("Forgetting obsolete instance %s", inst)

      del idict[inst]

    # Second, delete expired records

    earliest = time.time() - RETRY_EXPIRATION

    expired_instances = [i for i in idict

                         if idict[i][KEY_RESTART_WHEN] < earliest]

    for inst in expired_instances:

      logging.debug("Expiring record for instance %s", inst)

      del idict[inst]

    notepad.MaintainInstanceList(self.instances.keys())

          logging.warning("Not restarting instance %s, retries exhausted",

                          instance.name)