File Manager

X7ROOT File Manager

Current Path: /usr/lib/python2.7/site-packages/blivet

usr / lib / python2.7 / site-packages / blivet /

📁 ..
📄 __init__.py(117.33 KB)
📄 __init__.pyc(100.39 KB)
📄 __init__.pyo(100.39 KB)
📄 arch.py(9.45 KB)
📄 arch.pyc(8.63 KB)
📄 arch.pyo(8.63 KB)
📄 callbacks.py(3.55 KB)
📄 callbacks.pyc(1.85 KB)
📄 callbacks.pyo(1.85 KB)
📄 deviceaction.py(32.05 KB)
📄 deviceaction.pyc(33.21 KB)
📄 deviceaction.pyo(33.21 KB)
📄 devicefactory.py(63.97 KB)
📄 devicefactory.pyc(54.57 KB)
📄 devicefactory.pyo(54.57 KB)
📁 devicelibs
📁 devices
📄 devicetree.py(117.74 KB)
📄 devicetree.pyc(82.74 KB)
📄 devicetree.pyo(82.74 KB)
📄 errors.py(5.25 KB)
📄 errors.pyc(12.1 KB)
📄 errors.pyo(12.1 KB)
📄 fcoe.py(7.91 KB)
📄 fcoe.pyc(7.27 KB)
📄 fcoe.pyo(7.27 KB)
📄 flags.py(3.89 KB)
📄 flags.pyc(2.53 KB)
📄 flags.pyo(2.53 KB)
📁 formats
📄 i18n.py(1.21 KB)
📄 i18n.pyc(756 B)
📄 i18n.pyo(756 B)
📄 iscsi.py(19.29 KB)
📄 iscsi.pyc(16.36 KB)
📄 iscsi.pyo(16.36 KB)
📄 nvdimm.py(6.24 KB)
📄 nvdimm.pyc(6.16 KB)
📄 nvdimm.pyo(6.16 KB)
📄 partitioning.py(95.65 KB)
📄 partitioning.pyc(66.5 KB)
📄 partitioning.pyo(66.5 KB)
📄 partspec.py(4.05 KB)
📄 partspec.pyc(3.34 KB)
📄 partspec.pyo(3.34 KB)
📄 platform.py(17.38 KB)
📄 platform.pyc(18.52 KB)
📄 platform.pyo(18.52 KB)
📄 size.py(13.47 KB)
📄 size.pyc(11.4 KB)
📄 size.pyo(11.4 KB)
📄 storage_log.py(2.56 KB)
📄 storage_log.pyc(3.32 KB)
📄 storage_log.pyo(3.32 KB)
📄 tsort.py(3.37 KB)
📄 tsort.pyc(2.38 KB)
📄 tsort.pyo(2.38 KB)
📄 udev.py(28.34 KB)
📄 udev.pyc(30.19 KB)
📄 udev.pyo(30.19 KB)
📄 util.py(15.94 KB)
📄 util.pyc(19.52 KB)
📄 util.pyo(19.52 KB)
📄 zfcp.py(16.01 KB)
📄 zfcp.pyc(13 KB)
📄 zfcp.pyo(13 KB)

Editing: fcoe.py

#
# fcoe.py - fcoe class
#
# Copyright (C) 2009  Red Hat, Inc.  All rights reserved.
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 2 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program.  If not, see <http://www.gnu.org/licenses/>.
#

import os
from . import udev
from . import util
#from pyanaconda import isys
import logging
import time
import shutil
from .i18n import _
log = logging.getLogger("blivet")

_fcoe_module_loaded = False

def has_fcoe():
    global _fcoe_module_loaded
    if not _fcoe_module_loaded:
        util.run_program(["modprobe", "fcoe"])
        _fcoe_module_loaded = True
        if "bnx2x" in util.lsmod():
            log.info("fcoe: loading bnx2fc")
            util.run_program(["modprobe", "bnx2fc"])

return os.access("/sys/module/fcoe", os.X_OK)

class fcoe(object):
    """ FCoE utility class.

This class will automatically discover and connect to EDD configured
        FCoE SAN's when the startup() method gets called. It can also be
        used to manually configure FCoE SAN's through the addSan() method.

As this class needs to make sure certain things like starting fcoe
        daemons and connecting to firmware discovered SAN's only happens once
        and as it keeps a global list of all FCoE devices it is
        implemented as a Singleton.

.. warning::
            Since this is a singleton class, calling deepcopy() on the instance
            just returns ``self`` with no copy being created.
    """

def __init__(self):
        self.started = False
        self.lldpadStarted = False
        self.nics = []
        self.added_nics = []

# So that users can write fcoe() to get the singleton instance
    def __call__(self):
        return self

def __deepcopy__(self, memo_dict):
        # pylint: disable=unused-argument
        return self

def _stabilize(self):
        # I have no clue how long we need to wait, this ought to do the trick
        time.sleep(10)
        udev.settle()

def _startEDD(self):
        try:
            buf = util.capture_output(["/usr/libexec/fcoe/fcoe_edd.sh", "-i"])
        except OSError as e:
            log.info("Failed to read FCoE EDD info: %s", e.strerror)
            return

(key, _equals, val) = buf.strip().partition("=")
        if not val or key != "NIC":
            log.info("No FCoE EDD info found: %s", buf.rstrip())
            return

dcb = self._iface_driver(val) not in ("bnx2x", "bnx2fc")

log.info("FCoE NIC found in EDD: %s, using dcb: %s", val, dcb)
        self.addSan(val, dcb=dcb, auto_vlan=True)

def startup(self):
        if self.started:
            return

if not has_fcoe():
            return

self._startEDD()
        self.started = True

def _startLldpad(self):
        if self.lldpadStarted:
            return

util.run_program(["systemctl", "start", "lldpad.service"])
        self.lldpadStarted = True

def addSan(self, nic, dcb=False, auto_vlan=True):
        """Activates FCoE SANs attached to interface specified by nic.

Returns error message, or empty string if succeeded.
        """
        if not has_fcoe():
            raise IOError(_("FCoE not available"))

log.info("Activating FCoE SAN attached to %s, dcb: %s autovlan: %s",
                 nic, dcb, auto_vlan)

rc = 0
        out = ""
        timeout = 60
        error_msg = ""
        if dcb:

self._startLldpad()

timeout_msg = "waiting for lldpad to be ready"
            while timeout > 0:
                rc, out = util.run_program_and_capture_output(
                    ["lldptool", "-p"])
                if rc == 0:
                    break
                timeout -= 1
                time.sleep(1)

timeout_msg = "retrying to turn dcb on"
            while timeout > 0:
                rc, out = util.run_program_and_capture_output(
                    ["dcbtool", "sc", nic, "dcb", "on"])
                if rc == 0:
                    break
                timeout -= 1
                time.sleep(1)

timeout_msg = "retrying to set up dcb with pfc"
            while timeout > 0:
                rc, out = util.run_program_and_capture_output(
                    ["dcbtool", "sc", nic, "pfc", "e:1", "a:1", "w:1"])
                if rc == 0:
                    break
                timeout -= 1
                time.sleep(1)

timeout_msg = "retrying to set up dcb for fcoe"
            while timeout > 0:
                rc, out = util.run_program_and_capture_output(
                    ["dcbtool", "sc", nic, "app:fcoe", "e:1", "a:1", "w:1"])
                if rc == 0:
                    break
                timeout -= 1
                time.sleep(1)

time.sleep(1)

if rc == 0:
            self.write_nic_fcoe_cfg(nic, dcb=dcb, auto_vlan=auto_vlan)
            rc, out = util.run_program_and_capture_output(
                ["systemctl", "restart", "fcoe.service"])
        else:
            log.info("Timed out when %s", timeout_msg)

if rc == 0:
            self._stabilize()
            self.nics.append((nic, dcb, auto_vlan))
        else:
            log.debug("Activating FCoE SAN failed: %s %s", rc, out)
            error_msg = out

return error_msg

def _iface_driver(self, nic):
        try:
            dpath = os.readlink("/sys/class/net/%s/device/driver" % nic)
        except OSError as e:
            log.debug("Can't find driver of device %s, %s", nic, e)
            driver = ""
        else:
            driver = os.path.basename(dpath)
        return driver

def write(self, root):
        if not self.nics:
            return

# Done before packages are installed so don't call
        # write_nic_fcoe_cfg in target root but just copy the cfgs
        dest_cfg_dir = root + "/etc/fcoe"
        # The directory may already exist on image installation (eg RHEV).
        if os.path.isdir(dest_cfg_dir):
            shutil.rmtree(dest_cfg_dir)
        shutil.copytree("/etc/fcoe", dest_cfg_dir)

def write_nic_fcoe_cfg(self, nic, dcb=True, auto_vlan=True, enable=True, mode=None, root=""):
        cfg_dir = root + "/etc/fcoe"
        example_cfg = os.path.join(cfg_dir, "cfg-ethx")
        if os.access(example_cfg, os.R_OK):
            lines = open(example_cfg, "r").readlines()
        else:
            anaconda_cfg = """FCOE_ENABLE="yes"
DCB_REQUIRED="yes"
AUTO_VLAN="yes"
MODE="fabric"
"""
            lines = anaconda_cfg.splitlines(True)

new_cfg = open(os.path.join(cfg_dir, "cfg-%s" % nic), "w")
        new_cfg.write("# Generated by Anaconda installer\n")
        for line in lines:
            if not line.strip().startswith("#"):
                if line.startswith("FCOE_ENABLE"):
                    if enable:
                        line = 'FCOE_ENABLE="yes"\n'
                    else:
                        line = 'FCOE_ENABLE="no"\n'
                elif line.startswith("DCB_REQUIRED"):
                    if dcb:
                        line = 'DCB_REQUIRED="yes"\n'
                    else:
                        line = 'DCB_REQUIRED="no"\n'
                elif line.startswith("AUTO_VLAN"):
                    if auto_vlan:
                        line = 'AUTO_VLAN="yes"\n'
                    else:
                        line = 'AUTO_VLAN="no"\n'
                elif line.startswith("MODE"):
                    if mode:
                        line = 'MODE="%s"\n' % mode
            new_cfg.write(line)

# Create FCoE singleton
fcoe = fcoe()

# vim:tw=78:ts=4:et:sw=4

X7ROOT File Manager

Editing: fcoe.py

Upload File

Create Folder