Revision 098c0958 lib/cmdlib.py
b/lib/cmdlib.py | ||
---|---|---|
466 | 466 |
ourselves in the post-run node list. |
467 | 467 |
|
468 | 468 |
""" |
469 |
|
|
470 | 469 |
env = {"CLUSTER": self.op.cluster_name, |
471 | 470 |
"MASTER": self.hostname['hostname_full']} |
472 | 471 |
return env, [], [self.hostname['hostname_full']] |
... | ... | |
623 | 622 |
node: name of the node to check |
624 | 623 |
file_list: required list of files |
625 | 624 |
local_cksum: dictionary of local files and their checksums |
625 |
|
|
626 | 626 |
""" |
627 | 627 |
# compares ganeti version |
628 | 628 |
local_version = constants.PROTOCOL_VERSION |
... | ... | |
913 | 913 |
"""Check that mirrors are not degraded. |
914 | 914 |
|
915 | 915 |
""" |
916 |
|
|
917 | 916 |
cfgw.SetDiskID(dev, node) |
918 | 917 |
|
919 | 918 |
result = True |
... | ... | |
986 | 985 |
Any errors are signalled by raising errors.OpPrereqError. |
987 | 986 |
|
988 | 987 |
""" |
989 |
|
|
990 | 988 |
node = self.cfg.GetNodeInfo(self.cfg.ExpandNodeName(self.op.node_name)) |
991 | 989 |
if node is None: |
992 | 990 |
logger.Error("Error: Node '%s' is unknown." % self.op.node_name) |
... | ... | |
1441 | 1439 |
master. |
1442 | 1440 |
|
1443 | 1441 |
""" |
1444 |
|
|
1445 | 1442 |
#TODO: do not rely on gethostname returning the FQDN |
1446 | 1443 |
logger.Info("setting master to %s, old master: %s" % |
1447 | 1444 |
(self.new_master, self.old_master)) |
... | ... | |
1924 | 1921 |
"""Computes the list of nodes and their attributes. |
1925 | 1922 |
|
1926 | 1923 |
""" |
1927 |
|
|
1928 | 1924 |
instance_names = utils.NiceSort(self.cfg.GetInstanceList()) |
1929 | 1925 |
instance_list = [self.cfg.GetInstanceInfo(iname) for iname |
1930 | 1926 |
in instance_names] |
... | ... | |
2132 | 2128 |
This always creates all devices. |
2133 | 2129 |
|
2134 | 2130 |
""" |
2135 |
|
|
2136 | 2131 |
if device.children: |
2137 | 2132 |
for child in device.children: |
2138 | 2133 |
if not _CreateBlockDevOnPrimary(cfg, node, child): |
... | ... | |
3044 | 3039 |
|
3045 | 3040 |
def Exec(self, feedback_fn): |
3046 | 3041 |
"""Gather and return data""" |
3047 |
|
|
3048 | 3042 |
result = {} |
3049 | 3043 |
for instance in self.wanted_instances: |
3050 | 3044 |
remote_info = rpc.call_instance_info(instance.primary_node, |
... | ... | |
3096 | 3090 |
"""Compute and return the list of nodes. |
3097 | 3091 |
|
3098 | 3092 |
""" |
3099 |
|
|
3100 | 3093 |
ilist = [self.cfg.GetInstanceInfo(iname) for iname |
3101 | 3094 |
in self.cfg.GetInstanceList()] |
3102 | 3095 |
result = [] |
Also available in: Unified diff