Revision f198cf91 lib/masterd/instance.py
| b/lib/masterd/instance.py | ||
|---|---|---|
| 1007 | 1007 |
|
| 1008 | 1008 |
|
| 1009 | 1009 |
def TransferInstanceData(lu, feedback_fn, src_node_uuid, dest_node_uuid, |
| 1010 |
dest_ip, instance, all_transfers): |
|
| 1010 |
dest_ip, compress, instance, all_transfers):
|
|
| 1011 | 1011 |
"""Transfers an instance's data from one node to another. |
| 1012 | 1012 |
|
| 1013 | 1013 |
@param lu: Logical unit instance |
| ... | ... | |
| 1018 | 1018 |
@param dest_node_uuid: Destination node UUID |
| 1019 | 1019 |
@type dest_ip: string |
| 1020 | 1020 |
@param dest_ip: IP address of destination node |
| 1021 |
@type compress: string |
|
| 1022 |
@param compress: one of L{constants.IEC_ALL}
|
|
| 1021 | 1023 |
@type instance: L{objects.Instance}
|
| 1022 | 1024 |
@param instance: Instance object |
| 1023 | 1025 |
@type all_transfers: list of L{DiskTransfer} instances
|
| ... | ... | |
| 1027 | 1029 |
each transfer |
| 1028 | 1030 |
|
| 1029 | 1031 |
""" |
| 1030 |
# Disable compression for all moves as these are all within the same cluster |
|
| 1031 |
compress = constants.IEC_NONE |
|
| 1032 |
|
|
| 1033 | 1032 |
src_node_name = lu.cfg.GetNodeName(src_node_uuid) |
| 1034 | 1033 |
dest_node_name = lu.cfg.GetNodeName(dest_node_uuid) |
| 1035 | 1034 |
|
| ... | ... | |
| 1254 | 1253 |
dresults = TransferInstanceData(self._lu, self._feedback_fn, |
| 1255 | 1254 |
src_node_uuid, dest_node.uuid, |
| 1256 | 1255 |
dest_node.secondary_ip, |
| 1256 |
constants.IEC_NONE, |
|
| 1257 | 1257 |
instance, transfers) |
| 1258 | 1258 |
|
| 1259 | 1259 |
assert len(dresults) == len(instance.disks) |
Also available in: Unified diff