Remove Infortrend drivers
The Infortrend drivers were marked as deprecated and unsupported in Pike due to lack of CI. This situation has not changed and they will now be removed. Change-Id: I0f1d12776cfa553b117c5b3698b2ae0c9c88735e
This commit is contained in:
Sean McGinnis
parent
9e164a2acc
commit
3b68a9eaf1
@ -1276,12 +1276,6 @@ class XtremIOSnapshotsLimitExceeded(VolumeDriverException):
|
|||||||
message = _("Exceeded the limit of snapshots per volume")
|
message = _("Exceeded the limit of snapshots per volume")
|
||||||
|
|
||||||
|
|
||||||
# Infortrend EonStor DS Driver
|
|
||||||
class InfortrendCliException(VolumeDriverException):
|
|
||||||
message = _("Infortrend CLI exception: %(err)s Param: %(param)s "
|
|
||||||
"(Return Code: %(rc)s) (Output: %(out)s)")
|
|
||||||
|
|
||||||
|
|
||||||
# DOTHILL drivers
|
# DOTHILL drivers
|
||||||
class DotHillInvalidBackend(VolumeDriverException):
|
class DotHillInvalidBackend(VolumeDriverException):
|
||||||
message = _("Backend doesn't exist (%(backend)s)")
|
message = _("Backend doesn't exist (%(backend)s)")
|
||||||
|
|||||||
@ -143,8 +143,6 @@ from cinder.volume.drivers.ibm.storwize_svc import storwize_svc_fc as \
|
|||||||
from cinder.volume.drivers.ibm.storwize_svc import storwize_svc_iscsi as \
|
from cinder.volume.drivers.ibm.storwize_svc import storwize_svc_iscsi as \
|
||||||
cinder_volume_drivers_ibm_storwize_svc_storwizesvciscsi
|
cinder_volume_drivers_ibm_storwize_svc_storwizesvciscsi
|
||||||
from cinder.volume.drivers import infinidat as cinder_volume_drivers_infinidat
|
from cinder.volume.drivers import infinidat as cinder_volume_drivers_infinidat
|
||||||
from cinder.volume.drivers.infortrend.raidcmd_cli import common_cli as \
|
|
||||||
cinder_volume_drivers_infortrend_raidcmd_cli_commoncli
|
|
||||||
from cinder.volume.drivers.kaminario import kaminario_common as \
|
from cinder.volume.drivers.kaminario import kaminario_common as \
|
||||||
cinder_volume_drivers_kaminario_kaminariocommon
|
cinder_volume_drivers_kaminario_kaminariocommon
|
||||||
from cinder.volume.drivers.lenovo import lenovo_common as \
|
from cinder.volume.drivers.lenovo import lenovo_common as \
|
||||||
@ -332,10 +330,6 @@ def list_opts():
|
|||||||
cinder_volume_drivers_ibm_storwize_svc_storwizesvciscsi.
|
cinder_volume_drivers_ibm_storwize_svc_storwizesvciscsi.
|
||||||
storwize_svc_iscsi_opts,
|
storwize_svc_iscsi_opts,
|
||||||
cinder_volume_drivers_infinidat.infinidat_opts,
|
cinder_volume_drivers_infinidat.infinidat_opts,
|
||||||
cinder_volume_drivers_infortrend_raidcmd_cli_commoncli.
|
|
||||||
infortrend_esds_opts,
|
|
||||||
cinder_volume_drivers_infortrend_raidcmd_cli_commoncli.
|
|
||||||
infortrend_esds_extra_opts,
|
|
||||||
cinder_volume_drivers_kaminario_kaminariocommon.
|
cinder_volume_drivers_kaminario_kaminariocommon.
|
||||||
kaminario_opts,
|
kaminario_opts,
|
||||||
cinder_volume_drivers_lenovo_lenovocommon.common_opts,
|
cinder_volume_drivers_lenovo_lenovocommon.common_opts,
|
||||||
|
|||||||
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
@ -1,291 +0,0 @@
|
|||||||
# Copyright (c) 2015 Infortrend Technology, Inc.
|
|
||||||
# All Rights Reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
||||||
# not use this file except in compliance with 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.
|
|
||||||
"""
|
|
||||||
Fibre Channel Driver for Infortrend Eonstor based on CLI.
|
|
||||||
"""
|
|
||||||
|
|
||||||
|
|
||||||
from oslo_log import log as logging
|
|
||||||
|
|
||||||
from cinder import interface
|
|
||||||
from cinder.volume import driver
|
|
||||||
from cinder.volume.drivers.infortrend.raidcmd_cli import common_cli
|
|
||||||
from cinder.zonemanager import utils as fczm_utils
|
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
@interface.volumedriver
|
|
||||||
class InfortrendCLIFCDriver(driver.FibreChannelDriver):
|
|
||||||
|
|
||||||
"""Infortrend Fibre Channel Driver for Eonstor DS using CLI.
|
|
||||||
|
|
||||||
Version history:
|
|
||||||
1.0.0 - Initial driver
|
|
||||||
1.0.1 - Support DS4000
|
|
||||||
1.0.2 - Support GS Series
|
|
||||||
"""
|
|
||||||
|
|
||||||
# ThirdPartySystems wiki page
|
|
||||||
CI_WIKI_NAME = "Infortrend_Storage_CI"
|
|
||||||
VERSION = common_cli.InfortrendCommon.VERSION
|
|
||||||
|
|
||||||
# TODO(smcginnis) Remove driver in Queens if CI issues not resolved
|
|
||||||
SUPPORTED = False
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(InfortrendCLIFCDriver, self).__init__(*args, **kwargs)
|
|
||||||
self.common = common_cli.InfortrendCommon(
|
|
||||||
'FC', configuration=self.configuration)
|
|
||||||
self.VERSION = self.common.VERSION
|
|
||||||
|
|
||||||
def check_for_setup_error(self):
|
|
||||||
LOG.debug('check_for_setup_error start')
|
|
||||||
self.common.check_for_setup_error()
|
|
||||||
|
|
||||||
def create_volume(self, volume):
|
|
||||||
"""Creates a volume.
|
|
||||||
|
|
||||||
Can optionally return a Dictionary of changes
|
|
||||||
to the volume object to be persisted.
|
|
||||||
"""
|
|
||||||
LOG.debug('create_volume volume id=%(volume_id)s', {
|
|
||||||
'volume_id': volume['id']})
|
|
||||||
return self.common.create_volume(volume)
|
|
||||||
|
|
||||||
def create_volume_from_snapshot(self, volume, snapshot):
|
|
||||||
"""Creates a volume from a snapshot."""
|
|
||||||
LOG.debug(
|
|
||||||
'create_volume_from_snapshot volume id=%(volume_id)s '
|
|
||||||
'snapshot id=%(snapshot_id)s', {
|
|
||||||
'volume_id': volume['id'], 'snapshot_id': snapshot['id']})
|
|
||||||
return self.common.create_volume_from_snapshot(volume, snapshot)
|
|
||||||
|
|
||||||
def create_cloned_volume(self, volume, src_vref):
|
|
||||||
"""Creates a clone of the specified volume."""
|
|
||||||
LOG.debug(
|
|
||||||
'create_cloned_volume volume id=%(volume_id)s '
|
|
||||||
'src_vref provider_location=%(provider_location)s', {
|
|
||||||
'volume_id': volume['id'],
|
|
||||||
'provider_location': src_vref['provider_location']})
|
|
||||||
return self.common.create_cloned_volume(volume, src_vref)
|
|
||||||
|
|
||||||
def extend_volume(self, volume, new_size):
|
|
||||||
"""Extend a volume."""
|
|
||||||
LOG.debug(
|
|
||||||
'extend_volume volume id=%(volume_id)s new size=%(size)s', {
|
|
||||||
'volume_id': volume['id'], 'size': new_size})
|
|
||||||
self.common.extend_volume(volume, new_size)
|
|
||||||
|
|
||||||
def delete_volume(self, volume):
|
|
||||||
"""Deletes a volume."""
|
|
||||||
LOG.debug('delete_volume volume id=%(volume_id)s', {
|
|
||||||
'volume_id': volume['id']})
|
|
||||||
return self.common.delete_volume(volume)
|
|
||||||
|
|
||||||
def migrate_volume(self, ctxt, volume, host):
|
|
||||||
"""Migrate the volume to the specified host.
|
|
||||||
|
|
||||||
Returns a boolean indicating whether the migration occurred, as well as
|
|
||||||
model_update.
|
|
||||||
|
|
||||||
:param ctxt: Context
|
|
||||||
:param volume: A dictionary describing the volume to migrate
|
|
||||||
:param host: A dictionary describing the host to migrate to, where
|
|
||||||
host['host'] is its name, and host['capabilities'] is a
|
|
||||||
dictionary of its reported capabilities.
|
|
||||||
"""
|
|
||||||
LOG.debug('migrate_volume volume id=%(volume_id)s host=%(host)s', {
|
|
||||||
'volume_id': volume['id'], 'host': host['host']})
|
|
||||||
return self.common.migrate_volume(volume, host)
|
|
||||||
|
|
||||||
def create_snapshot(self, snapshot):
|
|
||||||
"""Creates a snapshot."""
|
|
||||||
LOG.debug(
|
|
||||||
'create_snapshot snapshot id=%(snapshot_id)s '
|
|
||||||
'volume id=%(volume_id)s', {
|
|
||||||
'snapshot_id': snapshot['id'],
|
|
||||||
'volume_id': snapshot['volume_id']})
|
|
||||||
return self.common.create_snapshot(snapshot)
|
|
||||||
|
|
||||||
def delete_snapshot(self, snapshot):
|
|
||||||
"""Deletes a snapshot."""
|
|
||||||
LOG.debug(
|
|
||||||
'delete_snapshot snapshot id=%(snapshot_id)s '
|
|
||||||
'volume id=%(volume_id)s', {
|
|
||||||
'snapshot_id': snapshot['id'],
|
|
||||||
'volume_id': snapshot['volume_id']})
|
|
||||||
self.common.delete_snapshot(snapshot)
|
|
||||||
|
|
||||||
def ensure_export(self, context, volume):
|
|
||||||
"""Synchronously recreates an export for a volume."""
|
|
||||||
pass
|
|
||||||
|
|
||||||
def create_export(self, context, volume, connector):
|
|
||||||
"""Exports the volume.
|
|
||||||
|
|
||||||
Can optionally return a Dictionary of changes
|
|
||||||
to the volume object to be persisted.
|
|
||||||
"""
|
|
||||||
LOG.debug(
|
|
||||||
'create_export volume provider_location=%(provider_location)s', {
|
|
||||||
'provider_location': volume['provider_location']})
|
|
||||||
return self.common.create_export(context, volume)
|
|
||||||
|
|
||||||
def remove_export(self, context, volume):
|
|
||||||
"""Removes an export for a volume."""
|
|
||||||
pass
|
|
||||||
|
|
||||||
@fczm_utils.add_fc_zone
|
|
||||||
def initialize_connection(self, volume, connector):
|
|
||||||
"""Initializes the connection and returns connection information.
|
|
||||||
|
|
||||||
Assign any created volume to a compute node/host so that it can be
|
|
||||||
used from that host.
|
|
||||||
|
|
||||||
The driver returns a driver_volume_type of 'fibre_channel'.
|
|
||||||
The target_wwn can be a single entry or a list of wwns that
|
|
||||||
correspond to the list of remote wwn(s) that will export the volume.
|
|
||||||
The initiator_target_map is a map that represents the remote wwn(s)
|
|
||||||
and a list of wwns which are visible to the remote wwn(s).
|
|
||||||
Example return values:
|
|
||||||
|
|
||||||
{
|
|
||||||
'driver_volume_type': 'fibre_channel'
|
|
||||||
'data': {
|
|
||||||
'target_discovered': True,
|
|
||||||
'target_lun': 1,
|
|
||||||
'target_wwn': '1234567890123',
|
|
||||||
'initiator_target_map': {
|
|
||||||
'1122334455667788': ['1234567890123']
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
or
|
|
||||||
|
|
||||||
{
|
|
||||||
'driver_volume_type': 'fibre_channel'
|
|
||||||
'data': {
|
|
||||||
'target_discovered': True,
|
|
||||||
'target_lun': 1,
|
|
||||||
'target_wwn': ['1234567890123', '0987654321321'],
|
|
||||||
'initiator_target_map': {
|
|
||||||
'1122334455667788': ['1234567890123',
|
|
||||||
'0987654321321']
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
"""
|
|
||||||
LOG.debug(
|
|
||||||
'initialize_connection volume id=%(volume_id)s '
|
|
||||||
'connector initiator=%(initiator)s', {
|
|
||||||
'volume_id': volume['id'],
|
|
||||||
'initiator': connector['initiator']})
|
|
||||||
return self.common.initialize_connection(volume, connector)
|
|
||||||
|
|
||||||
@fczm_utils.remove_fc_zone
|
|
||||||
def terminate_connection(self, volume, connector, **kwargs):
|
|
||||||
"""Disallow connection from connector."""
|
|
||||||
LOG.debug('terminate_connection volume id=%(volume_id)s', {
|
|
||||||
'volume_id': volume['id']})
|
|
||||||
return self.common.terminate_connection(volume, connector)
|
|
||||||
|
|
||||||
def get_volume_stats(self, refresh=False):
|
|
||||||
"""Get volume stats.
|
|
||||||
|
|
||||||
If 'refresh' is True, run update the stats first.
|
|
||||||
"""
|
|
||||||
LOG.debug('get_volume_stats refresh=%(refresh)s', {
|
|
||||||
'refresh': refresh})
|
|
||||||
return self.common.get_volume_stats(refresh)
|
|
||||||
|
|
||||||
def manage_existing(self, volume, existing_ref):
|
|
||||||
"""Manage an existing lun in the array.
|
|
||||||
|
|
||||||
The lun should be in a manageable pool backend, otherwise
|
|
||||||
error would return.
|
|
||||||
Rename the backend storage object so that it matches the,
|
|
||||||
volume['name'] which is how drivers traditionally map between a
|
|
||||||
cinder volume and the associated backend storage object.
|
|
||||||
|
|
||||||
.. code-block:: default
|
|
||||||
|
|
||||||
existing_ref:{
|
|
||||||
'id':lun_id
|
|
||||||
}
|
|
||||||
"""
|
|
||||||
LOG.debug(
|
|
||||||
'manage_existing volume id=%(volume_id)s '
|
|
||||||
'existing_ref source id=%(source_id)s', {
|
|
||||||
'volume_id': volume['id'],
|
|
||||||
'source_id': existing_ref['source-id']})
|
|
||||||
return self.common.manage_existing(volume, existing_ref)
|
|
||||||
|
|
||||||
def unmanage(self, volume):
|
|
||||||
"""Removes the specified volume from Cinder management.
|
|
||||||
|
|
||||||
Does not delete the underlying backend storage object.
|
|
||||||
|
|
||||||
:param volume: Cinder volume to unmanage
|
|
||||||
"""
|
|
||||||
LOG.debug('unmanage volume id=%(volume_id)s', {
|
|
||||||
'volume_id': volume['id']})
|
|
||||||
self.common.unmanage(volume)
|
|
||||||
|
|
||||||
def manage_existing_get_size(self, volume, existing_ref):
|
|
||||||
"""Return size of volume to be managed by manage_existing.
|
|
||||||
|
|
||||||
When calculating the size, round up to the next GB.
|
|
||||||
"""
|
|
||||||
LOG.debug(
|
|
||||||
'manage_existing_get_size volume id=%(volume_id)s '
|
|
||||||
'existing_ref source id=%(source_id)s', {
|
|
||||||
'volume_id': volume['id'],
|
|
||||||
'source_id': existing_ref['source-id']})
|
|
||||||
return self.common.manage_existing_get_size(volume, existing_ref)
|
|
||||||
|
|
||||||
def retype(self, ctxt, volume, new_type, diff, host):
|
|
||||||
"""Convert the volume to be of the new type.
|
|
||||||
|
|
||||||
:param ctxt: Context
|
|
||||||
:param volume: A dictionary describing the volume to migrate
|
|
||||||
:param new_type: A dictionary describing the volume type to convert to
|
|
||||||
:param diff: A dictionary with the difference between the two types
|
|
||||||
:param host: A dictionary describing the host to migrate to, where
|
|
||||||
host['host'] is its name, and host['capabilities'] is a
|
|
||||||
dictionary of its reported capabilities.
|
|
||||||
"""
|
|
||||||
LOG.debug(
|
|
||||||
'retype volume id=%(volume_id)s new_type id=%(type_id)s', {
|
|
||||||
'volume_id': volume['id'], 'type_id': new_type['id']})
|
|
||||||
return self.common.retype(ctxt, volume, new_type, diff, host)
|
|
||||||
|
|
||||||
def update_migrated_volume(self, ctxt, volume, new_volume,
|
|
||||||
original_volume_status):
|
|
||||||
"""Return model update for migrated volume.
|
|
||||||
|
|
||||||
:param volume: The original volume that was migrated to this backend
|
|
||||||
:param new_volume: The migration volume object that was created on
|
|
||||||
this backend as part of the migration process
|
|
||||||
:param original_volume_status: The status of the original volume
|
|
||||||
:returns: model_update to update DB with any needed changes
|
|
||||||
"""
|
|
||||||
LOG.debug(
|
|
||||||
'update migrated volume original volume id= %(volume_id)s '
|
|
||||||
'new volume id=%(new_volume_id)s', {
|
|
||||||
'volume_id': volume['id'], 'new_volume_id': new_volume['id']})
|
|
||||||
return self.common.update_migrated_volume(ctxt, volume, new_volume,
|
|
||||||
original_volume_status)
|
|
||||||
@ -1,264 +0,0 @@
|
|||||||
# Copyright (c) 2015 Infortrend Technology, Inc.
|
|
||||||
# All Rights Reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
||||||
# not use this file except in compliance with 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.
|
|
||||||
"""
|
|
||||||
iSCSI Driver for Infortrend Eonstor based on CLI.
|
|
||||||
"""
|
|
||||||
|
|
||||||
from oslo_log import log as logging
|
|
||||||
|
|
||||||
from cinder import interface
|
|
||||||
from cinder.volume import driver
|
|
||||||
from cinder.volume.drivers.infortrend.raidcmd_cli import common_cli
|
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
@interface.volumedriver
|
|
||||||
class InfortrendCLIISCSIDriver(driver.ISCSIDriver):
|
|
||||||
|
|
||||||
"""Infortrend iSCSI Driver for Eonstor DS using CLI.
|
|
||||||
|
|
||||||
Version history:
|
|
||||||
1.0.0 - Initial driver
|
|
||||||
1.0.1 - Support DS4000
|
|
||||||
1.0.2 - Support GS Series
|
|
||||||
"""
|
|
||||||
|
|
||||||
# ThirdPartySystems wiki page
|
|
||||||
CI_WIKI_NAME = "Infortrend_Storage_CI"
|
|
||||||
VERSION = common_cli.InfortrendCommon.VERSION
|
|
||||||
|
|
||||||
# TODO(smcginnis) Remove driver in Queens if CI issues not resolved
|
|
||||||
SUPPORTED = False
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(InfortrendCLIISCSIDriver, self).__init__(*args, **kwargs)
|
|
||||||
self.common = common_cli.InfortrendCommon(
|
|
||||||
'iSCSI', configuration=self.configuration)
|
|
||||||
self.VERSION = self.common.VERSION
|
|
||||||
|
|
||||||
def check_for_setup_error(self):
|
|
||||||
LOG.debug('check_for_setup_error start')
|
|
||||||
self.common.check_for_setup_error()
|
|
||||||
|
|
||||||
def create_volume(self, volume):
|
|
||||||
"""Creates a volume.
|
|
||||||
|
|
||||||
Can optionally return a Dictionary of changes
|
|
||||||
to the volume object to be persisted.
|
|
||||||
"""
|
|
||||||
LOG.debug('create_volume volume id=%(volume_id)s', {
|
|
||||||
'volume_id': volume['id']})
|
|
||||||
return self.common.create_volume(volume)
|
|
||||||
|
|
||||||
def create_volume_from_snapshot(self, volume, snapshot):
|
|
||||||
"""Creates a volume from a snapshot."""
|
|
||||||
LOG.debug(
|
|
||||||
'create_volume_from_snapshot volume id=%(volume_id)s '
|
|
||||||
'snapshot id=%(snapshot_id)s', {
|
|
||||||
'volume_id': volume['id'], 'snapshot_id': snapshot['id']})
|
|
||||||
return self.common.create_volume_from_snapshot(volume, snapshot)
|
|
||||||
|
|
||||||
def create_cloned_volume(self, volume, src_vref):
|
|
||||||
"""Creates a clone of the specified volume."""
|
|
||||||
LOG.debug(
|
|
||||||
'create_cloned_volume volume id=%(volume_id)s '
|
|
||||||
'src_vref provider_location=%(provider_location)s', {
|
|
||||||
'volume_id': volume['id'],
|
|
||||||
'provider_location': src_vref['provider_location']})
|
|
||||||
return self.common.create_cloned_volume(volume, src_vref)
|
|
||||||
|
|
||||||
def extend_volume(self, volume, new_size):
|
|
||||||
"""Extend a volume."""
|
|
||||||
LOG.debug(
|
|
||||||
'extend_volume volume id=%(volume_id)s new size=%(size)s', {
|
|
||||||
'volume_id': volume['id'], 'size': new_size})
|
|
||||||
self.common.extend_volume(volume, new_size)
|
|
||||||
|
|
||||||
def delete_volume(self, volume):
|
|
||||||
"""Deletes a volume."""
|
|
||||||
LOG.debug('delete_volume volume id=%(volume_id)s', {
|
|
||||||
'volume_id': volume['id']})
|
|
||||||
return self.common.delete_volume(volume)
|
|
||||||
|
|
||||||
def migrate_volume(self, ctxt, volume, host):
|
|
||||||
"""Migrate the volume to the specified host.
|
|
||||||
|
|
||||||
Returns a boolean indicating whether the migration occurred, as well as
|
|
||||||
model_update.
|
|
||||||
|
|
||||||
:param ctxt: Context
|
|
||||||
:param volume: A dictionary describing the volume to migrate
|
|
||||||
:param host: A dictionary describing the host to migrate to, where
|
|
||||||
host['host'] is its name, and host['capabilities'] is a
|
|
||||||
dictionary of its reported capabilities.
|
|
||||||
"""
|
|
||||||
LOG.debug('migrate_volume volume id=%(volume_id)s host=%(host)s', {
|
|
||||||
'volume_id': volume['id'], 'host': host['host']})
|
|
||||||
return self.common.migrate_volume(volume, host)
|
|
||||||
|
|
||||||
def create_snapshot(self, snapshot):
|
|
||||||
"""Creates a snapshot."""
|
|
||||||
LOG.debug(
|
|
||||||
'create_snapshot snapshot id=%(snapshot_id)s '
|
|
||||||
'volume_id=%(volume_id)s', {
|
|
||||||
'snapshot_id': snapshot['id'],
|
|
||||||
'volume_id': snapshot['volume_id']})
|
|
||||||
return self.common.create_snapshot(snapshot)
|
|
||||||
|
|
||||||
def delete_snapshot(self, snapshot):
|
|
||||||
"""Deletes a snapshot."""
|
|
||||||
LOG.debug(
|
|
||||||
'delete_snapshot snapshot id=%(snapshot_id)s '
|
|
||||||
'volume_id=%(volume_id)s', {
|
|
||||||
'snapshot_id': snapshot['id'],
|
|
||||||
'volume_id': snapshot['volume_id']})
|
|
||||||
self.common.delete_snapshot(snapshot)
|
|
||||||
|
|
||||||
def ensure_export(self, context, volume):
|
|
||||||
"""Synchronously recreates an export for a volume."""
|
|
||||||
pass
|
|
||||||
|
|
||||||
def create_export(self, context, volume, connector):
|
|
||||||
"""Exports the volume.
|
|
||||||
|
|
||||||
Can optionally return a Dictionary of changes
|
|
||||||
to the volume object to be persisted.
|
|
||||||
"""
|
|
||||||
LOG.debug(
|
|
||||||
'create_export volume provider_location=%(provider_location)s', {
|
|
||||||
'provider_location': volume['provider_location']})
|
|
||||||
return self.common.create_export(context, volume)
|
|
||||||
|
|
||||||
def remove_export(self, context, volume):
|
|
||||||
"""Removes an export for a volume."""
|
|
||||||
pass
|
|
||||||
|
|
||||||
def initialize_connection(self, volume, connector):
|
|
||||||
"""Initializes the connection and returns connection information.
|
|
||||||
|
|
||||||
The iscsi driver returns a driver_volume_type of 'iscsi'.
|
|
||||||
The format of the driver data is defined in _get_iscsi_properties.
|
|
||||||
Example return value::
|
|
||||||
|
|
||||||
{
|
|
||||||
'driver_volume_type': 'iscsi'
|
|
||||||
'data': {
|
|
||||||
'target_discovered': True,
|
|
||||||
'target_iqn': 'iqn.2010-10.org.openstack:volume-00000001',
|
|
||||||
'target_portal': '127.0.0.0.1:3260',
|
|
||||||
'volume_id': 1,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
"""
|
|
||||||
LOG.debug(
|
|
||||||
'initialize_connection volume id=%(volume_id)s '
|
|
||||||
'connector initiator=%(initiator)s', {
|
|
||||||
'volume_id': volume['id'],
|
|
||||||
'initiator': connector['initiator']})
|
|
||||||
return self.common.initialize_connection(volume, connector)
|
|
||||||
|
|
||||||
def terminate_connection(self, volume, connector, **kwargs):
|
|
||||||
"""Disallow connection from connector."""
|
|
||||||
LOG.debug('terminate_connection volume id=%(volume_id)s', {
|
|
||||||
'volume_id': volume['id']})
|
|
||||||
self.common.terminate_connection(volume, connector)
|
|
||||||
|
|
||||||
def get_volume_stats(self, refresh=False):
|
|
||||||
"""Get volume stats.
|
|
||||||
|
|
||||||
If 'refresh' is True, run update the stats first.
|
|
||||||
"""
|
|
||||||
LOG.debug('get_volume_stats refresh=%(refresh)s', {
|
|
||||||
'refresh': refresh})
|
|
||||||
return self.common.get_volume_stats(refresh)
|
|
||||||
|
|
||||||
def manage_existing(self, volume, existing_ref):
|
|
||||||
"""Manage an existing lun in the array.
|
|
||||||
|
|
||||||
The lun should be in a manageable pool backend, otherwise
|
|
||||||
error would return.
|
|
||||||
Rename the backend storage object so that it matches the,
|
|
||||||
volume['name'] which is how drivers traditionally map between a
|
|
||||||
cinder volume and the associated backend storage object.
|
|
||||||
|
|
||||||
.. code-block:: default
|
|
||||||
|
|
||||||
existing_ref:{
|
|
||||||
'id':lun_id
|
|
||||||
}
|
|
||||||
"""
|
|
||||||
LOG.debug(
|
|
||||||
'manage_existing volume id=%(volume_id)s '
|
|
||||||
'existing_ref source id=%(source_id)s', {
|
|
||||||
'volume_id': volume['id'],
|
|
||||||
'source_id': existing_ref['source-id']})
|
|
||||||
return self.common.manage_existing(volume, existing_ref)
|
|
||||||
|
|
||||||
def unmanage(self, volume):
|
|
||||||
"""Removes the specified volume from Cinder management.
|
|
||||||
|
|
||||||
Does not delete the underlying backend storage object.
|
|
||||||
|
|
||||||
:param volume: Cinder volume to unmanage
|
|
||||||
"""
|
|
||||||
LOG.debug('unmanage volume id=%(volume_id)s', {
|
|
||||||
'volume_id': volume['id']})
|
|
||||||
self.common.unmanage(volume)
|
|
||||||
|
|
||||||
def manage_existing_get_size(self, volume, existing_ref):
|
|
||||||
"""Return size of volume to be managed by manage_existing.
|
|
||||||
|
|
||||||
When calculating the size, round up to the next GB.
|
|
||||||
"""
|
|
||||||
LOG.debug(
|
|
||||||
'manage_existing_get_size volume id=%(volume_id)s '
|
|
||||||
'existing_ref source id=%(source_id)s', {
|
|
||||||
'volume_id': volume['id'],
|
|
||||||
'source_id': existing_ref['source-id']})
|
|
||||||
return self.common.manage_existing_get_size(volume, existing_ref)
|
|
||||||
|
|
||||||
def retype(self, ctxt, volume, new_type, diff, host):
|
|
||||||
"""Convert the volume to be of the new type.
|
|
||||||
|
|
||||||
:param ctxt: Context
|
|
||||||
:param volume: A dictionary describing the volume to migrate
|
|
||||||
:param new_type: A dictionary describing the volume type to convert to
|
|
||||||
:param diff: A dictionary with the difference between the two types
|
|
||||||
:param host: A dictionary describing the host to migrate to, where
|
|
||||||
host['host'] is its name, and host['capabilities'] is a
|
|
||||||
dictionary of its reported capabilities.
|
|
||||||
"""
|
|
||||||
LOG.debug(
|
|
||||||
'retype volume id=%(volume_id)s new_type id=%(type_id)s', {
|
|
||||||
'volume_id': volume['id'], 'type_id': new_type['id']})
|
|
||||||
return self.common.retype(ctxt, volume, new_type, diff, host)
|
|
||||||
|
|
||||||
def update_migrated_volume(self, ctxt, volume, new_volume,
|
|
||||||
original_volume_status):
|
|
||||||
"""Return model update for migrated volume.
|
|
||||||
|
|
||||||
:param volume: The original volume that was migrated to this backend
|
|
||||||
:param new_volume: The migration volume object that was created on
|
|
||||||
this backend as part of the migration process
|
|
||||||
:param original_volume_status: The status of the original volume
|
|
||||||
:returns: model_update to update DB with any needed changes
|
|
||||||
"""
|
|
||||||
LOG.debug(
|
|
||||||
'update migrated volume original volume id= %(volume_id)s '
|
|
||||||
'new volume id=%(new_volume_id)s', {
|
|
||||||
'volume_id': volume['id'], 'new_volume_id': new_volume['id']})
|
|
||||||
return self.common.update_migrated_volume(ctxt, volume, new_volume,
|
|
||||||
original_volume_status)
|
|
||||||
@ -1,737 +0,0 @@
|
|||||||
# Copyright (c) 2015 Infortrend Technology, Inc.
|
|
||||||
# All Rights Reserved.
|
|
||||||
#
|
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
||||||
# not use this file except in compliance with 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.
|
|
||||||
"""
|
|
||||||
Infortrend basic CLI factory.
|
|
||||||
"""
|
|
||||||
|
|
||||||
import abc
|
|
||||||
|
|
||||||
from oslo_concurrency import processutils
|
|
||||||
from oslo_log import log as logging
|
|
||||||
from oslo_utils import strutils
|
|
||||||
import six
|
|
||||||
|
|
||||||
from cinder import utils
|
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
DEFAULT_RETRY_TIME = 5
|
|
||||||
|
|
||||||
|
|
||||||
def retry_cli(func):
|
|
||||||
def inner(self, *args, **kwargs):
|
|
||||||
total_retry_time = self.cli_retry_time
|
|
||||||
|
|
||||||
if total_retry_time is None:
|
|
||||||
total_retry_time = DEFAULT_RETRY_TIME
|
|
||||||
|
|
||||||
retry_time = 0
|
|
||||||
while retry_time < total_retry_time:
|
|
||||||
rc, out = func(self, *args, **kwargs)
|
|
||||||
retry_time += 1
|
|
||||||
|
|
||||||
if rc == 0:
|
|
||||||
break
|
|
||||||
|
|
||||||
LOG.error(
|
|
||||||
'Retry %(retry)s times: %(method)s Failed '
|
|
||||||
'%(rc)s: %(reason)s', {
|
|
||||||
'retry': retry_time,
|
|
||||||
'method': self.__class__.__name__,
|
|
||||||
'rc': rc,
|
|
||||||
'reason': out})
|
|
||||||
LOG.debug(
|
|
||||||
'Method: %(method)s Return Code: %(rc)s '
|
|
||||||
'Output: %(out)s', {
|
|
||||||
'method': self.__class__.__name__, 'rc': rc, 'out': out})
|
|
||||||
return rc, out
|
|
||||||
return inner
|
|
||||||
|
|
||||||
|
|
||||||
def util_execute(command_line):
|
|
||||||
content, err = utils.execute(command_line, shell=True)
|
|
||||||
return content
|
|
||||||
|
|
||||||
|
|
||||||
def strip_empty_in_list(list):
|
|
||||||
result = []
|
|
||||||
for entry in list:
|
|
||||||
entry = entry.strip()
|
|
||||||
if entry != "":
|
|
||||||
result.append(entry)
|
|
||||||
|
|
||||||
return result
|
|
||||||
|
|
||||||
|
|
||||||
def table_to_dict(table):
|
|
||||||
tableHeader = table[0].split(" ")
|
|
||||||
tableHeaderList = strip_empty_in_list(tableHeader)
|
|
||||||
|
|
||||||
result = []
|
|
||||||
|
|
||||||
for i in range(len(table) - 2):
|
|
||||||
if table[i + 2].strip() == "":
|
|
||||||
break
|
|
||||||
|
|
||||||
resultEntry = {}
|
|
||||||
tableEntry = table[i + 2].split(" ")
|
|
||||||
tableEntryList = strip_empty_in_list(tableEntry)
|
|
||||||
|
|
||||||
for key, value in zip(tableHeaderList, tableEntryList):
|
|
||||||
resultEntry[key] = value
|
|
||||||
|
|
||||||
result.append(resultEntry)
|
|
||||||
return result
|
|
||||||
|
|
||||||
|
|
||||||
def content_lines_to_dict(content_lines):
|
|
||||||
result = []
|
|
||||||
resultEntry = {}
|
|
||||||
|
|
||||||
for content_line in content_lines:
|
|
||||||
|
|
||||||
if content_line.strip() == "":
|
|
||||||
result.append(resultEntry)
|
|
||||||
resultEntry = {}
|
|
||||||
continue
|
|
||||||
|
|
||||||
split_entry = content_line.strip().split(": ", 1)
|
|
||||||
resultEntry[split_entry[0]] = split_entry[1]
|
|
||||||
|
|
||||||
return result
|
|
||||||
|
|
||||||
|
|
||||||
@six.add_metaclass(abc.ABCMeta)
|
|
||||||
class BaseCommand(object):
|
|
||||||
|
|
||||||
"""The BaseCommand abstract class."""
|
|
||||||
|
|
||||||
def __init__(self):
|
|
||||||
super(BaseCommand, self).__init__()
|
|
||||||
|
|
||||||
@abc.abstractmethod
|
|
||||||
def execute(self, *args, **kwargs):
|
|
||||||
pass
|
|
||||||
|
|
||||||
|
|
||||||
class ExecuteCommand(BaseCommand):
|
|
||||||
|
|
||||||
"""The Common ExecuteCommand."""
|
|
||||||
|
|
||||||
def __init__(self, cli_conf):
|
|
||||||
super(ExecuteCommand, self).__init__()
|
|
||||||
self.cli_retry_time = cli_conf.get('cli_retry_time')
|
|
||||||
|
|
||||||
@retry_cli
|
|
||||||
def execute(self, *args, **kwargs):
|
|
||||||
result = None
|
|
||||||
rc = 0
|
|
||||||
try:
|
|
||||||
result, err = utils.execute(*args, **kwargs)
|
|
||||||
except processutils.ProcessExecutionError as pe:
|
|
||||||
rc = pe.exit_code
|
|
||||||
result = pe.stdout
|
|
||||||
result = result.replace('\n', '\\n')
|
|
||||||
LOG.error(
|
|
||||||
'Error on execute command. '
|
|
||||||
'Error code: %(exit_code)d Error msg: %(result)s', {
|
|
||||||
'exit_code': pe.exit_code, 'result': result})
|
|
||||||
return rc, result
|
|
||||||
|
|
||||||
|
|
||||||
class CLIBaseCommand(BaseCommand):
|
|
||||||
|
|
||||||
"""The CLIBaseCommand class."""
|
|
||||||
|
|
||||||
def __init__(self, cli_conf):
|
|
||||||
super(CLIBaseCommand, self).__init__()
|
|
||||||
self.java = "java -jar"
|
|
||||||
self.execute_file = cli_conf.get('path')
|
|
||||||
self.ip = cli_conf.get('ip')
|
|
||||||
self.password = cli_conf.get('password')
|
|
||||||
self.cli_retry_time = cli_conf.get('cli_retry_time')
|
|
||||||
self.command = ""
|
|
||||||
self.parameters = ()
|
|
||||||
self.command_line = ""
|
|
||||||
|
|
||||||
def _generate_command(self, parameters):
|
|
||||||
"""Generate execute Command. use java, execute, command, parameters."""
|
|
||||||
self.parameters = parameters
|
|
||||||
parameters_line = ' '.join(parameters)
|
|
||||||
|
|
||||||
if self.password:
|
|
||||||
parameters_line = 'password=%s %s' % (
|
|
||||||
self.password, parameters_line)
|
|
||||||
|
|
||||||
self.command_line = "{0} {1} {2} {3} {4}".format(
|
|
||||||
self.java,
|
|
||||||
self.execute_file,
|
|
||||||
self.ip,
|
|
||||||
self.command,
|
|
||||||
parameters_line)
|
|
||||||
|
|
||||||
return self.command_line
|
|
||||||
|
|
||||||
def _parser(self, content=None):
|
|
||||||
"""The parser to parse command result.
|
|
||||||
|
|
||||||
:param content: The parse Content
|
|
||||||
:returns: parse result
|
|
||||||
"""
|
|
||||||
content = content.replace("\r", "")
|
|
||||||
content = content.replace("\\/-", "")
|
|
||||||
content = content.strip()
|
|
||||||
LOG.debug(content)
|
|
||||||
|
|
||||||
if content is not None:
|
|
||||||
content_lines = content.split("\n")
|
|
||||||
rc, out = self._parse_return(content_lines)
|
|
||||||
|
|
||||||
if rc != 0:
|
|
||||||
return rc, out
|
|
||||||
else:
|
|
||||||
return rc, content_lines
|
|
||||||
|
|
||||||
return -1, None
|
|
||||||
|
|
||||||
@retry_cli
|
|
||||||
def execute(self, *args, **kwargs):
|
|
||||||
command_line = self._generate_command(args)
|
|
||||||
LOG.debug('Executing: %(command)s', {'command': command_line})
|
|
||||||
rc = 0
|
|
||||||
result = None
|
|
||||||
try:
|
|
||||||
content = self._execute(command_line)
|
|
||||||
rc, result = self._parser(content)
|
|
||||||
except processutils.ProcessExecutionError as pe:
|
|
||||||
rc = -2 # prevent confusing with cli real rc
|
|
||||||
result = pe.stdout
|
|
||||||
result = result.replace('\n', '\\n')
|
|
||||||
LOG.error(
|
|
||||||
'Error on execute %(command)s. '
|
|
||||||
'Error code: %(exit_code)d Error msg: %(result)s', {
|
|
||||||
'command': strutils.mask_password(command_line),
|
|
||||||
'exit_code': pe.exit_code,
|
|
||||||
'result': result})
|
|
||||||
return rc, result
|
|
||||||
|
|
||||||
def _execute(self, command_line):
|
|
||||||
return util_execute(command_line)
|
|
||||||
|
|
||||||
def set_ip(self, ip):
|
|
||||||
"""Set the Raid's ip."""
|
|
||||||
self.ip = ip
|
|
||||||
|
|
||||||
def _parse_return(self, content_lines):
|
|
||||||
"""Get the end of command line result."""
|
|
||||||
rc = 0
|
|
||||||
return_value = content_lines[-1].strip().split(' ', 1)[1]
|
|
||||||
return_cli_result = content_lines[-2].strip().split(' ', 1)[1]
|
|
||||||
|
|
||||||
rc = int(return_value, 16)
|
|
||||||
|
|
||||||
return rc, return_cli_result
|
|
||||||
|
|
||||||
|
|
||||||
class CreateLD(CLIBaseCommand):
|
|
||||||
|
|
||||||
"""The Create LD Command."""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(CreateLD, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "create ld"
|
|
||||||
|
|
||||||
|
|
||||||
class CreateLV(CLIBaseCommand):
|
|
||||||
|
|
||||||
"""The Create LV Command."""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(CreateLV, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "create lv"
|
|
||||||
|
|
||||||
|
|
||||||
class CreatePartition(CLIBaseCommand):
|
|
||||||
|
|
||||||
"""Create Partition.
|
|
||||||
|
|
||||||
create part [LV-ID] [name] [size={partition-size}]
|
|
||||||
[min={minimal-reserve-size}] [init={switch}]
|
|
||||||
[tier={tier-level-list}]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(CreatePartition, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "create part"
|
|
||||||
|
|
||||||
|
|
||||||
class DeletePartition(CLIBaseCommand):
|
|
||||||
|
|
||||||
"""Delete Partition.
|
|
||||||
|
|
||||||
delete part [partition-ID] [-y]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(DeletePartition, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "delete part"
|
|
||||||
|
|
||||||
|
|
||||||
class SetPartition(CLIBaseCommand):
|
|
||||||
|
|
||||||
"""Set Partition.
|
|
||||||
|
|
||||||
.. code-block:: bash
|
|
||||||
|
|
||||||
set part [partition-ID] [name={partition-name}]
|
|
||||||
[min={minimal-reserve-size}]
|
|
||||||
set part expand [partition-ID] [size={expand-size}]
|
|
||||||
set part purge [partition-ID] [number] [rule-type]
|
|
||||||
set part reclaim [partition-ID]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(SetPartition, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "set part"
|
|
||||||
|
|
||||||
|
|
||||||
class CreateMap(CLIBaseCommand):
|
|
||||||
|
|
||||||
"""Map the Partition on the channel.
|
|
||||||
|
|
||||||
create map [part] [partition-ID] [Channel-ID]
|
|
||||||
[Target-ID] [LUN-ID] [assign={assign-to}]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(CreateMap, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "create map"
|
|
||||||
|
|
||||||
|
|
||||||
class DeleteMap(CLIBaseCommand):
|
|
||||||
|
|
||||||
"""Unmap the Partition on the channel.
|
|
||||||
|
|
||||||
delete map [part] [partition-ID] [Channel-ID]
|
|
||||||
[Target-ID] [LUN-ID] [-y]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(DeleteMap, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "delete map"
|
|
||||||
|
|
||||||
|
|
||||||
class CreateSnapshot(CLIBaseCommand):
|
|
||||||
|
|
||||||
"""Create partition's Snapshot.
|
|
||||||
|
|
||||||
create si [part] [partition-ID]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(CreateSnapshot, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "create si"
|
|
||||||
|
|
||||||
|
|
||||||
class DeleteSnapshot(CLIBaseCommand):
|
|
||||||
|
|
||||||
"""Delete partition's Snapshot.
|
|
||||||
|
|
||||||
delete si [snapshot-image-ID] [-y]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(DeleteSnapshot, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "delete si"
|
|
||||||
|
|
||||||
|
|
||||||
class CreateReplica(CLIBaseCommand):
|
|
||||||
|
|
||||||
"""Create partition or snapshot's replica.
|
|
||||||
|
|
||||||
create replica [name] [part | si] [source-volume-ID]
|
|
||||||
[part] [target-volume-ID] [type={replication-mode}]
|
|
||||||
[priority={level}] [desc={description}]
|
|
||||||
[incremental={switch}] [timeout={value}]
|
|
||||||
[compression={switch}]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(CreateReplica, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "create replica"
|
|
||||||
|
|
||||||
|
|
||||||
class DeleteReplica(CLIBaseCommand):
|
|
||||||
|
|
||||||
"""Delete and terminate specific replication job.
|
|
||||||
|
|
||||||
delete replica [volume-pair-ID] [-y]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(DeleteReplica, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "delete replica"
|
|
||||||
|
|
||||||
|
|
||||||
class CreateIQN(CLIBaseCommand):
|
|
||||||
|
|
||||||
"""Create host iqn for CHAP or lun filter.
|
|
||||||
|
|
||||||
create iqn [IQN] [IQN-alias-name] [user={username}] [password={secret}]
|
|
||||||
[target={name}] [target-password={secret}] [ip={ip-address}]
|
|
||||||
[mask={netmask-ip}]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(CreateIQN, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "create iqn"
|
|
||||||
|
|
||||||
|
|
||||||
class DeleteIQN(CLIBaseCommand):
|
|
||||||
|
|
||||||
"""Delete host iqn by name.
|
|
||||||
|
|
||||||
delete iqn [name]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(DeleteIQN, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "delete iqn"
|
|
||||||
|
|
||||||
|
|
||||||
class ShowCommand(CLIBaseCommand):
|
|
||||||
|
|
||||||
"""Basic Show Command."""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(ShowCommand, self).__init__(*args, **kwargs)
|
|
||||||
self.param_detail = "-l"
|
|
||||||
self.default_type = "table"
|
|
||||||
self.start_key = ""
|
|
||||||
|
|
||||||
def _parser(self, content=None):
|
|
||||||
"""Parse Table or Detail format into dict.
|
|
||||||
|
|
||||||
# Table format
|
|
||||||
|
|
||||||
ID Name LD-amount
|
|
||||||
----------------------
|
|
||||||
123 LV-1 1
|
|
||||||
|
|
||||||
# Result
|
|
||||||
|
|
||||||
{
|
|
||||||
'ID': '123',
|
|
||||||
'Name': 'LV-1',
|
|
||||||
'LD-amount': '1'
|
|
||||||
}
|
|
||||||
|
|
||||||
# Detail format
|
|
||||||
|
|
||||||
ID: 5DE94FF775D81C30
|
|
||||||
Name: LV-1
|
|
||||||
LD-amount: 1
|
|
||||||
|
|
||||||
# Result
|
|
||||||
|
|
||||||
{
|
|
||||||
'ID': '123',
|
|
||||||
'Name': 'LV-1',
|
|
||||||
'LD-amount': '1'
|
|
||||||
}
|
|
||||||
|
|
||||||
:param content: The parse Content.
|
|
||||||
:returns: parse result
|
|
||||||
"""
|
|
||||||
rc, out = super(ShowCommand, self)._parser(content)
|
|
||||||
|
|
||||||
# Error.
|
|
||||||
if rc != 0:
|
|
||||||
return rc, out
|
|
||||||
|
|
||||||
# No content.
|
|
||||||
if len(out) < 6:
|
|
||||||
return rc, []
|
|
||||||
|
|
||||||
detect_type = self.detect_type()
|
|
||||||
|
|
||||||
# Show detail content.
|
|
||||||
if detect_type == "list":
|
|
||||||
|
|
||||||
start_id = self.detect_detail_start_index(out)
|
|
||||||
if start_id < 0:
|
|
||||||
return rc, []
|
|
||||||
|
|
||||||
result = content_lines_to_dict(out[start_id:-2])
|
|
||||||
else:
|
|
||||||
|
|
||||||
start_id = self.detect_table_start_index(out)
|
|
||||||
if start_id < 0:
|
|
||||||
return rc, []
|
|
||||||
|
|
||||||
result = table_to_dict(out[start_id:-3])
|
|
||||||
|
|
||||||
return rc, result
|
|
||||||
|
|
||||||
def detect_type(self):
|
|
||||||
if self.param_detail in self.parameters:
|
|
||||||
detect_type = "list"
|
|
||||||
else:
|
|
||||||
detect_type = self.default_type
|
|
||||||
return detect_type
|
|
||||||
|
|
||||||
def detect_table_start_index(self, content):
|
|
||||||
for i in range(3, len(content)):
|
|
||||||
key = content[i].strip().split(' ')
|
|
||||||
if self.start_key in key[0].strip():
|
|
||||||
return i
|
|
||||||
|
|
||||||
return -1
|
|
||||||
|
|
||||||
def detect_detail_start_index(self, content):
|
|
||||||
for i in range(3, len(content)):
|
|
||||||
split_entry = content[i].strip().split(' ')
|
|
||||||
if len(split_entry) >= 2 and ':' in split_entry[0]:
|
|
||||||
return i
|
|
||||||
|
|
||||||
return -1
|
|
||||||
|
|
||||||
|
|
||||||
class ShowLD(ShowCommand):
|
|
||||||
|
|
||||||
"""Show LD.
|
|
||||||
|
|
||||||
show ld [index-list]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(ShowLD, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "show ld"
|
|
||||||
|
|
||||||
|
|
||||||
class ShowLV(ShowCommand):
|
|
||||||
|
|
||||||
"""Show LV.
|
|
||||||
|
|
||||||
show lv [lv={LV-IDs}] [-l]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(ShowLV, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "show lv"
|
|
||||||
self.start_key = "ID"
|
|
||||||
|
|
||||||
def detect_table_start_index(self, content):
|
|
||||||
if "tier" in self.parameters:
|
|
||||||
self.start_key = "LV-Name"
|
|
||||||
|
|
||||||
for i in range(3, len(content)):
|
|
||||||
key = content[i].strip().split(' ')
|
|
||||||
if self.start_key in key[0].strip():
|
|
||||||
return i
|
|
||||||
|
|
||||||
return -1
|
|
||||||
|
|
||||||
|
|
||||||
class ShowPartition(ShowCommand):
|
|
||||||
|
|
||||||
"""Show Partition.
|
|
||||||
|
|
||||||
show part [part={partition-IDs} | lv={LV-IDs}] [-l]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(ShowPartition, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "show part"
|
|
||||||
self.start_key = "ID"
|
|
||||||
|
|
||||||
|
|
||||||
class ShowSnapshot(ShowCommand):
|
|
||||||
|
|
||||||
"""Show Snapshot.
|
|
||||||
|
|
||||||
show si [si={snapshot-image-IDs} | part={partition-IDs} | lv={LV-IDs}] [-l]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(ShowSnapshot, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "show si"
|
|
||||||
self.start_key = "Index"
|
|
||||||
|
|
||||||
|
|
||||||
class ShowDevice(ShowCommand):
|
|
||||||
|
|
||||||
"""Show Device.
|
|
||||||
|
|
||||||
show device
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(ShowDevice, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "show device"
|
|
||||||
self.start_key = "Index"
|
|
||||||
|
|
||||||
|
|
||||||
class ShowChannel(ShowCommand):
|
|
||||||
|
|
||||||
"""Show Channel.
|
|
||||||
|
|
||||||
show channel
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(ShowChannel, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "show channel"
|
|
||||||
self.start_key = "Ch"
|
|
||||||
|
|
||||||
|
|
||||||
class ShowDisk(ShowCommand):
|
|
||||||
|
|
||||||
"""The Show Disk Command.
|
|
||||||
|
|
||||||
show disk [disk-index-list | channel={ch}]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(ShowDisk, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "show disk"
|
|
||||||
|
|
||||||
|
|
||||||
class ShowMap(ShowCommand):
|
|
||||||
|
|
||||||
"""Show Map.
|
|
||||||
|
|
||||||
show map [part={partition-IDs} | channel={channel-IDs}] [-l]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(ShowMap, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "show map"
|
|
||||||
self.start_key = "Ch"
|
|
||||||
|
|
||||||
|
|
||||||
class ShowNet(ShowCommand):
|
|
||||||
|
|
||||||
"""Show IP network.
|
|
||||||
|
|
||||||
show net [id={channel-IDs}] [-l]
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(ShowNet, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "show net"
|
|
||||||
self.start_key = "ID"
|
|
||||||
|
|
||||||
|
|
||||||
class ShowLicense(ShowCommand):
|
|
||||||
|
|
||||||
"""Show License.
|
|
||||||
|
|
||||||
show license
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(ShowLicense, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "show license"
|
|
||||||
self.start_key = "License"
|
|
||||||
|
|
||||||
def _parser(self, content=None):
|
|
||||||
"""Parse License format.
|
|
||||||
|
|
||||||
# License format
|
|
||||||
|
|
||||||
License Amount(Partition/Subsystem) Expired
|
|
||||||
------------------------------------------------
|
|
||||||
EonPath --- True
|
|
||||||
|
|
||||||
# Result
|
|
||||||
|
|
||||||
{
|
|
||||||
'EonPath': {
|
|
||||||
'Amount': '---',
|
|
||||||
'Support': True
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
:param content: The parse Content.
|
|
||||||
:returns: parse result
|
|
||||||
"""
|
|
||||||
rc, out = super(ShowLicense, self)._parser(content)
|
|
||||||
|
|
||||||
if rc != 0:
|
|
||||||
return rc, out
|
|
||||||
|
|
||||||
if len(out) > 0:
|
|
||||||
result = {}
|
|
||||||
for entry in out:
|
|
||||||
if entry['Expired'] == '---' or entry['Expired'] == 'Expired':
|
|
||||||
support = False
|
|
||||||
else:
|
|
||||||
support = True
|
|
||||||
result[entry['License']] = {
|
|
||||||
'Amount':
|
|
||||||
entry['Amount(Partition/Subsystem)'],
|
|
||||||
'Support': support
|
|
||||||
}
|
|
||||||
return rc, result
|
|
||||||
|
|
||||||
return rc, []
|
|
||||||
|
|
||||||
|
|
||||||
class ShowReplica(ShowCommand):
|
|
||||||
|
|
||||||
"""Show information of all replication jobs or specific job.
|
|
||||||
|
|
||||||
show replica [id={volume-pair-IDs}] [-l] id={volume-pair-IDs}
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(ShowReplica, self).__init__(*args, **kwargs)
|
|
||||||
self.command = 'show replica'
|
|
||||||
|
|
||||||
|
|
||||||
class ShowWWN(ShowCommand):
|
|
||||||
|
|
||||||
"""Show Fibre network.
|
|
||||||
|
|
||||||
show wwn
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(ShowWWN, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "show wwn"
|
|
||||||
self.start_key = "CH"
|
|
||||||
|
|
||||||
|
|
||||||
class ShowIQN(ShowCommand):
|
|
||||||
|
|
||||||
"""Show iSCSI initiator IQN which is set by create iqn.
|
|
||||||
|
|
||||||
show iqn
|
|
||||||
"""
|
|
||||||
|
|
||||||
LIST_START_LINE = "List of initiator IQN(s):"
|
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super(ShowIQN, self).__init__(*args, **kwargs)
|
|
||||||
self.command = "show iqn"
|
|
||||||
self.default_type = "list"
|
|
||||||
|
|
||||||
def detect_detail_start_index(self, content):
|
|
||||||
for i in range(3, len(content)):
|
|
||||||
if content[i].strip() == self.LIST_START_LINE:
|
|
||||||
return i + 2
|
|
||||||
|
|
||||||
return -1
|
|
||||||
File diff suppressed because it is too large
Load Diff
@ -1,130 +0,0 @@
|
|||||||
========================
|
|
||||||
Infortrend volume driver
|
|
||||||
========================
|
|
||||||
|
|
||||||
The `Infortrend <http://www.infortrend.com/global>`__ volume driver is a Block Storage driver
|
|
||||||
providing iSCSI and Fibre Channel support for Infortrend storages.
|
|
||||||
|
|
||||||
Supported operations
|
|
||||||
~~~~~~~~~~~~~~~~~~~~
|
|
||||||
|
|
||||||
The Infortrend volume driver supports the following volume operations:
|
|
||||||
|
|
||||||
* Create, delete, attach, and detach volumes.
|
|
||||||
* Create and delete a snapshot.
|
|
||||||
* Create a volume from a snapshot.
|
|
||||||
* Copy an image to a volume.
|
|
||||||
* Copy a volume to an image.
|
|
||||||
* Clone a volume.
|
|
||||||
* Extend a volume
|
|
||||||
* Retype a volume.
|
|
||||||
* Manage and unmanage a volume.
|
|
||||||
* Migrate a volume with back-end assistance.
|
|
||||||
* Live migrate an instance with volumes hosted on an Infortrend backend.
|
|
||||||
|
|
||||||
System requirements
|
|
||||||
~~~~~~~~~~~~~~~~~~~
|
|
||||||
|
|
||||||
To use the Infortrend volume driver, the following settings are required:
|
|
||||||
|
|
||||||
Set up Infortrend storage
|
|
||||||
-------------------------
|
|
||||||
|
|
||||||
* Create logical volumes in advance.
|
|
||||||
* Host side setting ``Peripheral device type`` should be
|
|
||||||
``No Device Present (Type=0x7f)``.
|
|
||||||
|
|
||||||
Set up cinder-volume node
|
|
||||||
-------------------------
|
|
||||||
|
|
||||||
* Install Oracle Java 7 or later.
|
|
||||||
|
|
||||||
* Download the Infortrend storage CLI from the
|
|
||||||
`release page <https://github.com/infortrend-openstack/infortrend-cinder-driver/releases>`__,
|
|
||||||
and assign it to the default path ``/opt/bin/Infortrend/``.
|
|
||||||
|
|
||||||
Driver configuration
|
|
||||||
~~~~~~~~~~~~~~~~~~~~
|
|
||||||
|
|
||||||
On ``cinder-volume`` nodes, set the following in your
|
|
||||||
``/etc/cinder/cinder.conf``, and use the following options to configure it:
|
|
||||||
|
|
||||||
Driver options
|
|
||||||
--------------
|
|
||||||
|
|
||||||
.. include:: ../../tables/cinder-infortrend.inc
|
|
||||||
|
|
||||||
iSCSI configuration example
|
|
||||||
---------------------------
|
|
||||||
|
|
||||||
.. code-block:: ini
|
|
||||||
|
|
||||||
[DEFAULT]
|
|
||||||
default_volume_type = IFT-ISCSI
|
|
||||||
enabled_backends = IFT-ISCSI
|
|
||||||
|
|
||||||
[IFT-ISCSI]
|
|
||||||
volume_driver = cinder.volume.drivers.infortrend.infortrend_iscsi_cli.InfortrendCLIISCSIDriver
|
|
||||||
volume_backend_name = IFT-ISCSI
|
|
||||||
infortrend_pools_name = POOL-1,POOL-2
|
|
||||||
san_ip = MANAGEMENT_PORT_IP
|
|
||||||
infortrend_slots_a_channels_id = 0,1,2,3
|
|
||||||
infortrend_slots_b_channels_id = 0,1,2,3
|
|
||||||
|
|
||||||
Fibre Channel configuration example
|
|
||||||
-----------------------------------
|
|
||||||
|
|
||||||
.. code-block:: ini
|
|
||||||
|
|
||||||
[DEFAULT]
|
|
||||||
default_volume_type = IFT-FC
|
|
||||||
enabled_backends = IFT-FC
|
|
||||||
|
|
||||||
[IFT-FC]
|
|
||||||
volume_driver = cinder.volume.drivers.infortrend.infortrend_fc_cli.InfortrendCLIFCDriver
|
|
||||||
volume_backend_name = IFT-FC
|
|
||||||
infortrend_pools_name = POOL-1,POOL-2,POOL-3
|
|
||||||
san_ip = MANAGEMENT_PORT_IP
|
|
||||||
infortrend_slots_a_channels_id = 4,5
|
|
||||||
|
|
||||||
Multipath configuration
|
|
||||||
-----------------------
|
|
||||||
|
|
||||||
* Enable multipath for image transfer in ``/etc/cinder/cinder.conf``.
|
|
||||||
|
|
||||||
.. code-block:: ini
|
|
||||||
|
|
||||||
use_multipath_for_image_xfer = True
|
|
||||||
|
|
||||||
Restart the ``cinder-volume`` service.
|
|
||||||
|
|
||||||
* Enable multipath for volume attach and detach in ``/etc/nova/nova.conf``.
|
|
||||||
|
|
||||||
.. code-block:: ini
|
|
||||||
|
|
||||||
[libvirt]
|
|
||||||
...
|
|
||||||
volume_use_multipath = True
|
|
||||||
...
|
|
||||||
|
|
||||||
Restart the ``nova-compute`` service.
|
|
||||||
|
|
||||||
Extra spec usage
|
|
||||||
----------------
|
|
||||||
|
|
||||||
* ``infortrend:provisioning`` - Defaults to ``full`` provisioning,
|
|
||||||
the valid values are thin and full.
|
|
||||||
|
|
||||||
* ``infortrend:tiering`` - Defaults to use ``all`` tiering,
|
|
||||||
the valid values are subsets of 0, 1, 2, 3.
|
|
||||||
|
|
||||||
If multi-pools are configured in ``cinder.conf``,
|
|
||||||
it can be specified for each pool, separated by semicolon.
|
|
||||||
|
|
||||||
For example:
|
|
||||||
|
|
||||||
``infortrend:provisioning``: ``POOL-1:thin; POOL-2:full``
|
|
||||||
|
|
||||||
``infortrend:tiering``: ``POOL-1:all; POOL-2:0; POOL-3:0,1,3``
|
|
||||||
|
|
||||||
For more details, see `Infortrend documents <http://www.infortrend.com/ImageLoader/LoadDoc/715>`_.
|
|
||||||
@ -36,7 +36,6 @@ Volume drivers
|
|||||||
drivers/ibm-storage-volume-driver.rst
|
drivers/ibm-storage-volume-driver.rst
|
||||||
drivers/ibm-flashsystem-volume-driver.rst
|
drivers/ibm-flashsystem-volume-driver.rst
|
||||||
drivers/infinidat-volume-driver.rst
|
drivers/infinidat-volume-driver.rst
|
||||||
drivers/infortrend-volume-driver.rst
|
|
||||||
drivers/itri-disco-driver.rst
|
drivers/itri-disco-driver.rst
|
||||||
drivers/kaminario-driver.rst
|
drivers/kaminario-driver.rst
|
||||||
drivers/lenovo-driver.rst
|
drivers/lenovo-driver.rst
|
||||||
|
|||||||
@ -1,36 +0,0 @@
|
|||||||
..
|
|
||||||
Warning: Do not edit this file. It is automatically generated from the
|
|
||||||
software project's code and your changes will be overwritten.
|
|
||||||
|
|
||||||
The tool to generate this file lives in openstack-doc-tools repository.
|
|
||||||
|
|
||||||
Please make any changes needed in the code, then run the
|
|
||||||
autogenerate-config-doc tool from the openstack-doc-tools repository, or
|
|
||||||
ask for help on the documentation mailing list, IRC channel or meeting.
|
|
||||||
|
|
||||||
.. _cinder-infortrend:
|
|
||||||
|
|
||||||
.. list-table:: Description of Infortrend volume driver configuration options
|
|
||||||
:header-rows: 1
|
|
||||||
:class: config-ref-table
|
|
||||||
|
|
||||||
* - Configuration option = Default value
|
|
||||||
- Description
|
|
||||||
* - **[DEFAULT]**
|
|
||||||
-
|
|
||||||
* - ``infortrend_cli_max_retries`` = ``5``
|
|
||||||
- (Integer) Maximum retry time for cli. Default is 5.
|
|
||||||
* - ``infortrend_cli_path`` = ``/opt/bin/Infortrend/raidcmd_ESDS10.jar``
|
|
||||||
- (String) The Infortrend CLI absolute path. By default, it is at /opt/bin/Infortrend/raidcmd_ESDS10.jar
|
|
||||||
* - ``infortrend_cli_timeout`` = ``30``
|
|
||||||
- (Integer) Default timeout for CLI copy operations in minutes. Support: migrate volume, create cloned volume and create volume from snapshot. By Default, it is 30 minutes.
|
|
||||||
* - ``infortrend_pools_name`` =
|
|
||||||
- (String) Infortrend raid pool name list. It is separated with comma.
|
|
||||||
* - ``infortrend_provisioning`` = ``full``
|
|
||||||
- (String) Let the volume use specific provisioning. By default, it is the full provisioning. The supported options are full or thin.
|
|
||||||
* - ``infortrend_slots_a_channels_id`` = ``0,1,2,3,4,5,6,7``
|
|
||||||
- (String) Infortrend raid channel ID list on Slot A for OpenStack usage. It is separated with comma. By default, it is the channel 0~7.
|
|
||||||
* - ``infortrend_slots_b_channels_id`` = ``0,1,2,3,4,5,6,7``
|
|
||||||
- (String) Infortrend raid channel ID list on Slot B for OpenStack usage. It is separated with comma. By default, it is the channel 0~7.
|
|
||||||
* - ``infortrend_tiering`` = ``0``
|
|
||||||
- (String) Let the volume use specific tiering level. By default, it is the level 0. The supported levels are 0,2,3,4.
|
|
||||||
@ -8,4 +8,5 @@ upgrade:
|
|||||||
* Blockbridge
|
* Blockbridge
|
||||||
* Coho
|
* Coho
|
||||||
* FalconStor FSS
|
* FalconStor FSS
|
||||||
|
* Infortrend
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user