author Girish Moodalbail <Girish.Moodalbail@oracle.COM>
Mon, 08 Dec 2014 15:34:49 -0800
changeset 3524 ad6a9e0880b9
parent 2083 87196737f09f
child 3998 5bd484384122
permissions -rw-r--r--
20089330 Horizon reports "Error: Unable to contact Neutron" on large data set 20103259 unable to delete instance, reports "EVS controller: vport in use" 19970607 disabling neutron smf services does not remove services' vports 18091479 unable delete a port that was associated with incomplete zone
# Copyright (c) 2013, 2014, Oracle and/or its affiliates. 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
#    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.
# @author: Girish Moodalbail, Oracle, Inc.

from oslo.config import cfg

from neutron.agent.linux import utils
from neutron.agent.solaris import net_lib

OPTS = [
    cfg.StrOpt('evs_controller', default='ssh://[email protected]',
               help=_("An URI that specifies an EVS controller"))

class SolarisVNICDriver(object):
    """Driver used to manage Solaris EVS VNICs.

    This class provides methods to create/delete an EVS VNIC and
    plumb/unplumb ab IP interface and addresses on the EVS VNIC.

    # TODO(gmoodalb): dnsmasq uses old style `ifreq', so 16 is the maximum
    # length including the NUL character. If we change it to use new style
    # `lifreq', then we will be able to extend the length to 32 characters.
    VNIC_NAME_PREFIX = 'evs'

    def __init__(self, conf):
        self.conf = conf
        # Since there is no connect_uri() yet, we need to do this ourselves
        # parse ssh://[email protected]
        suh = self.conf.evs_controller.split('://')
        if len(suh) != 2 or suh[0] != 'ssh' or not suh[1].strip():
            raise SystemExit(_("Specified evs_controller is invalid"))
        uh = suh[1].split('@')
        if len(uh) != 2 or not uh[0].strip() or not uh[1].strip():
            raise SystemExit(_("'user' and 'hostname' need to be specified "
                               "for evs_controller"))

        # set the controller property for this host
        cmd = ['/usr/sbin/evsadm', 'show-prop', '-co', 'value', '-p',
        stdout = utils.execute(cmd)
        if conf.evs_controller != stdout.strip():
            cmd = ['/usr/sbin/evsadm', 'set-prop', '-p',
                   'controller=%s' % (conf.evs_controller)]

    def fini_l3(self, device_name):
        ipif = net_lib.IPInterface(device_name)

    def init_l3(self, device_name, ip_cidrs):
        """Set the L3 settings for the interface using data from the port.
           ip_cidrs: list of 'X.X.X.X/YY' strings
        ipif = net_lib.IPInterface(device_name)
        for ip_cidr in ip_cidrs:

    # TODO(gmoodalb): - probably take PREFIX?? for L3
    def get_device_name(self, port):
        vnicname = (self.VNIC_NAME_PREFIX +
        vnicname += self.VNIC_NAME_SUFFIX
        return vnicname.replace('-', '_')

    def plug(self, tenant_id, network_id, port_id, datalink_name,
             namespace=None, prefix=None, protection=False):
        """Plug in the interface."""

        evs_vport = ('%s/%s') % (network_id, port_id)
        dl = net_lib.Datalink(datalink_name)

        # This is to handle HA when the 1st DHCP/L3 agent is down and
        # the second DHCP/L3 agent tries to connect its VNIC to EVS, we will
        # end up in "vport in use" error. So, we need to reset the vport
        # before we connect the VNIC to EVS.
        cmd = ['/usr/sbin/evsadm', 'show-vport', '-f',
               'vport=%s' % port_id, '-co', 'evs,vport,status']
        stdout = utils.execute(cmd)
        evsname, vportname, status = stdout.strip().split(':')
        if status == 'used':
            cmd = ['/usr/sbin/evsadm', 'reset-vport', '-T', tenant_id,
                   '%s/%s' % (evsname, vportname)]

        dl.connect_vnic(evs_vport, tenant_id)

        if not protection:
            cmd = ['/usr/sbin/evsadm', 'set-vportprop', '-T', tenant_id,
                   '-p', 'protection=none', evs_vport]

    def unplug(self, device_name, namespace=None, prefix=None):
        """Unplug the interface."""

        dl = net_lib.Datalink(device_name)