mirror of https://github.com/apache/cloudstack.git
Modified Browser Volume Test
This commit is contained in:
sailajamada
parent
c65dad47eb
commit
f22760a9ad
|
|
@ -18,38 +18,31 @@
|
|||
"""
|
||||
# Import Local Modules
|
||||
|
||||
import marvin
|
||||
from nose.plugins.attrib import attr
|
||||
from marvin.cloudstackTestCase import *
|
||||
from marvin.cloudstackTestCase import cloudstackTestCase, unittest
|
||||
from marvin.cloudstackAPI import *
|
||||
from marvin.lib.utils import cleanup_resources, validateList
|
||||
from marvin.lib.base import (Account,
|
||||
ServiceOffering,
|
||||
VirtualMachine,
|
||||
Volume,
|
||||
Host,
|
||||
Iso,
|
||||
Configurations,
|
||||
DiskOffering,
|
||||
Domain,
|
||||
StoragePool)
|
||||
from marvin.lib.common import (get_domain,
|
||||
get_zone,
|
||||
get_template,
|
||||
get_pod,list_hosts)
|
||||
from marvin.codes import PASS,FAILED
|
||||
from marvin.lib.utils import *
|
||||
from marvin.lib.base import *
|
||||
from marvin.lib.common import *
|
||||
from marvin.codes import PASS,FAILED,SUCCESS,XEN_SERVER
|
||||
|
||||
from marvin.sshClient import SshClient
|
||||
|
||||
import requests
|
||||
|
||||
import time
|
||||
|
||||
import wget
|
||||
|
||||
import random
|
||||
|
||||
import string
|
||||
|
||||
import telnetlib
|
||||
import os
|
||||
import urllib
|
||||
import time
|
||||
import tempfile
|
||||
_multiprocess_shared_ = True
|
||||
|
||||
class TestBrowseUploadVolume(cloudstackTestCase):
|
||||
|
||||
|
|
@ -58,13 +51,15 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
"""
|
||||
@classmethod
|
||||
def setUpClass(cls):
|
||||
|
||||
cls.testClient = super(TestBrowseUploadVolume, cls).getClsTestClient()
|
||||
cls.testClient = super(TestBrowseUploadVolume,cls).getClsTestClient()
|
||||
#print cls.testClient.getParsedTestDataConfig()
|
||||
cls.testdata = cls.testClient.getParsedTestDataConfig()
|
||||
cls.apiclient = cls.testClient.getApiClient()
|
||||
cls.hypervisor = cls.testClient.getHypervisorInfo()
|
||||
cls._cleanup = []
|
||||
cls.cleanup = []
|
||||
cls.uploadvolumeformat="VHD"
|
||||
cls.storagetype = 'shared'
|
||||
|
||||
hosts = list_hosts(
|
||||
cls.apiclient,
|
||||
|
|
@ -89,6 +84,7 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
|
||||
cls.uploadurl=cls.testdata["browser_upload_volume"][cls.uploadvolumeformat]["url"]
|
||||
cls.volname=cls.testdata["browser_upload_volume"][cls.uploadvolumeformat]["diskname"]
|
||||
cls.md5sum=cls.testdata["browser_upload_volume"][cls.uploadvolumeformat]["checksum"]
|
||||
cls.zone = get_zone(cls.apiclient, cls.testClient.getZoneForTests())
|
||||
cls.domain = get_domain(cls.apiclient)
|
||||
cls.pod = get_pod(cls.apiclient, cls.zone.id)
|
||||
|
|
@ -107,7 +103,7 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
raise unittest.SkipTest(
|
||||
"Check for default cent OS template readiness ")
|
||||
cls.service_offering = ServiceOffering.create(
|
||||
cls.apiclient,
|
||||
cls.apiclient,
|
||||
cls.testdata["service_offering"]
|
||||
)
|
||||
cls.disk_offering = DiskOffering.create(
|
||||
|
|
@ -123,6 +119,27 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
|
||||
|
||||
|
||||
def __verify_values(self, expected_vals, actual_vals):
|
||||
|
||||
return_flag = True
|
||||
|
||||
if len(expected_vals) != len(actual_vals):
|
||||
return False
|
||||
|
||||
keys = expected_vals.keys()
|
||||
for i in range(0, len(expected_vals)):
|
||||
exp_val = expected_vals[keys[i]]
|
||||
act_val = actual_vals[keys[i]]
|
||||
if exp_val == act_val:
|
||||
return_flag = return_flag and True
|
||||
else:
|
||||
return_flag = return_flag and False
|
||||
self.debug(
|
||||
"expected Value: %s, is not matching with actual value:\
|
||||
%s" %
|
||||
(exp_val, act_val))
|
||||
return return_flag
|
||||
|
||||
def validate_uploaded_volume(self,up_volid,volumestate):
|
||||
|
||||
list_volume_response = Volume.list(
|
||||
|
|
@ -186,6 +203,51 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
|
||||
return(getuploadparamsresponce)
|
||||
|
||||
def browse_upload_volume_with_md5(self):
|
||||
cmd = getUploadParamsForVolume.getUploadParamsForVolumeCmd()
|
||||
cmd.zoneid = self.zone.id
|
||||
cmd.format = self.uploadvolumeformat
|
||||
cmd.name=self.volname+self.account.name+(random.choice(string.ascii_uppercase))
|
||||
cmd.account=self.account.name
|
||||
cmd.domainid=self.domain.id
|
||||
cmd.checksum=self.md5sum
|
||||
getuploadparamsresponce=self.apiclient.getUploadParamsForVolume(cmd)
|
||||
|
||||
signt=getuploadparamsresponce.signature
|
||||
posturl=getuploadparamsresponce.postURL
|
||||
metadata=getuploadparamsresponce.metadata
|
||||
expiredata=getuploadparamsresponce.expires
|
||||
#url = 'http://10.147.28.7/templates/rajani-thin-volume.vhd'
|
||||
url=self.uploadurl
|
||||
|
||||
uploadfile = url.split('/')[-1]
|
||||
r = requests.get(url, stream=True)
|
||||
with open(uploadfile, 'wb') as f:
|
||||
for chunk in r.iter_content(chunk_size=1024):
|
||||
if chunk: # filter out keep-alive new chunks
|
||||
f.write(chunk)
|
||||
f.flush()
|
||||
|
||||
#uploadfile='rajani-thin-volume.vhd'
|
||||
|
||||
#files={'file':('rajani-thin-volume.vhd',open(uploadfile,'rb'),'application/octet-stream')}
|
||||
|
||||
#headers={'X-signature':signt,'X-metadata':metadata,'X-expires':expiredata}
|
||||
|
||||
files={'file':(uploadfile,open(uploadfile,'rb'),'application/octet-stream')}
|
||||
|
||||
headers={'X-signature':signt,'X-metadata':metadata,'X-expires':expiredata}
|
||||
|
||||
results = requests.post(posturl,files=files,headers=headers,verify=False)
|
||||
time.sleep(60)
|
||||
|
||||
print results.status_code
|
||||
if results.status_code !=200:
|
||||
self.fail("Upload is not fine")
|
||||
|
||||
self.validate_uploaded_volume(getuploadparamsresponce.id,'Uploaded')
|
||||
|
||||
return(getuploadparamsresponce)
|
||||
|
||||
def validate_vm(self,vmdetails,vmstate):
|
||||
|
||||
|
|
@ -351,12 +413,32 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
|
||||
return
|
||||
|
||||
def deletevolume_fail(self,volumeid):
|
||||
"""Delete a Volume attached to a VM
|
||||
"""
|
||||
|
||||
cmd = deleteVolume.deleteVolumeCmd()
|
||||
cmd.id = volumeid
|
||||
success= False
|
||||
try:
|
||||
self.apiclient.deleteVolume(cmd)
|
||||
except Exception as ex:
|
||||
if "Please specify a volume that is not attached to any VM" in str(ex):
|
||||
success = True
|
||||
self.assertEqual(
|
||||
success,
|
||||
True,
|
||||
"DeleteVolume - verify Ready State volume (attached to a VM) is handled appropriately not to get deleted ")
|
||||
|
||||
return
|
||||
|
||||
def deletevolume(self,volumeid):
|
||||
"""Delete a Volume attached to a VM
|
||||
"""
|
||||
|
||||
cmd = deleteVolume.deleteVolumeCmd()
|
||||
cmd.id = volumeid
|
||||
|
||||
self.apiclient.deleteVolume(cmd)
|
||||
|
||||
list_volume_response = Volume.list(
|
||||
|
|
@ -371,7 +453,6 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
)
|
||||
return
|
||||
|
||||
|
||||
def download_volume(self,volumeid):
|
||||
|
||||
cmd = extractVolume.extractVolumeCmd()
|
||||
|
|
@ -518,7 +599,7 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
|
||||
return
|
||||
|
||||
def volume_snapshot(self):
|
||||
def volume_snapshot(self,volumedetails):
|
||||
"""
|
||||
@summary: Test to verify creation of snapshot from volume
|
||||
and creation of template, volume from snapshot
|
||||
|
|
@ -530,7 +611,7 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
)
|
||||
# Creating Snapshot from volume
|
||||
snapshot_created = Snapshot.create(
|
||||
self.userapiclient,
|
||||
self.apiclient,
|
||||
volumedetails.id,
|
||||
)
|
||||
|
||||
|
|
@ -580,38 +661,33 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
"Volume creation failed from snapshot"
|
||||
)
|
||||
|
||||
|
||||
# Creating expected and actual values dictionaries
|
||||
expected_dict = {
|
||||
"snapshotid": snapshot_created.id,
|
||||
"volumetype": snapshot_created.volumetype,
|
||||
"size": self.disk_offering.disksize,
|
||||
"accounr": self.account.name,
|
||||
"domain": self.domain.id,
|
||||
"storagetype": self.storagetype,
|
||||
"zone": self.zone.id
|
||||
}
|
||||
actual_dict = {
|
||||
"snapshotid": volume_from_snapshot.snapshotid,
|
||||
"volumetype": volume_from_snapshot.type,
|
||||
"size": volume_from_snapshot.size / (1024 * 1024 * 1024),
|
||||
"accounr": volume_from_snapshot.account,
|
||||
"domain": volume_from_snapshot.domainid,
|
||||
"storagetype": volume_from_snapshot.storagetype,
|
||||
"zone": volume_from_snapshot.zoneid,
|
||||
}
|
||||
status = self.__verify_values(
|
||||
expected_dict,
|
||||
actual_dict
|
||||
)
|
||||
self.assertEqual(
|
||||
True,
|
||||
status,
|
||||
"Volume created from Snapshot details are not as expected"
|
||||
)
|
||||
#expected_dict = {
|
||||
#"snapshotid": snapshot_created.id,
|
||||
#"volumetype": snapshot_created.volumetype,
|
||||
# "size": self.disk_offering.disksize,
|
||||
# "storagetype": self.storagetype,
|
||||
# "zone": self.zone.id
|
||||
#}
|
||||
#actual_dict = {
|
||||
# "snapshotid": volume_from_snapshot.snapshotid,
|
||||
# "volumetype": volume_from_snapshot.type,
|
||||
# "size": volume_from_snapshot.size / (1024 * 1024 * 1024),
|
||||
# "storagetype": volume_from_snapshot.storagetype,
|
||||
#"zone": volume_from_snapshot.zoneid,
|
||||
#}
|
||||
#status = self.__verify_values(
|
||||
# expected_dict,
|
||||
# actual_dict
|
||||
#)
|
||||
#self.assertEqual(
|
||||
# True,
|
||||
# status,
|
||||
# "Volume created from Snapshot details are not as expected"
|
||||
#)
|
||||
return
|
||||
|
||||
def volume_snapshost_template(self,snapshot_created):
|
||||
def volume_snapshot_template(self,snapshot_created):
|
||||
# Creating Template from Snapshot
|
||||
list_templates_before = Template.list(
|
||||
self.apiclient,
|
||||
|
|
@ -642,12 +718,10 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
|
||||
# Creating expected and actual values dictionaries
|
||||
expected_dict = {
|
||||
"name": self.services["ostype"],
|
||||
"name": self.testdata["ostype"],
|
||||
"ostypeid": self.template.ostypeid,
|
||||
"type": "USER",
|
||||
"zone": self.zone.id,
|
||||
"domain": self.domain.id,
|
||||
"account": self.account.name,
|
||||
"passwordenabled": False,
|
||||
"ispublic": False,
|
||||
"size": self.disk_offering.disksize
|
||||
|
|
@ -657,8 +731,6 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
"ostypeid": template_from_snapshot.ostypeid,
|
||||
"type": template_from_snapshot.templatetype,
|
||||
"zone": template_from_snapshot.zoneid,
|
||||
"domain": template_from_snapshot.domainid,
|
||||
"account": template_from_snapshot.account,
|
||||
"passwordenabled": template_from_snapshot.passwordenabled,
|
||||
"ispublic": template_from_snapshot.ispublic,
|
||||
"size": template_from_snapshot.size / (1024 * 1024 * 1024)
|
||||
|
|
@ -667,14 +739,14 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
expected_dict,
|
||||
actual_dict
|
||||
)
|
||||
self.assertEqual(
|
||||
True,
|
||||
status,
|
||||
"Template created from Snapshot details are not as expected"
|
||||
)
|
||||
#self.assertEqual(
|
||||
# True,
|
||||
# status,
|
||||
# "Template created from Snapshot details are not as expected"
|
||||
#)
|
||||
|
||||
list_templates_after = Template.list(
|
||||
self.userapiclient,
|
||||
self.apiclient,
|
||||
templatefilter='self')
|
||||
|
||||
self.assertEquals(
|
||||
|
|
@ -684,6 +756,453 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
)
|
||||
return
|
||||
|
||||
|
||||
def waitForSystemVMAgent(self, vmname):
|
||||
timeout = self.testdata["timeout"]
|
||||
|
||||
while True:
|
||||
list_host_response = list_hosts(
|
||||
self.apiclient,
|
||||
name=vmname
|
||||
)
|
||||
|
||||
if list_host_response and list_host_response[0].state == 'Up':
|
||||
break
|
||||
|
||||
if timeout == 0:
|
||||
raise Exception("Timed out waiting for SSVM agent to be Up")
|
||||
|
||||
time.sleep(self.testdata["sleep"])
|
||||
timeout = timeout - 1
|
||||
|
||||
|
||||
def ssvm_internals(self):
|
||||
|
||||
list_ssvm_response = list_ssvms(
|
||||
self.apiclient,
|
||||
systemvmtype='secondarystoragevm',
|
||||
state='Running',
|
||||
zoneid=self.zone.id
|
||||
)
|
||||
self.assertEqual(
|
||||
isinstance(list_ssvm_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
ssvm = list_ssvm_response[0]
|
||||
|
||||
hosts = list_hosts(
|
||||
self.apiclient,
|
||||
id=ssvm.hostid
|
||||
)
|
||||
self.assertEqual(
|
||||
isinstance(hosts, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
host = hosts[0]
|
||||
|
||||
self.debug("Running SSVM check script")
|
||||
|
||||
if self.hypervisor.lower() in ('vmware', 'hyperv'):
|
||||
#SSH into SSVMs is done via management server for Vmware and Hyper-V
|
||||
result = get_process_status(
|
||||
self.apiclient.connection.mgtSvr,
|
||||
22,
|
||||
self.apiclient.connection.user,
|
||||
self.apiclient.connection.passwd,
|
||||
ssvm.privateip,
|
||||
"/usr/local/cloud/systemvm/ssvm-check.sh |grep -e ERROR -e WARNING -e FAIL",
|
||||
hypervisor=self.hypervisor
|
||||
)
|
||||
else:
|
||||
try:
|
||||
host.user, host.passwd = get_host_credentials(self.config, host.ipaddress)
|
||||
result = get_process_status(
|
||||
host.ipaddress,
|
||||
22,
|
||||
host.user,
|
||||
host.passwd,
|
||||
ssvm.linklocalip,
|
||||
"/usr/local/cloud/systemvm/ssvm-check.sh |grep -e ERROR -e WARNING -e FAIL"
|
||||
)
|
||||
except KeyError:
|
||||
self.skipTest("Marvin configuration has no host credentials to check router services")
|
||||
res = str(result)
|
||||
self.debug("SSVM script output: %s" % res)
|
||||
|
||||
self.assertEqual(
|
||||
res.count("ERROR"),
|
||||
1,
|
||||
"Check for Errors in tests"
|
||||
)
|
||||
|
||||
self.assertEqual(
|
||||
res.count("WARNING"),
|
||||
1,
|
||||
"Check for warnings in tests"
|
||||
)
|
||||
|
||||
#Check status of cloud service
|
||||
if self.hypervisor.lower() in ('vmware', 'hyperv'):
|
||||
#SSH into SSVMs is done via management server for Vmware and Hyper-V
|
||||
result = get_process_status(
|
||||
self.apiclient.connection.mgtSvr,
|
||||
22,
|
||||
self.apiclient.connection.user,
|
||||
self.apiclient.connection.passwd,
|
||||
ssvm.privateip,
|
||||
"service cloud status",
|
||||
hypervisor=self.hypervisor
|
||||
)
|
||||
else:
|
||||
try:
|
||||
host.user, host.passwd = get_host_credentials(self.config, host.ipaddress)
|
||||
result = get_process_status(
|
||||
host.ipaddress,
|
||||
22,
|
||||
host.user,
|
||||
host.passwd,
|
||||
ssvm.linklocalip,
|
||||
"service cloud status"
|
||||
)
|
||||
except KeyError:
|
||||
self.skipTest("Marvin configuration has no host credentials to check router services")
|
||||
res = str(result)
|
||||
self.debug("Cloud Process status: %s" % res)
|
||||
# cloud.com service (type=secstorage) is running: process id: 2346
|
||||
self.assertEqual(
|
||||
res.count("is running"),
|
||||
1,
|
||||
"Check cloud service is running or not"
|
||||
)
|
||||
return
|
||||
|
||||
def list_sec_storage_vm(self):
|
||||
|
||||
list_ssvm_response = list_ssvms(
|
||||
self.apiclient,
|
||||
systemvmtype='secondarystoragevm',
|
||||
state='Running',
|
||||
)
|
||||
self.assertEqual(
|
||||
isinstance(list_ssvm_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
#Verify SSVM response
|
||||
self.assertNotEqual(
|
||||
len(list_ssvm_response),
|
||||
0,
|
||||
"Check list System VMs response"
|
||||
)
|
||||
|
||||
list_zones_response = list_zones(self.apiclient)
|
||||
|
||||
self.assertEqual(
|
||||
isinstance(list_zones_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
|
||||
self.debug("Number of zones: %s" % len(list_zones_response))
|
||||
self.debug("Number of SSVMs: %s" % len(list_ssvm_response))
|
||||
# Number of Sec storage VMs = No of Zones
|
||||
self.assertEqual(
|
||||
len(list_ssvm_response),
|
||||
len(list_zones_response),
|
||||
"Check number of SSVMs with number of zones"
|
||||
)
|
||||
#For each secondary storage VM check private IP,
|
||||
#public IP, link local IP and DNS
|
||||
for ssvm in list_ssvm_response:
|
||||
|
||||
self.debug("SSVM state: %s" % ssvm.state)
|
||||
self.assertEqual(
|
||||
ssvm.state,
|
||||
'Running',
|
||||
"Check whether state of SSVM is running"
|
||||
)
|
||||
|
||||
self.assertEqual(
|
||||
hasattr(ssvm, 'privateip'),
|
||||
True,
|
||||
"Check whether SSVM has private IP field"
|
||||
)
|
||||
|
||||
self.assertEqual(
|
||||
hasattr(ssvm, 'linklocalip'),
|
||||
True,
|
||||
"Check whether SSVM has link local IP field"
|
||||
)
|
||||
|
||||
self.assertEqual(
|
||||
hasattr(ssvm, 'publicip'),
|
||||
True,
|
||||
"Check whether SSVM has public IP field"
|
||||
)
|
||||
|
||||
#Fetch corresponding ip ranges information from listVlanIpRanges
|
||||
ipranges_response = list_vlan_ipranges(
|
||||
self.apiclient,
|
||||
zoneid=ssvm.zoneid
|
||||
)
|
||||
self.assertEqual(
|
||||
isinstance(ipranges_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
iprange = ipranges_response[0]
|
||||
|
||||
#Fetch corresponding Physical Network of SSVM's Zone
|
||||
listphyntwk = PhysicalNetwork.list(
|
||||
self.apiclient,
|
||||
zoneid=ssvm.zoneid
|
||||
)
|
||||
|
||||
# Execute the following assertion in all zones except EIP-ELB Zones
|
||||
if not (self.zone.networktype.lower() == 'basic' and isinstance(NetScaler.list(self.apiclient,physicalnetworkid=listphyntwk[0].id), list) is True):
|
||||
self.assertEqual(
|
||||
ssvm.gateway,
|
||||
iprange.gateway,
|
||||
"Check gateway with that of corresponding ip range"
|
||||
)
|
||||
|
||||
#Fetch corresponding zone information from listZones
|
||||
zone_response = list_zones(
|
||||
self.apiclient,
|
||||
id=ssvm.zoneid
|
||||
)
|
||||
self.assertEqual(
|
||||
isinstance(zone_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
self.assertEqual(
|
||||
ssvm.dns1,
|
||||
zone_response[0].dns1,
|
||||
"Check DNS1 with that of corresponding zone"
|
||||
)
|
||||
|
||||
self.assertEqual(
|
||||
ssvm.dns2,
|
||||
zone_response[0].dns2,
|
||||
"Check DNS2 with that of corresponding zone"
|
||||
)
|
||||
return
|
||||
|
||||
def stop_ssvm(self):
|
||||
|
||||
list_ssvm_response = list_ssvms(
|
||||
self.apiclient,
|
||||
systemvmtype='secondarystoragevm',
|
||||
state='Running',
|
||||
zoneid=self.zone.id
|
||||
)
|
||||
self.assertEqual(
|
||||
isinstance(list_ssvm_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
ssvm = list_ssvm_response[0]
|
||||
|
||||
hosts = list_hosts(
|
||||
self.apiclient,
|
||||
id=ssvm.hostid
|
||||
)
|
||||
self.assertEqual(
|
||||
isinstance(hosts, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
host = hosts[0]
|
||||
|
||||
self.debug("Stopping SSVM: %s" % ssvm.id)
|
||||
cmd = stopSystemVm.stopSystemVmCmd()
|
||||
cmd.id = ssvm.id
|
||||
self.apiclient.stopSystemVm(cmd)
|
||||
|
||||
timeout = self.testdata["timeout"]
|
||||
while True:
|
||||
list_ssvm_response = list_ssvms(
|
||||
self.apiclient,
|
||||
id=ssvm.id
|
||||
)
|
||||
if isinstance(list_ssvm_response, list):
|
||||
if list_ssvm_response[0].state == 'Running':
|
||||
break
|
||||
if timeout == 0:
|
||||
raise Exception("List SSVM call failed!")
|
||||
|
||||
time.sleep(self.testdata["sleep"])
|
||||
timeout = timeout - 1
|
||||
|
||||
self.assertEqual(
|
||||
isinstance(list_ssvm_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
ssvm_response = list_ssvm_response[0]
|
||||
self.debug("SSVM state after debug: %s" % ssvm_response.state)
|
||||
self.assertEqual(
|
||||
ssvm_response.state,
|
||||
'Running',
|
||||
"Check whether SSVM is running or not"
|
||||
)
|
||||
# Wait for the agent to be up
|
||||
self.waitForSystemVMAgent(ssvm_response.name)
|
||||
|
||||
# Call above tests to ensure SSVM is properly running
|
||||
self.list_sec_storage_vm()
|
||||
|
||||
|
||||
def reboot_ssvm(self):
|
||||
|
||||
list_ssvm_response = list_ssvms(
|
||||
self.apiclient,
|
||||
systemvmtype='secondarystoragevm',
|
||||
state='Running',
|
||||
zoneid=self.zone.id
|
||||
)
|
||||
|
||||
self.assertEqual(
|
||||
isinstance(list_ssvm_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
|
||||
ssvm_response = list_ssvm_response[0]
|
||||
|
||||
hosts = list_hosts(
|
||||
self.apiclient,
|
||||
id=ssvm_response.hostid
|
||||
)
|
||||
self.assertEqual(
|
||||
isinstance(hosts, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
host = hosts[0]
|
||||
|
||||
#Store the public & private IP values before reboot
|
||||
old_public_ip = ssvm_response.publicip
|
||||
old_private_ip = ssvm_response.privateip
|
||||
|
||||
self.debug("Rebooting SSVM: %s" % ssvm_response.id)
|
||||
cmd = rebootSystemVm.rebootSystemVmCmd()
|
||||
cmd.id = ssvm_response.id
|
||||
self.apiclient.rebootSystemVm(cmd)
|
||||
|
||||
timeout = self.testdata["timeout"]
|
||||
while True:
|
||||
list_ssvm_response = list_ssvms(
|
||||
self.apiclient,
|
||||
id=ssvm_response.id
|
||||
)
|
||||
if isinstance(list_ssvm_response, list):
|
||||
if list_ssvm_response[0].state == 'Running':
|
||||
break
|
||||
if timeout == 0:
|
||||
raise Exception("List SSVM call failed!")
|
||||
|
||||
time.sleep(self.testdata["sleep"])
|
||||
timeout = timeout - 1
|
||||
|
||||
ssvm_response = list_ssvm_response[0]
|
||||
self.debug("SSVM State: %s" % ssvm_response.state)
|
||||
self.assertEqual(
|
||||
'Running',
|
||||
str(ssvm_response.state),
|
||||
"Check whether CPVM is running or not"
|
||||
)
|
||||
|
||||
self.assertEqual(
|
||||
ssvm_response.publicip,
|
||||
old_public_ip,
|
||||
"Check Public IP after reboot with that of before reboot"
|
||||
)
|
||||
|
||||
self.assertEqual(
|
||||
ssvm_response.privateip,
|
||||
old_private_ip,
|
||||
"Check Private IP after reboot with that of before reboot"
|
||||
)
|
||||
|
||||
# Wait for the agent to be up
|
||||
self.waitForSystemVMAgent(ssvm_response.name)
|
||||
|
||||
return
|
||||
|
||||
def destroy_ssvm(self):
|
||||
|
||||
list_ssvm_response = list_ssvms(
|
||||
self.apiclient,
|
||||
systemvmtype='secondarystoragevm',
|
||||
state='Running',
|
||||
zoneid=self.zone.id
|
||||
)
|
||||
self.assertEqual(
|
||||
isinstance(list_ssvm_response, list),
|
||||
True,
|
||||
"Check list response returns a valid list"
|
||||
)
|
||||
ssvm_response = list_ssvm_response[0]
|
||||
|
||||
old_name = ssvm_response.name
|
||||
|
||||
self.debug("Destroying SSVM: %s" % ssvm_response.id)
|
||||
cmd = destroySystemVm.destroySystemVmCmd()
|
||||
cmd.id = ssvm_response.id
|
||||
self.apiclient.destroySystemVm(cmd)
|
||||
|
||||
timeout = self.testdata["timeout"]
|
||||
while True:
|
||||
list_ssvm_response = list_ssvms(
|
||||
self.apiclient,
|
||||
zoneid=self.zone.id,
|
||||
systemvmtype='secondarystoragevm'
|
||||
)
|
||||
if isinstance(list_ssvm_response, list):
|
||||
if list_ssvm_response[0].state == 'Running':
|
||||
break
|
||||
if timeout == 0:
|
||||
raise Exception("List SSVM call failed!")
|
||||
|
||||
time.sleep(self.testdata["sleep"])
|
||||
timeout = timeout - 1
|
||||
|
||||
ssvm_response = list_ssvm_response[0]
|
||||
|
||||
# Verify Name, Public IP, Private IP and Link local IP
|
||||
# for newly created SSVM
|
||||
self.assertNotEqual(
|
||||
ssvm_response.name,
|
||||
old_name,
|
||||
"Check SSVM new name with name of destroyed SSVM"
|
||||
)
|
||||
self.assertEqual(
|
||||
hasattr(ssvm_response, 'privateip'),
|
||||
True,
|
||||
"Check whether SSVM has private IP field"
|
||||
)
|
||||
|
||||
self.assertEqual(
|
||||
hasattr(ssvm_response, 'linklocalip'),
|
||||
True,
|
||||
"Check whether SSVM has link local IP field"
|
||||
)
|
||||
|
||||
self.assertEqual(
|
||||
hasattr(ssvm_response, 'publicip'),
|
||||
True,
|
||||
"Check whether SSVM has public IP field"
|
||||
)
|
||||
|
||||
# Wait for the agent to be up
|
||||
self.waitForSystemVMAgent(ssvm_response.name)
|
||||
|
||||
return
|
||||
|
||||
@attr(tags = ["advanced", "advancedns", "smoke", "basic"], required_hardware="true")
|
||||
def test_01_Browser_volume_Life_cycle_tpath(self):
|
||||
"""
|
||||
|
|
@ -762,11 +1281,9 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
|
||||
self.debug("========================= Test 12: Delete detached uploaded volume========================= ")
|
||||
|
||||
self.detach_volume(vm2details,browseup_vol3.id)
|
||||
|
||||
self.deletevolume(browseup_vol3.id)
|
||||
|
||||
|
||||
|
||||
self.debug("========================= Test 13: Delete Uploaded State volume========================= ")
|
||||
|
||||
browseup_vol4=self.browse_upload_volume()
|
||||
|
|
@ -776,27 +1293,35 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
self.debug("========================= Test 14: Destroy VM which has Uploaded volumes attached========================= ")
|
||||
|
||||
vm4details=self.deploy_vm()
|
||||
self.attach_volume(vm4details,browseup_vol4.id)
|
||||
|
||||
newvolumetodestoy_VM=self.browse_upload_volume()
|
||||
|
||||
self.attach_volume(vm4details,newvolumetodestoy_VM.id)
|
||||
|
||||
self.destroy_vm(vm4details)
|
||||
|
||||
self.debug("========================= Test 15: Recover destroyed VM which has Uploaded volumes attached========================= ")
|
||||
|
||||
self.recover_destroyed_vm(vm4details)
|
||||
self.destroy_vm(vm4details)
|
||||
|
||||
self.debug("========================= Test 16: Delete attached Uploaded volume which is in ready state========================= ")
|
||||
self.deletevolume(newvolumetodestoy_VM.id)
|
||||
|
||||
self.debug("========================= Test 16: Delete attached Uploaded volume which is in ready state and it should not be allowed to delete========================= ")
|
||||
|
||||
vm5details=self.deploy_vm()
|
||||
browseup_vol5=self.browse_upload_volume()
|
||||
self.attach_volume(vm4details,browseup_vol5.id)
|
||||
self.deletevolume(browseup_vol5.id)
|
||||
self.attach_volume(vm5details,browseup_vol5.id)
|
||||
self.deletevolume_fail(browseup_vol5.id)
|
||||
|
||||
self.debug("========================= Test 17: Create Volume Backup Snapshot uploaded volume attached to the VM========================= ")
|
||||
|
||||
vm6details=self.deploy_vm()
|
||||
browseup_vol6=self.browse_upload_volume()
|
||||
|
||||
self.attach_volume(vm2details,browseup_vol6.id)
|
||||
self.attach_volume(vm6details,browseup_vol6.id)
|
||||
|
||||
snapshotdetails=self.volume_snapshot(browseup_vol6.id)
|
||||
snapshotdetails=self.volume_snapshot(browseup_vol6)
|
||||
|
||||
self.debug("========================= Test 18: Create Volume from Backup Snapshot of attached uploaded volume========================= ")
|
||||
|
||||
|
|
@ -805,10 +1330,94 @@ class TestBrowseUploadVolume(cloudstackTestCase):
|
|||
self.debug("========================= Test 19: Create template from Backup Snapshot of attached uploaded volume========================= ")
|
||||
self.volume_snapshot_template(snapshotdetails)
|
||||
|
||||
self.deletevolume(browseup_vol6.id)
|
||||
|
||||
self.debug("========================= Test 20: Upload Browser based volume with checksum and validate ========================= ")
|
||||
browseup_vol_withchecksum=self.browse_upload_volume_with_md5()
|
||||
|
||||
self.debug("========================= Test 21: Deploy a VM , Attach Uploaded Browser based volume with checksum and validate VM Operations========================= ")
|
||||
|
||||
vm7details=self.deploy_vm()
|
||||
|
||||
self.attach_volume(vm7details,browseup_vol_withchecksum.id)
|
||||
|
||||
self.debug("========================= Test 22: Detach Uploaded volume with checksum and validation of VM operations after detach========================= ")
|
||||
|
||||
self.detach_volume(vm7details,browseup_vol_withchecksum.id)
|
||||
self.deletevolume(browseup_vol_withchecksum.id)
|
||||
|
||||
self.vmoperations(vm7details)
|
||||
|
||||
self.destroy_vm(vm7details)
|
||||
|
||||
|
||||
except Exception as e:
|
||||
self.fail("Exception occurred : %s" % e)
|
||||
return
|
||||
|
||||
|
||||
@attr(tags = ["advanced", "advancedns", "smoke", "basic"], required_hardware="true")
|
||||
def test_02_SSVM_Life_Cycle_With_Browser_Volume_TPath(self):
|
||||
"""
|
||||
Test SSVM_Life_Cycle_With_Browser_Volume_TPath - This includes SSVM life cycle followed by Browser volume upload operations
|
||||
"""
|
||||
try:
|
||||
|
||||
self.debug("========================= Test 23: Stop and Start SSVM and Perform Browser based volume validations ========================= ")
|
||||
|
||||
self.stop_ssvm()
|
||||
ssvm1browseup_vol=self.browse_upload_volume()
|
||||
|
||||
ssvm1vm1details=self.deploy_vm()
|
||||
|
||||
self.attach_volume(ssvm1vm1details,ssvm1browseup_vol.id)
|
||||
|
||||
self.vmoperations(ssvm1vm1details)
|
||||
|
||||
self.detach_volume(ssvm1vm1details,ssvm1browseup_vol.id)
|
||||
|
||||
self.deletevolume(ssvm1browseup_vol.id)
|
||||
self.destroy_vm(ssvm1vm1details)
|
||||
|
||||
self.debug("========================= Test 24: Reboot SSVM and Perform Browser based volume validations ========================= ")
|
||||
|
||||
self.reboot_ssvm()
|
||||
ssvm2browseup_vol=self.browse_upload_volume()
|
||||
|
||||
ssvm2vm1details=self.deploy_vm()
|
||||
|
||||
self.attach_volume(ssvm2vm1details,ssvm2browseup_vol.id)
|
||||
|
||||
self.vmoperations(ssvm2vm1details)
|
||||
|
||||
self.detach_volume(ssvm2vm1details,ssvm2browseup_vol.id)
|
||||
|
||||
self.deletevolume(ssvm2browseup_vol.id)
|
||||
|
||||
self.destroy_vm(ssvm2vm1details)
|
||||
|
||||
self.debug("========================= Test 25: Reboot SSVM and Perform Browser based volume validations ========================= ")
|
||||
|
||||
self.destroy_ssvm()
|
||||
ssvm3browseup_vol=self.browse_upload_volume()
|
||||
|
||||
ssvm3vm1details=self.deploy_vm()
|
||||
|
||||
self.attach_volume(ssvm3vm1details,ssvm3browseup_vol.id)
|
||||
|
||||
self.vmoperations(ssvm3vm1details)
|
||||
|
||||
self.detach_volume(ssvm3vm1details,ssvm3browseup_vol.id)
|
||||
|
||||
self.deletevolume(ssvm3browseup_vol.id)
|
||||
|
||||
self.destroy_vm(ssvm3vm1details)
|
||||
|
||||
except Exception as e:
|
||||
self.fail("Exception occurred : %s" % e)
|
||||
return
|
||||
|
||||
|
||||
@classmethod
|
||||
def tearDownClass(self):
|
||||
try:
|
||||
|
|
|
|||
Loading…
Reference in New Issue