Synnefo » snf-ganeti » ganeti-local

class SimpleOpener(urllib.FancyURLopener):

  """A simple url opener"""

    """No-interaction version of prompt_user_passwd."""

    return None, None

  def wrapper(self, *args, **kwargs):

    val = fn(self, *args, **kwargs)

    for instance in self.instances:

    return val

  return wrapper

        Log("Idempotent %s succeeded after %d retries" %

            (msg, MAX_RETRIES - retry_count))

      return val

      if retry_count == 0:

        Log("Non-idempotent %s failed, aborting" % (msg, ))

        raise

      Log("waiting for job %s for %s" % (jid, iname), indent=2)

      try:

        results.append(cli.PollJob(jid, cl=self.cl, feedback_fn=self.Feedback))

        Log("Job for %s failed: %s" % (iname, err))

    if len(results) != len(jobs):

      raise BurninFailure()

                                    disks=[i for i in range(self.disk_count)])

        Log("run %s" % mode, indent=2)

        ops.append(op)

  @_DoBatch(True)

  def BurnReplaceDisks2(self):

                                      ignore_secondaries=False)

        Log("reboot with type '%s'" % reboot_type, indent=2)

        ops.append(op)

  @_DoCheckInstances

  @_DoBatch(True)

      if not self.opts.keep_instances:

        try:

          self.BurnRemove()

          if has_err: # already detected errors, so errors in removal

                      # are quite expected

            Log("Note: error detected during instance remove: %s" % str(err))