diff --git a/lib/cmdlib.py b/lib/cmdlib.py index 1ab20ac9203091a47f3951dd3f5855cda3cc64c4..e491163ac3182fed7cc4cdfc42d2a39df4c34ad1 100644 --- a/lib/cmdlib.py +++ b/lib/cmdlib.py @@ -6293,12 +6293,12 @@ class LUExportInstance(LogicalUnit): self.cfg.SetDiskID(disk, src_node) try: - for disk in instance.disks: + for idx, disk in enumerate(instance.disks): # new_dev_name will be a snapshot of an lvm leaf of the one we passed new_dev_name = self.rpc.call_blockdev_snapshot(src_node, disk) if new_dev_name.failed or not new_dev_name.data: - self.LogWarning("Could not snapshot block device %s on node %s", - disk.logical_id[1], src_node) + self.LogWarning("Could not snapshot disk/%d on node %s", + idx, src_node) snap_disks.append(False) else: new_dev = objects.Disk(dev_type=constants.LD_LV, size=disk.size, @@ -6323,13 +6323,12 @@ class LUExportInstance(LogicalUnit): result = self.rpc.call_snapshot_export(src_node, dev, dst_node.name, instance, cluster_name, idx) if result.failed or not result.data: - self.LogWarning("Could not export block device %s from node %s to" - " node %s", dev.logical_id[1], src_node, - dst_node.name) + self.LogWarning("Could not export disk/%d from node %s to" + " node %s", idx, src_node, dst_node.name) msg = self.rpc.call_blockdev_remove(src_node, dev).RemoteFailMsg() if msg: - self.LogWarning("Could not remove snapshot block device %s from node" - " %s: %s", dev.logical_id[1], src_node, msg) + self.LogWarning("Could not remove snapshot for disk/%d from node" + " %s: %s", idx, src_node, msg) result = self.rpc.call_finalize_export(dst_node.name, instance, snap_disks) if result.failed or not result.data: diff --git a/lib/rpc.py b/lib/rpc.py index 48a48dc697cb67e44067fbc824c48dded3bb8771..b50c3d16669124f7a9d8d73acabd317ff5924610 100644 --- a/lib/rpc.py +++ b/lib/rpc.py @@ -959,7 +959,10 @@ class RpcRunner(object): """ flat_disks = [] for disk in snap_disks: - flat_disks.append(disk.ToDict()) + if isinstance(disk, bool): + flat_disks.append(disk) + else: + flat_disks.append(disk.ToDict()) return self._SingleNodeCall(node, "finalize_export", [self._InstDict(instance), flat_disks])