storage/devicelibs/dm.py

#
# dm.py
# device-mapper functions
#
# 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/>.
#
# Author(s): Dave Lehman <dlehman@redhat.com>
#

import os

import block
import iutil
from ..errors import *

import gettext
_ = lambda x: gettext.ldgettext("anaconda", x)

import logging
log = logging.getLogger("storage")

def name_from_dm_node(dm_node):
    name = block.getNameFromDmNode(dm_node)
    if name is not None:
        return name

    st = os.stat("/dev/%s" % dm_node)
    major = os.major(st.st_rdev)
    minor = os.minor(st.st_rdev)
    name = iutil.execWithCapture("dmsetup",
                                 ["info", "--columns",
                                  "--noheadings", "-o", "name",
                                  "-j", str(major), "-m", str(minor)],
                                 stderr="/dev/tty5")
    log.debug("name_from_dm(%s) returning '%s'" % (dm_node, name.strip()))
    return name.strip()

def dm_node_from_name(map_name):
    dm_node = block.getDmNodeFromName(map_name)
    if dm_node is not None:
        return dm_node

    devnum = iutil.execWithCapture("dmsetup",
                                   ["info", "--columns",
                                    "--noheadings",
                                    "-o", "devno",
                                    map_name],
                                    stderr="/dev/tty5")
    (major, sep, minor) = devnum.strip().partition(":")
    if not sep:
        raise DMError("dm device does not exist")

    dm_node = "dm-%d" % int(minor)
    log.debug("dm_node_from_name(%s) returning '%s'" % (map_name, dm_node))
    return dm_node

def dm_is_multipath(info):
    major = None
    minor = None

    if info.has_key('MAJOR'):
        major = info['MAJOR']
    elif info.has_key('DM_MAJOR'):
        major = info['DM_MAJOR']
    if info.has_key('MINOR'):
        minor = info['MINOR']
    elif info.has_key('DM_MINOR'):
        minor = info['DM_MINOR']

    if major is None or minor is None:
        return False

    for map in block.dm.maps():
        dev = map.dev
        if dev.major == int(major) and dev.minor == int(minor):
            for table in map.table:
                if table.type == 'multipath':
                    return True

def _get_backing_devnums_from_map(map_name):
    ret = []
    buf = iutil.execWithCapture("dmsetup",
                                ["info", "--columns",
                                 "--noheadings",
                                 "-o", "devnos_used",
                                 map_name],
                                stderr="/dev/tty5")
    dev_nums = buf.split()
    for dev_num in dev_nums:
        (major, colon, minor) = dev_num.partition(":")
        ret.append((int(major), int(minor)))

    return ret

def get_backing_devnums(dm_node):
    #dm_node = dm_node_from_name(map_name)
    if not dm_node:
        return None

    top_dir = "/sys/block"
    backing_devs = os.listdir("%s/%s/slaves/" % (top_dir, dm_node))
    dev_nums = []
    for backing_dev in backing_devs:
        dev_num = open("%s/%s/dev" % (top_dir, backing_dev)).read().strip()
        (_major, _minor) = dev_num.split(":")
        dev_nums.append((int(_major), int(_minor)))

    return dev_nums

def get_backing_devs_from_name(map_name):
    dm_node = dm_node_from_name(map_name)
    if not dm_node:
        return None

    slave_devs = os.listdir("/sys/block/virtual/%s" % dm_node)
    return slave_devs

1	charliebrady	1.1	#
2			# dm.py
3			# device-mapper functions
4			#
5			# Copyright (C) 2009 Red Hat, Inc. All rights reserved.
6			#
7			# This program is free software; you can redistribute it and/or modify
8			# it under the terms of the GNU General Public License as published by
9			# the Free Software Foundation; either version 2 of the License, or
10			# (at your option) any later version.
11			#
12			# This program is distributed in the hope that it will be useful,
13			# but WITHOUT ANY WARRANTY; without even the implied warranty of
14			# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15			# GNU General Public License for more details.
16			#
17			# You should have received a copy of the GNU General Public License
18			# along with this program. If not, see <http://www.gnu.org/licenses/>.
19			#
20			# Author(s): Dave Lehman <dlehman@redhat.com>
21			#
22
23			import os
24
25			import block
26			import iutil
27			from ..errors import *
28
29			import gettext
30			_ = lambda x: gettext.ldgettext("anaconda", x)
31
32			import logging
33			log = logging.getLogger("storage")
34
35			def name_from_dm_node(dm_node):
36			name = block.getNameFromDmNode(dm_node)
37			if name is not None:
38			return name
39
40			st = os.stat("/dev/%s" % dm_node)
41			major = os.major(st.st_rdev)
42			minor = os.minor(st.st_rdev)
43			name = iutil.execWithCapture("dmsetup",
44			["info", "--columns",
45			"--noheadings", "-o", "name",
46			"-j", str(major), "-m", str(minor)],
47			stderr="/dev/tty5")
48			log.debug("name_from_dm(%s) returning '%s'" % (dm_node, name.strip()))
49			return name.strip()
50
51			def dm_node_from_name(map_name):
52			dm_node = block.getDmNodeFromName(map_name)
53			if dm_node is not None:
54			return dm_node
55
56			devnum = iutil.execWithCapture("dmsetup",
57			["info", "--columns",
58			"--noheadings",
59			"-o", "devno",
60			map_name],
61			stderr="/dev/tty5")
62			(major, sep, minor) = devnum.strip().partition(":")
63			if not sep:
64			raise DMError("dm device does not exist")
65
66			dm_node = "dm-%d" % int(minor)
67			log.debug("dm_node_from_name(%s) returning '%s'" % (map_name, dm_node))
68			return dm_node
69
70			def dm_is_multipath(info):
71			major = None
72			minor = None
73
74			if info.has_key('MAJOR'):
75			major = info['MAJOR']
76			elif info.has_key('DM_MAJOR'):
77			major = info['DM_MAJOR']
78			if info.has_key('MINOR'):
79			minor = info['MINOR']
80			elif info.has_key('DM_MINOR'):
81			minor = info['DM_MINOR']
82
83			if major is None or minor is None:
84			return False
85
86			for map in block.dm.maps():
87			dev = map.dev
88			if dev.major == int(major) and dev.minor == int(minor):
89			for table in map.table:
90			if table.type == 'multipath':
91			return True
92
93			def _get_backing_devnums_from_map(map_name):
94			ret = []
95			buf = iutil.execWithCapture("dmsetup",
96			["info", "--columns",
97			"--noheadings",
98			"-o", "devnos_used",
99			map_name],
100			stderr="/dev/tty5")
101			dev_nums = buf.split()
102			for dev_num in dev_nums:
103			(major, colon, minor) = dev_num.partition(":")
104			ret.append((int(major), int(minor)))
105
106			return ret
107
108			def get_backing_devnums(dm_node):
109			#dm_node = dm_node_from_name(map_name)
110			if not dm_node:
111			return None
112
113			top_dir = "/sys/block"
114			backing_devs = os.listdir("%s/%s/slaves/" % (top_dir, dm_node))
115			dev_nums = []
116			for backing_dev in backing_devs:
117			dev_num = open("%s/%s/dev" % (top_dir, backing_dev)).read().strip()
118			(_major, _minor) = dev_num.split(":")
119			dev_nums.append((int(_major), int(_minor)))
120
121			return dev_nums
122
123			def get_backing_devs_from_name(map_name):
124			dm_node = dm_node_from_name(map_name)
125			if not dm_node:
126			return None
127
128			slave_devs = os.listdir("/sys/block/virtual/%s" % dm_node)
129			return slave_devs
130