Add Cinder driver for TOYOU ACS5000
* Supported Protocol - iSCSI * Supported Feature - Volume Create/Delete - Volume Attach/Detach - Snapshot Create/Delete - Create Volume from Snapshot - Get Volume Stats - Copy Image to Volume - Copy Volume to Image - Clone Volume - Extend Volume - Volume Migration ThirdPartySystems: TOYOU ACS5000 CI Change-Id: Ia7d2056e0a49032654812da74dac514dfac83529 Implement: blueprint toyou-acs5000-driver
This commit is contained in:
yangheng
parent
108c554dc3
commit
fe0822b1bc
@ -158,6 +158,10 @@ from cinder.volume.drivers.stx import common as \
|
||||
cinder_volume_drivers_stx_common
|
||||
from cinder.volume.drivers.synology import synology_common as \
|
||||
cinder_volume_drivers_synology_synologycommon
|
||||
from cinder.volume.drivers.toyou.acs5000 import acs5000_common as \
|
||||
cinder_volume_drivers_toyou_acs5000_acs5000common
|
||||
from cinder.volume.drivers.toyou.acs5000 import acs5000_iscsi as \
|
||||
cinder_volume_drivers_toyou_acs5000_acs5000iscsi
|
||||
from cinder.volume.drivers.veritas_access import veritas_iscsi as \
|
||||
cinder_volume_drivers_veritas_access_veritasiscsi
|
||||
from cinder.volume.drivers.vmware import vmdk as \
|
||||
@ -272,6 +276,10 @@ def list_opts():
|
||||
cinder_volume_drivers_open_e_options.jdss_iscsi_opts,
|
||||
cinder_volume_drivers_open_e_options.jdss_volume_opts,
|
||||
cinder_volume_drivers_sandstone_sdsdriver.sds_opts,
|
||||
cinder_volume_drivers_toyou_acs5000_acs5000common.
|
||||
acs5000c_opts,
|
||||
cinder_volume_drivers_toyou_acs5000_acs5000iscsi.
|
||||
acs5000_iscsi_opts,
|
||||
cinder_volume_drivers_veritas_access_veritasiscsi.VA_VOL_OPTS,
|
||||
cinder_volume_manager.volume_manager_opts,
|
||||
cinder_wsgi_eventletserver.socket_opts,
|
||||
|
||||
0
cinder/tests/unit/volume/drivers/toyou/__init__.py
Normal file
0
cinder/tests/unit/volume/drivers/toyou/__init__.py
Normal file
1341
cinder/tests/unit/volume/drivers/toyou/test_acs5000.py
Normal file
1341
cinder/tests/unit/volume/drivers/toyou/test_acs5000.py
Normal file
File diff suppressed because it is too large
Load Diff
0
cinder/volume/drivers/toyou/__init__.py
Normal file
0
cinder/volume/drivers/toyou/__init__.py
Normal file
0
cinder/volume/drivers/toyou/acs5000/__init__.py
Normal file
0
cinder/volume/drivers/toyou/acs5000/__init__.py
Normal file
828
cinder/volume/drivers/toyou/acs5000/acs5000_common.py
Normal file
828
cinder/volume/drivers/toyou/acs5000/acs5000_common.py
Normal file
@ -0,0 +1,828 @@
|
||||
# Copyright 2020 toyou Corp.
|
||||
# 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.
|
||||
|
||||
"""
|
||||
acs5000 san for common driver
|
||||
It will be called by iSCSI driver
|
||||
"""
|
||||
|
||||
import json
|
||||
import random
|
||||
|
||||
from eventlet import greenthread
|
||||
from oslo_concurrency import processutils
|
||||
from oslo_config import cfg
|
||||
from oslo_log import log as logging
|
||||
from oslo_utils import excutils
|
||||
from oslo_utils import units
|
||||
import paramiko
|
||||
|
||||
from cinder import coordination
|
||||
from cinder import exception
|
||||
from cinder.i18n import _
|
||||
from cinder import ssh_utils
|
||||
from cinder import utils as cinder_utils
|
||||
from cinder.volume import driver
|
||||
from cinder.volume.drivers.san import san
|
||||
from cinder.volume import volume_utils
|
||||
|
||||
VOLUME_PREFIX = 'cinder-'
|
||||
|
||||
LOG = logging.getLogger(__name__)
|
||||
acs5000c_opts = [
|
||||
cfg.ListOpt(
|
||||
'acs5000_volpool_name',
|
||||
default=['pool01'],
|
||||
help='Comma separated list of storage system storage '
|
||||
'pools for volumes.'),
|
||||
cfg.IntOpt(
|
||||
'acs5000_copy_interval',
|
||||
default=5,
|
||||
min=3,
|
||||
max=100,
|
||||
help='When volume copy task is going on,refresh volume '
|
||||
'status interval')
|
||||
]
|
||||
CONF = cfg.CONF
|
||||
CONF.register_opts(acs5000c_opts)
|
||||
|
||||
|
||||
class Command(object):
|
||||
|
||||
def __init__(self, run_ssh):
|
||||
self._ssh = run_ssh
|
||||
|
||||
def _run_ssh(self, ssh_cmd):
|
||||
try:
|
||||
return self._ssh(ssh_cmd)
|
||||
except processutils.ProcessExecutionError as e:
|
||||
msg = (_('CLI Exception output:\n command: %(cmd)s\n '
|
||||
'stdout: %(out)s\n stderr: %(err)s.') %
|
||||
{'cmd': ssh_cmd,
|
||||
'out': e.stdout,
|
||||
'err': e.stderr})
|
||||
LOG.error(msg)
|
||||
raise exception.VolumeBackendAPIException(data=msg)
|
||||
|
||||
def run_ssh_info(self, ssh_cmd, key=False):
|
||||
"""Run an SSH command and return parsed output."""
|
||||
out, err = self._run_ssh(ssh_cmd)
|
||||
if len(err):
|
||||
msg = (_('Execute command %(cmd)s failed, '
|
||||
'out: %(out)s, err: %(err)s.') %
|
||||
{'cmd': ' '.join(ssh_cmd),
|
||||
'out': str(out),
|
||||
'err': str(err)})
|
||||
LOG.error(msg)
|
||||
raise exception.VolumeBackendAPIException(data=msg)
|
||||
try:
|
||||
info = json.loads(out)
|
||||
except json.JSONDecodeError as e:
|
||||
msg = (_('Parse response error from CLI command %(cmd)s, '
|
||||
'out: %(out)s, err: %(err)s') %
|
||||
{'cmd': ' '.join(ssh_cmd),
|
||||
'out': str(out),
|
||||
'err': e})
|
||||
LOG.error(msg)
|
||||
raise exception.VolumeBackendAPIException(data=msg)
|
||||
|
||||
if not isinstance(info, dict):
|
||||
msg = (_('Unexpected format from CLI command %(cmd)s, '
|
||||
'result: %(info)s.') %
|
||||
{'cmd': ' '.join(ssh_cmd),
|
||||
'info': str(info)})
|
||||
LOG.error(msg)
|
||||
raise exception.VolumeBackendAPIException(data=msg)
|
||||
require = ('key', 'msg', 'arr')
|
||||
require_valid = True
|
||||
for r in require:
|
||||
if r not in info.keys():
|
||||
require_valid = False
|
||||
break
|
||||
if not require_valid:
|
||||
msg = (_('Unexpected response from CLI command %(cmd)s, '
|
||||
'require \'key\' \'msg\' \'arr\'. out: %(info)s.') %
|
||||
{'cmd': ' '.join(ssh_cmd),
|
||||
'info': str(info)})
|
||||
LOG.error(msg)
|
||||
raise exception.VolumeBackendAPIException(data=msg)
|
||||
elif int(info['key']) != 0:
|
||||
msg = (_('Unexpected error output from CLI command %(cmd)s, '
|
||||
'key: %(key)s, msg: %(msg)s.') %
|
||||
{'cmd': ' '.join(ssh_cmd),
|
||||
'msg': info['msg'],
|
||||
'key': info['key']})
|
||||
LOG.error(msg)
|
||||
if not key:
|
||||
raise exception.VolumeBackendAPIException(data=msg)
|
||||
if key:
|
||||
info['key'] = int(info['key'])
|
||||
return info
|
||||
else:
|
||||
return info['arr']
|
||||
|
||||
def get_system(self):
|
||||
ssh_cmd = ['cinder', 'Storage', 'sshGetSystem']
|
||||
return self.run_ssh_info(ssh_cmd)
|
||||
|
||||
def get_ip_connect(self, target):
|
||||
ssh_cmd = ['cinder',
|
||||
'Storage',
|
||||
'sshGetIscsiConnect',
|
||||
'--target',
|
||||
target]
|
||||
return self.run_ssh_info(ssh_cmd)
|
||||
|
||||
def get_pool_info(self, pool):
|
||||
ssh_cmd = ['cinder',
|
||||
'Storage',
|
||||
'sshGetPoolInfo',
|
||||
'--poolName',
|
||||
pool]
|
||||
return self.run_ssh_info(ssh_cmd)
|
||||
|
||||
def get_volume(self, volume):
|
||||
ssh_cmd = ['cinder',
|
||||
'Storage',
|
||||
'sshGetVolume']
|
||||
if not volume:
|
||||
return []
|
||||
elif isinstance(volume, str):
|
||||
ssh_cmd.append('--name')
|
||||
ssh_cmd.append(volume)
|
||||
elif isinstance(volume, list):
|
||||
for vol in volume:
|
||||
ssh_cmd.append('--name')
|
||||
ssh_cmd.append(vol)
|
||||
result = self.run_ssh_info(ssh_cmd)
|
||||
if not result:
|
||||
return []
|
||||
else:
|
||||
return result
|
||||
|
||||
def ls_ctr_info(self):
|
||||
ssh_cmd = ['cinder', 'Storage', 'sshGetCtrInfo']
|
||||
ctrs = self.run_ssh_info(ssh_cmd)
|
||||
nodes = {}
|
||||
for node_data in ctrs:
|
||||
nodes[node_data['id']] = {
|
||||
'id': node_data['id'],
|
||||
'name': node_data['name'],
|
||||
'iscsi_name': node_data['iscsi_name'],
|
||||
'WWNN': node_data['WWNN'],
|
||||
'WWPN': [],
|
||||
'status': node_data['status'],
|
||||
'ipv4': [],
|
||||
'ipv6': [],
|
||||
'enabled_protocols': []
|
||||
}
|
||||
return nodes
|
||||
|
||||
def create_volume(self, name, size, pool_name, type='0'):
|
||||
ssh_cmd = ['cinder',
|
||||
'Storage',
|
||||
'sshCreateVolume',
|
||||
'--volumesize',
|
||||
size,
|
||||
'--volumename',
|
||||
name,
|
||||
'--cinderPool',
|
||||
pool_name,
|
||||
'--type',
|
||||
type]
|
||||
return self.run_ssh_info(ssh_cmd, key=True)
|
||||
|
||||
def delete_volume(self, volume):
|
||||
ssh_cmd = ['cinder',
|
||||
'Storage',
|
||||
'sshDeleteVolume',
|
||||
'--cinderVolume',
|
||||
volume]
|
||||
return self.run_ssh_info(ssh_cmd)
|
||||
|
||||
def extend_volume(self, volume, size):
|
||||
ssh_cmd = ['cinder',
|
||||
'Storage',
|
||||
'sshCinderExtendVolume',
|
||||
'--cinderVolume',
|
||||
volume,
|
||||
'--extendunit',
|
||||
'gb',
|
||||
'--extendsize',
|
||||
str(size)]
|
||||
return self.run_ssh_info(ssh_cmd, key=True)
|
||||
|
||||
def create_clone(self, volume_name, clone_name):
|
||||
ssh_cmd = ['cinder',
|
||||
'Storage',
|
||||
'sshMkLocalClone',
|
||||
'--cinderVolume',
|
||||
volume_name,
|
||||
'--cloneVolume',
|
||||
clone_name]
|
||||
return self.run_ssh_info(ssh_cmd, key=True)
|
||||
|
||||
def start_clone(self, volume_name, snapshot=''):
|
||||
ssh_cmd = ['cinder',
|
||||
'Storage',
|
||||
'sshMkStartLocalClone',
|
||||
'--cinderVolume',
|
||||
volume_name,
|
||||
'--snapshot',
|
||||
snapshot]
|
||||
return self.run_ssh_info(ssh_cmd, key=True)
|
||||
|
||||
def delete_clone(self, volume_name, snapshot=''):
|
||||
ssh_cmd = ['cinder',
|
||||
'Storage',
|
||||
'sshRemoveLocalClone',
|
||||
'--name',
|
||||
volume_name,
|
||||
'--snapshot',
|
||||
snapshot]
|
||||
return self.run_ssh_info(ssh_cmd, key=True)
|
||||
|
||||
def create_lun_map(self, volume_name, protocol, host, target=None):
|
||||
"""Map volume to host."""
|
||||
LOG.debug('enter: create_lun_map volume %s.', volume_name)
|
||||
ssh_cmd = ['cinder',
|
||||
'Storage',
|
||||
'sshMapVoltoHost',
|
||||
'--cinderVolume',
|
||||
volume_name,
|
||||
'--protocol',
|
||||
protocol]
|
||||
if isinstance(host, list):
|
||||
for ht in host:
|
||||
ssh_cmd.append('--host')
|
||||
ssh_cmd.append(ht)
|
||||
else:
|
||||
ssh_cmd.append('--host')
|
||||
ssh_cmd.append(str(host))
|
||||
if target:
|
||||
ssh_cmd.append('--target')
|
||||
ssh_cmd.append(target)
|
||||
return self.run_ssh_info(ssh_cmd, key=True)
|
||||
|
||||
def delete_lun_map(self, volume_name, protocol, host, target=''):
|
||||
ssh_cmd = ['cinder',
|
||||
'Storage',
|
||||
'sshDeleteLunMap',
|
||||
'--cinderVolume',
|
||||
volume_name,
|
||||
'--protocol',
|
||||
protocol]
|
||||
if isinstance(host, list):
|
||||
for ht in host:
|
||||
ssh_cmd.append('--cinderHost')
|
||||
ssh_cmd.append(ht)
|
||||
else:
|
||||
ssh_cmd.append('--cinderHost')
|
||||
ssh_cmd.append(str(host))
|
||||
if target:
|
||||
ssh_cmd.append('--cinderTarget')
|
||||
ssh_cmd.append(target)
|
||||
return self.run_ssh_info(ssh_cmd, key=True)
|
||||
|
||||
def create_snapshot(self, volume_name, snapshot_name):
|
||||
ssh_cmd = ['cinder',
|
||||
'Storage',
|
||||
'sshCreateSnapshot',
|
||||
'--volume',
|
||||
volume_name,
|
||||
'--snapshot',
|
||||
snapshot_name]
|
||||
return self.run_ssh_info(ssh_cmd, key=True)
|
||||
|
||||
def delete_snapshot(self, volume_name, snapshot_name):
|
||||
ssh_cmd = ['cinder',
|
||||
'Storage',
|
||||
'sshDeleteSnapshot',
|
||||
'--volume',
|
||||
volume_name,
|
||||
'--snapshot',
|
||||
snapshot_name]
|
||||
return self.run_ssh_info(ssh_cmd, key=True)
|
||||
|
||||
def set_volume_property(self, name, setting):
|
||||
ssh_cmd = ['cinder',
|
||||
'Storage',
|
||||
'sshSetVolumeProperty',
|
||||
'--volume',
|
||||
name]
|
||||
for key, value in setting.items():
|
||||
ssh_cmd.extend(['--' + key, value])
|
||||
return self.run_ssh_info(ssh_cmd, key=True)
|
||||
|
||||
|
||||
class Acs5000CommonDriver(san.SanDriver,
|
||||
driver.MigrateVD,
|
||||
driver.CloneableImageVD):
|
||||
"""TOYOU ACS5000 storage abstract common class.
|
||||
|
||||
.. code-block:: none
|
||||
|
||||
Version history:
|
||||
1.0.0 - Initial driver
|
||||
|
||||
"""
|
||||
VENDOR = 'TOYOU'
|
||||
VERSION = '1.0.0'
|
||||
|
||||
def __init__(self, *args, **kwargs):
|
||||
super(Acs5000CommonDriver, self).__init__(*args, **kwargs)
|
||||
self.configuration.append_config_values(acs5000c_opts)
|
||||
self._backend_name = self.configuration.safe_get('volume_backend_name')
|
||||
self.pools = self.configuration.acs5000_volpool_name
|
||||
self._cmd = Command(self._run_ssh)
|
||||
self.protocol = None
|
||||
self._state = {'storage_nodes': {},
|
||||
'enabled_protocols': set(),
|
||||
'system_name': None,
|
||||
'system_id': None,
|
||||
'code_level': None,
|
||||
'version': None}
|
||||
|
||||
@cinder_utils.trace_method
|
||||
def do_setup(self, ctxt):
|
||||
"""Check that we have all configuration details from the storage."""
|
||||
self._validate_pools_exist()
|
||||
|
||||
self._state.update(self._cmd.get_system())
|
||||
|
||||
self._state['storage_nodes'] = self._cmd.ls_ctr_info()
|
||||
ports = self._cmd.get_ip_connect(
|
||||
str(self.configuration.acs5000_target))
|
||||
if ports['iscsi_name']:
|
||||
self._state['enabled_protocols'].add('iSCSI')
|
||||
iscsi_name = ' '.join(ports['iscsi_name'])
|
||||
for node in self._state['storage_nodes'].values():
|
||||
if ('ctr%s' % node['id']) in iscsi_name:
|
||||
node['enabled_protocols'].append('iSCSI')
|
||||
return
|
||||
|
||||
def _validate_pools_exist(self):
|
||||
LOG.debug('_validate_pools_exist. '
|
||||
'pools: %s', ' '.join(self.pools))
|
||||
for pool in self.pools:
|
||||
pool_data = self._cmd.get_pool_info(pool)
|
||||
if not pool_data:
|
||||
msg = _('Failed getting details for pool %s.') % pool
|
||||
raise exception.InvalidInput(reason=msg)
|
||||
return True
|
||||
|
||||
@cinder_utils.trace_method
|
||||
def check_for_setup_error(self):
|
||||
"""Ensure that the params are set properly."""
|
||||
if self._state['system_name'] is None:
|
||||
exception_msg = _('Unable to determine system name.')
|
||||
raise exception.VolumeBackendAPIException(data=exception_msg)
|
||||
if self._state['system_id'] is None:
|
||||
exception_msg = _('Unable to determine system id.')
|
||||
raise exception.VolumeBackendAPIException(data=exception_msg)
|
||||
if len(self._state['storage_nodes']) != 2:
|
||||
msg = _('do_setup: No configured nodes.')
|
||||
LOG.error(msg)
|
||||
raise exception.VolumeDriverException(message=msg)
|
||||
if self.protocol not in self._state['enabled_protocols']:
|
||||
raise exception.InvalidInput(
|
||||
reason=(_('The storage device does not support %(prot)s. '
|
||||
'Please configure the device to support %(prot)s '
|
||||
'or switch to a driver using a different '
|
||||
'protocol.') % {'prot': self.protocol}))
|
||||
required = ['san_ip',
|
||||
'san_ssh_port',
|
||||
'san_login',
|
||||
'acs5000_volpool_name']
|
||||
for param in required:
|
||||
if not self.configuration.safe_get(param):
|
||||
raise exception.InvalidInput(
|
||||
reason=_('%s is not set.') % param)
|
||||
|
||||
if not self.configuration.san_password:
|
||||
raise exception.InvalidInput(
|
||||
reason='Password is required for authentication')
|
||||
|
||||
return
|
||||
|
||||
def _run_ssh(self, cmd_list, check_exit_code=True):
|
||||
cinder_utils.check_ssh_injection(cmd_list)
|
||||
command = ' '.join(cmd_list)
|
||||
if not self.sshpool:
|
||||
try:
|
||||
self.sshpool = self._set_up_sshpool(self.configuration.san_ip)
|
||||
except paramiko.SSHException as e:
|
||||
raise exception.VolumeDriverException(message=e)
|
||||
ssh_execute = self._ssh_execute(
|
||||
self.sshpool, command, check_exit_code)
|
||||
return ssh_execute
|
||||
|
||||
def _set_up_sshpool(self, ip):
|
||||
port = self.configuration.get('san_ssh_port', 22)
|
||||
login = self.configuration.get('san_login')
|
||||
password = self.configuration.get('san_password')
|
||||
timeout = self.configuration.get('ssh_conn_timeout', 30)
|
||||
min_size = self.configuration.get('ssh_min_pool_conn', 1)
|
||||
max_size = self.configuration.get('ssh_max_pool_conn', 5)
|
||||
sshpool = ssh_utils.SSHPool(ip,
|
||||
port,
|
||||
timeout,
|
||||
login,
|
||||
password=password,
|
||||
min_size=min_size,
|
||||
max_size=max_size)
|
||||
return sshpool
|
||||
|
||||
def _ssh_execute(
|
||||
self,
|
||||
sshpool,
|
||||
command,
|
||||
check_exit_code=True):
|
||||
# noinspection PyBroadException
|
||||
try:
|
||||
with sshpool.item() as ssh:
|
||||
try:
|
||||
return processutils.ssh_execute(
|
||||
ssh, command, check_exit_code=check_exit_code)
|
||||
except Exception as e:
|
||||
LOG.error('Error has occurred: %s', e)
|
||||
raise processutils.ProcessExecutionError(
|
||||
exit_code=e.exit_code,
|
||||
stdout=e.stdout,
|
||||
stderr=e.stderr,
|
||||
cmd=e.cmd)
|
||||
except Exception:
|
||||
with excutils.save_and_reraise_exception():
|
||||
LOG.error('Error running SSH command: %s', command)
|
||||
|
||||
def create_volume(self, volume):
|
||||
LOG.debug('create_volume, volume %s.', volume['id'])
|
||||
volume_name = VOLUME_PREFIX + volume['id'][-12:]
|
||||
pool_name = volume_utils.extract_host(volume['host'], 'pool')
|
||||
ret = self._cmd.create_volume(
|
||||
volume_name,
|
||||
str(volume['size']),
|
||||
pool_name)
|
||||
if ret['key'] == 310:
|
||||
msg = _('Volume: %s with same name '
|
||||
'already exists on the system.') % volume_name
|
||||
raise exception.VolumeBackendAPIException(data=msg)
|
||||
elif ret['key'] == 102:
|
||||
allow_size = 0
|
||||
for p in self._stats['pools']:
|
||||
if p['pool_name'] == pool_name:
|
||||
allow_size = p['free_capacity_gb']
|
||||
break
|
||||
raise exception.VolumeSizeExceedsLimit(size=int(volume['size']),
|
||||
limit=allow_size)
|
||||
elif ret['key'] == 307:
|
||||
raise exception.VolumeLimitExceeded(allowed=96,
|
||||
name=volume_name)
|
||||
elif ret['key'] == 308:
|
||||
raise exception.VolumeLimitExceeded(allowed=4096,
|
||||
name=volume_name)
|
||||
model_update = None
|
||||
return model_update
|
||||
|
||||
def delete_volume(self, volume):
|
||||
volume_name = VOLUME_PREFIX + volume['id'][-12:]
|
||||
self._cmd.delete_volume(volume_name)
|
||||
|
||||
def create_snapshot(self, snapshot):
|
||||
volume_name = VOLUME_PREFIX + snapshot['volume_name'][-12:]
|
||||
snapshot_name = VOLUME_PREFIX + snapshot['name'][-12:]
|
||||
ret = self._cmd.create_snapshot(volume_name, snapshot_name)
|
||||
if ret['key'] == 303:
|
||||
raise exception.VolumeNotFound(volume_id=volume_name)
|
||||
elif ret['key'] == 503:
|
||||
raise exception.SnapshotLimitExceeded(allowed=4096)
|
||||
elif ret['key'] == 504:
|
||||
raise exception.SnapshotLimitExceeded(allowed=64)
|
||||
|
||||
def delete_snapshot(self, snapshot):
|
||||
volume_name = VOLUME_PREFIX + snapshot['volume_name'][-12:]
|
||||
snapshot_name = VOLUME_PREFIX + snapshot['name'][-12:]
|
||||
ret = self._cmd.delete_snapshot(volume_name, snapshot_name)
|
||||
if ret['key'] == 505:
|
||||
raise exception.SnapshotNotFound(snapshot_id=snapshot['id'])
|
||||
|
||||
def create_volume_from_snapshot(self, volume, snapshot):
|
||||
snapshot_name = VOLUME_PREFIX + snapshot['name'][-12:]
|
||||
volume_name = VOLUME_PREFIX + volume['id'][-12:]
|
||||
source_volume = VOLUME_PREFIX + snapshot['volume_name'][-12:]
|
||||
pool = volume_utils.extract_host(volume['host'], 'pool')
|
||||
self._cmd.create_volume(volume_name,
|
||||
str(volume['size']),
|
||||
pool, '10')
|
||||
self._local_clone_copy(source_volume,
|
||||
volume_name,
|
||||
'create_volume_from_snapshot',
|
||||
snapshot_name)
|
||||
|
||||
def create_cloned_volume(self, tgt_volume, src_volume):
|
||||
clone_name = VOLUME_PREFIX + tgt_volume['id'][-12:]
|
||||
volume_name = VOLUME_PREFIX + src_volume['id'][-12:]
|
||||
tgt_pool = volume_utils.extract_host(tgt_volume['host'], 'pool')
|
||||
try:
|
||||
self._cmd.create_volume(clone_name, str(
|
||||
tgt_volume['size']), tgt_pool, '10')
|
||||
self._local_clone_copy(
|
||||
volume_name, clone_name, 'create_cloned_volume')
|
||||
except exception.VolumeBackendAPIException:
|
||||
self._cmd.delete_volume(clone_name)
|
||||
raise exception.VolumeBackendAPIException(
|
||||
data='create_cloned_volume failed.')
|
||||
|
||||
def extend_volume(self, volume, new_size):
|
||||
volume_name = VOLUME_PREFIX + volume['id'][-12:]
|
||||
ret = self._cmd.extend_volume(volume_name, int(new_size))
|
||||
if ret['key'] == 303:
|
||||
raise exception.VolumeNotFound(volume_id=volume_name)
|
||||
elif ret['key'] == 321:
|
||||
msg = _('Volume capacity shall not be '
|
||||
'less than the current size %sG.') % volume['size']
|
||||
raise exception.VolumeBackendAPIException(data=msg)
|
||||
elif ret['key'] == 102:
|
||||
pool_name = volume_utils.extract_host(volume['host'], 'pool')
|
||||
allow_size = 0
|
||||
for p in self._stats['pools']:
|
||||
if p['pool_name'] == pool_name:
|
||||
allow_size = p['free_capacity_gb']
|
||||
break
|
||||
raise exception.VolumeSizeExceedsLimit(size=int(new_size),
|
||||
limit=allow_size)
|
||||
|
||||
def migrate_volume(self, ctxt, volume, host):
|
||||
LOG.debug('enter: migrate_volume id %(id)s, host %(host)s',
|
||||
{'id': volume['id'], 'host': host['host']})
|
||||
pool = volume_utils.extract_host(volume['host'], 'pool')
|
||||
if 'system_id' not in host['capabilities']:
|
||||
LOG.error('Target host has no system_id')
|
||||
return (False, None)
|
||||
if host['capabilities']['system_id'] != self._state['system_id']:
|
||||
LOG.info('The target host does not belong to the same '
|
||||
'storage system as the current volume')
|
||||
return (False, None)
|
||||
if host['capabilities']['pool_name'] == pool:
|
||||
LOG.info('The target host belongs to the same storage system '
|
||||
'and pool as the current volume.')
|
||||
return (True, None)
|
||||
LOG.info('The target host belongs to the same storage system '
|
||||
'as the current but to a different pool. '
|
||||
'The same storage system will clone volume into the new pool')
|
||||
volume_name = VOLUME_PREFIX + volume['id'][-12:]
|
||||
tmp_name = VOLUME_PREFIX + 'tmp'
|
||||
tmp_name += str(random.randint(0, 999999)).zfill(8)
|
||||
self._cmd.create_volume(tmp_name,
|
||||
str(volume['size']),
|
||||
host['capabilities']['pool_name'],
|
||||
'10')
|
||||
self._local_clone_copy(
|
||||
volume_name, tmp_name, 'migrate_volume')
|
||||
self._cmd.delete_volume(volume_name)
|
||||
self._cmd.set_volume_property(tmp_name,
|
||||
{'type': '"RAID Volume"',
|
||||
'new_name': volume_name})
|
||||
return (True, None)
|
||||
|
||||
def get_volume_stats(self, refresh=False):
|
||||
"""Get volume stats.
|
||||
|
||||
If we haven't gotten stats yet or 'refresh' is True,
|
||||
run update the stats first.
|
||||
"""
|
||||
if not self._stats or refresh:
|
||||
self._update_volume_stats()
|
||||
return self._stats
|
||||
|
||||
def _update_volume_stats(self):
|
||||
"""Retrieve stats info from volume group."""
|
||||
LOG.debug('Updating volume stats, '
|
||||
'pools: \'%(host)s#%(pool)s\'.',
|
||||
{'host': self.host,
|
||||
'pool': ','.join(self.pools)})
|
||||
data = {}
|
||||
data['vendor_name'] = self.VENDOR
|
||||
data['driver_version'] = self.VERSION
|
||||
data['storage_protocol'] = self.protocol
|
||||
backend_name = self.configuration.safe_get('volume_backend_name')
|
||||
data['volume_backend_name'] = (backend_name or
|
||||
self._state['system_name'])
|
||||
data['pools'] = [self._build_pool_stats(pool)
|
||||
for pool in self.pools]
|
||||
|
||||
self._stats = data
|
||||
|
||||
def _build_pool_stats(self, pool):
|
||||
"""Build pool status"""
|
||||
pool_stats = {}
|
||||
try:
|
||||
pool_data = self._cmd.get_pool_info(pool)
|
||||
if pool_data:
|
||||
total_capacity_gb = float(pool_data['capacity']) / units.Gi
|
||||
free_capacity_gb = float(pool_data['free_capacity']) / units.Gi
|
||||
allocated_capacity_gb = float(
|
||||
pool_data['used_capacity']) / units.Gi
|
||||
total_volumes = None
|
||||
if 'total_volumes' in pool_data.keys():
|
||||
total_volumes = int(pool_data['total_volumes'])
|
||||
pool_stats = {
|
||||
'pool_name': pool_data['name'],
|
||||
'total_capacity_gb': total_capacity_gb,
|
||||
'free_capacity_gb': free_capacity_gb,
|
||||
'allocated_capacity_gb': allocated_capacity_gb,
|
||||
'compression_support': True,
|
||||
'reserved_percentage':
|
||||
self.configuration.reserved_percentage,
|
||||
'QoS_support': False,
|
||||
'consistencygroup_support': False,
|
||||
'multiattach': False,
|
||||
'easytier_support': False,
|
||||
'total_volumes': total_volumes,
|
||||
'system_id': self._state['system_id']}
|
||||
else:
|
||||
msg = _('Backend storage pool "%s" not found.') % pool
|
||||
LOG.error(msg)
|
||||
raise exception.VolumeBackendAPIException(data=msg)
|
||||
except exception.VolumeBackendAPIException:
|
||||
msg = _('Failed getting details for pool %s.') % pool
|
||||
raise exception.VolumeBackendAPIException(data=msg)
|
||||
|
||||
return pool_stats
|
||||
|
||||
def _local_clone_copy(self, volume, clone, action=None, snapshot=''):
|
||||
LOG.debug('enter: copy volume %(vol)s to %(clone)s by %(action)s.',
|
||||
{'vol': volume,
|
||||
'clone': clone,
|
||||
'action': action})
|
||||
if self._wait_volume_copy(volume, clone, action, 'wait'):
|
||||
LOG.info('start copy task.')
|
||||
ret = self._cmd.create_clone(volume, clone)
|
||||
if ret['key'] != 0:
|
||||
self._cmd.delete_volume(clone)
|
||||
if ret['key'] == 306:
|
||||
raise exception.VolumeBackendAPIException(
|
||||
data='The source volume must not be larger '
|
||||
'than the target volume in a clone relation. ')
|
||||
elif ret['key'] == 0:
|
||||
ret = self._cmd.start_clone(volume, snapshot)
|
||||
if ret['key'] == 505:
|
||||
raise exception.SnapshotNotFound(snapshot_id=snapshot)
|
||||
else:
|
||||
LOG.error('%(action)s failed.', {'action': action})
|
||||
raise exception.VolumeBackendAPIException(data='clone failed!')
|
||||
|
||||
if self._wait_volume_copy(volume, clone, action, 'copy'):
|
||||
self._cmd.delete_clone(volume, snapshot)
|
||||
LOG.info('%s successfully.', action)
|
||||
else:
|
||||
LOG.error('%(action)s failed.', {'action': action})
|
||||
raise exception.VolumeBackendAPIException(data='clone failed!')
|
||||
LOG.debug('leave: copy volume %(vol)s to %(clone)s by %(action)s. ',
|
||||
{'vol': volume,
|
||||
'clone': clone,
|
||||
'action': action})
|
||||
|
||||
@coordination.synchronized('acs5000-copy-{volume}-task')
|
||||
def _wait_volume_copy(self, volume, clone, function=None, action=None):
|
||||
LOG.debug('_wait_volume_copy, volume %s.', volume)
|
||||
if volume is None or clone is None:
|
||||
LOG.error('volume parameter error.')
|
||||
return False
|
||||
ret = False
|
||||
while_exit = False
|
||||
rescan = 0
|
||||
interval = self.configuration.acs5000_copy_interval
|
||||
wait_status = (
|
||||
'Initiating',
|
||||
'Rebuilding',
|
||||
'Erasing',
|
||||
'Delayed rebuilding')
|
||||
# All status
|
||||
# {"Offline", "Online", "Initiating",
|
||||
# ###"Rebuilding", "Migrating", "Parity chking",
|
||||
# ###"Cloning", "Rolling back", "Parity chking",
|
||||
# ###"Replicating", "Erasing", "Moving", "Replacing",
|
||||
# "Reclaiming", "Delayed rebuilding", "Relocation", "N/A"};
|
||||
# All health
|
||||
# {"Optimal", "Degraded", "Deleted", "Missing", "Failed",
|
||||
# "Partially optimal", "N/A"}
|
||||
while True:
|
||||
rescan += 1
|
||||
volume_info = self._cmd.get_volume([volume, clone])
|
||||
if len(volume_info) == 2:
|
||||
for vol in volume_info:
|
||||
if vol['type'] == 'BACKUP':
|
||||
if vol['health'] == 'Optimal' and (
|
||||
vol['status'] in wait_status):
|
||||
LOG.info('%(function)s %(action)s task: '
|
||||
'rescan %(scan)s times, clone %(clone)s '
|
||||
'need wait,status is %(status)s, '
|
||||
'health is %(health)s, '
|
||||
'process is %(process)s%%. ',
|
||||
{'function': function,
|
||||
'action': action,
|
||||
'scan': rescan,
|
||||
'clone': vol['name'],
|
||||
'status': vol['status'],
|
||||
'health': vol['health'],
|
||||
'process': vol['r']})
|
||||
elif vol['status'] == 'Cloning':
|
||||
LOG.info('%(function)s %(action)s task: '
|
||||
'rescan %(scan)s times,volume %(volume)s '
|
||||
'copy process %(process)s%%. ',
|
||||
{'function': function,
|
||||
'action': action,
|
||||
'scan': rescan,
|
||||
'volume': vol['name'],
|
||||
'process': vol['r']})
|
||||
elif vol['status'] == 'Queued':
|
||||
LOG.info('%(function)s %(action)s task: '
|
||||
'rescan %(scan)s times, '
|
||||
'volume %(volume)s is in the queue. ',
|
||||
{'function': function,
|
||||
'action': action, 'scan': rescan,
|
||||
'volume': vol['name']})
|
||||
elif (vol['type'] == 'RAID Volume'
|
||||
and vol['status'] == 'Online'):
|
||||
ret = True
|
||||
while_exit = True
|
||||
LOG.info('%(function)s %(action)s task: '
|
||||
'rescan %(scan)s times,volume %(volume)s '
|
||||
'copy task completed,status is Online. ',
|
||||
{'function': function,
|
||||
'action': action,
|
||||
'scan': rescan,
|
||||
'volume': vol['name']})
|
||||
elif (vol['health'] == 'Optimal'
|
||||
and (vol['status'] in wait_status)):
|
||||
LOG.info('%(function)s %(action)s task: '
|
||||
'rescan %(scan)s times,volume %(volume)s '
|
||||
'need wait, '
|
||||
'status is %(status)s,health is %(health)s, '
|
||||
'process is %(process)s%%. ',
|
||||
{'function': function,
|
||||
'action': action,
|
||||
'scan': rescan,
|
||||
'volume': vol['name'],
|
||||
'status': vol['status'],
|
||||
'health': vol['health'],
|
||||
'process': vol['r']})
|
||||
else:
|
||||
LOG.info('%(function)s %(action)s task: '
|
||||
'rescan %(scan)s times,volume %(volume)s '
|
||||
'is not normal, '
|
||||
'status %(status)s,health is %(health)s. ',
|
||||
{'function': function,
|
||||
'action': action,
|
||||
'scan': rescan,
|
||||
'volume': vol['name'],
|
||||
'status': vol['status'],
|
||||
'health': vol['health']})
|
||||
while_exit = True
|
||||
break
|
||||
elif len(volume_info) == 1:
|
||||
while_exit = True
|
||||
if volume_info[0]['name'] == volume:
|
||||
LOG.info('%(function)s %(action)s task: '
|
||||
'rescan %(scan)s times,clone %(clone)s '
|
||||
'does not exist! ',
|
||||
{'function': function,
|
||||
'action': action,
|
||||
'scan': rescan,
|
||||
'clone': clone})
|
||||
else:
|
||||
LOG.info('%(function)s %(action)s task: '
|
||||
'rescan %(scan)s times,volume %(volume)s '
|
||||
'does not exist! ',
|
||||
{'function': function,
|
||||
'action': action,
|
||||
'scan': rescan,
|
||||
'volume': volume})
|
||||
else:
|
||||
while_exit = True
|
||||
LOG.info('%(function)s %(action)s task: '
|
||||
'rescan %(scan)s times,volume %(volume)s '
|
||||
'clone %(clone)s does not exist! ',
|
||||
{'function': function,
|
||||
'action': action,
|
||||
'scan': rescan,
|
||||
'volume': volume,
|
||||
'clone': clone})
|
||||
|
||||
if while_exit:
|
||||
break
|
||||
greenthread.sleep(interval)
|
||||
return ret
|
||||
136
cinder/volume/drivers/toyou/acs5000/acs5000_iscsi.py
Normal file
136
cinder/volume/drivers/toyou/acs5000/acs5000_iscsi.py
Normal file
@ -0,0 +1,136 @@
|
||||
# Copyright 2020 toyou Corp.
|
||||
# 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.
|
||||
|
||||
"""
|
||||
acs5000 iSCSI driver
|
||||
"""
|
||||
|
||||
from oslo_config import cfg
|
||||
from oslo_log import log as logging
|
||||
|
||||
from cinder import exception
|
||||
from cinder import interface
|
||||
from cinder import utils
|
||||
from cinder.volume.drivers.toyou.acs5000 import acs5000_common
|
||||
|
||||
LOG = logging.getLogger(__name__)
|
||||
|
||||
acs5000_iscsi_opts = [
|
||||
cfg.IntOpt(
|
||||
'acs5000_target',
|
||||
default=0,
|
||||
min=0,
|
||||
max=127,
|
||||
help='A storage system iSCSI support 0 - 127 targets. '
|
||||
'Devices connected to the SCSI bus are usually '
|
||||
'described by the target ID(also known as the SCSI ID). '
|
||||
'Multiple LUN numbers can be supported under a target. '
|
||||
'A single device is usually identified '
|
||||
'by the target and the LUN.')
|
||||
]
|
||||
|
||||
CONF = cfg.CONF
|
||||
CONF.register_opts(acs5000_iscsi_opts)
|
||||
|
||||
|
||||
@interface.volumedriver
|
||||
class Acs5000ISCSIDriver(acs5000_common.Acs5000CommonDriver):
|
||||
"""TOYOU ACS5000 storage iSCSI volume driver.
|
||||
|
||||
.. code-block:: none
|
||||
|
||||
Version history:
|
||||
1.0.0 - Initial driver
|
||||
|
||||
"""
|
||||
|
||||
VENDOR = 'TOYOU'
|
||||
VERSION = '1.0.0'
|
||||
PROTOCOL = 'iSCSI'
|
||||
|
||||
# ThirdPartySystems wiki page
|
||||
CI_WIKI_NAME = 'TOYOU_ACS5000_CI'
|
||||
|
||||
def __init__(self, *args, **kwargs):
|
||||
super(Acs5000ISCSIDriver, self).__init__(*args, **kwargs)
|
||||
self.protocol = self.PROTOCOL
|
||||
self.configuration.append_config_values(
|
||||
acs5000_iscsi_opts)
|
||||
|
||||
@staticmethod
|
||||
def get_driver_options():
|
||||
return acs5000_common.acs5000c_opts + acs5000_iscsi_opts
|
||||
|
||||
def validate_connector(self, connector):
|
||||
"""Check connector for at least one enabled iSCSI protocol."""
|
||||
if 'initiator' not in connector:
|
||||
LOG.error('The connector does not '
|
||||
'contain the required information.')
|
||||
raise exception.InvalidConnectorException(
|
||||
missing='initiator')
|
||||
|
||||
@utils.synchronized('Acs5000A-host', external=True)
|
||||
def initialize_connection(self, volume, connector):
|
||||
LOG.debug('initialize_connection: volume %(vol)s with connector '
|
||||
'%(conn)s', {'vol': volume['id'], 'conn': connector})
|
||||
volume_name = acs5000_common.VOLUME_PREFIX + volume['name'][-12:]
|
||||
target = self.configuration.acs5000_target
|
||||
ret = self._cmd.create_lun_map(volume_name,
|
||||
'WITH_ISCSI',
|
||||
connector['initiator'],
|
||||
str(target))
|
||||
if ret['key'] == 303:
|
||||
raise exception.VolumeNotFound(volume_id=volume_name)
|
||||
elif ret['key'] == 402:
|
||||
raise exception.ISCSITargetAttachFailed(volume_id=volume_name)
|
||||
else:
|
||||
volume_attributes = self._cmd.get_ip_connect(str(target))
|
||||
lun_info = ret['arr']
|
||||
lun = []
|
||||
for i in range(len(volume_attributes['portal'])):
|
||||
lun.append(int(lun_info['info']))
|
||||
properties = {}
|
||||
properties['target_discovered'] = False
|
||||
properties['target_iqns'] = volume_attributes['iscsi_name']
|
||||
properties['target_portals'] = volume_attributes['portal']
|
||||
properties['target_luns'] = lun
|
||||
properties['volume_id'] = volume['id']
|
||||
properties['auth_method'] = ''
|
||||
properties['auth_username'] = ''
|
||||
properties['auth_password'] = ''
|
||||
properties['discovery_auth_method'] = ''
|
||||
properties['discovery_auth_username'] = ''
|
||||
properties['discovery_auth_password'] = ''
|
||||
return {'driver_volume_type': 'iscsi', 'data': properties}
|
||||
|
||||
@utils.synchronized('Acs5000A-host', external=True)
|
||||
def terminate_connection(self, volume, connector, **kwargs):
|
||||
LOG.debug('terminate_connection: volume %(vol)s with connector '
|
||||
'%(conn)s', {'vol': volume['id'], 'conn': connector})
|
||||
info = {'driver_volume_type': 'iscsi', 'data': {}}
|
||||
name = acs5000_common.VOLUME_PREFIX + volume['name'][-12:]
|
||||
target = self.configuration.acs5000_target
|
||||
# -1 means all lun maps
|
||||
initiator = '-1'
|
||||
if connector and connector['initiator']:
|
||||
initiator = connector['initiator']
|
||||
self._cmd.delete_lun_map(name,
|
||||
'WITH_ISCSI',
|
||||
initiator,
|
||||
str(target))
|
||||
LOG.debug('leave: terminate_connection: volume %(vol)s with '
|
||||
'connector %(conn)s', {'vol': volume['id'],
|
||||
'conn': connector})
|
||||
return info
|
||||
@ -0,0 +1,74 @@
|
||||
==========================
|
||||
TOYOU ACS5000 iSCSI driver
|
||||
==========================
|
||||
|
||||
TOYOU ACS5000 series volume driver provides OpenStack Compute instances
|
||||
with access to TOYOU ACS5000 series storage systems.
|
||||
|
||||
TOYOU ACS5000 storage can be used with iSCSI connection.
|
||||
|
||||
This documentation explains how to configure and connect the block storage
|
||||
nodes to TOYOU ACS5000 series storage.
|
||||
|
||||
Driver options
|
||||
~~~~~~~~~~~~~~
|
||||
|
||||
The following table contains the configuration options supported by the
|
||||
TOYOU ACS5000 iSCSI driver.
|
||||
|
||||
.. config-table::
|
||||
:config-target: TOYOU ACS5000
|
||||
|
||||
cinder.volume.drivers.toyou.acs5000.acs5000_iscsi
|
||||
cinder.volume.drivers.toyou.acs5000.acs5000_common
|
||||
|
||||
Supported operations
|
||||
~~~~~~~~~~~~~~~~~~~~
|
||||
|
||||
- Create, list, delete, attach (map), and detach (unmap) volumes.
|
||||
- Create, list and delete volume snapshots.
|
||||
- Create a volume from a snapshot.
|
||||
- Copy an image to a volume.
|
||||
- Copy a volume to an image.
|
||||
- Clone a volume.
|
||||
- Extend a volume.
|
||||
- Migrate a volume.
|
||||
|
||||
Configure TOYOU ACS5000 iSCSI backend
|
||||
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
||||
|
||||
This section details the steps required to configure the TOYOU ACS5000
|
||||
storage cinder driver.
|
||||
|
||||
#. In the ``cinder.conf`` configuration file under the ``[DEFAULT]``
|
||||
section, set the enabled_backends parameter.
|
||||
|
||||
.. code-block:: ini
|
||||
|
||||
[DEFAULT]
|
||||
enabled_backends = ACS5000-1
|
||||
|
||||
|
||||
#. Add a backend group section for the backend group specified
|
||||
in the enabled_backends parameter.
|
||||
|
||||
#. In the newly created backend group section, set the
|
||||
following configuration options:
|
||||
|
||||
.. code-block:: ini
|
||||
|
||||
[ACS5000-1]
|
||||
# The driver path
|
||||
volume_driver = cinder.volume.drivers.toyou.acs5000.acs5000_iscsi.Acs5000ISCSIDriver
|
||||
# Management IP of TOYOU ACS5000 storage array
|
||||
san_ip = 10.0.0.10
|
||||
# Management username of TOYOU ACS5000 storage array
|
||||
san_login = cliuser
|
||||
# Management password of TOYOU ACS5000 storage array
|
||||
san_password = clipassword
|
||||
# The Pool used to allocated volumes
|
||||
acs5000_volpool_name = pool01
|
||||
# Lun map target,support 0 - 127
|
||||
acs5000_target = 0
|
||||
# Backend name
|
||||
volume_backend_name = ACS5000
|
||||
@ -168,6 +168,9 @@ title=StorPool Storage Driver (storpool)
|
||||
[driver.synology]
|
||||
title=Synology Storage Driver (iSCSI)
|
||||
|
||||
[driver.toyou]
|
||||
title=TOYOU ACS5000 Storage Driver (iSCSI)
|
||||
|
||||
[driver.vrtsaccess]
|
||||
title=Veritas Access iSCSI Driver (iSCSI)
|
||||
|
||||
@ -250,6 +253,7 @@ driver.sandstone=complete
|
||||
driver.seagate=complete
|
||||
driver.storpool=complete
|
||||
driver.synology=complete
|
||||
driver.toyou=complete
|
||||
driver.vrtsaccess=missing
|
||||
driver.vrtscnfs=missing
|
||||
driver.vzstorage=missing
|
||||
@ -314,6 +318,7 @@ driver.sandstone=complete
|
||||
driver.seagate=complete
|
||||
driver.storpool=complete
|
||||
driver.synology=complete
|
||||
driver.toyou=missing
|
||||
driver.vrtsaccess=complete
|
||||
driver.vrtscnfs=complete
|
||||
driver.vzstorage=complete
|
||||
@ -378,6 +383,7 @@ driver.sandstone=missing
|
||||
driver.seagate=missing
|
||||
driver.storpool=missing
|
||||
driver.synology=missing
|
||||
driver.toyou=missing
|
||||
driver.vrtsaccess=missing
|
||||
driver.vrtscnfs=missing
|
||||
driver.vzstorage=missing
|
||||
@ -445,6 +451,7 @@ driver.sandstone=complete
|
||||
driver.seagate=missing
|
||||
driver.storpool=missing
|
||||
driver.synology=missing
|
||||
driver.toyou=missing
|
||||
driver.vrtsaccess=missing
|
||||
driver.vrtscnfs=missing
|
||||
driver.vzstorage=missing
|
||||
@ -511,6 +518,7 @@ driver.sandstone=complete
|
||||
driver.seagate=missing
|
||||
driver.storpool=complete
|
||||
driver.synology=missing
|
||||
driver.toyou=missing
|
||||
driver.vrtsaccess=missing
|
||||
driver.vrtscnfs=missing
|
||||
driver.vzstorage=missing
|
||||
@ -578,6 +586,7 @@ driver.sandstone=missing
|
||||
driver.seagate=missing
|
||||
driver.storpool=missing
|
||||
driver.synology=missing
|
||||
driver.toyou=missing
|
||||
driver.vrtsaccess=missing
|
||||
driver.vrtscnfs=missing
|
||||
driver.vzstorage=missing
|
||||
@ -644,6 +653,7 @@ driver.sandstone=complete
|
||||
driver.seagate=missing
|
||||
driver.storpool=complete
|
||||
driver.synology=missing
|
||||
driver.toyou=missing
|
||||
driver.vrtsaccess=missing
|
||||
driver.vrtscnfs=missing
|
||||
driver.vzstorage=missing
|
||||
@ -711,6 +721,7 @@ driver.sandstone=missing
|
||||
driver.seagate=missing
|
||||
driver.storpool=complete
|
||||
driver.synology=missing
|
||||
driver.toyou=complete
|
||||
driver.vrtsaccess=missing
|
||||
driver.vrtscnfs=missing
|
||||
driver.vzstorage=missing
|
||||
@ -778,6 +789,7 @@ driver.sandstone=complete
|
||||
driver.seagate=complete
|
||||
driver.storpool=complete
|
||||
driver.synology=missing
|
||||
driver.toyou=missing
|
||||
driver.vrtsaccess=missing
|
||||
driver.vrtscnfs=missing
|
||||
driver.vzstorage=missing
|
||||
@ -842,6 +854,7 @@ driver.sandstone=complete
|
||||
driver.seagate=missing
|
||||
driver.storpool=missing
|
||||
driver.synology=missing
|
||||
driver.toyou=missing
|
||||
driver.vrtsaccess=missing
|
||||
driver.vrtscnfs=missing
|
||||
driver.vzstorage=missing
|
||||
@ -910,6 +923,7 @@ driver.sandstone=complete
|
||||
driver.seagate=missing
|
||||
driver.storpool=missing
|
||||
driver.synology=missing
|
||||
driver.toyou=missing
|
||||
driver.vrtsaccess=missing
|
||||
driver.vrtscnfs=missing
|
||||
driver.vzstorage=missing
|
||||
|
||||
@ -0,0 +1,5 @@
|
||||
---
|
||||
features:
|
||||
- |
|
||||
New Cinder volume driver for TOYOU ACS5000.
|
||||
The new driver supports iSCSI.
|
||||
Loading…
Reference in New Issue
Block a user