Merge "libvirt: Remove unreachable native QEMU iSCSI initiator config code"
This commit is contained in:
@@ -14,7 +14,6 @@ import mock
|
|||||||
|
|
||||||
import nova.conf
|
import nova.conf
|
||||||
from nova.tests.unit.virt.libvirt.volume import test_volume
|
from nova.tests.unit.virt.libvirt.volume import test_volume
|
||||||
from nova.virt.libvirt import host
|
|
||||||
from nova.virt.libvirt.volume import net
|
from nova.virt.libvirt.volume import net
|
||||||
|
|
||||||
CONF = nova.conf.CONF
|
CONF = nova.conf.CONF
|
||||||
@@ -220,28 +219,6 @@ class LibvirtNetVolumeDriverTestCase(
|
|||||||
libvirt_driver.disconnect_volume(connection_info,
|
libvirt_driver.disconnect_volume(connection_info,
|
||||||
mock.sentinel.instance)
|
mock.sentinel.instance)
|
||||||
|
|
||||||
@mock.patch.object(host.Host, 'find_secret')
|
|
||||||
@mock.patch.object(host.Host, 'create_secret')
|
|
||||||
@mock.patch.object(host.Host, 'delete_secret')
|
|
||||||
def test_libvirt_iscsi_net_driver(self, mock_delete, mock_create,
|
|
||||||
mock_find):
|
|
||||||
mock_find.return_value = test_volume.FakeSecret()
|
|
||||||
mock_create.return_value = test_volume.FakeSecret()
|
|
||||||
libvirt_driver = net.LibvirtNetVolumeDriver(self.fake_host)
|
|
||||||
connection_info = self.iscsi_connection(self.vol, self.location,
|
|
||||||
self.iqn, auth=True)
|
|
||||||
secret_type = 'iscsi'
|
|
||||||
flags_user = connection_info['data']['auth_username']
|
|
||||||
conf = libvirt_driver.get_config(connection_info, self.disk_info)
|
|
||||||
tree = conf.format_dom()
|
|
||||||
self._assertISCSINetworkAndProtocolEquals(tree)
|
|
||||||
self.assertEqual(flags_user, tree.find('./auth').get('username'))
|
|
||||||
self.assertEqual(secret_type, tree.find('./auth/secret').get('type'))
|
|
||||||
self.assertEqual(test_volume.SECRET_UUID,
|
|
||||||
tree.find('./auth/secret').get('uuid'))
|
|
||||||
libvirt_driver.disconnect_volume(connection_info,
|
|
||||||
mock.sentinel.instance)
|
|
||||||
|
|
||||||
def test_extend_volume(self):
|
def test_extend_volume(self):
|
||||||
device_path = '/dev/fake-dev'
|
device_path = '/dev/fake-dev'
|
||||||
connection_info = {'data': {'device_path': device_path}}
|
connection_info = {'data': {'device_path': device_path}}
|
||||||
|
|||||||
@@ -13,9 +13,6 @@
|
|||||||
from oslo_log import log as logging
|
from oslo_log import log as logging
|
||||||
|
|
||||||
import nova.conf
|
import nova.conf
|
||||||
from nova import exception
|
|
||||||
from nova.i18n import _
|
|
||||||
from nova import utils
|
|
||||||
from nova.virt.libvirt.volume import volume as libvirt_volume
|
from nova.virt.libvirt.volume import volume as libvirt_volume
|
||||||
|
|
||||||
|
|
||||||
@@ -29,30 +26,6 @@ class LibvirtNetVolumeDriver(libvirt_volume.LibvirtBaseVolumeDriver):
|
|||||||
super(LibvirtNetVolumeDriver,
|
super(LibvirtNetVolumeDriver,
|
||||||
self).__init__(host, is_block_dev=False)
|
self).__init__(host, is_block_dev=False)
|
||||||
|
|
||||||
def _get_secret_uuid(self, conf, password=None):
|
|
||||||
# TODO(mriedem): Add delegation methods to connection (LibvirtDriver)
|
|
||||||
# to call through for these secret CRUD operations so the volume driver
|
|
||||||
# doesn't need to know the internal attributes of the connection
|
|
||||||
# object.
|
|
||||||
secret = self.host.find_secret(conf.source_protocol,
|
|
||||||
conf.source_name)
|
|
||||||
if secret is None:
|
|
||||||
secret = self.host.create_secret(conf.source_protocol,
|
|
||||||
conf.source_name,
|
|
||||||
password)
|
|
||||||
return secret.UUIDString()
|
|
||||||
|
|
||||||
def _delete_secret_by_name(self, connection_info):
|
|
||||||
source_protocol = connection_info['driver_volume_type']
|
|
||||||
netdisk_properties = connection_info['data']
|
|
||||||
if source_protocol == 'rbd':
|
|
||||||
return
|
|
||||||
elif source_protocol == 'iscsi':
|
|
||||||
usage_type = 'iscsi'
|
|
||||||
usage_name = ("%(target_iqn)s/%(target_lun)s" %
|
|
||||||
netdisk_properties)
|
|
||||||
self.host.delete_secret(usage_type, usage_name)
|
|
||||||
|
|
||||||
def _set_auth_config_rbd(self, conf, netdisk_properties):
|
def _set_auth_config_rbd(self, conf, netdisk_properties):
|
||||||
# The rbd volume driver in cinder sets auth_enabled if the rbd_user is
|
# The rbd volume driver in cinder sets auth_enabled if the rbd_user is
|
||||||
# set in cinder. The rbd auth values from the cinder connection take
|
# set in cinder. The rbd auth values from the cinder connection take
|
||||||
@@ -94,13 +67,6 @@ class LibvirtNetVolumeDriver(libvirt_volume.LibvirtBaseVolumeDriver):
|
|||||||
# secret_type is always hard-coded to 'ceph' in cinder
|
# secret_type is always hard-coded to 'ceph' in cinder
|
||||||
conf.auth_secret_type = netdisk_properties['secret_type']
|
conf.auth_secret_type = netdisk_properties['secret_type']
|
||||||
|
|
||||||
def _set_auth_config_iscsi(self, conf, netdisk_properties):
|
|
||||||
if netdisk_properties.get('auth_method') == 'CHAP':
|
|
||||||
conf.auth_secret_type = 'iscsi'
|
|
||||||
password = netdisk_properties.get('auth_password')
|
|
||||||
conf.auth_secret_uuid = self._get_secret_uuid(conf, password)
|
|
||||||
conf.auth_username = netdisk_properties['auth_username']
|
|
||||||
|
|
||||||
def get_config(self, connection_info, disk_info):
|
def get_config(self, connection_info, disk_info):
|
||||||
"""Returns xml for libvirt."""
|
"""Returns xml for libvirt."""
|
||||||
conf = super(LibvirtNetVolumeDriver,
|
conf = super(LibvirtNetVolumeDriver,
|
||||||
@@ -114,28 +80,8 @@ class LibvirtNetVolumeDriver(libvirt_volume.LibvirtBaseVolumeDriver):
|
|||||||
conf.source_ports = netdisk_properties.get('ports', [])
|
conf.source_ports = netdisk_properties.get('ports', [])
|
||||||
if conf.source_protocol == 'rbd':
|
if conf.source_protocol == 'rbd':
|
||||||
self._set_auth_config_rbd(conf, netdisk_properties)
|
self._set_auth_config_rbd(conf, netdisk_properties)
|
||||||
elif conf.source_protocol == 'iscsi':
|
|
||||||
try:
|
|
||||||
conf.source_name = ("%(target_iqn)s/%(target_lun)s" %
|
|
||||||
netdisk_properties)
|
|
||||||
target_portal = netdisk_properties['target_portal']
|
|
||||||
except KeyError:
|
|
||||||
raise exception.InternalError(_("Invalid volume source data"))
|
|
||||||
|
|
||||||
ip, port = utils.parse_server_string(target_portal)
|
|
||||||
if ip == '' or port == '':
|
|
||||||
raise exception.InternalError(_("Invalid target_lun"))
|
|
||||||
conf.source_hosts = [ip]
|
|
||||||
conf.source_ports = [port]
|
|
||||||
self._set_auth_config_iscsi(conf, netdisk_properties)
|
|
||||||
return conf
|
return conf
|
||||||
|
|
||||||
def disconnect_volume(self, connection_info, instance):
|
|
||||||
"""Detach the volume from instance_name."""
|
|
||||||
super(LibvirtNetVolumeDriver,
|
|
||||||
self).disconnect_volume(connection_info, instance)
|
|
||||||
self._delete_secret_by_name(connection_info)
|
|
||||||
|
|
||||||
def extend_volume(self, connection_info, instance, requested_size):
|
def extend_volume(self, connection_info, instance, requested_size):
|
||||||
# There is nothing to do for network volumes. Cinder already extended
|
# There is nothing to do for network volumes. Cinder already extended
|
||||||
# the volume and there is no local block device which needs to be
|
# the volume and there is no local block device which needs to be
|
||||||
|
|||||||
Reference in New Issue
Block a user