diff --git a/cinder/tests/zonemanager/test_volume_manager_fc.py b/cinder/tests/zonemanager/test_volume_manager_fc.py index a4d3ce3a5d4..5cc5a7078d6 100644 --- a/cinder/tests/zonemanager/test_volume_manager_fc.py +++ b/cinder/tests/zonemanager/test_volume_manager_fc.py @@ -119,7 +119,7 @@ class TestVolumeManager(manager.VolumeManager, test.TestCase): with mock.patch.object(manager.VolumeManager, '_add_or_delete_fc_connection')\ as add_del_conn_mock: - self.terminate_connection(None, None, None, False) + self.terminate_connection(self.context_mock, None, None, False) add_del_conn_mock.assert_called_once_with(conn_info, 0) @mock.patch.object(utils, 'require_driver_initialized') @@ -131,7 +131,7 @@ class TestVolumeManager(manager.VolumeManager, test.TestCase): as add_del_conn_mock: self.configuration.zoning_mode = 'none' self.zonemanager = None - self.terminate_connection(None, None, None, False) + self.terminate_connection(self.context_mock, None, None, False) assert not add_del_conn_mock.called @mock.patch.object(utils, 'require_driver_initialized') @@ -142,7 +142,7 @@ class TestVolumeManager(manager.VolumeManager, test.TestCase): with mock.patch.object(manager.VolumeManager, '_add_or_delete_fc_connection')\ as add_del_conn_mock: - self.terminate_connection(None, None, None, False) + self.terminate_connection(self.context_mock, None, None, False) assert not add_del_conn_mock.called @mock.patch.object(fc_zone_manager.ZoneManager, 'add_connection') diff --git a/cinder/volume/manager.py b/cinder/volume/manager.py index 5f6b6f57d00..8916effb3e3 100644 --- a/cinder/volume/manager.py +++ b/cinder/volume/manager.py @@ -779,7 +779,8 @@ class VolumeManager(manager.SchedulerDependentManager): model_update = None try: LOG.debug(_("Volume %s: creating export"), volume_id) - model_update = self.driver.create_export(context, volume) + model_update = self.driver.create_export(context.elevated(), + volume) if model_update: volume = self.db.volume_update(context, volume_id, @@ -798,7 +799,7 @@ class VolumeManager(manager.SchedulerDependentManager): 'backend: %(err)s') % {'err': err}) LOG.error(err_msg) - self.driver.remove_export(context, volume) + self.driver.remove_export(context.elevated(), volume) raise exception.VolumeBackendAPIException(data=err_msg) @@ -867,7 +868,7 @@ class VolumeManager(manager.SchedulerDependentManager): try: LOG.debug(_("volume %s: removing export"), volume_id) - self.driver.remove_export(context, volume_ref) + self.driver.remove_export(context.elevated(), volume_ref) except Exception as ex: LOG.exception(_("Error detaching volume %(volume)s, " "due to remove export failure."),