Synnefo » snf-ganeti » ganeti-local

    master = client.QueryConfigValues(["master_node"])[0]

    if master != utils.HostInfo().name:

      raise NotMasterError("This is not the master node")

    self.instances, self.bootids, self.smap = GetClusterData()

    self.started_instances = set()

    self.opts = opts

    """

    notepad = self.notepad

    self.CheckInstances(notepad)

    self.CheckDisks(notepad)

    self.VerifyDisks()

    """Archive old jobs.

    """

  utils.SetupLogging(constants.LOG_WATCHER, debug=options.debug,

                     stderr_logging=options.debug)

  try:

    notepad = WatcherState()

    try:

      except errors.OpPrereqError:

        # this is, from cli.GetClient, a not-master case

        logging.debug("Not on master, exiting")

        sys.exit(constants.EXIT_SUCCESS)

      except luxi.NoMasterError, err:

        logging.warning("Master seems to be down (%s), trying to restart",

                        str(err))

        if not StartMaster():

          logging.critical("Can't start the master, exiting")

          sys.exit(constants.EXIT_FAILURE)

        # else retry the connection

        client = cli.GetClient()

        watcher = Watcher(options, notepad)

      except errors.ConfigurationError:

        # Just exit if there's no configuration

        sys.exit(constants.EXIT_SUCCESS)

      watcher.Run()

    finally:

      if update_file:

        notepad.Save()

  except errors.ResolverError, err:

    logging.error("Cannot resolve hostname '%s', exiting.", err.args[0])

    sys.exit(constants.EXIT_NODESETUP_ERROR)

  except Exception, err:

    logging.error(str(err), exc_info=True)

    sys.exit(constants.EXIT_FAILURE)