# License for the specific language governing permissions and limitations
# under the License.
+import copy
import errno
import httplib
import re
'metadata': {'vendor': 'ProphetStor',
'version': '1.5'}}
+DATA_POOLS = 0, {
+ 'children': [POOLUUID]
+}
+
DATA_POOLINFO = 0, {
'capabilitiesURI': '',
'children': [],
'childrenrange': '',
'completionStatus': 'Complete',
- 'metadata': {'available_capacity': 4194074624,
+ 'metadata': {'available_capacity': 4294967296,
'ctime': 1390551362349,
'vendor': 'prophetstor',
'version': '1.5',
'pool_uuid': POOLUUID,
'properties': {'raid_level': 'raid0'},
'state': 'Online',
- 'total_capacity': 4194828288,
+ 'used_capacity': 0,
+ 'total_capacity': 4294967296,
'zpool_guid': '8173612007304181810'},
'objectType': 'application/cdmi-container',
'percentComplete': 100}
DATA_IN_VOLUME = {'id': 'abc123',
'display_name': 'abc123',
'display_description': '',
- 'size': 1}
+ 'size': 1,
+ 'host': "hostname@backend#%s" % POOLUUID}
DATA_IN_VOLUME_VG = {'id': 'abc123',
'display_name': 'abc123',
'size': 1,
'consistencygroup_id':
'fe2dbc51-5810-451d-ab2f-8c8a48d15bee',
- 'status': 'available'}
+ 'status': 'available',
+ 'host': "hostname@backend#%s" % POOLUUID}
DATA_IN_VOLUME1 = {'id': 'abc456',
'display_name': 'abc456',
'display_description': '',
- 'size': 1}
+ 'size': 1,
+ 'host': "hostname@backend#%s" % POOLUUID}
DATA_IN_CG_SNAPSHOT = {
'consistencygroup_id': 'fe2dbc51-5810-451d-ab2f-8c8a48d15bee',
self.DPL_MOCK.get_pool.return_value = DATA_POOLINFO
self.DPL_MOCK.get_server_info.return_value = DATA_SERVER_INFO
res = self.dpldriver.get_volume_stats(True)
- self.assertEqual(res['vendor_name'], 'ProphetStor')
- self.assertEqual(res['driver_version'], '1.5')
- self.assertEqual(res['total_capacity_gb'], 3.91)
- self.assertEqual(res['free_capacity_gb'], 3.91)
- self.assertEqual(res['reserved_percentage'], 0)
- self.assertEqual(res['QoS_support'], False)
+ self.assertEqual('ProphetStor', res['vendor_name'])
+ self.assertEqual('1.5', res['driver_version'])
+ pool = res["pools"][0]
+ self.assertEqual(4, pool['total_capacity_gb'])
+ self.assertEqual(4, pool['free_capacity_gb'])
+ self.assertEqual(0, pool['reserved_percentage'])
+ self.assertEqual(False, pool['QoS_support'])
def test_create_volume(self):
self.DPL_MOCK.create_vdev.return_value = DATA_OUTPUT
int(DATA_IN_VOLUME['size']) * units.Gi,
True)
+ def test_create_volume_without_pool(self):
+ fake_volume = copy.deepcopy(DATA_IN_VOLUME)
+ self.DPL_MOCK.create_vdev.return_value = DATA_OUTPUT
+ self.configuration.dpl_pool = ""
+ fake_volume['host'] = "host@backend" # missing pool
+ self.assertRaises(exception.InvalidHost, self.dpldriver.create_volume,
+ volume=fake_volume)
+
+ def test_create_volume_with_configuration_pool(self):
+ fake_volume = copy.deepcopy(DATA_IN_VOLUME)
+ fake_volume['host'] = "host@backend" # missing pool
+
+ self.DPL_MOCK.create_vdev.return_value = DATA_OUTPUT
+ self.dpldriver.create_volume(fake_volume)
+ self.DPL_MOCK.create_vdev.assert_called_once_with(
+ self._conver_uuid2hex(DATA_IN_VOLUME['id']),
+ DATA_IN_VOLUME['display_name'],
+ DATA_IN_VOLUME['display_description'],
+ self.configuration.dpl_pool,
+ int(DATA_IN_VOLUME['size']) * units.Gi,
+ True)
+
def test_create_volume_of_group(self):
self.DPL_MOCK.create_vdev.return_value = DATA_OUTPUT
self.DPL_MOCK.join_vg.return_value = DATA_OUTPUT
self.DPL_MOCK.get_vdev.return_value = DATA_ASSIGNVDEV
res = self.dpldriver.initialize_connection(DATA_IN_VOLUME,
DATA_IN_CONNECTOR)
- self.assertEqual(res['driver_volume_type'], 'iscsi')
- self.assertEqual(res['data']['target_lun'], '101')
- self.assertEqual(res['data']['target_discovered'], True)
- self.assertEqual(res['data']['target_portal'], '172.31.1.210:3260')
- self.assertEqual(res['data']['target_iqn'], 'iqn.2013-09.com.'
- 'prophetstor:hypervisor.'
- '886423051816')
+ self.assertEqual('iscsi', res['driver_volume_type'])
+ self.assertEqual('101', res['data']['target_lun'])
+ self.assertEqual(True, res['data']['target_discovered'])
+ self.assertEqual('172.31.1.210:3260', res['data']['target_portal'])
+ self.assertEqual(
+ 'iqn.2013-09.com.prophetstor:hypervisor.886423051816',
+ res['data']['target_iqn'])
def test_terminate_connection(self):
self.DPL_MOCK.unassign_vdev.return_value = DATA_OUTPUT
def test_get_pool_info(self):
self.DPL_MOCK.get_pool.return_value = DATA_POOLINFO
_, res = self.dpldriver._get_pool_info(POOLUUID)
- self.assertEqual(res['metadata']['available_capacity'], 4194074624)
- self.assertEqual(res['metadata']['ctime'], 1390551362349)
- self.assertEqual(res['metadata']['display_description'],
- 'Default Pool')
- self.assertEqual(res['metadata']['display_name'],
- 'default_pool')
- self.assertEqual(res['metadata']['event_uuid'],
- '4f7c4d679a664857afa4d51f282a516a')
- self.assertEqual(res['metadata']['physical_device'], {
- 'cache': [],
- 'data': ['disk_uuid_0', 'disk_uuid_1', 'disk_uuid_2'],
- 'log': [],
- 'spare': []})
- self.assertEqual(res['metadata']['pool_uuid'], POOLUUID)
- self.assertEqual(res['metadata']['properties'], {
- 'raid_level': 'raid0'})
- self.assertEqual(res['metadata']['state'], 'Online')
- self.assertEqual(res['metadata']['total_capacity'], 4194828288)
- self.assertEqual(res['metadata']['zpool_guid'], '8173612007304181810')
+ self.assertEqual(4294967296, res['metadata']['available_capacity'])
+ self.assertEqual(1390551362349, res['metadata']['ctime'])
+ self.assertEqual('Default Pool',
+ res['metadata']['display_description'])
+ self.assertEqual('default_pool',
+ res['metadata']['display_name'])
+ self.assertEqual('4f7c4d679a664857afa4d51f282a516a',
+ res['metadata']['event_uuid'])
+ self.assertEqual(
+ {'cache': [],
+ 'data': ['disk_uuid_0', 'disk_uuid_1', 'disk_uuid_2'],
+ 'log': [],
+ 'spare': []},
+ res['metadata']['physical_device'])
+ self.assertEqual(POOLUUID, res['metadata']['pool_uuid'])
+ self.assertEqual(
+ {'raid_level': 'raid0'},
+ res['metadata']['properties'])
+ self.assertEqual('Online', res['metadata']['state'])
+ self.assertEqual(4294967296, res['metadata']['total_capacity'])
+ self.assertEqual('8173612007304181810', res['metadata']['zpool_guid'])
def test_create_consistency_group(self):
self.DPL_MOCK.create_vg.return_value = DATA_OUTPUT
import six
from cinder import exception
-from cinder.i18n import _
+from cinder.i18n import _, _LI, _LE
from cinder.openstack.common import log as logging
from cinder.volume import driver
from cinder.volume.drivers.prophetstor import dplcommon
if fcInfo['type'] == 'fc':
fcInfos[fcUuid] = fcInfo
except Exception as e:
- msg = _("Failed to get fiber channel info from storage due "
- "to %(stat)s") % {'stat': six.string_types(e)}
+ msg = _LE("Failed to get fiber channel info from storage due "
+ "to %(stat)s") % {'stat': six.text_type(e)}
LOG.error(msg)
return fcInfos
targetI['targetAddr'] = targetInfo[2]
targetInfos[str(targetInfo[0])] = targetI
except Exception as e:
- msg = _("Failed to get fiber channel target from storage server"
- " due to %(stat)s") % {'stat': six.text_type(e)}
+ msg = _LE("Failed to get fiber channel target from storage server"
+ " due to %(stat)s") % {'stat': six.text_type(e)}
targetInfos = {}
LOG.error(msg)
return targetInfos
targetWwpns = fc_info.get('target_identifier', '')
lstargetWwpns.append(targetWwpns)
except Exception as e:
- msg = _("Failed to get target wwpns from storage due "
- "to %(stat)s") % {'stat': six.text_type(e)}
+ msg = _LE("Failed to get target wwpns from storage due "
+ "to %(stat)s") % {'stat': six.text_type(e)}
LOG.error(msg)
lstargetWwpns = []
return lstargetWwpns
fActive = True
break
except Exception:
- LOG.error(_('Failed to get sns table'))
+ LOG.error(_LE('Failed to get sns table'))
return fActive
def _convertHex2String(self, wwpns):
self._conver_uuid2hex(volumeid), targetwwpns,
initiatorwwpns, volumename)
except Exception:
- msg = _('Volume %(volumeid)s failed to send assign command, '
- 'ret: %(status)s output: %(output)s') % \
+ msg = _LE('Volume %(volumeid)s failed to send assign command, '
+ 'ret: %(status)s output: %(output)s') % \
{'volumeid': volumeid, 'status': ret, 'output': output}
LOG.error(msg)
ret = errno.EFAULT
msg = _('Flexvisor failed to assign volume %(id)s: '
'%(status)s.') % {'id': volumeid,
'status': status}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
else:
ret = errno.EFAULT
msg = _('Flexvisor failed to assign volume %(id)s due to '
'unable to query status by event '
'id.') % {'id': volumeid}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
elif ret != 0:
msg = _('Flexvisor assign volume failed:%(id)s:'
'%(status)s.') % {'id': volumeid, 'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
return ret
msg = _('Flexvisor failed to unassign volume %(id)s:'
' %(status)s.') % {'id': volumeid,
'status': status}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
else:
msg = _('Flexvisor failed to unassign volume (get event) '
'%(id)s.') % {'id': volumeid}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
elif ret != 0:
msg = _('Flexvisor unassign volume failed:%(id)s:'
'%(status)s.') % {'id': volumeid, 'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
else:
- msg = _('Flexvisor succeed to unassign volume '
- '%(id)s.') % {'id': volumeid}
+ msg = _LI('Flexvisor succeed to unassign volume '
+ '%(id)s.') % {'id': volumeid}
LOG.info(msg)
return ret
ret = 0
targetIdentifier = []
szwwpns = []
- LOG.info('initialize_connection volume: %s,'
- ' connector: %s' % (volume, connector))
+ msg = _LI('initialize_connection volume: %(volume)s, connector:'
+ ' %(connector)s') % {"volume": volume,
+ "connector": connector}
+ LOG.info(msg)
# Get Storage Fiber channel controller
dc_fc = self._get_fc_channel()
# Get existed FC target list to decide target wwpn
dc_target = self._get_targets()
if len(dc_target) == 0:
- msg = _('Backend storage did not configure fiber channel target.')
+ msg = _('Backend storage did not configure fiber channel '
+ 'target.')
raise exception.VolumeBackendAPIException(data=msg)
for keyFc in dc_fc.keys():
msg = _('Invalid wwpns format %(wwpns)s') % \
{'wwpns': connector['wwpns']}
raise exception.VolumeBackendAPIException(data=msg)
- LOG.error(msg)
szwwpns.append(szwwpn)
if len(szwwpns):
{}).get('targetAddr', '')
lsTargetWwpn.append(targetWwpn)
# Use wwpns to assign volume.
- msg = _('Prefer use target wwpn %(wwpn)s') % {'wwpn': lsTargetWwpn}
+ msg = _LI('Prefer use target wwpn %(wwpn)s') % {'wwpn': lsTargetWwpn}
LOG.info(msg)
# Start to create export in all FC target node.
assignedTarget = []
else:
assignedTarget.append(pTarget)
except Exception as e:
- msg = _('Failed to export fiber channel target '
- 'due to %s') % (six.text_type(e))
+ msg = _LE('Failed to export fiber channel target '
+ 'due to %s') % (six.text_type(e))
LOG.error(msg)
ret = errno.EFAULT
break
properties['target_lun'] = int(nLun)
properties['volume_id'] = volume['id']
properties['initiator_target_map'] = init_targ_map
- msg = _('%(volume)s assign type fibre_channel, properties '
- '%(properties)s') % {'volume': volume['id'],
- 'properties': properties}
+ msg = _LI('%(volume)s assign type fibre_channel, properties '
+ '%(properties)s') % {'volume': volume['id'],
+ 'properties': properties}
LOG.info(msg)
else:
msg = _('Invalid connection initialization response of '
'volume %(name)s') % {'name': volume['name']}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
- msg = _('Connect initialization info: '
- '{driver_volume_type: fibre_channel, '
- 'data: %(properties)s') % {'properties': properties}
+ msg = _LI('Connect initialization info: '
+ '{driver_volume_type: fibre_channel, '
+ 'data: %(properties)s') % {'properties': properties}
LOG.info(msg)
return {'driver_volume_type': 'fibre_channel',
'data': properties}
szwwpns = []
ret = 0
info = {'driver_volume_type': 'fibre_channel', 'data': {}}
- msg = _('terminate_connection volume: %(volume)s, '
- 'connector: %(con)s') % {'volume': volume, 'con': connector}
+ msg = _LI('terminate_connection volume: %(volume)s, '
+ 'connector: %(con)s') % {'volume': volume, 'con': connector}
LOG.info(msg)
# Query targetwwpns.
# Get all target list of volume.
msg = _('Invalid wwpns format %(wwpns)s') % \
{'wwpns': connector['wwpns']}
raise exception.VolumeBackendAPIException(data=msg)
- LOG.error(msg)
szwwpns.append(szwwpn)
if len(szwwpns) == 0:
ret = errno.EFAULT
msg = _('Invalid wwpns format %(wwpns)s') % \
{'wwpns': connector['wwpns']}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
else:
for szwwpn in szwwpns:
finally:
if ret:
msg = _('Faield to unassign %(volume)s') % (volume['id'])
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
# Failed to delete export with fibre channel
"""
Implementation of the class of ProphetStor DPL storage adapter of Federator.
# v2.0.1 Consistency group support
+ # v2.0.2 Pool aware scheduler
"""
import base64
import six
from cinder import exception
-from cinder.i18n import _, _LE, _LI
+from cinder.i18n import _, _LI, _LW, _LE
from cinder.openstack.common import log as logging
from cinder.openstack.common import loopingcall
from cinder.openstack.common import units
from cinder.volume import driver
from cinder.volume.drivers.prophetstor import options
from cinder.volume.drivers.san import san
+from cinder.volume import utils as volume_utils
LOG = logging.getLogger(__name__)
return self._execute(method, url, params,
[httplib.OK, httplib.ACCEPTED, httplib.CREATED])
+ def get_pools(self):
+ method = 'GET'
+ url = '/%s/%s/' % (DPL_VER_V1, DPL_OBJ_POOL)
+ return self._execute(method, url, None, [httplib.OK])
+
def get_pool(self, poolid):
method = 'GET'
url = '/%s/%s/%s/' % (DPL_VER_V1, DPL_OBJ_POOL, poolid)
-
return self._execute(method, url, None, [httplib.OK, httplib.ACCEPTED])
def clone_vdev(self, SourceVolumeID, NewVolumeID, poolID, volumeName,
msg = _('Flexvisor failed to add volume %(id)s '
'to group %(cgid)s.') % {'id': volume['id'],
'cgid': cgId}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
else:
- msg = _('Flexvisor succeeded to add volume %(id)s to '
- 'group %(cgid)s.') % {'id': volume['id'],
- 'cgid': cgId}
+ msg = _LI('Flexvisor succeeded to add volume %(id)s to '
+ 'group %(cgid)s.') % {'id': volume['id'],
+ 'cgid': cgId}
LOG.info(msg)
def _get_snapshotid_of_vgsnapshot(self, vgID, vgsnapshotID, volumeID):
msg = _('Flexvisor failed to get snapshot id of volume '
'%(id)s from group %(vgid)s.') % {'id': volumeID,
'vgid': vgID}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
if not snapshotID:
msg = _('Flexvisor could not find volume %(id)s snapshot in'
def create_consistencygroup(self, context, group):
"""Creates a consistencygroup."""
- LOG.info(_LI('Start to create consistency group: %(group_name)s '
- 'id: %(id)s') %
- {'group_name': group['name'], 'id': group['id']})
+ msg = _LI('Start to create consistency group: %(group_name)s '
+ 'id: %(id)s') % {'group_name': group['name'],
+ 'id': group['id']}
+ LOG.info(msg)
model_update = {'status': 'available'}
try:
ret, output = self.dpl.create_vg(
msg = _('Failed to create consistency group '
'%(id)s:%(ret)s.') % {'id': group['id'],
'ret': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
else:
return model_update
msg = _('Failed to create consistency group '
'%(id)s due to %(reason)s.') % {'id': group['id'],
'reason': six.text_type(e)}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
def delete_consistencygroup(self, context, group):
msg = _('Failed to delete consistency group %(id)s '
'due to %(reason)s.') % {'id': group['id'],
'reason': six.text_type(e)}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
for volume_ref in volumes:
msg = _('Failed to create cg snapshot %(id)s '
'due to %(reason)s.') % {'id': cgsnapshot_id,
'reason': six.text_type(e)}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
model_update['status'] = 'available'
msg = _('Failed to delete cgsnapshot %(id)s due to '
'%(reason)s.') % {'id': cgsnapshot_id,
'reason': six.text_type(e)}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
model_update['status'] = 'deleted'
def create_volume(self, volume):
"""Create a volume."""
- pool = self.configuration.dpl_pool
+ pool = volume_utils.extract_host(volume['host'],
+ level='pool')
+ if not pool:
+ if not self.configuration.dpl_pool:
+ msg = _("Pool is not available in the volume host fields.")
+ raise exception.InvalidHost(reason=msg)
+ else:
+ pool = self.configuration.dpl_pool
+
ret, output = self.dpl.create_vdev(
self._conver_uuid2hex(volume['id']),
volume.get('display_name', ''),
msg = _('Flexvisor failed to create volume %(volume)s: '
'%(status)s.') % {'volume': volume['id'],
'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
else:
msg = _('Flexvisor failed to create volume (get event) '
'%s.') % (volume['id'])
- LOG.error(msg)
raise exception.VolumeBackendAPIException(
data=msg)
elif ret != 0:
msg = _('Flexvisor create volume failed.:%(volumeid)s:'
- '%(status)s.') % {'volumeid': volume['id'], 'status': ret}
- LOG.error(msg)
+ '%(status)s.') % {'volumeid': volume['id'],
+ 'status': ret}
raise exception.VolumeBackendAPIException(
data=msg)
else:
- msg = _('Flexvisor succeed to create volume '
- '%(id)s.') % {'id': volume['id']}
+ msg = _LI('Flexvisor succeed to create volume '
+ '%(id)s.') % {'id': volume['id']}
LOG.info(msg)
if volume.get('consistencygroup_id', None):
except Exception:
msg = _("Flexvisor unable to find the source volume "
"%(id)s info.") % {'id': src_volumeID}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
if src_volume:
vgID = src_volume.get('consistencygroup_id', None)
self._conver_uuid2hex(cgsnapshotID),
self._conver_uuid2hex(src_volumeID))
- pool = self.configuration.dpl_pool
+ pool = volume_utils.extract_host(volume['host'],
+ level='pool')
+ if not pool:
+ if not self.configuration.dpl_pool:
+ msg = _("Pool is not available in the volume host fields.")
+ raise exception.InvalidHost(reason=msg)
+ else:
+ pool = self.configuration.dpl_pool
+
ret, output = self.dpl.create_vdev_from_snapshot(
self._conver_uuid2hex(volume['id']),
volume.get('display_name', ''),
volume['id'],
event_uuid)
if status['state'] != 'available':
- msg = _('Flexvisor failed to create volume from snapshot '
- '%(id)s:%(status)s.') % {'id': snapshot['id'],
- 'status': ret}
- LOG.error(msg)
+ msg = _('Flexvisor failed to create volume from '
+ 'snapshot %(id)s:'
+ '%(status)s.') % {'id': snapshot['id'],
+ 'status': ret}
raise exception.VolumeBackendAPIException(
data=msg)
else:
msg = _('Flexvisor failed to create volume from snapshot '
'(failed to get event) '
'%(id)s.') % {'id': snapshot['id']}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
elif ret != 0:
msg = _('Flexvisor failed to create volume from snapshot '
'%(id)s: %(status)s.') % {'id': snapshot['id'],
'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(
data=msg)
else:
- msg = _('Flexvisor succeed to create volume %(id)s '
- 'from snapshot.') % {'id': volume['id']}
+ msg = _LI('Flexvisor succeed to create volume %(id)s '
+ 'from snapshot.') % {'id': volume['id']}
LOG.info(msg)
if volume.get('consistencygroup_id', None):
msg = _('Flexvisor failed to spawn volume from snapshot '
'%(id)s:%(status)s.') % {'id': snapshot['id'],
'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
else:
msg = _('Flexvisor failed to spawn volume from snapshot '
'(failed to get event) '
'%(id)s.') % {'id': snapshot['id']}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
elif ret != 0:
msg = _('Flexvisor failed to create volume from snapshot '
'%(id)s: %(status)s.') % {'id': snapshot['id'],
'status': ret}
- LOG.error(msg)
+
raise exception.VolumeBackendAPIException(
data=msg)
else:
- msg = _('Flexvisor succeed to create volume %(id)s '
- 'from snapshot.') % {'id': volume['id']}
+ msg = _LI('Flexvisor succeed to create volume %(id)s '
+ 'from snapshot.') % {'id': volume['id']}
LOG.info(msg)
def create_cloned_volume(self, volume, src_vref):
"""Creates a clone of the specified volume."""
- pool = self.configuration.dpl_pool
+ pool = volume_utils.extract_host(volume['host'],
+ level='pool')
+ if not pool:
+ if not self.configuration.dpl_pool:
+ msg = _("Pool is not available in the volume host fields.")
+ raise exception.InvalidHost(reason=msg)
+ else:
+ pool = self.configuration.dpl_pool
+
ret, output = self.dpl.clone_vdev(
self._conver_uuid2hex(src_vref['id']),
self._conver_uuid2hex(volume['id']),
msg = _('Flexvisor failed to clone volume %(id)s: '
'%(status)s.') % {'id': src_vref['id'],
'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
else:
- msg = _('Flexvisor failed to clone volume (failed to get event'
- ') %(id)s.') % {'id': src_vref['id']}
- LOG.error(msg)
+ msg = _('Flexvisor failed to clone volume (failed to'
+ ' get event) %(id)s.') % {'id': src_vref['id']}
raise exception.VolumeBackendAPIException(
data=msg)
elif ret != 0:
msg = _('Flexvisor failed to clone volume %(id)s: '
'%(status)s.') % {'id': src_vref['id'], 'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(
data=msg)
else:
- msg = _('Flexvisor succeed to clone '
- 'volume %(id)s.') % {'id': volume['id']}
+ msg = _LI('Flexvisor succeed to clone '
+ 'volume %(id)s.') % {'id': volume['id']}
LOG.info(msg)
if volume.get('consistencygroup_id', None):
self._conver_uuid2hex(volume['id']),
self._conver_uuid2hex(volume['consistencygroup_id']))
if ret:
- msg = _('Flexvisor failed to delete volume %(id)s from'
- ' the group %(vgid)s.') % {
+ msg = _LW('Flexvisor failed to delete volume %(id)s from'
+ ' the group %(vgid)s.') % {
'id': volume['id'],
'vgid': volume['consistencygroup_id']}
except Exception as e:
- msg = _('Flexvisor failed to delete volume %(id)s from '
- 'group %(vgid)s due to %(status)s.') % {
+ msg = _LW('Flexvisor failed to delete volume %(id)s from '
+ 'group %(vgid)s due to %(status)s.') % {
'id': volume['id'],
'vgid': volume['consistencygroup_id'],
'status': six.text_type(e)}
if ret:
ret = 0
- LOG.warn(msg)
+ LOG.warning(msg)
ret, output = self.dpl.delete_vdev(self._conver_uuid2hex(volume['id']))
if ret == errno.EAGAIN:
if status['state'] == 'error':
msg = _('Flexvisor failed deleting volume %(id)s: '
'%(status)s.') % {'id': volume['id'], 'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
elif ret == errno.ENODATA:
ret = 0
- msg = _('Flexvisor volume %(id)s does not '
- 'exist.') % {'id': volume['id']}
+ msg = _LI('Flexvisor volume %(id)s does not '
+ 'exist.') % {'id': volume['id']}
LOG.info(msg)
elif ret != 0:
msg = _('Flexvisor failed to delete volume %(id)s: '
'%(status)s.') % {'id': volume['id'], 'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(
data=msg)
msg = _('Flexvisor failed to extend volume '
'%(id)s:%(status)s.') % {'id': volume,
'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(
data=msg)
else:
msg = _('Flexvisor failed to extend volume '
'(failed to get event) '
'%(id)s.') % {'id': volume['id']}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
elif ret != 0:
msg = _('Flexvisor failed to extend volume '
'%(id)s: %(status)s.') % {'id': volume['id'],
'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(
data=msg)
else:
- msg = _('Flexvisor succeed to extend volume'
- ' %(id)s.') % {'id': volume['id']}
+ msg = _LI('Flexvisor succeed to extend volume'
+ ' %(id)s.') % {'id': volume['id']}
LOG.info(msg)
def create_snapshot(self, snapshot):
msg = _('Flexvisor failed to create snapshot for volume '
'%(id)s: %(status)s.') % \
{'id': snapshot['volume_id'], 'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
else:
msg = _('Flexvisor failed to create snapshot for volume '
'(failed to get event) %(id)s.') % \
{'id': snapshot['volume_id']}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
elif ret != 0:
msg = _('Flexvisor failed to create snapshot for volume %(id)s: '
'%(status)s.') % {'id': snapshot['volume_id'],
'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
def delete_snapshot(self, snapshot):
msg = _('Flexvisor failed to delete snapshot %(id)s: '
'%(status)s.') % {'id': snapshot['id'],
'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
else:
msg = _('Flexvisor failed to delete snapshot (failed to '
'get event) %(id)s.') % {'id': snapshot['id']}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
elif ret == errno.ENODATA:
- msg = _('Flexvisor snapshot %(id)s not existed.') % \
+ msg = _LI('Flexvisor snapshot %(id)s not existed.') % \
{'id': snapshot['id']}
LOG.info(msg)
elif ret != 0:
msg = _('Flexvisor failed to delete snapshot %(id)s: '
'%(status)s.') % {'id': snapshot['id'], 'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
else:
- msg = _('Flexvisor succeed to delete '
- 'snapshot %(id)s.') % {'id': snapshot['id']}
+ msg = _LI('Flexvisor succeed to delete '
+ 'snapshot %(id)s.') % {'id': snapshot['id']}
LOG.info(msg)
def get_volume_stats(self, refresh=False):
return self._stats
+ def _get_pools(self):
+ pools = []
+ qpools = []
+ # Defined access pool by cinder configuration.
+ defined_pool = self.configuration.dpl_pool
+ if defined_pool:
+ qpools.append(defined_pool)
+ else:
+ try:
+ ret, output = self.dpl.get_pools()
+ if ret == 0:
+ for poolUuid, poolName in output.get('children', []):
+ qpools.append(poolUuid)
+ else:
+ msg = _LE("Flexvisor failed to get pool list."
+ "(Error: %d)") % (ret)
+ LOG.error(msg)
+ except Exception as e:
+ msg = _LE("Flexvisor failed to get pool list due to "
+ "%s.") % (six.text_type(e))
+ LOG.error(msg)
+
+ # Query pool detail information
+ for poolid in qpools:
+ ret, output = self._get_pool_info(poolid)
+ if ret == 0:
+ pool = {}
+ pool['pool_name'] = output['metadata']['pool_uuid']
+ pool['total_capacity_gb'] = \
+ self._convert_size_GB(
+ int(output['metadata']['total_capacity']))
+ pool['free_capacity_gb'] = \
+ self._convert_size_GB(
+ int(output['metadata']['available_capacity']))
+ pool['allocated_capacity_gb'] = \
+ self._convert_size_GB(
+ int(output['metadata']['used_capacity']))
+ pool['QoS_support'] = False
+ pool['reserved_percentage'] = 0
+ pools.append(pool)
+ else:
+ msg = _LW("Failed to query pool %(id)s status "
+ "%(ret)d.") % {'id': poolid,
+ 'ret': ret}
+ LOG.warning(msg)
+ continue
+ return pools
+
def _update_volume_stats(self, refresh=False):
"""Return the current state of the volume service. If 'refresh' is
True, run the update first.
"""
data = {}
- totalSize = 0
- availableSize = 0
-
- ret, output = self._get_pool_info(self.configuration.dpl_pool)
- if ret == 0:
- totalSize = int(output['metadata']['total_capacity'])
- availableSize = int(output['metadata']['available_capacity'])
- else:
- totalSize = 0
- availableSize = 0
-
+ pools = self._get_pools()
data['volume_backend_name'] = \
self.configuration.safe_get('volume_backend_name')
-
location_info = '%(driver)s:%(host)s:%(volume)s' % {
'driver': self.__class__.__name__,
'host': self.configuration.san_ip,
'volume': self.configuration.dpl_pool
}
-
try:
ret, output = self.dpl.get_server_info()
if ret == 0:
data['vendor_name'] = output['metadata']['vendor']
data['driver_version'] = output['metadata']['version']
data['storage_protocol'] = 'iSCSI'
- data['total_capacity_gb'] = self._convert_size_GB(totalSize)
- data['free_capacity_gb'] = self._convert_size_GB(availableSize)
- data['reserved_percentage'] = 0
- data['QoS_support'] = False
data['location_info'] = location_info
data['consistencygroup_support'] = True
+ data['pools'] = pools
self._stats = data
except Exception as e:
- msg = _('Failed to get server info due to '
- '%(state)s.') % {'state': six.text_type(e)}
+ msg = _LE('Failed to get server info due to '
+ '%(state)s.') % {'state': six.text_type(e)}
LOG.error(msg)
return self._stats
if status['state'] != 'available':
msg = _('Flexvisor failed to get pool info %(id)s: '
'%(status)s.') % {'id': poolid, 'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
else:
ret = 0
output = status.get('output', {})
else:
- LOG.error(_LE('Flexvisor failed to get pool info '
- '(failed to get event)%s.') % (poolid))
+ LOG.error(_('Flexvisor failed to get pool info '
+ '(failed to get event)%s.') % (poolid))
raise exception.VolumeBackendAPIException(
data="failed to get event")
elif ret != 0:
msg = _('Flexvisor failed to get pool info %(id)s: '
'%(status)s.') % {'id': poolid, 'status': ret}
- LOG.error(msg)
raise exception.VolumeBackendAPIException(data=msg)
else:
- msg = 'Flexvisor succeed to get pool info.'
+ msg = _('Flexvisor succeed to get pool info.')
LOG.debug(msg)
return ret, output
Code Review / openstack-build / cinder-build.git / commitdiff