1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
#!/usr/bin/python
#
# raid.py - raid probing control
#
# Erik Troan <ewt@redhat.com>
#
# Copyright 2001 Red Hat, Inc.
#
# This software may be freely redistributed under the terms of the GNU
# library public license.
#
# You should have received a copy of the GNU Library Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
#
import parted
import isys
import os
import partitioning
from log import log
def scanForRaid(drives):
raidSets = {}
raidDevices = {}
for d in drives:
parts = []
isys.makeDevInode(d, "/tmp/" + d)
try:
dev = parted.PedDevice.get("/tmp/" + d)
disk = parted.PedDisk.open(dev)
raidParts = partitioning.get_raid_partitions(disk)
for part in raidParts:
parts.append(partitioning.get_partition_name(part))
except:
pass
os.remove("/tmp/" + d)
for dev in parts:
try:
(major, minor, raidSet, level, nrDisks, totalDisks, mdMinor) =\
isys.raidsb(dev)
except ValueError:
# bad magic, this can't be part of our raid set
continue
if raidSets.has_key(raidSet):
(knownLevel, knownDisks, knownMinor, knownDevices) = \
raidSets[raidSet]
if knownLevel != level or knownDisks != totalDisks or \
knownMinor != mdMinor:
# Raise hell
log("raid set inconsistency for md%d: "
"all drives in this raid set do not "
"agree on raid parameters. Skipping raid device",
mdMinor)
continue
knownDevices.append(dev)
raidSets[raidSet] = (knownLevel, knownDisks, knownMinor,
knownDevices)
else:
raidSets[raidSet] = (level, totalDisks, mdMinor, [dev,])
if raidDevices.has_key(mdMinor):
if (raidDevices[mdMinor] != raidSet):
log("raid set inconsistency for md%d: "
"found members of multiple raid sets "
"that claim to be md%d. Using only the first "
"array found.", mdMinor, mdMinor)
continue
else:
raidDevices[mdMinor] = raidSet
raidList = []
for key in raidSets.keys():
(level, totalDisks, mdMinor, devices) = raidSets[key]
if len(devices) < totalDisks:
log("missing components of raid device md%d. The "
"raid device needs %d drive(s) and only %d (was/were) found. "
"This raid device will not be started.", mdMinor,
totalDisks, len(devices))
continue
raidList.append((mdMinor, devices, level, totalDisks))
return raidList
def startAllRaid(driveList):
rc = []
mdList = scanForRaid(driveList)
for mdDevice, deviceList, level, numActive in mdList:
devName = "md%d" % (mdDevice,)
isys.raidstart(devName, deviceList[0])
rc.append((devName, deviceList, level, numActive))
return rc
def stopAllRaid(mdList):
for dev, devices, level, numActive in mdList:
isys.raidstop(dev)
|
