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
|
#!/usr/bin/python
import _balkan
import isys
import os
def scanForRaid(drives):
raidSets = {}
raidDevices = {}
for d in drives:
isys.makeDevInode(d, "/tmp/" + d)
try:
parts = _balkan.readTable('/tmp/' + d)
except SystemError, msg:
parts = []
os.remove("/tmp/" + d)
for i in range(0, len(parts)):
(type, start, size) = parts[i]
if type != _balkan.RAID: continue
dev = "%s%d" % (d, i + 1)
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
raise SystemError, ("raid set inconsistency for md%d: "
"all drives in this raid set do not "
"agree on raid parameters" % (mdMinor,))
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):
raise SystemError, ("raid set inconsistency for md%d: "
"found members of multiple raid sets "
"that claim to be md%d"
% (mdMinor, mdMinor))
else:
raidDevices[mdMinor] = raidSet
raidList = []
for key in raidSets.keys():
(level, totalDisks, mdMinor, devices) = raidSets[key]
if len(devices) < totalDisks:
str = ("missing components of raid device md%d. The "
"raid device needs %d drives and only %d were found."
% (mdMinor, len(devices), totalDisks))
raise SystemError, str
raidList.append((mdMinor, devices))
return raidList
def startAllRaid(driveList):
mdList = []
for (mdDevice, deviceList) in scanForRaid(driveList):
devName = "md%d" % (mdDevice,)
isys.raidstart(devName, deviceList[0])
mdList.append(devName)
return mdList
def stopAllRaid(mdList):
for dev in mdList:
isys.raidstop(dev)
|
