apache/cloudstack
1
0
Fork 0
mirror of https://github.com/apache/cloudstack.git synced 2025-10-26 08:42:29 +01:00
Code Issues Packages Projects Releases Wiki Activity

Add helper method to migrate router vms

Browse Source
This commit is contained in:
Miguel Ferreira 2015-12-24 11:08:59 +01:00 committed by nvazquez
parent 88774a93e8
commit 3dba689f31
1 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
tools/marvin/marvin/lib/common.py
View File

@ -56,7 +56,8 @@ from marvin.cloudstackAPI import (listConfigurations,
listVirtualRouterElements, listVirtualRouterElements,
listNetworkOfferings, listNetworkOfferings,
listResourceLimits, listResourceLimits,
listVPCOfferings) listVPCOfferings,
migrateSystemVm)
from marvin.sshClient import SshClient from marvin.sshClient import SshClient
from marvin.codes import (PASS, FAILED, ISOLATED_NETWORK, VPC_NETWORK, from marvin.codes import (PASS, FAILED, ISOLATED_NETWORK, VPC_NETWORK,
BASIC_ZONE, FAIL, NAT_RULE, STATIC_NAT_RULE, BASIC_ZONE, FAIL, NAT_RULE, STATIC_NAT_RULE,
@ -64,8 +65,8 @@ from marvin.codes import (PASS, FAILED, ISOLATED_NETWORK, VPC_NETWORK,
RESOURCE_CPU, RESOURCE_MEMORY, PUBLIC_TRAFFIC, RESOURCE_CPU, RESOURCE_MEMORY, PUBLIC_TRAFFIC,
GUEST_TRAFFIC, MANAGEMENT_TRAFFIC, STORAGE_TRAFFIC, GUEST_TRAFFIC, MANAGEMENT_TRAFFIC, STORAGE_TRAFFIC,
VMWAREDVS) VMWAREDVS)
from marvin.lib.utils import (validateList, from marvin.lib.utils import (validateList,
xsplit, xsplit,
get_process_status, get_process_status,
random_gen, random_gen,
format_volume_to_ext3) format_volume_to_ext3)
@ -1419,13 +1420,13 @@ def isNetworkDeleted(apiclient, networkid, timeout=600):
return networkDeleted return networkDeleted
def createChecksum(service=None, def createChecksum(service=None,
virtual_machine=None, virtual_machine=None,
disk=None, disk=None,
disk_type=None): disk_type=None):
""" Calculate the MD5 checksum of the disk by writing \ """ Calculate the MD5 checksum of the disk by writing \
data on the disk where disk_type is either root disk or data disk data on the disk where disk_type is either root disk or data disk
@return: returns the calculated checksum""" @return: returns the calculated checksum"""
random_data_0 = random_gen(size=100) random_data_0 = random_gen(size=100)
@ -1440,7 +1441,7 @@ def createChecksum(service=None,
virtual_machine.username, virtual_machine.username,
virtual_machine.password virtual_machine.password
) )
except Exception: except Exception:
raise Exception("SSH access failed for server with IP address: %s" % raise Exception("SSH access failed for server with IP address: %s" %
virtual_machine.ssh_ip) virtual_machine.ssh_ip)
@ -1898,3 +1899,10 @@ def verifyVCenterPortGroups(
except Exception as e: except Exception as e:
return [FAIL, e] return [FAIL, e]
return [PASS, None] return [PASS, None]
def migrate_router(apiclient, router_id, host_id):
cmd = migrateSystemVm.migrateSystemVmCmd()
cmd.hostid = host_id
cmd.virtualmachineid = router_id
apiclient.migrateSystemVm(cmd)