Merge "Trim 50s from huawei ISCSIDriver unit tests"

This commit is contained in:
Jenkins 2016-03-02 05:52:29 +00:00 committed by Gerrit Code Review
commit 52e51cf53e

View File

@ -25,11 +25,13 @@ from oslo_log import log as logging
from cinder import exception from cinder import exception
from cinder import test from cinder import test
from cinder.tests.unit import utils
from cinder.volume import configuration as conf from cinder.volume import configuration as conf
from cinder.volume.drivers.huawei import constants from cinder.volume.drivers.huawei import constants
from cinder.volume.drivers.huawei import fc_zone_helper from cinder.volume.drivers.huawei import fc_zone_helper
from cinder.volume.drivers.huawei import huawei_conf from cinder.volume.drivers.huawei import huawei_conf
from cinder.volume.drivers.huawei import huawei_driver from cinder.volume.drivers.huawei import huawei_driver
from cinder.volume.drivers.huawei import huawei_utils
from cinder.volume.drivers.huawei import hypermetro from cinder.volume.drivers.huawei import hypermetro
from cinder.volume.drivers.huawei import replication from cinder.volume.drivers.huawei import replication
from cinder.volume.drivers.huawei import rest_client from cinder.volume.drivers.huawei import rest_client
@ -2777,11 +2779,16 @@ class HuaweiISCSIDriverTestCase(test.TestCase):
common_driver = replication.ReplicaCommonDriver(self.configuration, op) common_driver = replication.ReplicaCommonDriver(self.configuration, op)
self.mock_object(replication.PairOp, 'get_replica_info', self.mock_object(replication.PairOp, 'get_replica_info',
mock.Mock(return_value={'SECRESACCESS': access_ro})) mock.Mock(return_value={'SECRESACCESS': access_ro}))
self.mock_object(huawei_utils.time, 'time', mock.Mock(
side_effect = utils.generate_timeout_series(
constants.DEFAULT_REPLICA_WAIT_TIMEOUT)))
common_driver.wait_second_access(pair_id, access_ro) common_driver.wait_second_access(pair_id, access_ro)
self.assertRaises(exception.VolumeBackendAPIException, self.assertRaises(exception.VolumeBackendAPIException,
common_driver.wait_second_access, pair_id, access_rw) common_driver.wait_second_access, pair_id, access_rw)
@mock.patch('oslo_service.loopingcall.FixedIntervalLoopingCall',
new=utils.ZeroIntervalLoopingCall)
def test_wait_replica_ready(self): def test_wait_replica_ready(self):
normal_status = { normal_status = {
'RUNNINGSTATUS': constants.REPLICA_RUNNING_STATUS_NORMAL, 'RUNNINGSTATUS': constants.REPLICA_RUNNING_STATUS_NORMAL,
@ -2840,11 +2847,19 @@ class HuaweiISCSIDriverTestCase(test.TestCase):
@ddt.unpack @ddt.unpack
def test_replication_enable_fail(self, mock_module, mock_func, mock_value): def test_replication_enable_fail(self, mock_module, mock_func, mock_value):
self.mock_object(mock_module, mock_func, mock_value) self.mock_object(mock_module, mock_func, mock_value)
self.mock_object(huawei_utils.time, 'time', mock.Mock(
side_effect = utils.generate_timeout_series(
constants.DEFAULT_REPLICA_WAIT_TIMEOUT)))
self.assertRaises( self.assertRaises(
exception.VolumeBackendAPIException, exception.VolumeBackendAPIException,
self.driver.replication_enable, None, replication_volume) self.driver.replication_enable, None, replication_volume)
def test_replication_disable_fail(self): def test_replication_disable_fail(self):
self.mock_object(huawei_utils.time, 'time', mock.Mock(
side_effect = utils.generate_timeout_series(
constants.DEFAULT_REPLICA_WAIT_TIMEOUT)))
self.assertRaises( self.assertRaises(
exception.VolumeBackendAPIException, exception.VolumeBackendAPIException,
self.driver.replication_disable, None, replication_volume) self.driver.replication_disable, None, replication_volume)
@ -2901,6 +2916,10 @@ class HuaweiISCSIDriverTestCase(test.TestCase):
mock.Mock( mock.Mock(
side_effect=exception.VolumeBackendAPIException(data="error"))) side_effect=exception.VolumeBackendAPIException(data="error")))
self.mock_object(mock_module, mock_func, mock_value) self.mock_object(mock_module, mock_func, mock_value)
self.mock_object(huawei_utils.time, 'time', mock.Mock(
side_effect = utils.generate_timeout_series(
constants.DEFAULT_REPLICA_WAIT_TIMEOUT)))
self.assertRaises( self.assertRaises(
exception.VolumeBackendAPIException, exception.VolumeBackendAPIException,
self.driver.replication_failover, self.driver.replication_failover,