Synnefo » snf-ganeti

class SimpleOpener(urllib.FancyURLopener):

  """A simple url opener"""

  def prompt_user_passwd(self, host, realm, clear_cache=0):

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

    # we follow parent class' API

    return None, None

  def http_error_default(self, url, fp, errcode, errmsg, headers):

  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

      cli.SetGenericOpcodeOpts(ops, self.opts)

      self.queued_ops.append((ops, name, post_process))

    else:

      if post_process is not None:

        post_process()

      return val

    self.ClearFeedbackBuf()

    jex = cli.JobExecutor(cl=self.cl, feedback_fn=self.Feedback)

    for ops, name, _ in jobs:

    try:

      results = jex.GetResults()

      Log("Jobs failed: %s", err)

      raise BurninFailure()

        if post_process:

          try:

            post_process()

            Log("Post process call for job %s failed: %s", name, err)

            fail = True

        val.append(result)

      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", err)