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

CLOUDSTACK-8098: Fixed VM snapshot issue in smoke/test_vm_snapshots.py

Browse Source 
Signed-off-by: SrikanteswaraRao Talluri <talluri@apache.org>
This commit is contained in:
Gaurav Aradhye 2014-12-19 17:38:06 +05:30 committed by SrikanteswaraRao Talluri
parent 0d75682a34
commit fc2c1a09a7
1 changed files with 51 additions and 49 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

100
test/integration/smoke/test_vm_snapshots.py
View File

@ -19,7 +19,6 @@
from marvin.codes import FAILED, KVM from marvin.codes import FAILED, KVM
from nose.plugins.attrib import attr from nose.plugins.attrib import attr
from marvin.cloudstackTestCase import cloudstackTestCase, unittest from marvin.cloudstackTestCase import cloudstackTestCase, unittest
from marvin.cloudstackAPI import startVirtualMachine
from marvin.lib.utils import random_gen, cleanup_resources from marvin.lib.utils import random_gen, cleanup_resources
from marvin.lib.base import (Account, from marvin.lib.base import (Account,
ServiceOffering, ServiceOffering,
@ -27,10 +26,10 @@ from marvin.lib.base import (Account,
VmSnapshot) VmSnapshot)
from marvin.lib.common import (get_zone, from marvin.lib.common import (get_zone,
get_domain, get_domain,
get_template, get_template)
list_virtual_machines)
import time import time
class TestVmSnapshot(cloudstackTestCase): class TestVmSnapshot(cloudstackTestCase):
@classmethod @classmethod
@ -39,7 +38,8 @@ class TestVmSnapshot(cloudstackTestCase):
hypervisor = testClient.getHypervisorInfo() hypervisor = testClient.getHypervisorInfo()
if hypervisor.lower() in (KVM.lower(), "hyperv", "lxc"): if hypervisor.lower() in (KVM.lower(), "hyperv", "lxc"):
raise unittest.SkipTest("VM snapshot feature is not supported on KVM, Hyper-V or LXC") raise unittest.SkipTest(
"VM snapshot feature is not supported on KVM, Hyper-V or LXC")
cls.apiclient = testClient.getApiClient() cls.apiclient = testClient.getApiClient()
cls.services = testClient.getParsedTestDataConfig() cls.services = testClient.getParsedTestDataConfig()
@ -48,12 +48,13 @@ class TestVmSnapshot(cloudstackTestCase):
cls.zone = get_zone(cls.apiclient, testClient.getZoneForTests()) cls.zone = get_zone(cls.apiclient, testClient.getZoneForTests())
template = get_template( template = get_template(
cls.apiclient, cls.apiclient,
cls.zone.id, cls.zone.id,
cls.services["ostype"] cls.services["ostype"]
) )
if template == FAILED: if template == FAILED:
assert False, "get_template() failed to return template with description %s" % cls.services["ostype"] assert False, "get_template() failed to return template\
with description %s" % cls.services["ostype"]
cls.services["domainid"] = cls.domain.id cls.services["domainid"] = cls.domain.id
cls.services["server"]["zoneid"] = cls.zone.id cls.services["server"]["zoneid"] = cls.zone.id
@ -62,31 +63,31 @@ class TestVmSnapshot(cloudstackTestCase):
# Create VMs, NAT Rules etc # Create VMs, NAT Rules etc
cls.account = Account.create( cls.account = Account.create(
cls.apiclient, cls.apiclient,
cls.services["account"], cls.services["account"],
domainid=cls.domain.id domainid=cls.domain.id
) )
cls.service_offering = ServiceOffering.create( cls.service_offering = ServiceOffering.create(
cls.apiclient, cls.apiclient,
cls.services["service_offerings"] cls.services["service_offerings"]
) )
cls.virtual_machine = VirtualMachine.create( cls.virtual_machine = VirtualMachine.create(
cls.apiclient, cls.apiclient,
cls.services["server"], cls.services["server"],
templateid=template.id, templateid=template.id,
accountid=cls.account.name, accountid=cls.account.name,
domainid=cls.account.domainid, domainid=cls.account.domainid,
serviceofferingid=cls.service_offering.id, serviceofferingid=cls.service_offering.id,
mode=cls.zone.networktype mode=cls.zone.networktype
) )
cls.random_data_0 = random_gen(size=100) cls.random_data_0 = random_gen(size=100)
cls.test_dir = "/tmp" cls.test_dir = "/tmp"
cls.random_data = "random.data" cls.random_data = "random.data"
cls._cleanup = [ cls._cleanup = [
cls.service_offering, cls.service_offering,
cls.account, cls.account,
] ]
return return
@classmethod @classmethod
@ -122,9 +123,10 @@ class TestVmSnapshot(cloudstackTestCase):
ssh_client = self.virtual_machine.get_ssh_client() ssh_client = self.virtual_machine.get_ssh_client()
cmds = [ cmds = [
"echo %s > %s/%s" % (self.random_data_0, self.test_dir, self.random_data), "echo %s > %s/%s" %
"cat %s/%s" % (self.test_dir, self.random_data) (self.random_data_0, self.test_dir, self.random_data),
] "cat %s/%s" %
(self.test_dir, self.random_data)]
for c in cmds: for c in cmds:
self.debug(c) self.debug(c)
@ -183,7 +185,10 @@ class TestVmSnapshot(cloudstackTestCase):
time.sleep(self.services["sleep"]) time.sleep(self.services["sleep"])
list_snapshot_response = VmSnapshot.list(self.apiclient, vmid=self.virtual_machine.id, listall=True) list_snapshot_response = VmSnapshot.list(
self.apiclient,
vmid=self.virtual_machine.id,
listall=True)
self.assertEqual( self.assertEqual(
isinstance(list_snapshot_response, list), isinstance(list_snapshot_response, list),
@ -202,24 +207,13 @@ class TestVmSnapshot(cloudstackTestCase):
"Check the snapshot of vm is ready!" "Check the snapshot of vm is ready!"
) )
VmSnapshot.revertToSnapshot(self.apiclient, list_snapshot_response[0].id) self.virtual_machine.stop(self.apiclient)
list_vm_response = list_virtual_machines( VmSnapshot.revertToSnapshot(
self.apiclient, self.apiclient,
id=self.virtual_machine.id list_snapshot_response[0].id)
)
self.assertEqual( self.virtual_machine.start(self.apiclient)
list_vm_response[0].state,
"Stopped",
"Check the state of vm is Stopped!"
)
cmd = startVirtualMachine.startVirtualMachineCmd()
cmd.id = list_vm_response[0].id
self.apiclient.startVirtualMachine(cmd)
time.sleep(self.services["sleep"])
try: try:
ssh_client = self.virtual_machine.get_ssh_client(reconnect=True) ssh_client = self.virtual_machine.get_ssh_client(reconnect=True)
@ -248,7 +242,10 @@ class TestVmSnapshot(cloudstackTestCase):
"""Test to delete vm snapshots """Test to delete vm snapshots
""" """
list_snapshot_response = VmSnapshot.list(self.apiclient, vmid=self.virtual_machine.id, listall=True) list_snapshot_response = VmSnapshot.list(
self.apiclient,
vmid=self.virtual_machine.id,
listall=True)
self.assertEqual( self.assertEqual(
isinstance(list_snapshot_response, list), isinstance(list_snapshot_response, list),
@ -260,11 +257,16 @@ class TestVmSnapshot(cloudstackTestCase):
None, None,
"Check if snapshot exists in ListSnapshot" "Check if snapshot exists in ListSnapshot"
) )
VmSnapshot.deleteVMSnapshot(self.apiclient, list_snapshot_response[0].id) VmSnapshot.deleteVMSnapshot(
self.apiclient,
list_snapshot_response[0].id)
time.sleep(self.services["sleep"] * 3) time.sleep(self.services["sleep"] * 3)
list_snapshot_response = VmSnapshot.list(self.apiclient, vmid=self.virtual_machine.id, listall=True) list_snapshot_response = VmSnapshot.list(
self.apiclient,
vmid=self.virtual_machine.id,
listall=True)
self.assertEqual( self.assertEqual(
list_snapshot_response, list_snapshot_response,