PSARC 2015/110 OpenStack service updates for Juno PSARC 2014/302 oslo.messaging - OpenStack RPC and notifications PSARC 2014/303 concurrent.futures - high-level Python interface for asynchronous execution PSARC 2014/304 networkx - Python module for complex networks PSARC 2014/305 taskflow - Python module for task execution PSARC 2014/329 pycadf - Python interface for CADF (cloud auditing) PSARC 2014/330 posix_ipc - POSIX IPC primitives for Python PSARC 2014/331 oauthlib - Python implementation of OAuth request-signing logic PSARC 2015/058 oslo - OpenStack common libraries (context, db, i18n, middleware, serialization, utils, vmware) PSARC 2015/059 glance_store - Glance storage library PSARC 2015/060 ipaddr - an IPv4/IPv6 manipulation library in Python PSARC 2015/061 simplegeneric - single-dispatch generic Python functions PSARC 2015/062 wsme - Web Services Made Easy PSARC 2015/063 retrying - General purpose Python retrying library PSARC 2015/065 osprofiler - an OpenStack cross-project profiling library PSARC 2015/066 OpenStack client for Sahara (Hadoop as a Service) PSARC 2015/067 keystonemiddleware - Middleware for OpenStack Identity PSARC 2015/068 pyScss - Compiler for the SCSS flavor of the Sass language PSARC 2015/069 django-pyscss - pyScss support for Django PSARC 2015/073 barbicanclient - OpenStack client for Barbican (Key Management) PSARC 2015/074 pysendfile - Python interface to sendfile PSARC 2015/097 ldappool - a connection pool for python-ldap PSARC 2015/098 rfc3986 - URI reference validation module for Python PSARC 2015/102 iniparse - python .ini file parsing module 20667775 OpenStack service updates for Juno (Umbrella) 18615101 Horizon should prevent network, subnet, and port names with hyphens in them 18772068 instance failed to launch with NoValidHost but no reason 18887457 openstack shouldn't deliver .po files 18905324 hostname.xml should set config/ignore_dhcp_hostname = true 18961031 Duplicate names for role-create and user-create are allowed 19015363 Users should not be allowed to attempt to create volumes when quota exceed 19050335 user appears logged in but unauthorised after horizon reboot 19144215 Instance manipulation buttons greyed out after all instances terminated 19249066 heat stack-preview doesn't appear to do anything 19313272 Need bottom slidebar in horizon for small browser windows 19462265 The Python module oslo.messaging should be added to Userland 19462397 The Python module futures should be added to Userland 19476604 The Python module networkx should be added to Userland 19476953 The Python module taskflow should be added to Userland 19519227 The Python module pycadf should be added to Userland 19582394 The Python module posix_ipc should be added to Userland 19598430 The Python module oauthlib should be added to Userland 19815780 nova package should have dependencies on brand-solaris and brand-solaris-kz 19883623 Image snapshots are missing 'instance_uuid' property 19887874 horizon should set up apache log rotation 19987962 Cinder lists additional volumes attached to instance with linuxy device names 20027791 horizon should be migrated to Apache 2.4 20164815 The Python module django-pyscss should be added to Userland 20173049 The Python module retrying should be added to Userland 20174489 The Python module WSME should be added to Userland 20176001 The Python module keystonemiddleware should be added to Userland 20182039 The Python module pysendfile should be added to Userland 20200162 The Python module pyScss should be added to Userland 20222184 horizon doesn't send start request on shutdown instance 20312312 The Python module python-saharaclient should be added to Userland 20514287 wrong vnic label name used for dhcp vnic in evs 20596802 The Python module oslo.middleware should be added to Userland 20596803 The Python module barbicanclient should be added to Userland 20596804 The Python module oslo.context should be added to Userland 20596805 The Python module iniparse should be added to Userland 20596806 The Python module oslo.vmware should be added to Userland 20596807 The Python module osprofiler should be added to Userland 20596808 The Python module oslo.i18n should be added to Userland 20596809 The Python module oslo.utils should be added to Userland 20596811 The Python module ipaddr should be added to Userland 20596812 The Python module glance_store should be added to Userland 20596813 The Python module oslo.serialization should be added to Userland 20596814 The Python module oslo.db should be added to Userland 20596815 The Python module simplegeneric should be added to Userland 20602690 The Python module ldappool should be added to Userland 20602722 The Python module rfc3986 should be added to Userland 20638369 compilemessages.py requires GNU msgfmt without calling gmsgfmt 20715741 cinder 2014.2.2 20715742 glance 2014.2.2 20715743 heat 2014.2.2 20715744 horizon 2014.2.2 20715745 keystone 2014.2.2 20715746 neutron 2014.2.2 20715747 nova 2014.2.2 20715748 swift 2.2.2 20715749 alembic 0.7.4 20715750 amqp 1.4.6 20715751 boto 2.34.0 20715752 ceilometerclient 1.0.12 20715753 cinderclient 1.1.1 20715754 cliff 1.9.0 20715756 django 1.4.19 20715757 django_compressor 1.4 20715758 django_openstack_auth 1.1.9 20715759 eventlet 0.15.2 20715761 glanceclient 0.15.0 20715762 greenlet 0.4.5 20715763 heatclient 0.2.12 20715764 keystoneclient 1.0.0 20715765 kombu 3.0.7 20715766 mysql 1.2.5 20715767 netaddr 0.7.13 20715769 netifaces 0.10.4 20715770 neutronclient 2.3.10 20715771 novaclient 2.20.0 20715772 oslo.config 1.6.0 20715773 py 1.4.26 20715774 pyflakes 0.8.1 20715775 pytest 2.6.4 20715776 pytz 2014.10 20715777 requests 2.6.0 20715778 simplejson 3.6.5 20715779 six 1.9.0 20715780 sqlalchemy-migrate 0.9.1 20715781 sqlalchemy 0.9.8 20715782 stevedore 1.2.0 20715783 swiftclient 2.3.1 20715784 tox 1.8.1 20715785 troveclient 1.0.8 20715786 virtualenv 12.0.7 20715787 websockify 0.6.0

     1

# vim: tabstop=4 shiftwidth=4 softtabstop=4

     2

     3

# Copyright (c) 2015, Oracle and/or its affiliates. All rights reserved.

     4

#

     5

#    Licensed under the Apache License, Version 2.0 (the "License"); you may

     6

#    not use this file except in compliance with the License. You may obtain

     7

#    a copy of the License at

     8

#

     9

#         http://www.apache.org/licenses/LICENSE-2.0

    10

#

    11

#    Unless required by applicable law or agreed to in writing, software

    12

#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT

    13

#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the

    14

#    License for the specific language governing permissions and limitations

    15

#    under the License.

    16

    17

"""Generic Solaris Fibre Channel utilities."""

    18

    19

import os

    20

import time

    21

    22

from cinder.brick import exception

    23

from cinder.openstack.common.gettextutils import _

    24

from cinder.openstack.common import log as logging

    25

from cinder.openstack.common import processutils as putils

    26

    27

LOG = logging.getLogger(__name__)

    28

    29

    30

class SolarisFibreChannel(object):

    31

    def __init__(self, *args, **kwargs):

    32

        self.execute = putils.execute

    33

    34

    def _get_fc_hbas(self):

    35

        """Get Fibre Channel HBA information."""

    36

        out = None

    37

        try:

    38

            out, err = self.execute('/usr/sbin/fcinfo', 'hba-port')

    39

        except putils.ProcessExecutionError as err:

    40

            return None

    41

    42

        if out is None:

    43

            LOG.info(_("Cannot find any Fibre Channel HBAs"))

    44

            return None

    45

    46

        hbas = []

    47

        hba = {}

    48

        for line in out.splitlines():

    49

            line = line.strip()

    50

            # Collect the following hba-port data:

    51

            # 1: Port WWN

    52

            # 2: State (online|offline)

    53

            # 3: Node WWN

    54

            if line.startswith("HBA Port WWN:"):

    55

                # New HBA port entry

    56

                hba = {}

    57

                wwpn = line.split()[-1]

    58

                hba['port_name'] = wwpn

    59

                continue

    60

            elif line.startswith("Port Mode:"):

    61

                mode = line.split()[-1]

    62

                # Skip Target mode ports

    63

                if mode != 'Initiator':

    64

                    break

    65

            elif line.startswith("State:"):

    66

                state = line.split()[-1]

    67

                hba['port_state'] = state

    68

                continue

    69

            elif line.startswith("Node WWN:"):

    70

                wwnn = line.split()[-1]

    71

                hba['node_name'] = wwnn

    72

                continue

    73

            if len(hba) == 3:

    74

                hbas.append(hba)

    75

                hba = {}

    76

        return hbas

    77

    78

    def get_fc_wwnns(self):

    79

        """Get Fibre Channel WWNNs from the system, if any."""

    80

        hbas = self._get_fc_hbas()

    81

        if hbas is None:

    82

            return None

    83

    84

        wwnns = []

    85

        for hba in hbas:

    86

            if hba['port_state'] == 'online':

    87

                wwnn = hba['node_name']

    88

                wwnns.append(wwnn)

    89

        return wwnns

    90

    91

    def get_fc_wwpns(self):

    92

        """Get Fibre Channel WWPNs from the system, if any."""

    93

        hbas = self._get_fc_hbas()

    94

        if hbas is None:

    95

            return None

    96

    97

        wwpns = []

    98

        for hba in hbas:

    99

            if hba['port_state'] == 'online':

   100

                wwpn = hba['port_name']

   101

                wwpns.append(wwpn)

   102

        return wwpns

   103

   104

    def _refresh_connection(self):

   105

        """Force the link reinitialization to make the LUN present."""

   106

        wwpns = self.get_fc_wwpns()

   107

        for wwpn in wwpns:

   108

            self.execute('/usr/sbin/fcadm', 'force-lip', wwpn)

   109

   110

    def get_device_path(self, wwn):

   111

        """Get the Device Name of the WWN"""

   112

        try:

   113

            out, err = self.execute('/usr/sbin/fcinfo', 'logical-unit', '-v')

   114

        except putils.ProcessExecutionError as err:

   115

            return None

   116

   117

        host_dev = None

   118

        remote_port = None

   119

        if out is not None:

   120

            for line in [l.strip() for l in out.splitlines()]:

   121

                if line.startswith("OS Device Name:"):

   122

                    host_dev = line.split()[-1]

   123

                if line.startswith("Remote Port WWN:"):

   124

                    remote_port = line.split()[-1]

   125

                if remote_port == wwn:

   126

                    return host_dev

   127

   128

        return None

   129

   130

    def connect_volume(self, connection_properties, scan_tries):

   131

        """Attach the volume to instance_name.

   132

   133

        connection_properties for Fibre Channel must include:

   134

        target_portal - ip and optional port

   135

        target_iqn - iSCSI Qualified Name

   136

        target_lun - LUN id of the volume

   137

        """

   138

        device_info = {'type': 'block'}

   139

        target_wwn = connection_properties['target_wwn']

   140

        # Check for multiple target_wwn values in a list

   141

        if isinstance(target_wwn, list):

   142

            wwn = target_wwn[0]

   143

   144

        # The scsi_vhci disk node is not always present immediately.

   145

        # Sometimes we need to reinitialize the connection to trigger

   146

        # a refresh.

   147

        for i in range(1, scan_tries):

   148

            LOG.debug("Looking for Fibre Channel device")

   149

            host_dev = self.get_device_path(wwn)

   150

   151

            if host_dev is not None and os.path.exists(host_dev):

   152

                break

   153

            else:

   154

                self._refresh_connection()

   155

                time.sleep(i ** 2)

   156

        else:

   157

            msg = _("Fibre Channel volume device not found.")

   158

            LOG.error(msg)

   159

            raise exception.NoFibreChannelVolumeDeviceFound()

   160

   161

        device_info['path'] = host_dev

   162

        return device_info