| 89 |
89 |
|
| 90 |
90 |
@type instance: string
|
| 91 |
91 |
@param instance: the instance name
|
| 92 |
|
@return: a dictionary with two keys:
|
|
92 |
@return: a dictionary with the following keys:
|
| 93 |
93 |
- "nodes": instance nodes, a list of strings
|
| 94 |
94 |
- "volumes": instance volume IDs, a list of strings
|
|
95 |
- "drbd-minors": DRBD minors used by the instance, a dictionary where
|
|
96 |
keys are nodes, and values are lists of integers (or an empty
|
|
97 |
dictionary for non-DRBD instances)
|
| 95 |
98 |
|
| 96 |
99 |
"""
|
| 97 |
100 |
master = qa_config.GetMasterNode()
|
| ... | ... | |
| 106 |
109 |
# FIXME This works with no more than 2 secondaries
|
| 107 |
110 |
re_nodelist = re.compile(node_elem + "(?:," + node_elem + ")?$")
|
| 108 |
111 |
re_vol = re.compile(r"^\s+logical_id:\s+(\S+)$")
|
|
112 |
re_drbdnode = re.compile(r"^\s+node[AB]:\s+([^\s,]+),\s+minor=([0-9]+)$")
|
| 109 |
113 |
nodes = []
|
| 110 |
114 |
vols = []
|
|
115 |
drbd_min = {}
|
| 111 |
116 |
for line in info_out.splitlines():
|
| 112 |
117 |
m = re_node.match(line)
|
| 113 |
118 |
if m:
|
| ... | ... | |
| 120 |
125 |
m = re_vol.match(line)
|
| 121 |
126 |
if m:
|
| 122 |
127 |
vols.append(m.group(1))
|
|
128 |
m = re_drbdnode.match(line)
|
|
129 |
if m:
|
|
130 |
node = m.group(1)
|
|
131 |
minor = int(m.group(2))
|
|
132 |
if drbd_min.get(node) is not None:
|
|
133 |
drbd_min[node].append(minor)
|
|
134 |
else:
|
|
135 |
drbd_min[node] = [minor]
|
| 123 |
136 |
assert vols
|
| 124 |
137 |
assert nodes
|
| 125 |
|
return {"nodes": nodes, "volumes": vols}
|
|
138 |
return {"nodes": nodes, "volumes": vols, "drbd-minors": drbd_min}
|
| 126 |
139 |
|
| 127 |
140 |
|
| 128 |
141 |
def _DestroyInstanceVolumes(instance):
|
| ... | ... | |
| 698 |
711 |
def TestBackupListFields():
|
| 699 |
712 |
"""gnt-backup list-fields"""
|
| 700 |
713 |
qa_utils.GenericQueryFieldsTest("gnt-backup", query.EXPORT_FIELDS.keys())
|
|
714 |
|
|
715 |
|
|
716 |
def TestRemoveInstanceOfflineNode(instance, snode, set_offline, set_online):
|
|
717 |
"""gtn-instance remove with an off-line node
|
|
718 |
|
|
719 |
@param instance: instance
|
|
720 |
@param snode: secondary node, to be set offline
|
|
721 |
@param set_offline: function to call to set the node off-line
|
|
722 |
@param set_online: function to call to set the node on-line
|
|
723 |
|
|
724 |
"""
|
|
725 |
info = _GetInstanceInfo(instance["name"])
|
|
726 |
set_offline(snode)
|
|
727 |
try:
|
|
728 |
TestInstanceRemove(instance)
|
|
729 |
finally:
|
|
730 |
set_online(snode)
|
|
731 |
# Clean up the disks on the offline node
|
|
732 |
for minor in info["drbd-minors"][snode["primary"]]:
|
|
733 |
AssertCommand(["drbdsetup", str(minor), "down"], node=snode)
|
|
734 |
AssertCommand(["lvremove", "-f"] + info["volumes"], node=snode)
|