/ - Diff - snf-ganeti - Greek Research and Technology Network's projects

       _CleanDirectory(pathutils.JOB_QUEUE_ARCHIVE_DIR)
     def GetMasterInfo():
       """Returns master information.
     def GetMasterNodeName():
       """Returns the master node name.
       This is an utility function to compute master information, either
       for consumption here or from the node daemon.
       @rtype: tuple
       @return: master_netdev, master_ip, master_name, primary_ip_family,
         master_netmask
       @rtype: string
       @return: name of the master node
       @raise RPCFail: in case of errors
       """
       try:
         cfg = _GetConfig()
         master_netdev = cfg.GetMasterNetdev()
         master_ip = cfg.GetMasterIP()
         master_netmask = cfg.GetMasterNetmask()
         master_node = cfg.GetMasterNode()
         primary_ip_family = cfg.GetPrimaryIPFamily()
         return _GetConfig().GetMasterNode()
       except errors.ConfigurationError, err:
         _Fail("Cluster configuration incomplete: %s", err, exc=True)
       return (master_netdev, master_ip, master_node, primary_ip_family,
               master_netmask)
     def RunLocalHooks(hook_opcode, hooks_path, env_builder_fn):

       if not node_names:
         # no nodes left (eventually after removing myself)
         return []
       results = rpc.BootstrapRunner().call_master_info(node_names)
       results = rpc.BootstrapRunner().call_master_node_name(node_names)
       if not isinstance(results, dict):
         # this should not happen (unless internal error in rpc)
         logging.critical("Can't complete rpc call, aborting master startup")
-...
       votes = {}
       for node_name in results:
         nres = results[node_name]
         data = nres.payload
         msg = nres.fail_msg
         fail = False
         if msg:
           logging.warning("Error contacting node %s: %s", node_name, msg)
           fail = True
         # for now we accept both length 3, 4 and 5 (data[3] is primary ip version
         # and data[4] is the master netmask)
         elif not isinstance(data, (tuple, list)) or len(data) < 3:
           logging.warning("Invalid data received from node %s: %s",
                           node_name, data)
           fail = True
         if fail:
           if None not in votes:
             votes[None] = 0
           votes[None] += 1
           continue
         master_node = data[2]
         if master_node not in votes:
           votes[master_node] = 0
         votes[master_node] += 1
           node = None
         else:
           node = nres.payload
         if node not in votes:
           votes[node] = 1
         else:
           votes[node] += 1
       vote_list = [v for v in votes.items()]
       # sort first on number of votes then on name, since we want None

           ("modify_ssh_setup", None, None),
           ], None, None,
          "Requests a node to clean the cluster information it has"),
         ("master_info", MULTI, None, constants.RPC_TMO_URGENT, [], None, None,
          "Query master info"),
         ("master_node_name", MULTI, None, constants.RPC_TMO_URGENT, [], None, None,
          "Returns the master node name"),
         ]),
       "RpcClientDnsOnly": _Prepare([
         ("version", MULTI, ACCEPT_OFFLINE_NODE, constants.RPC_TMO_URGENT, [], None,

         return backend.UploadFile(*(params[0]))
       @staticmethod
       def perspective_master_info(params):
         """Query master information.
       def perspective_master_node_name(params):
         """Returns the master node name.
         """
         return backend.GetMasterInfo()
         return backend.GetMasterNodeName()
       @staticmethod
       def perspective_run_oob(params):

Synnefo » snf-ganeti

Revision cb8028f3