summaryrefslogtreecommitdiffstats
path: root/raid.py
blob: a74bc6fded0537517ffa1c4043b6b784093810be (plain)
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
#!/usr/bin/python

import _balkan
import isys
import os

def scanForRaid(drives):
    for d in drives:
	isys.makeDevInode(d, "/tmp/" + d)
	try:
	    parts = _balkan.readTable('/tmp/' + d)
	except SystemError, msg:
	    parts = []

	os.remove("/tmp/" + d)
	raidSets = {}
	raidDevices = {}
	for i in range(0, len(parts) - 1):
	    (type, start, size) = parts[i]
	    if type != 7: continue

	    dev = "%s%d" % (d, i + 1)

	    (major, minor, raidSet, level, nrDisks, totalDisks, mdMinor) = \
	    	isys.raidsb(dev)

	    if raidSets.has_key(raidSet):
	    	(knownLevel, knownDisks, knownMinor, knownDevices) = \
			raidSets[raidSet]
		if knownLevel != level or knownDisks != totalDisks or \
		   knownMinor != mdMinor:
		       # Raise hell
		       pass
		knownDevices.append(dev)
	    else:
		raidSets[raidSet] = (level, totalDisks, mdMinor, [dev,])

	    if raidDevices.has_key(mdMinor):
	    	if (raidDevices[mdMinor] != raidSet):
		    # Raise hell
		    pass
	    else:
	    	raidDevices[mdMinor] = raidSet

	raidList = []
	for key in raidSets.keys():
	    (level, totalDisks, mdMinor, devices) = raidSets[key]
	    if len(devices) != totalDisks:
	    	# raise hell
		pass
	    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)