← Back to branch summary

~ubuntu-branches/ubuntu/raring/mdadm/raring

« back to all changes in this revision

Viewing changes to raid5extend.c

  • Committer: Package Import Robot
  • Author(s): Fabio M. Di Nitto
  • Date: 2004-10-01 06:23:38 UTC
  • Revision ID: package-import@ubuntu.com-20041001062338-qbvwn77thdz9fbwi
Tags: upstream-1.5.0
Import upstream version 1.5.0

Show diffs side-by-side

added added

removed removed

Lines of Context:
raid5extend.c
 
1
 
 
2
int phys2log(int phys, int stripe, int n, int layout)
 
3
{
 
4
    /* In an 'n' disk array using 'layout',
 
5
     * in stripe 'stripe', the physical disc 'phys'
 
6
     * stores what logical chunk?
 
7
     * -1 mean parity.
 
8
     *
 
9
     */
 
10
    switch(layout) {
 
11
    case ALGORITHM_LEFT_ASYMMETRIC:
 
12
        pd = (n-1) - (stripe % n);
 
13
        if (phys < pd)
 
14
            return phys;
 
15
        else if (phys == pd)
 
16
            return -1;
 
17
        else return phys-1;
 
18
 
 
19
    case ALGORITHM_RIGHT_ASYMMETRIC:
 
20
        pd = stripe % n;
 
21
        if (phys < pd)
 
22
            return phys;
 
23
        else if (phys == pd)
 
24
            return -1;
 
25
        else return phys-1;
 
26
 
 
27
    case ALGORITHM_LEFT_SYMMETRIC:
 
28
        pd = (n-1) - (stripe %n);
 
29
        if (phys < pd)
 
30
            return phys+ n-1-pd;
 
31
        else if (phys == pd)
 
32
            return -1;
 
33
        else return phys-pd-1;
 
34
 
 
35
    case ALGORITHM_RIGHT_SYMMETRIC:
 
36
        pd = stripe % n;
 
37
        if (phys < pd)
 
38
            return phys+ n-1-pd;
 
39
        else if (phys == pd)
 
40
            return -1;
 
41
        else return phys-pd-1;
 
42
    }
 
43
    return -2;
 
44
}
 
45
 
 
46
raid5_extend(unsigned long len, int chunksize, int layout, int n, int m, int rfds[], int wfds[])
 
47
{
 
48
 
 
49
    static char buf[4096];
 
50
 
 
51
    unsigned long blocks = len/4;
 
52
    unsigned int blocksperchunk= chunksize/4096;
 
53
 
 
54
    unsigned long b;
 
55
    
 
56
    for (b=0; b<blocks; b++) {
 
57
        unsigned long stripe = b / blocksperchunk;
 
58
        unsigned int offset = b - (stripe*blocksperchunk);
 
59
        unsigned long chunk = stripe * (n-1);
 
60
        int src;
 
61
        for (src=0; src<n; src++) {
 
62
            int dnum, snum;
 
63
            if (read(rfds[src], buf, sizeof(buf)) != sizeof(buf)) {
 
64
                error();
 
65
                return 0;
 
66
            }
 
67
 
 
68
            snum = phys2log(src, stripe, n, layout);
 
69
 
 
70
            if (snum == -1)
 
71
                continue;
 
72
            chunk = stripe*(n-1)+snum;
 
73
 
 
74
            dstripe = chunk/(m-1);
 
75
            dnum = log2phys(chunk-(stripe*(m-1)), dstripe, m, layout);
 
76
            llseek(wfds[dnum], dstripe*chunksize+(offset*4096), 0);
 
77
            write(wfds[dnum], buf, sizeof(buf));
 
78
        }
 
79
    }
 
80
}