Revision bb3011ad lib/cmdlib/group.py
b/lib/cmdlib/group.py | ||
---|---|---|
915 | 915 |
node_to_inst.setdefault(node_uuid, []).append(inst) |
916 | 916 |
|
917 | 917 |
for (node_uuid, insts) in node_to_inst.items(): |
918 |
node_disks = [(inst.disks, inst) for inst in insts]
|
|
918 |
node_disks = [(self.cfg.GetInstanceDisks(inst), inst) for inst in insts]
|
|
919 | 919 |
node_res = self.rpc.call_drbd_needs_activation(node_uuid, node_disks) |
920 | 920 |
msg = node_res.fail_msg |
921 | 921 |
if msg: |
... | ... | |
926 | 926 |
|
927 | 927 |
faulty_disk_uuids = set(node_res.payload) |
928 | 928 |
for inst in self.instances.values(): |
929 |
inst_disk_uuids = set([disk.uuid for disk in inst.disks]) |
|
929 |
disks = self.cfg.GetInstanceDisks(inst) |
|
930 |
inst_disk_uuids = set([disk.uuid for disk in disks]) |
|
930 | 931 |
if inst_disk_uuids.intersection(faulty_disk_uuids): |
931 | 932 |
offline_disk_instance_names.add(inst.name) |
932 | 933 |
|
Also available in: Unified diff