mirror of
https://github.com/apache/cloudstack.git
synced 2025-10-26 08:42:29 +01:00
1474 lines
61 KiB
Python
1474 lines
61 KiB
Python
# -*- encoding: utf-8 -*-
|
|
# Copyright 2012 Citrix Systems, Inc. Licensed under the
|
|
# Apache License, Version 2.0 (the "License"); you may not use this
|
|
# file except in compliance with the License. Citrix Systems, Inc.
|
|
# reserves all rights not expressly granted by the License.
|
|
# You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
#
|
|
# Automatically generated by addcopyright.py at 04/03/2012
|
|
""" P1 tests for Resource limits
|
|
"""
|
|
#Import Local Modules
|
|
import marvin
|
|
from marvin.cloudstackTestCase import *
|
|
from marvin.cloudstackAPI import *
|
|
from integration.lib.utils import *
|
|
from integration.lib.base import *
|
|
from integration.lib.common import *
|
|
import datetime
|
|
|
|
class Services:
|
|
"""Test Resource Limits Services
|
|
"""
|
|
|
|
def __init__(self):
|
|
self.services = {
|
|
"domain": {
|
|
"name": "Domain",
|
|
},
|
|
"account": {
|
|
"email": "test@test.com",
|
|
"firstname": "Test",
|
|
"lastname": "User",
|
|
"username": "test",
|
|
# Random characters are appended for unique
|
|
# username
|
|
"password": "fr3sca",
|
|
},
|
|
"service_offering": {
|
|
"name": "Tiny Instance",
|
|
"displaytext": "Tiny Instance",
|
|
"cpunumber": 1,
|
|
"cpuspeed": 100, # in MHz
|
|
"memory": 64, # In MBs
|
|
},
|
|
"disk_offering": {
|
|
"displaytext": "Small",
|
|
"name": "Small",
|
|
"disksize": 1
|
|
},
|
|
"volume": {
|
|
"diskname": "TestDiskServ",
|
|
},
|
|
"server": {
|
|
"displayname": "TestVM",
|
|
"username": "root",
|
|
"password": "password",
|
|
"ssh_port": 22,
|
|
"hypervisor": 'XenServer',
|
|
"privateport": 22,
|
|
"publicport": 22,
|
|
"protocol": 'TCP',
|
|
},
|
|
"template": {
|
|
"displaytext": "Cent OS Template",
|
|
"name": "Cent OS Template",
|
|
"ostypeid": '144f66aa-7f74-4cfe-9799-80cc21439cb3',
|
|
"templatefilter": 'self',
|
|
},
|
|
"ostypeid": '144f66aa-7f74-4cfe-9799-80cc21439cb3',
|
|
# Cent OS 5.3 (64 bit)
|
|
"sleep": 60,
|
|
"timeout": 10,
|
|
"mode": 'advanced',
|
|
}
|
|
|
|
class TestResourceLimitsAccount(cloudstackTestCase):
|
|
|
|
@classmethod
|
|
def setUpClass(cls):
|
|
cls.api_client = super(TestResourceLimitsAccount, cls).getClsTestClient().getApiClient()
|
|
cls.services = Services().services
|
|
# Get Zone, Domain and templates
|
|
cls.domain = get_domain(cls.api_client, cls.services)
|
|
cls.zone = get_zone(cls.api_client, cls.services)
|
|
|
|
cls.template = get_template(
|
|
cls.api_client,
|
|
cls.zone.id,
|
|
cls.services["ostypeid"]
|
|
)
|
|
cls.services["server"]["zoneid"] = cls.zone.id
|
|
|
|
# Create Account, VMs etc
|
|
cls.account_1 = Account.create(
|
|
cls.api_client,
|
|
cls.services["account"],
|
|
domainid=cls.domain.id
|
|
)
|
|
# Create Account, VMs etc
|
|
cls.account_2 = Account.create(
|
|
cls.api_client,
|
|
cls.services["account"],
|
|
domainid=cls.domain.id
|
|
)
|
|
|
|
cls.service_offering = ServiceOffering.create(
|
|
cls.api_client,
|
|
cls.services["service_offering"]
|
|
)
|
|
cls.disk_offering = DiskOffering.create(
|
|
cls.api_client,
|
|
cls.services["disk_offering"]
|
|
)
|
|
cls._cleanup = [
|
|
cls.disk_offering,
|
|
cls.service_offering,
|
|
cls.account_1,
|
|
cls.account_2
|
|
]
|
|
return
|
|
|
|
@classmethod
|
|
def tearDownClass(cls):
|
|
try:
|
|
#Cleanup resources used
|
|
cleanup_resources(cls.api_client, cls._cleanup)
|
|
except Exception as e:
|
|
raise Exception("Warning: Exception during cleanup : %s" % e)
|
|
return
|
|
|
|
def setUp(self):
|
|
self.apiclient = self.testClient.getApiClient()
|
|
self.dbclient = self.testClient.getDbConnection()
|
|
self.cleanup = []
|
|
return
|
|
|
|
def tearDown(self):
|
|
try:
|
|
#Clean up, terminate the created instance, volumes and snapshots
|
|
cleanup_resources(self.apiclient, self.cleanup)
|
|
except Exception as e:
|
|
raise Exception("Warning: Exception during cleanup : %s" % e)
|
|
return
|
|
|
|
def test_01_vm_per_account(self):
|
|
"""Test VM limit per account
|
|
"""
|
|
|
|
# Validate the following
|
|
# 1. Set user_vm=1 limit for account 1.
|
|
# 2. Try to start 2 VMs account 1. Verify start of second VM is denied
|
|
# for this account.
|
|
# 3. Try to start 2 VMs account 2. Verify 2 SM are started properly
|
|
|
|
self.debug(
|
|
"Updating instance resource limit for account: %s" %
|
|
self.account_1.account.name)
|
|
# Set usage_vm=1 for Account 1
|
|
update_resource_limit(
|
|
self.apiclient,
|
|
0, # Instance
|
|
account=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
max=1
|
|
)
|
|
self.debug(
|
|
"Deploying VM instance in account: %s" %
|
|
self.account_1.account.name)
|
|
|
|
virtual_machine = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine)
|
|
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
|
|
# Exception should be raised for second instance (account_1)
|
|
with self.assertRaises(Exception):
|
|
VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.debug(
|
|
"Deploying VM instance in account: %s" %
|
|
self.account_2.account.name)
|
|
# Start 2 instances for account_2
|
|
virtual_machine_1 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account_2.account.name,
|
|
domainid=self.account_2.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_1)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_1.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
|
|
self.debug(
|
|
"Deploying VM instance in account: %s" %
|
|
self.account_2.account.name)
|
|
virtual_machine_2 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account_2.account.name,
|
|
domainid=self.account_2.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_2)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_2.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
return
|
|
|
|
def test_02_publicip_per_account(self):
|
|
"""Test Public IP limit per account
|
|
"""
|
|
|
|
# Validate the following
|
|
# 1. Set Public_IP= 2 limit for account 1.
|
|
# 2. start 1 VMs account 1
|
|
# 3. start 1 VMs account 2
|
|
# 4. Acquire 2 IP in account 1. Verify account with limit should be
|
|
# denied to acquire more than one IP.
|
|
# 5. Acquire 2 IP in account 2. Verify account 2 should be able to
|
|
# Acquire IP without any warning
|
|
|
|
self.debug(
|
|
"Updating public IP resource limit for account: %s" %
|
|
self.account_1.account.name)
|
|
# Set usage_vm=1 for Account 1
|
|
update_resource_limit(
|
|
self.apiclient,
|
|
1, # Public Ip
|
|
account=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
max=2
|
|
)
|
|
|
|
self.debug(
|
|
"Deploying VM instance in account: %s" %
|
|
self.account_1.account.name)
|
|
virtual_machine_1 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_1)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_1.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
|
|
self.debug(
|
|
"Deploying VM instance in account: %s" %
|
|
self.account_2.account.name)
|
|
# Create VM for second account
|
|
virtual_machine_2 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account_2.account.name,
|
|
domainid=self.account_2.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_2)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_2.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
self.debug(
|
|
"Associating public IP for account: %s" %
|
|
virtual_machine_1.account)
|
|
public_ip_1 = PublicIPAddress.create(
|
|
self.apiclient,
|
|
virtual_machine_1.account,
|
|
virtual_machine_1.zoneid,
|
|
virtual_machine_1.domainid,
|
|
self.services["server"]
|
|
)
|
|
self.cleanup.append(public_ip_1)
|
|
|
|
# Sleep to ensure that state is reflected across all the calls
|
|
time.sleep(self.services["sleep"])
|
|
|
|
# Verify Public IP state
|
|
self.assertEqual(
|
|
public_ip_1.ipaddress.state in [
|
|
'Allocated',
|
|
'Allocating'
|
|
],
|
|
True,
|
|
"Check Public IP state is allocated or not"
|
|
)
|
|
|
|
# Exception should be raised for second instance (account_1)
|
|
with self.assertRaises(Exception):
|
|
public_ip_2 = PublicIPAddress.create(
|
|
self.apiclient,
|
|
virtual_machine_1.account,
|
|
virtual_machine_1.zoneid,
|
|
virtual_machine_1.domainid,
|
|
self.services["server"]
|
|
)
|
|
|
|
self.debug(
|
|
"Associating public IP for account: %s" %
|
|
virtual_machine_2.account)
|
|
# Assign Public IP for account 2
|
|
public_ip_3 = PublicIPAddress.create(
|
|
self.apiclient,
|
|
virtual_machine_2.account,
|
|
virtual_machine_2.zoneid,
|
|
virtual_machine_2.domainid,
|
|
self.services["server"]
|
|
)
|
|
self.cleanup.append(public_ip_3)
|
|
|
|
# Verify Public IP state
|
|
self.assertEqual(
|
|
public_ip_3.ipaddress.state in [
|
|
'Allocated',
|
|
'Allocating'
|
|
],
|
|
True,
|
|
"Check Public IP state is allocated or not"
|
|
)
|
|
self.debug(
|
|
"Associating public IP for account: %s" %
|
|
virtual_machine_2.account)
|
|
public_ip_4 = PublicIPAddress.create(
|
|
self.apiclient,
|
|
virtual_machine_2.account,
|
|
virtual_machine_2.zoneid,
|
|
virtual_machine_2.domainid,
|
|
self.services["server"]
|
|
)
|
|
self.cleanup.append(public_ip_4)
|
|
# Verify Public IP state
|
|
self.assertEqual(
|
|
public_ip_4.ipaddress.state in [
|
|
'Allocated',
|
|
'Allocating'
|
|
],
|
|
True,
|
|
"Check Public IP state is allocated or not"
|
|
)
|
|
return
|
|
|
|
def test_03_snapshots_per_account(self):
|
|
"""Test Snapshot limit per account
|
|
"""
|
|
|
|
# Validate the following
|
|
# 1. Set snapshot= 2 limit for account 1.
|
|
# 2. start 1 VMs account 1
|
|
# 3. start 1 VMs account 2
|
|
# 4. Create 2 snapshot in account 1. Verify account with limit should
|
|
# be denied to create more than one snapshot.
|
|
# 5. Create 2 snapshot in account 2. Verify account 2 should be able to
|
|
# create snapshots without any warning
|
|
|
|
self.debug(
|
|
"Updating public IP resource limit for account: %s" %
|
|
self.account_1.account.name)
|
|
# Set usage_vm=1 for Account 1
|
|
update_resource_limit(
|
|
self.apiclient,
|
|
3, # Snapshot
|
|
account=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
max=1
|
|
)
|
|
|
|
self.debug(
|
|
"Deploying VM instance in account: %s" %
|
|
self.account_1.account.name)
|
|
virtual_machine_1 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_1)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_1.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
|
|
self.debug(
|
|
"Deploying VM instance in account: %s" %
|
|
self.account_1.account.name)
|
|
# Create VM for second account
|
|
virtual_machine_2 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account_2.account.name,
|
|
domainid=self.account_2.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_2)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_2.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
|
|
# Get the Root disk of VM
|
|
volumes = list_volumes(
|
|
self.apiclient,
|
|
virtualmachineid=virtual_machine_1.id,
|
|
type='ROOT',
|
|
listall=True
|
|
)
|
|
self.assertEqual(
|
|
isinstance(volumes, list),
|
|
True,
|
|
"Check for list volume response return valid data"
|
|
)
|
|
volume = volumes[0]
|
|
|
|
self.debug("Creating snapshot from volume: %s" % volumes[0].id)
|
|
# Create a snapshot from the ROOTDISK (Account 1)
|
|
snapshot_1 = Snapshot.create(self.apiclient,
|
|
volumes[0].id,
|
|
account=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
)
|
|
self.cleanup.append(snapshot_1)
|
|
# Verify Snapshot state
|
|
self.assertEqual(
|
|
snapshot_1.state in [
|
|
'BackedUp',
|
|
'CreatedOnPrimary'
|
|
],
|
|
True,
|
|
"Check Snapshot state is Running or not"
|
|
)
|
|
|
|
# Exception should be raised for second snapshot (account_1)
|
|
with self.assertRaises(Exception):
|
|
Snapshot.create(self.apiclient,
|
|
volumes[0].id,
|
|
account=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
)
|
|
|
|
# Get the Root disk of VM
|
|
volumes = list_volumes(
|
|
self.apiclient,
|
|
virtualmachineid=virtual_machine_2.id,
|
|
type='ROOT',
|
|
listall=True
|
|
)
|
|
self.assertEqual(
|
|
isinstance(volumes, list),
|
|
True,
|
|
"Check for list volume response return valid data"
|
|
)
|
|
volume = volumes[0]
|
|
|
|
self.debug("Creating snapshot from volume: %s" % volumes[0].id)
|
|
# Create a snapshot from the ROOTDISK (Account 2)
|
|
snapshot_2 = Snapshot.create(self.apiclient,
|
|
volumes[0].id,
|
|
account=self.account_2.account.name,
|
|
domainid=self.account_2.account.domainid,
|
|
)
|
|
self.cleanup.append(snapshot_2)
|
|
# Verify Snapshot state
|
|
self.assertEqual(
|
|
snapshot_2.state in [
|
|
'BackedUp',
|
|
'CreatedOnPrimary'
|
|
],
|
|
True,
|
|
"Check Snapshot state is Running or not"
|
|
)
|
|
|
|
self.debug("Creating snapshot from volume: %s" % volumes[0].id)
|
|
# Create a second snapshot from the ROOTDISK (Account 2)
|
|
snapshot_3 = Snapshot.create(self.apiclient,
|
|
volumes[0].id,
|
|
account=self.account_2.account.name,
|
|
domainid=self.account_2.account.domainid,
|
|
)
|
|
self.cleanup.append(snapshot_3)
|
|
# Verify Snapshot state
|
|
self.assertEqual(
|
|
snapshot_3.state in [
|
|
'BackedUp',
|
|
'CreatedOnPrimary'
|
|
],
|
|
True,
|
|
"Check Snapshot state is Running or not"
|
|
)
|
|
return
|
|
|
|
def test_04_volumes_per_account(self):
|
|
"""Test Volumes limit per account
|
|
"""
|
|
|
|
# Validate the following
|
|
# 1. Set volumes=2 limit for account 1.
|
|
# 2. Start 1 VMs account 1
|
|
# 3. Start 1 VMs account 2
|
|
# 4. Create 2 volumes in account 1. Verify account with limit should be
|
|
# denied to create more than one volume.
|
|
# 5. Create 2 volumes in account 2. Verify account 2 should be able to
|
|
# create Volume without any warning
|
|
|
|
self.debug(
|
|
"Updating volume resource limit for account: %s" %
|
|
self.account_1.account.name)
|
|
# Set usage_vm=1 for Account 1
|
|
update_resource_limit(
|
|
self.apiclient,
|
|
2, # Volume
|
|
account=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
max=2
|
|
)
|
|
|
|
self.debug(
|
|
"Deploying VM for account: %s" % self.account_1.account.name)
|
|
|
|
virtual_machine_1 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_1)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_1.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
|
|
self.debug(
|
|
"Deploying VM for account: %s" % self.account_2.account.name)
|
|
|
|
# Create VM for second account
|
|
virtual_machine_2 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account_2.account.name,
|
|
domainid=self.account_2.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_2)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_2.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
|
|
self.debug(
|
|
"Create a data volume for account: %s" % self.account_1.account.name)
|
|
volume_1 = Volume.create(
|
|
self.apiclient,
|
|
self.services["volume"],
|
|
zoneid=self.zone.id,
|
|
account=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
diskofferingid=self.disk_offering.id
|
|
)
|
|
self.cleanup.append(volume_1)
|
|
# Verify Volume state
|
|
self.assertEqual(
|
|
volume_1.state in [
|
|
'Allocated',
|
|
'Ready'
|
|
],
|
|
True,
|
|
"Check Volume state is Ready or not"
|
|
)
|
|
|
|
# Exception should be raised for second snapshot (account_1)
|
|
with self.assertRaises(Exception):
|
|
Volume.create(
|
|
self.apiclient,
|
|
self.services["volume"],
|
|
zoneid=self.zone.id,
|
|
account=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
diskofferingid=self.disk_offering.id
|
|
)
|
|
|
|
self.debug(
|
|
"Create a data volume for account: %s" % self.account_2.account.name)
|
|
# Create volume for Account 2
|
|
volume_2 = Volume.create(
|
|
self.apiclient,
|
|
self.services["volume"],
|
|
zoneid=self.zone.id,
|
|
account=self.account_2.account.name,
|
|
domainid=self.account_2.account.domainid,
|
|
diskofferingid=self.disk_offering.id
|
|
)
|
|
self.cleanup.append(volume_2)
|
|
# Verify Volume state
|
|
self.assertEqual(
|
|
volume_2.state in [
|
|
'Allocated',
|
|
'Ready'
|
|
],
|
|
True,
|
|
"Check Volume state is Ready or not"
|
|
)
|
|
|
|
self.debug(
|
|
"Create a data volume for account: %s" % self.account_2.account.name)
|
|
# Create a second volume from the ROOTDISK (Account 2)
|
|
volume_3 = Volume.create(
|
|
self.apiclient,
|
|
self.services["volume"],
|
|
zoneid=self.zone.id,
|
|
account=self.account_2.account.name,
|
|
domainid=self.account_2.account.domainid,
|
|
diskofferingid=self.disk_offering.id
|
|
)
|
|
self.cleanup.append(volume_3)
|
|
# Verify Volume state
|
|
self.assertEqual(
|
|
volume_3.state in [
|
|
'Allocated',
|
|
'Ready'
|
|
],
|
|
True,
|
|
"Check Volume state is Ready or not"
|
|
)
|
|
return
|
|
|
|
def test_05_templates_per_account(self):
|
|
"""Test Templates limit per account
|
|
"""
|
|
|
|
# Validate the following
|
|
# 1. Set templates=1 limit for account 1.
|
|
# 2. Try to create 2 templates in account 1. Verify account with limit
|
|
# should be denied to create more than 1 template.
|
|
# 3. Try to create 2 templates in account 2. Verify account 2 should be
|
|
# able to create template without any error
|
|
|
|
self.debug(
|
|
"Updating template resource limit for account: %s" %
|
|
self.account_1.account.name)
|
|
# Set usage_vm=1 for Account 1
|
|
update_resource_limit(
|
|
self.apiclient,
|
|
4, # Template
|
|
account=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
max=1
|
|
)
|
|
|
|
self.debug(
|
|
"Updating volume resource limit for account: %s" %
|
|
self.account_1.account.name)
|
|
virtual_machine_1 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_1)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_1.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
|
|
self.debug(
|
|
"Deploying virtual machine for account: %s" %
|
|
self.account_2.account.name)
|
|
# Create VM for second account
|
|
virtual_machine_2 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account_2.account.name,
|
|
domainid=self.account_2.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_2)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_2.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
|
|
virtual_machine_1.stop(self.apiclient)
|
|
# Get the Root disk of VM
|
|
volumes = list_volumes(
|
|
self.apiclient,
|
|
virtualmachineid=virtual_machine_1.id,
|
|
type='ROOT',
|
|
listall=True
|
|
)
|
|
self.assertEqual(
|
|
isinstance(volumes, list),
|
|
True,
|
|
"Check for list volume response return valid data"
|
|
)
|
|
volume = volumes[0]
|
|
|
|
self.debug(
|
|
"Creating template from volume: %s" % volume.id)
|
|
# Create a template from the ROOTDISK (Account 1)
|
|
template_1 = Template.create(
|
|
self.apiclient,
|
|
self.services["template"],
|
|
volumeid=volume.id,
|
|
account=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
)
|
|
|
|
self.cleanup.append(template_1)
|
|
# Verify Template state
|
|
self.assertEqual(
|
|
template_1.isready,
|
|
True,
|
|
"Check Template is in ready state or not"
|
|
)
|
|
|
|
# Exception should be raised for second snapshot (account_1)
|
|
with self.assertRaises(Exception):
|
|
Template.create(
|
|
self.apiclient,
|
|
self.services["template"],
|
|
volumeid=volume.id,
|
|
account=self.account_1.account.name,
|
|
domainid=self.account_1.account.domainid,
|
|
)
|
|
virtual_machine_2.stop(self.apiclient)
|
|
# Get the Root disk of VM
|
|
volumes = list_volumes(
|
|
self.apiclient,
|
|
virtualmachineid=virtual_machine_2.id,
|
|
type='ROOT',
|
|
listall=True
|
|
)
|
|
self.assertEqual(
|
|
isinstance(volumes, list),
|
|
True,
|
|
"Check for list volume response return valid data"
|
|
)
|
|
volume = volumes[0]
|
|
|
|
self.debug(
|
|
"Creating template from volume: %s" % volume.id)
|
|
# Create a snapshot from the ROOTDISK (Account 1)
|
|
template_2 = Template.create(
|
|
self.apiclient,
|
|
self.services["template"],
|
|
volumeid=volume.id,
|
|
account=self.account_2.account.name,
|
|
domainid=self.account_2.account.domainid,
|
|
)
|
|
|
|
self.cleanup.append(template_2)
|
|
# Verify Template state
|
|
self.assertEqual(
|
|
template_2.isready,
|
|
True,
|
|
"Check Template is in ready state or not"
|
|
)
|
|
self.debug(
|
|
"Creating template from volume: %s" % volume.id)
|
|
# Create a second volume from the ROOTDISK (Account 2)
|
|
template_3 = Template.create(
|
|
self.apiclient,
|
|
self.services["template"],
|
|
volumeid=volume.id,
|
|
account=self.account_2.account.name,
|
|
domainid=self.account_2.account.domainid,
|
|
)
|
|
|
|
self.cleanup.append(template_3)
|
|
# Verify Template state
|
|
self.assertEqual(
|
|
template_3.isready,
|
|
True,
|
|
"Check Template is in ready state or not"
|
|
)
|
|
return
|
|
|
|
|
|
class TestResourceLimitsDomain(cloudstackTestCase):
|
|
|
|
@classmethod
|
|
def setUpClass(cls):
|
|
cls.api_client = super(TestResourceLimitsDomain, cls).getClsTestClient().getApiClient()
|
|
cls.services = Services().services
|
|
# Get Zone, Domain and templates
|
|
cls.zone = get_zone(cls.api_client, cls.services)
|
|
|
|
cls.template = get_template(
|
|
cls.api_client,
|
|
cls.zone.id,
|
|
cls.services["ostypeid"]
|
|
)
|
|
cls.services["server"]["zoneid"] = cls.zone.id
|
|
|
|
# Create Domains, Account etc
|
|
cls.domain = Domain.create(
|
|
cls.api_client,
|
|
cls.services["domain"]
|
|
)
|
|
|
|
cls.account = Account.create(
|
|
cls.api_client,
|
|
cls.services["account"],
|
|
domainid=cls.domain.id
|
|
)
|
|
|
|
cls.services["account"] = cls.account.account.name
|
|
|
|
# Create Service offering and disk offerings etc
|
|
cls.service_offering = ServiceOffering.create(
|
|
cls.api_client,
|
|
cls.services["service_offering"]
|
|
)
|
|
cls.disk_offering = DiskOffering.create(
|
|
cls.api_client,
|
|
cls.services["disk_offering"]
|
|
)
|
|
cls._cleanup = [
|
|
cls.service_offering,
|
|
cls.disk_offering,
|
|
cls.account,
|
|
cls.domain
|
|
]
|
|
return
|
|
|
|
@classmethod
|
|
def tearDownClass(cls):
|
|
try:
|
|
#Cleanup resources used
|
|
cleanup_resources(cls.api_client, cls._cleanup)
|
|
except Exception as e:
|
|
raise Exception("Warning: Exception during cleanup : %s" % e)
|
|
return
|
|
|
|
def setUp(self):
|
|
self.apiclient = self.testClient.getApiClient()
|
|
self.dbclient = self.testClient.getDbConnection()
|
|
self.cleanup = []
|
|
return
|
|
|
|
def tearDown(self):
|
|
try:
|
|
#Clean up, terminate the created instance, volumes and snapshots
|
|
cleanup_resources(self.apiclient, self.cleanup)
|
|
except Exception as e:
|
|
raise Exception("Warning: Exception during cleanup : %s" % e)
|
|
return
|
|
|
|
def test_01_vm_per_domain(self):
|
|
"""Test VM limit per domain
|
|
"""
|
|
|
|
# Validate the following
|
|
# 1. Set max VM per domain to 2
|
|
# 2. Create account and start 2 VMs. Verify VM state is Up and Running
|
|
# 3. Try to create 3rd VM instance. The appropriate error or alert
|
|
# should be raised
|
|
|
|
self.debug(
|
|
"Updating instance resource limits for domain: %s" %
|
|
self.account.account.domainid)
|
|
# Set usage_vm=1 for Account 1
|
|
update_resource_limit(
|
|
self.apiclient,
|
|
0, # Instance
|
|
domainid=self.account.account.domainid,
|
|
max=2
|
|
)
|
|
|
|
self.debug("Deploying VM for account: %s" % self.account.account.name)
|
|
virtual_machine_1 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account.account.name,
|
|
domainid=self.account.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_1)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_1.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
self.debug("Deploying VM for account: %s" % self.account.account.name)
|
|
virtual_machine_2 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account.account.name,
|
|
domainid=self.account.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_2)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_2.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
# Exception should be raised for second instance
|
|
with self.assertRaises(Exception):
|
|
VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account_1.account.name,
|
|
domainid=self.account.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
return
|
|
|
|
def test_01_publicip_per_domain(self):
|
|
"""Test Public IP limit per domain
|
|
"""
|
|
|
|
# Validate the following
|
|
# 1. set max no of IPs per domain to 2.
|
|
# 2. Create an account in this domain
|
|
# 3. Create 1 VM in this domain
|
|
# 4. Acquire 1 IP in the domain. IP should be successfully acquired
|
|
# 5. Try to acquire 3rd IP in this domain. It should give the user an
|
|
# appropriate error and an alert should be generated.
|
|
|
|
self.debug(
|
|
"Updating public IP resource limits for domain: %s" %
|
|
self.account.account.domainid)
|
|
# Set usage_vm=1 for Account 1
|
|
update_resource_limit(
|
|
self.apiclient,
|
|
1, # Public Ip
|
|
domainid=self.account.account.domainid,
|
|
max=2
|
|
)
|
|
|
|
self.debug("Deploying VM for account: %s" % self.account.account.name)
|
|
virtual_machine_1 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account.account.name,
|
|
domainid=self.account.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_1)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_1.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
self.debug("Associating public IP for account: %s" % self.account.account.name)
|
|
public_ip_1 = PublicIPAddress.create(
|
|
self.apiclient,
|
|
virtual_machine_1.account,
|
|
virtual_machine_1.zoneid,
|
|
virtual_machine_1.domainid,
|
|
self.services["server"]
|
|
)
|
|
self.cleanup.append(public_ip_1)
|
|
# Verify Public IP state
|
|
self.assertEqual(
|
|
public_ip_1.ipaddress.state in [
|
|
'Allocated',
|
|
'Allocating'
|
|
],
|
|
True,
|
|
"Check Public IP state is allocated or not"
|
|
)
|
|
|
|
# Exception should be raised for second Public IP
|
|
with self.assertRaises(Exception):
|
|
public_ip_2 = PublicIPAddress.create(
|
|
self.apiclient,
|
|
virtual_machine_1.account,
|
|
virtual_machine_1.zoneid,
|
|
virtual_machine_1.domainid,
|
|
self.services["server"]
|
|
)
|
|
return
|
|
|
|
def test_03_snapshots_per_domain(self):
|
|
"""Test Snapshot limit per domain
|
|
"""
|
|
|
|
# Validate the following
|
|
# 1. set max no of snapshots per domain to 1.
|
|
# 2. Create an account in this domain
|
|
# 3. Create 1 VM in this domain
|
|
# 4. Create one snapshot in the domain. Snapshot should be successfully
|
|
# created
|
|
# 5. Try to create another snapshot in this domain. It should give the
|
|
# user an appropriate error and an alert should be generated.
|
|
|
|
self.debug(
|
|
"Updating snapshot resource limits for domain: %s" %
|
|
self.account.account.domainid)
|
|
# Set usage_vm=1 for Account 1
|
|
update_resource_limit(
|
|
self.apiclient,
|
|
3, # Snapshot
|
|
domainid=self.account.account.domainid,
|
|
max=1
|
|
)
|
|
|
|
self.debug("Deploying VM for account: %s" % self.account.account.name)
|
|
virtual_machine_1 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account.account.name,
|
|
domainid=self.account.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_1)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_1.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
|
|
# Get the Root disk of VM
|
|
volumes = list_volumes(
|
|
self.apiclient,
|
|
virtualmachineid=virtual_machine_1.id,
|
|
type='ROOT',
|
|
listall=True
|
|
)
|
|
self.assertEqual(
|
|
isinstance(volumes, list),
|
|
True,
|
|
"Check for list volume response return valid data"
|
|
)
|
|
volume = volumes[0]
|
|
|
|
self.debug("Creating snapshot from volume: %s" % volumes[0].id)
|
|
# Create a snapshot from the ROOTDISK
|
|
snapshot_1 = Snapshot.create(self.apiclient,
|
|
volumes[0].id,
|
|
account=self.account.account.name,
|
|
domainid=self.account.account.domainid,
|
|
)
|
|
self.cleanup.append(snapshot_1)
|
|
# Verify Snapshot state
|
|
self.assertEqual(
|
|
snapshot_1.state in [
|
|
'BackedUp',
|
|
'CreatedOnPrimary'
|
|
],
|
|
True,
|
|
"Check Snapshot state is Running or not"
|
|
)
|
|
|
|
# Exception should be raised for second snapshot
|
|
with self.assertRaises(Exception):
|
|
Snapshot.create(self.apiclient,
|
|
volumes[0].id,
|
|
account=self.account.account.name,
|
|
domainid=self.account.account.domainid,
|
|
)
|
|
return
|
|
|
|
def test_04_volumes_per_domain(self):
|
|
"""Test Volumes limit per domain
|
|
"""
|
|
|
|
# Validate the following
|
|
# 1. set max no of volume per domain to 1.
|
|
# 2. Create an account in this domain
|
|
# 3. Create 1 VM in this domain
|
|
# 4. Try to Create another VM in the domain. It should give the user an
|
|
# appropriate error that Volume limit is exhausted and an alert
|
|
# should be generated.
|
|
|
|
self.debug(
|
|
"Updating volume resource limits for domain: %s" %
|
|
self.account.account.domainid)
|
|
# Set usage_vm=1 for Account 1
|
|
update_resource_limit(
|
|
self.apiclient,
|
|
2, # Volume
|
|
domainid=self.account.account.domainid,
|
|
max=2
|
|
)
|
|
|
|
self.debug("Deploying VM for account: %s" % self.account.account.name)
|
|
virtual_machine_1 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account.account.name,
|
|
domainid=self.account.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_1)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_1.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
|
|
# Exception should be raised for second volume
|
|
with self.assertRaises(Exception):
|
|
Volume.create(
|
|
self.apiclient,
|
|
self.services["volume"],
|
|
zoneid=self.zone.id,
|
|
account=self.account.account.name,
|
|
domainid=self.account.account.domainid,
|
|
diskofferingid=self.disk_offering.id
|
|
)
|
|
return
|
|
|
|
def test_05_templates_per_domain(self):
|
|
"""Test Templates limit per domain
|
|
"""
|
|
|
|
# Validate the following
|
|
# 1. set max no of templates per domain to 2.
|
|
# 2. Create an account in this domain
|
|
# 3. Create 2 templates in this domain. Both template should be in
|
|
# ready state
|
|
# 4. Try create 3rd template in the domain. It should give the user an
|
|
# appropriate error and an alert should be generated.
|
|
|
|
# Set usage_vm=1 for Account 1
|
|
update_resource_limit(
|
|
self.apiclient,
|
|
2, # Volume
|
|
domainid=self.account.account.domainid,
|
|
max=5
|
|
)
|
|
|
|
self.debug(
|
|
"Updating template resource limits for domain: %s" %
|
|
self.account.account.domainid)
|
|
# Set usage_vm=1 for Account 1
|
|
update_resource_limit(
|
|
self.apiclient,
|
|
4, # Template
|
|
domainid=self.account.account.domainid,
|
|
max=2
|
|
)
|
|
|
|
self.debug("Deploying VM for account: %s" % self.account.account.name)
|
|
virtual_machine_1 = VirtualMachine.create(
|
|
self.apiclient,
|
|
self.services["server"],
|
|
templateid=self.template.id,
|
|
accountid=self.account.account.name,
|
|
domainid=self.account.account.domainid,
|
|
serviceofferingid=self.service_offering.id
|
|
)
|
|
self.cleanup.append(virtual_machine_1)
|
|
# Verify VM state
|
|
self.assertEqual(
|
|
virtual_machine_1.state,
|
|
'Running',
|
|
"Check VM state is Running or not"
|
|
)
|
|
virtual_machine_1.stop(self.apiclient)
|
|
# Get the Root disk of VM
|
|
volumes = list_volumes(
|
|
self.apiclient,
|
|
virtualmachineid=virtual_machine_1.id,
|
|
type='ROOT',
|
|
listall=True
|
|
)
|
|
self.assertEqual(
|
|
isinstance(volumes, list),
|
|
True,
|
|
"Check for list volume response return valid data"
|
|
)
|
|
volume = volumes[0]
|
|
|
|
self.debug("Creating template from volume: %s" % volume.id)
|
|
# Create a template from the ROOTDISK
|
|
template_1 = Template.create(
|
|
self.apiclient,
|
|
self.services["template"],
|
|
volumeid=volume.id,
|
|
account=self.account.account.name,
|
|
domainid=self.account.account.domainid,
|
|
)
|
|
|
|
self.cleanup.append(template_1)
|
|
# Verify Template state
|
|
self.assertEqual(
|
|
template_1.isready,
|
|
True,
|
|
"Check Template is in ready state or not"
|
|
)
|
|
self.debug("Creating template from volume: %s" % volume.id)
|
|
# Create a template from the ROOTDISK
|
|
template_2 = Template.create(
|
|
self.apiclient,
|
|
self.services["template"],
|
|
volumeid=volume.id,
|
|
account=self.account.account.name,
|
|
domainid=self.account.account.domainid,
|
|
)
|
|
|
|
self.cleanup.append(template_2)
|
|
# Verify Template state
|
|
self.assertEqual(
|
|
template_2.isready,
|
|
True,
|
|
"Check Template is in ready state or not"
|
|
)
|
|
|
|
# Exception should be raised for second template
|
|
with self.assertRaises(Exception):
|
|
Template.create(
|
|
self.apiclient,
|
|
self.services["template"],
|
|
volumeid=volume.id,
|
|
account=self.account.account.name,
|
|
domainid=self.account.account.domainid,
|
|
)
|
|
return
|
|
|
|
|
|
class TestResources(cloudstackTestCase):
|
|
|
|
@classmethod
|
|
def setUpClass(cls):
|
|
cls.api_client = super(
|
|
TestResources,
|
|
cls
|
|
).getClsTestClient().getApiClient()
|
|
cls.services = Services().services
|
|
# Get Zone, Domain and templates
|
|
cls.zone = get_zone(cls.api_client, cls.services)
|
|
cls._cleanup = []
|
|
return
|
|
|
|
@classmethod
|
|
def tearDownClass(cls):
|
|
try:
|
|
#Cleanup resources used
|
|
cleanup_resources(cls.api_client, cls._cleanup)
|
|
except Exception as e:
|
|
raise Exception("Warning: Exception during cleanup : %s" % e)
|
|
return
|
|
|
|
def setUp(self):
|
|
self.apiclient = self.testClient.getApiClient()
|
|
self.dbclient = self.testClient.getDbConnection()
|
|
self.cleanup = []
|
|
return
|
|
|
|
def tearDown(self):
|
|
try:
|
|
#Clean up, terminate the created instance, volumes and snapshots
|
|
cleanup_resources(self.apiclient, self.cleanup)
|
|
except Exception as e:
|
|
raise Exception("Warning: Exception during cleanup : %s" % e)
|
|
return
|
|
|
|
def test_01_zones(self):
|
|
"""Check the status of zones"""
|
|
|
|
# Validate the following
|
|
# 1. List zones
|
|
# 2. Check allocation state is "enabled" or not
|
|
|
|
zones = Zone.list(
|
|
self.apiclient,
|
|
id=self.zone.id,
|
|
listall=True
|
|
)
|
|
self.assertEqual(
|
|
isinstance(zones, list),
|
|
True,
|
|
"Check if listZones returns a valid response"
|
|
)
|
|
for zone in zones:
|
|
self.assertEqual(
|
|
zone.allocationstate,
|
|
'Enabled',
|
|
"Zone allocation state should be enabled"
|
|
)
|
|
return
|
|
|
|
def test_02_pods(self):
|
|
"""Check the status of pods"""
|
|
|
|
# Validate the following
|
|
# 1. List pods
|
|
# 2. Check allocation state is "enabled" or not
|
|
|
|
pods = Pod.list(
|
|
self.apiclient,
|
|
zoneid=self.zone.id,
|
|
listall=True
|
|
)
|
|
self.assertEqual(
|
|
isinstance(pods, list),
|
|
True,
|
|
"Check if listPods returns a valid response"
|
|
)
|
|
for pod in pods:
|
|
self.assertEqual(
|
|
pod.allocationstate,
|
|
'Enabled',
|
|
"Pods allocation state should be enabled"
|
|
)
|
|
return
|
|
|
|
def test_03_clusters(self):
|
|
"""Check the status of clusters"""
|
|
|
|
# Validate the following
|
|
# 1. List clusters
|
|
# 2. Check allocation state is "enabled" or not
|
|
|
|
clusters = Cluster.list(
|
|
self.apiclient,
|
|
zoneid=self.zone.id,
|
|
listall=True
|
|
)
|
|
self.assertEqual(
|
|
isinstance(clusters, list),
|
|
True,
|
|
"Check if listClusters returns a valid response"
|
|
)
|
|
for cluster in clusters:
|
|
self.assertEqual(
|
|
cluster.allocationstate,
|
|
'Enabled',
|
|
"Clusters allocation state should be enabled"
|
|
)
|
|
return
|
|
|
|
def test_04_hosts(self):
|
|
"""Check the status of hosts"""
|
|
|
|
# Validate the following
|
|
# 1. List hosts with type=Routing
|
|
# 2. Check state is "Up" or not
|
|
|
|
hosts = Host.list(
|
|
self.apiclient,
|
|
zoneid=self.zone.id,
|
|
type='Routing',
|
|
listall=True
|
|
)
|
|
self.assertEqual(
|
|
isinstance(hosts, list),
|
|
True,
|
|
"Check if listHosts returns a valid response"
|
|
)
|
|
for host in hosts:
|
|
self.assertEqual(
|
|
host.state,
|
|
'Up',
|
|
"Host should be in Up state and running"
|
|
)
|
|
return
|
|
|
|
def test_05_storage_pools(self):
|
|
"""Check the status of Storage pools"""
|
|
|
|
# Validate the following
|
|
# 1. List storage pools for the zone
|
|
# 2. Check state is "enabled" or not
|
|
|
|
storage_pools = StoragePool.list(
|
|
self.apiclient,
|
|
zoneid=self.zone.id,
|
|
listall=True
|
|
)
|
|
self.assertEqual(
|
|
isinstance(storage_pools, list),
|
|
True,
|
|
"Check if listStoragePools returns a valid response"
|
|
)
|
|
for storage_pool in storage_pools:
|
|
self.assertEqual(
|
|
storage_pool.state,
|
|
'Up',
|
|
"storage pool should be in Up state and running"
|
|
)
|
|
return
|
|
|
|
def test_06_secondary_storage(self):
|
|
"""Check the status of secondary storage"""
|
|
|
|
# Validate the following
|
|
# 1. List secondary storage
|
|
# 2. Check state is "Up" or not
|
|
|
|
sec_storages = Host.list(
|
|
self.apiclient,
|
|
zoneid=self.zone.id,
|
|
type='SecondaryStorage',
|
|
listall=True
|
|
)
|
|
self.assertEqual(
|
|
isinstance(sec_storages, list),
|
|
True,
|
|
"Check if listHosts returns a valid response"
|
|
)
|
|
for sec_storage in sec_storages:
|
|
self.assertEqual(
|
|
sec_storage.state,
|
|
'Up',
|
|
"Secondary storage should be in Up state"
|
|
)
|
|
return
|