197 lines
8.1 KiB
Python
197 lines
8.1 KiB
Python
# Copyright (c) 2016 by Kaminario Technologies, Ltd.
|
|
# 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.
|
|
"""Volume driver for Kaminario K2 all-flash arrays."""
|
|
import six
|
|
|
|
from oslo_log import log as logging
|
|
|
|
from cinder import exception
|
|
from cinder import utils
|
|
from cinder.i18n import _, _LE
|
|
from cinder.objects import fields
|
|
from cinder.volume.drivers.kaminario import kaminario_common as common
|
|
from cinder.zonemanager import utils as fczm_utils
|
|
|
|
K2_REP_FAILED_OVER = fields.ReplicationStatus.FAILED_OVER
|
|
LOG = logging.getLogger(__name__)
|
|
kaminario_logger = common.kaminario_logger
|
|
|
|
|
|
class KaminarioFCDriver(common.KaminarioCinderDriver):
|
|
"""Kaminario K2 FC Volume Driver.
|
|
|
|
Version history:
|
|
1.0.2.0 - Initial driver
|
|
"""
|
|
|
|
VERSION = '1.0.2.0'
|
|
|
|
# ThirdPartySystems wiki page name
|
|
CI_WIKI_NAME = "Kaminario_K2_CI"
|
|
|
|
@kaminario_logger
|
|
def __init__(self, *args, **kwargs):
|
|
super(KaminarioFCDriver, self).__init__(*args, **kwargs)
|
|
self._protocol = 'FC'
|
|
self.lookup_service = fczm_utils.create_lookup_service()
|
|
|
|
@fczm_utils.AddFCZone
|
|
@kaminario_logger
|
|
@utils.synchronized(common.K2_LOCK_NAME, external=True)
|
|
def initialize_connection(self, volume, connector):
|
|
"""Attach K2 volume to host."""
|
|
# Check wwpns in host connector.
|
|
if not connector.get('wwpns'):
|
|
msg = _("No wwpns found in host connector.")
|
|
LOG.error(msg)
|
|
raise exception.KaminarioCinderDriverException(reason=msg)
|
|
# To support replication failback
|
|
temp_client = None
|
|
if (hasattr(volume, 'replication_status') and
|
|
volume.replication_status == K2_REP_FAILED_OVER):
|
|
temp_client = self.client
|
|
self.client = self.target
|
|
# Get target wwpns.
|
|
target_wwpns = self.get_target_info(volume)
|
|
# Map volume.
|
|
lun = self.k2_initialize_connection(volume, connector)
|
|
# Create initiator-target mapping.
|
|
target_wwpns, init_target_map = self._build_initiator_target_map(
|
|
connector, target_wwpns)
|
|
# To support replication failback
|
|
if temp_client:
|
|
self.client = temp_client
|
|
# Return target volume information.
|
|
return {'driver_volume_type': 'fibre_channel',
|
|
'data': {"target_discovered": True,
|
|
"target_lun": lun,
|
|
"target_wwn": target_wwpns,
|
|
"initiator_target_map": init_target_map}}
|
|
|
|
@fczm_utils.RemoveFCZone
|
|
@kaminario_logger
|
|
@utils.synchronized(common.K2_LOCK_NAME, external=True)
|
|
def terminate_connection(self, volume, connector, **kwargs):
|
|
# To support replication failback
|
|
temp_client = None
|
|
if (hasattr(volume, 'replication_status') and
|
|
volume.replication_status == K2_REP_FAILED_OVER):
|
|
temp_client = self.client
|
|
self.client = self.target
|
|
super(KaminarioFCDriver, self).terminate_connection(volume, connector)
|
|
properties = {"driver_volume_type": "fibre_channel", "data": {}}
|
|
host_name = self.get_initiator_host_name(connector)
|
|
host_rs = self.client.search("hosts", name=host_name)
|
|
# In terminate_connection, host_entry is deleted if host
|
|
# is not attached to any volume
|
|
if host_rs.total == 0:
|
|
# Get target wwpns.
|
|
target_wwpns = self.get_target_info(volume)
|
|
target_wwpns, init_target_map = self._build_initiator_target_map(
|
|
connector, target_wwpns)
|
|
properties["data"] = {"target_wwn": target_wwpns,
|
|
"initiator_target_map": init_target_map}
|
|
# To support replication failback
|
|
if temp_client:
|
|
self.client = temp_client
|
|
return properties
|
|
|
|
@kaminario_logger
|
|
def get_target_info(self, volume):
|
|
LOG.debug("Searching target wwpns in K2.")
|
|
fc_ports_rs = self.client.search("system/fc_ports")
|
|
target_wwpns = []
|
|
if hasattr(fc_ports_rs, 'hits') and fc_ports_rs.total != 0:
|
|
for port in fc_ports_rs.hits:
|
|
if port.pwwn:
|
|
target_wwpns.append((port.pwwn).replace(':', ''))
|
|
if not target_wwpns:
|
|
msg = _("Unable to get FC target wwpns from K2.")
|
|
LOG.error(msg)
|
|
raise exception.KaminarioCinderDriverException(reason=msg)
|
|
return target_wwpns
|
|
|
|
@kaminario_logger
|
|
def _get_host_object(self, connector):
|
|
host_name = self.get_initiator_host_name(connector)
|
|
LOG.debug("Searching initiator hostname: %s in K2.", host_name)
|
|
host_rs = self.client.search("hosts", name=host_name)
|
|
host_wwpns = connector['wwpns']
|
|
if host_rs.total == 0:
|
|
try:
|
|
LOG.debug("Creating initiator hostname: %s in K2.", host_name)
|
|
host = self.client.new("hosts", name=host_name,
|
|
type="Linux").save()
|
|
except Exception as ex:
|
|
LOG.exception(_LE("Unable to create host : %s in K2."),
|
|
host_name)
|
|
raise exception.KaminarioCinderDriverException(
|
|
reason=six.text_type(ex.message))
|
|
else:
|
|
# Use existing host.
|
|
LOG.debug("Use existing initiator hostname: %s in K2.", host_name)
|
|
host = host_rs.hits[0]
|
|
# Adding host wwpn.
|
|
for wwpn in host_wwpns:
|
|
wwpn = ":".join([wwpn[i:i + 2] for i in range(0, len(wwpn), 2)])
|
|
if self.client.search("host_fc_ports", pwwn=wwpn,
|
|
host=host).total == 0:
|
|
LOG.debug("Adding wwpn: %(wwpn)s to host: "
|
|
"%(host)s in K2.", {'wwpn': wwpn,
|
|
'host': host_name})
|
|
try:
|
|
self.client.new("host_fc_ports", pwwn=wwpn,
|
|
host=host).save()
|
|
except Exception as ex:
|
|
if host_rs.total == 0:
|
|
self._delete_host_by_name(host_name)
|
|
LOG.exception(_LE("Unable to add wwpn : %(wwpn)s to "
|
|
"host: %(host)s in K2."),
|
|
{'wwpn': wwpn, 'host': host_name})
|
|
raise exception.KaminarioCinderDriverException(
|
|
reason=six.text_type(ex.message))
|
|
return host, host_rs, host_name
|
|
|
|
@kaminario_logger
|
|
def _build_initiator_target_map(self, connector, all_target_wwns):
|
|
"""Build the target_wwns and the initiator target map."""
|
|
target_wwns = []
|
|
init_targ_map = {}
|
|
|
|
if self.lookup_service is not None:
|
|
# use FC san lookup.
|
|
dev_map = self.lookup_service.get_device_mapping_from_network(
|
|
connector.get('wwpns'),
|
|
all_target_wwns)
|
|
|
|
for fabric_name in dev_map:
|
|
fabric = dev_map[fabric_name]
|
|
target_wwns += fabric['target_port_wwn_list']
|
|
for initiator in fabric['initiator_port_wwn_list']:
|
|
if initiator not in init_targ_map:
|
|
init_targ_map[initiator] = []
|
|
init_targ_map[initiator] += fabric['target_port_wwn_list']
|
|
init_targ_map[initiator] = list(set(
|
|
init_targ_map[initiator]))
|
|
target_wwns = list(set(target_wwns))
|
|
else:
|
|
initiator_wwns = connector.get('wwpns', [])
|
|
target_wwns = all_target_wwns
|
|
|
|
for initiator in initiator_wwns:
|
|
init_targ_map[initiator] = target_wwns
|
|
|
|
return target_wwns, init_targ_map
|