diff options
author | Dimitri John Ledkov <xnox@ubuntu.com> | 2016-07-02 19:16:01 +0100 |
---|---|---|
committer | Dimitri John Ledkov <xnox@ubuntu.com> | 2016-07-02 19:16:01 +0100 |
commit | b83f8fcaffa542498c5698a3a161b9967ac1d3d6 (patch) | |
tree | 3cb83259723d112fd7b08b5bd299df2f5ee94009 /raid5extend.c |
mdadm (3.4-2) unstable; urgency=low
* Reneable incremental assembly
* Rely on udev to assemble incremental arrays
* In environments with systemd rely on mdadm-last-resort@.timer|.service
units to activate degrated raids
* In environments initramfs-tools initrd (no systemd) add local-block
script to do the same after 2/3rds of root delay iteration
* Drop local-top initramfs script
* Drop dependency on initscripts package
* Drop INITRDSTART support
* Drop mdadm-raid init script
* Drop ancient preinst
* In mdadm.init remove dependency on mdadm-raid
* In mdadm.init check, and bail out running in a container
* In mdadm.config drop mdadm/autostart logic
* Drop CREATE stanzas from mkconf and don't include them in the
initramfs. The generated defaults, are the compiled-in defaults. And
the current one generates warnings when running mdadm in the
initramfs, as there is no passwd|group files to resolve root/disk
uid/gid. Closes: 717609
* Adapt changes and formatting of initramfs hook from Ubuntu
* Bump standards version to 3.9.7, no changes required
* Fix copyright-refers-to-symlink-license
* Closes: #781172, #796624, #769201, #813335, #632401, #804973, #714155,
#770002, #737132, #675452, #726390, #813637, #814036.
# imported from the archive
Diffstat (limited to 'raid5extend.c')
-rw-r--r-- | raid5extend.c | 80 |
1 files changed, 80 insertions, 0 deletions
diff --git a/raid5extend.c b/raid5extend.c new file mode 100644 index 00000000..d8e62c2c --- /dev/null +++ b/raid5extend.c @@ -0,0 +1,80 @@ + +int phys2log(int phys, int stripe, int n, int layout) +{ + /* In an 'n' disk array using 'layout', + * in stripe 'stripe', the physical disc 'phys' + * stores what logical chunk? + * -1 mean parity. + * + */ + switch(layout) { + case ALGORITHM_LEFT_ASYMMETRIC: + pd = (n-1) - (stripe % n); + if (phys < pd) + return phys; + else if (phys == pd) + return -1; + else return phys-1; + + case ALGORITHM_RIGHT_ASYMMETRIC: + pd = stripe % n; + if (phys < pd) + return phys; + else if (phys == pd) + return -1; + else return phys-1; + + case ALGORITHM_LEFT_SYMMETRIC: + pd = (n-1) - (stripe %n); + if (phys < pd) + return phys+ n-1-pd; + else if (phys == pd) + return -1; + else return phys-pd-1; + + case ALGORITHM_RIGHT_SYMMETRIC: + pd = stripe % n; + if (phys < pd) + return phys+ n-1-pd; + else if (phys == pd) + return -1; + else return phys-pd-1; + } + return -2; +} + +raid5_extend(unsigned long len, int chunksize, int layout, int n, int m, int rfds[], int wfds[]) +{ + + static char buf[4096]; + + unsigned long blocks = len/4; + unsigned int blocksperchunk= chunksize/4096; + + unsigned long b; + + for (b=0; b<blocks; b++) { + unsigned long stripe = b / blocksperchunk; + unsigned int offset = b - (stripe*blocksperchunk); + unsigned long chunk = stripe * (n-1); + int src; + for (src=0; src<n; src++) { + int dnum, snum; + if (read(rfds[src], buf, sizeof(buf)) != sizeof(buf)) { + error(); + return 0; + } + + snum = phys2log(src, stripe, n, layout); + + if (snum == -1) + continue; + chunk = stripe*(n-1)+snum; + + dstripe = chunk/(m-1); + dnum = log2phys(chunk-(stripe*(m-1)), dstripe, m, layout); + llseek(wfds[dnum], dstripe*chunksize+(offset*4096), 0); + write(wfds[dnum], buf, sizeof(buf)); + } + } +} |