]> git.ipfire.org Git - thirdparty/mdadm.git/blob - Grow.c
error check reading of 'degraded' from sysfs.
[thirdparty/mdadm.git] / Grow.c
1 /*
2 * mdadm - manage Linux "md" devices aka RAID arrays.
3 *
4 * Copyright (C) 2001-2009 Neil Brown <neilb@suse.de>
5 *
6 *
7 * This program is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License as published by
9 * the Free Software Foundation; either version 2 of the License, or
10 * (at your option) any later version.
11 *
12 * This program is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 * GNU General Public License for more details.
16 *
17 * You should have received a copy of the GNU General Public License
18 * along with this program; if not, write to the Free Software
19 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
20 *
21 * Author: Neil Brown
22 * Email: <neilb@suse.de>
23 */
24 #include "mdadm.h"
25 #include "dlink.h"
26 #include <sys/mman.h>
27
28 #if ! defined(__BIG_ENDIAN) && ! defined(__LITTLE_ENDIAN)
29 #error no endian defined
30 #endif
31 #include "md_u.h"
32 #include "md_p.h"
33
34 #ifndef offsetof
35 #define offsetof(t,f) ((size_t)&(((t*)0)->f))
36 #endif
37
38 int Grow_Add_device(char *devname, int fd, char *newdev)
39 {
40 /* Add a device to an active array.
41 * Currently, just extend a linear array.
42 * This requires writing a new superblock on the
43 * new device, calling the kernel to add the device,
44 * and if that succeeds, update the superblock on
45 * all other devices.
46 * This means that we need to *find* all other devices.
47 */
48 struct mdinfo info;
49
50 struct stat stb;
51 int nfd, fd2;
52 int d, nd;
53 struct supertype *st = NULL;
54
55
56 if (ioctl(fd, GET_ARRAY_INFO, &info.array) < 0) {
57 fprintf(stderr, Name ": cannot get array info for %s\n", devname);
58 return 1;
59 }
60
61 st = super_by_fd(fd);
62 if (!st) {
63 fprintf(stderr, Name ": cannot handle arrays with superblock version %d\n", info.array.major_version);
64 return 1;
65 }
66
67 if (info.array.level != -1) {
68 fprintf(stderr, Name ": can only add devices to linear arrays\n");
69 return 1;
70 }
71
72 nfd = open(newdev, O_RDWR|O_EXCL|O_DIRECT);
73 if (nfd < 0) {
74 fprintf(stderr, Name ": cannot open %s\n", newdev);
75 return 1;
76 }
77 fstat(nfd, &stb);
78 if ((stb.st_mode & S_IFMT) != S_IFBLK) {
79 fprintf(stderr, Name ": %s is not a block device!\n", newdev);
80 close(nfd);
81 return 1;
82 }
83 /* now check out all the devices and make sure we can read the superblock */
84 for (d=0 ; d < info.array.raid_disks ; d++) {
85 mdu_disk_info_t disk;
86 char *dv;
87
88 disk.number = d;
89 if (ioctl(fd, GET_DISK_INFO, &disk) < 0) {
90 fprintf(stderr, Name ": cannot get device detail for device %d\n",
91 d);
92 return 1;
93 }
94 dv = map_dev(disk.major, disk.minor, 1);
95 if (!dv) {
96 fprintf(stderr, Name ": cannot find device file for device %d\n",
97 d);
98 return 1;
99 }
100 fd2 = dev_open(dv, O_RDWR);
101 if (!fd2) {
102 fprintf(stderr, Name ": cannot open device file %s\n", dv);
103 return 1;
104 }
105 st->ss->free_super(st);
106
107 if (st->ss->load_super(st, fd2, NULL)) {
108 fprintf(stderr, Name ": cannot find super block on %s\n", dv);
109 close(fd2);
110 return 1;
111 }
112 close(fd2);
113 }
114 /* Ok, looks good. Lets update the superblock and write it out to
115 * newdev.
116 */
117
118 info.disk.number = d;
119 info.disk.major = major(stb.st_rdev);
120 info.disk.minor = minor(stb.st_rdev);
121 info.disk.raid_disk = d;
122 info.disk.state = (1 << MD_DISK_SYNC) | (1 << MD_DISK_ACTIVE);
123 st->ss->update_super(st, &info, "linear-grow-new", newdev,
124 0, 0, NULL);
125
126 if (st->ss->store_super(st, nfd)) {
127 fprintf(stderr, Name ": Cannot store new superblock on %s\n",
128 newdev);
129 close(nfd);
130 return 1;
131 }
132 close(nfd);
133
134 if (ioctl(fd, ADD_NEW_DISK, &info.disk) != 0) {
135 fprintf(stderr, Name ": Cannot add new disk to this array\n");
136 return 1;
137 }
138 /* Well, that seems to have worked.
139 * Now go through and update all superblocks
140 */
141
142 if (ioctl(fd, GET_ARRAY_INFO, &info.array) < 0) {
143 fprintf(stderr, Name ": cannot get array info for %s\n", devname);
144 return 1;
145 }
146
147 nd = d;
148 for (d=0 ; d < info.array.raid_disks ; d++) {
149 mdu_disk_info_t disk;
150 char *dv;
151
152 disk.number = d;
153 if (ioctl(fd, GET_DISK_INFO, &disk) < 0) {
154 fprintf(stderr, Name ": cannot get device detail for device %d\n",
155 d);
156 return 1;
157 }
158 dv = map_dev(disk.major, disk.minor, 1);
159 if (!dv) {
160 fprintf(stderr, Name ": cannot find device file for device %d\n",
161 d);
162 return 1;
163 }
164 fd2 = dev_open(dv, O_RDWR);
165 if (fd2 < 0) {
166 fprintf(stderr, Name ": cannot open device file %s\n", dv);
167 return 1;
168 }
169 if (st->ss->load_super(st, fd2, NULL)) {
170 fprintf(stderr, Name ": cannot find super block on %s\n", dv);
171 close(fd);
172 return 1;
173 }
174 info.array.raid_disks = nd+1;
175 info.array.nr_disks = nd+1;
176 info.array.active_disks = nd+1;
177 info.array.working_disks = nd+1;
178
179 st->ss->update_super(st, &info, "linear-grow-update", dv,
180 0, 0, NULL);
181
182 if (st->ss->store_super(st, fd2)) {
183 fprintf(stderr, Name ": Cannot store new superblock on %s\n", dv);
184 close(fd2);
185 return 1;
186 }
187 close(fd2);
188 }
189
190 return 0;
191 }
192
193 int Grow_addbitmap(char *devname, int fd, char *file, int chunk, int delay, int write_behind, int force)
194 {
195 /*
196 * First check that array doesn't have a bitmap
197 * Then create the bitmap
198 * Then add it
199 *
200 * For internal bitmaps, we need to check the version,
201 * find all the active devices, and write the bitmap block
202 * to all devices
203 */
204 mdu_bitmap_file_t bmf;
205 mdu_array_info_t array;
206 struct supertype *st;
207 int major = BITMAP_MAJOR_HI;
208 int vers = md_get_version(fd);
209 unsigned long long bitmapsize, array_size;
210
211 if (vers < 9003) {
212 major = BITMAP_MAJOR_HOSTENDIAN;
213 #ifdef __BIG_ENDIAN
214 fprintf(stderr, Name ": Warning - bitmaps created on this kernel are not portable\n"
215 " between different architectured. Consider upgrading the Linux kernel.\n");
216 #endif
217 }
218
219 if (ioctl(fd, GET_BITMAP_FILE, &bmf) != 0) {
220 if (errno == ENOMEM)
221 fprintf(stderr, Name ": Memory allocation failure.\n");
222 else
223 fprintf(stderr, Name ": bitmaps not supported by this kernel.\n");
224 return 1;
225 }
226 if (bmf.pathname[0]) {
227 if (strcmp(file,"none")==0) {
228 if (ioctl(fd, SET_BITMAP_FILE, -1)!= 0) {
229 fprintf(stderr, Name ": failed to remove bitmap %s\n",
230 bmf.pathname);
231 return 1;
232 }
233 return 0;
234 }
235 fprintf(stderr, Name ": %s already has a bitmap (%s)\n",
236 devname, bmf.pathname);
237 return 1;
238 }
239 if (ioctl(fd, GET_ARRAY_INFO, &array) != 0) {
240 fprintf(stderr, Name ": cannot get array status for %s\n", devname);
241 return 1;
242 }
243 if (array.state & (1<<MD_SB_BITMAP_PRESENT)) {
244 if (strcmp(file, "none")==0) {
245 array.state &= ~(1<<MD_SB_BITMAP_PRESENT);
246 if (ioctl(fd, SET_ARRAY_INFO, &array)!= 0) {
247 fprintf(stderr, Name ": failed to remove internal bitmap.\n");
248 return 1;
249 }
250 return 0;
251 }
252 fprintf(stderr, Name ": Internal bitmap already present on %s\n",
253 devname);
254 return 1;
255 }
256 if (array.level <= 0) {
257 fprintf(stderr, Name ": Bitmaps not meaningful with level %s\n",
258 map_num(pers, array.level)?:"of this array");
259 return 1;
260 }
261 bitmapsize = array.size;
262 bitmapsize <<= 1;
263 if (get_dev_size(fd, NULL, &array_size) &&
264 array_size > (0x7fffffffULL<<9)) {
265 /* Array is big enough that we cannot trust array.size
266 * try other approaches
267 */
268 bitmapsize = get_component_size(fd);
269 }
270 if (bitmapsize == 0) {
271 fprintf(stderr, Name ": Cannot reliably determine size of array to create bitmap - sorry.\n");
272 return 1;
273 }
274
275 if (array.level == 10) {
276 int ncopies = (array.layout&255)*((array.layout>>8)&255);
277 bitmapsize = bitmapsize * array.raid_disks / ncopies;
278 }
279
280 st = super_by_fd(fd);
281 if (!st) {
282 fprintf(stderr, Name ": Cannot understand version %d.%d\n",
283 array.major_version, array.minor_version);
284 return 1;
285 }
286 if (strcmp(file, "none") == 0) {
287 fprintf(stderr, Name ": no bitmap found on %s\n", devname);
288 return 1;
289 } else if (strcmp(file, "internal") == 0) {
290 int d;
291 if (st->ss->add_internal_bitmap == NULL) {
292 fprintf(stderr, Name ": Internal bitmaps not supported "
293 "with %s metadata\n", st->ss->name);
294 return 1;
295 }
296 for (d=0; d< st->max_devs; d++) {
297 mdu_disk_info_t disk;
298 char *dv;
299 disk.number = d;
300 if (ioctl(fd, GET_DISK_INFO, &disk) < 0)
301 continue;
302 if (disk.major == 0 &&
303 disk.minor == 0)
304 continue;
305 if ((disk.state & (1<<MD_DISK_SYNC))==0)
306 continue;
307 dv = map_dev(disk.major, disk.minor, 1);
308 if (dv) {
309 int fd2 = dev_open(dv, O_RDWR);
310 if (fd2 < 0)
311 continue;
312 if (st->ss->load_super(st, fd2, NULL)==0) {
313 if (st->ss->add_internal_bitmap(
314 st,
315 &chunk, delay, write_behind,
316 bitmapsize, 0, major)
317 )
318 st->ss->write_bitmap(st, fd2);
319 else {
320 fprintf(stderr, Name ": failed to create internal bitmap - chunksize problem.\n");
321 close(fd2);
322 return 1;
323 }
324 }
325 close(fd2);
326 }
327 }
328 array.state |= (1<<MD_SB_BITMAP_PRESENT);
329 if (ioctl(fd, SET_ARRAY_INFO, &array)!= 0) {
330 fprintf(stderr, Name ": failed to set internal bitmap.\n");
331 return 1;
332 }
333 } else {
334 int uuid[4];
335 int bitmap_fd;
336 int d;
337 int max_devs = st->max_devs;
338
339 /* try to load a superblock */
340 for (d=0; d<max_devs; d++) {
341 mdu_disk_info_t disk;
342 char *dv;
343 int fd2;
344 disk.number = d;
345 if (ioctl(fd, GET_DISK_INFO, &disk) < 0)
346 continue;
347 if ((disk.major==0 && disk.minor==0) ||
348 (disk.state & (1<<MD_DISK_REMOVED)))
349 continue;
350 dv = map_dev(disk.major, disk.minor, 1);
351 if (!dv) continue;
352 fd2 = dev_open(dv, O_RDONLY);
353 if (fd2 >= 0 &&
354 st->ss->load_super(st, fd2, NULL) == 0) {
355 close(fd2);
356 st->ss->uuid_from_super(st, uuid);
357 break;
358 }
359 close(fd2);
360 }
361 if (d == max_devs) {
362 fprintf(stderr, Name ": cannot find UUID for array!\n");
363 return 1;
364 }
365 if (CreateBitmap(file, force, (char*)uuid, chunk,
366 delay, write_behind, bitmapsize, major)) {
367 return 1;
368 }
369 bitmap_fd = open(file, O_RDWR);
370 if (bitmap_fd < 0) {
371 fprintf(stderr, Name ": weird: %s cannot be opened\n",
372 file);
373 return 1;
374 }
375 if (ioctl(fd, SET_BITMAP_FILE, bitmap_fd) < 0) {
376 fprintf(stderr, Name ": Cannot set bitmap file for %s: %s\n",
377 devname, strerror(errno));
378 return 1;
379 }
380 }
381
382 return 0;
383 }
384
385
386 /*
387 * When reshaping an array we might need to backup some data.
388 * This is written to all spares with a 'super_block' describing it.
389 * The superblock goes 4K from the end of the used space on the
390 * device.
391 * It if written after the backup is complete.
392 * It has the following structure.
393 */
394
395 static struct mdp_backup_super {
396 char magic[16]; /* md_backup_data-1 or -2 */
397 __u8 set_uuid[16];
398 __u64 mtime;
399 /* start/sizes in 512byte sectors */
400 __u64 devstart; /* address on backup device/file of data */
401 __u64 arraystart;
402 __u64 length;
403 __u32 sb_csum; /* csum of preceeding bytes. */
404 __u32 pad1;
405 __u64 devstart2; /* offset in to data of second section */
406 __u64 arraystart2;
407 __u64 length2;
408 __u32 sb_csum2; /* csum of preceeding bytes. */
409 __u8 pad[512-68-32];
410 } __attribute__((aligned(512))) bsb, bsb2;
411
412 __u32 bsb_csum(char *buf, int len)
413 {
414 int i;
415 int csum = 0;
416 for (i=0; i<len; i++)
417 csum = (csum<<3) + buf[0];
418 return __cpu_to_le32(csum);
419 }
420
421 static int child_grow(int afd, struct mdinfo *sra, unsigned long blocks,
422 int *fds, unsigned long long *offsets,
423 int disks, int chunk, int level, int layout, int data,
424 int dests, int *destfd, unsigned long long *destoffsets);
425 static int child_shrink(int afd, struct mdinfo *sra, unsigned long blocks,
426 int *fds, unsigned long long *offsets,
427 int disks, int chunk, int level, int layout, int data,
428 int dests, int *destfd, unsigned long long *destoffsets);
429 static int child_same_size(int afd, struct mdinfo *sra, unsigned long blocks,
430 int *fds, unsigned long long *offsets,
431 unsigned long long start,
432 int disks, int chunk, int level, int layout, int data,
433 int dests, int *destfd, unsigned long long *destoffsets);
434
435 int freeze_array(struct mdinfo *sra)
436 {
437 /* Try to freeze resync on this array.
438 * Return -1 if the array is busy,
439 * return 0 if this kernel doesn't support 'frozen'
440 * return 1 if it worked.
441 */
442 char buf[20];
443 if (sysfs_get_str(sra, NULL, "sync_action", buf, 20) <= 0)
444 return 0;
445 if (strcmp(buf, "idle\n") != 0 &&
446 strcmp(buf, "frozen\n") != 0)
447 return -1;
448 if (sysfs_set_str(sra, NULL, "sync_action", "frozen") < 0)
449 return 0;
450 return 1;
451 }
452
453 void unfreeze_array(struct mdinfo *sra, int frozen)
454 {
455 /* If 'frozen' is 1, unfreeze the array */
456 if (frozen > 0)
457 sysfs_set_str(sra, NULL, "sync_action", "idle");
458 }
459
460 void wait_reshape(struct mdinfo *sra)
461 {
462 int fd = sysfs_get_fd(sra, NULL, "sync_action");
463 char action[20];
464
465 do {
466 fd_set rfds;
467 FD_ZERO(&rfds);
468 FD_SET(fd, &rfds);
469 select(fd+1, NULL, NULL, &rfds, NULL);
470
471 if (sysfs_fd_get_str(fd, action, 20) < 0) {
472 close(fd);
473 return;
474 }
475 } while (strncmp(action, "reshape", 7) == 0);
476 }
477
478
479 int Grow_reshape(char *devname, int fd, int quiet, char *backup_file,
480 long long size,
481 int level, char *layout_str, int chunksize, int raid_disks)
482 {
483 /* Make some changes in the shape of an array.
484 * The kernel must support the change.
485 *
486 * There are three different changes. Each can trigger
487 * a resync or recovery so we freeze that until we have
488 * requested everything (if kernel supports freezing - 2.6.30).
489 * The steps are:
490 * - change size (i.e. component_size)
491 * - change level
492 * - change layout/chunksize/ndisks
493 *
494 * The last can require a reshape. It is different on different
495 * levels so we need to check the level before actioning it.
496 * Some times the level change needs to be requested after the
497 * reshape (e.g. raid6->raid5, raid5->raid0)
498 *
499 */
500 struct mdu_array_info_s array, orig;
501 char *c;
502 int rv = 0;
503 struct supertype *st;
504
505 int nchunk, ochunk;
506 int nlayout, olayout;
507 int ndisks, odisks;
508 unsigned int ndata, odata;
509 int orig_level = UnSet;
510 char alt_layout[40];
511 int *fdlist;
512 unsigned long long *offsets;
513 int d, i;
514 int nrdisks;
515 int err;
516 int frozen;
517 unsigned long a,b, blocks, stripes;
518 unsigned long cache;
519 unsigned long long array_size;
520 int changed = 0;
521 int done;
522
523 struct mdinfo *sra;
524 struct mdinfo *sd;
525
526 if (ioctl(fd, GET_ARRAY_INFO, &array) < 0) {
527 fprintf(stderr, Name ": %s is not an active md array - aborting\n",
528 devname);
529 return 1;
530 }
531
532 if (size >= 0 &&
533 (chunksize || level!= UnSet || layout_str || raid_disks)) {
534 fprintf(stderr, Name ": cannot change component size at the same time "
535 "as other changes.\n"
536 " Change size first, then check data is intact before "
537 "making other changes.\n");
538 return 1;
539 }
540
541 if (raid_disks && raid_disks < array.raid_disks && array.level > 1 &&
542 get_linux_version() < 2006032 &&
543 !check_env("MDADM_FORCE_FEWER")) {
544 fprintf(stderr, Name ": reducing the number of devices is not safe before Linux 2.6.32\n"
545 " Please use a newer kernel\n");
546 return 1;
547 }
548 sra = sysfs_read(fd, 0, GET_LEVEL);
549 if (sra)
550 frozen = freeze_array(sra);
551 else {
552 fprintf(stderr, Name ": failed to read sysfs parameters for %s\n",
553 devname);
554 return 1;
555 }
556 if (frozen < 0) {
557 fprintf(stderr, Name ": %s is performing resync/recovery and cannot"
558 " be reshaped\n", devname);
559 return 1;
560 }
561
562 /* ========= set size =============== */
563 if (size >= 0 && (size == 0 || size != array.size)) {
564 array.size = size;
565 if (array.size != size) {
566 /* got truncated to 32bit, write to
567 * component_size instead
568 */
569 if (sra)
570 rv = sysfs_set_num(sra, NULL,
571 "component_size", size);
572 else
573 rv = -1;
574 } else
575 rv = ioctl(fd, SET_ARRAY_INFO, &array);
576 if (rv != 0) {
577 int err = errno;
578 fprintf(stderr, Name ": Cannot set device size for %s: %s\n",
579 devname, strerror(err));
580 if (err == EBUSY &&
581 (array.state & (1<<MD_SB_BITMAP_PRESENT)))
582 fprintf(stderr, " Bitmap must be removed before size can be changed\n");
583 rv = 1;
584 goto release;
585 }
586 ioctl(fd, GET_ARRAY_INFO, &array);
587 size = get_component_size(fd)/2;
588 if (size == 0)
589 size = array.size;
590 if (!quiet)
591 fprintf(stderr, Name ": component size of %s has been set to %lluK\n",
592 devname, size);
593 changed = 1;
594 } else {
595 size = get_component_size(fd)/2;
596 if (size == 0)
597 size = array.size;
598 }
599
600 /* ======= set level =========== */
601 if (level != UnSet && level != array.level) {
602 /* Trying to change the level.
603 * We might need to change layout first and schedule a
604 * level change for later.
605 * Level changes that can happen immediately are:
606 * 0->4,5,6 1->5 4->5,6 5->1,6
607 * Level changes that need a layout change first are:
608 * 6->5,4,0 : need a -6 layout, or parity-last
609 * 5->4,0 : need parity-last
610 */
611 if ((array.level == 6 || array.level == 5) &&
612 (level == 5 || level == 4 || level == 0)) {
613 /* Don't change level yet, but choose intermediate
614 * layout
615 */
616 if (level == 5) {
617 if (layout_str == NULL)
618 switch (array.layout) {
619 case ALGORITHM_LEFT_ASYMMETRIC:
620 case ALGORITHM_LEFT_ASYMMETRIC_6:
621 case ALGORITHM_ROTATING_N_RESTART:
622 layout_str = "left-asymmetric-6";
623 break;
624 case ALGORITHM_LEFT_SYMMETRIC:
625 case ALGORITHM_LEFT_SYMMETRIC_6:
626 case ALGORITHM_ROTATING_N_CONTINUE:
627 layout_str = "left-symmetric-6";
628 break;
629 case ALGORITHM_RIGHT_ASYMMETRIC:
630 case ALGORITHM_RIGHT_ASYMMETRIC_6:
631 case ALGORITHM_ROTATING_ZERO_RESTART:
632 layout_str = "right-asymmetric-6";
633 break;
634 case ALGORITHM_RIGHT_SYMMETRIC:
635 case ALGORITHM_RIGHT_SYMMETRIC_6:
636 layout_str = "right-symmetric-6";
637 break;
638 case ALGORITHM_PARITY_0:
639 case ALGORITHM_PARITY_0_6:
640 layout_str = "parity-first-6";
641 break;
642 case ALGORITHM_PARITY_N:
643 layout_str = "parity-last";
644 break;
645 default:
646 fprintf(stderr, Name ": %s: cannot"
647 "convert layout to RAID5 equivalent\n",
648 devname);
649 rv = 1;
650 goto release;
651 }
652 else {
653 int l = map_name(r5layout, layout_str);
654 if (l == UnSet) {
655 fprintf(stderr, Name ": %s: layout '%s' not recognised\n",
656 devname, layout_str);
657 rv = 1;
658 goto release;
659 }
660 if (l != ALGORITHM_PARITY_N) {
661 /* need the -6 version */
662 char *ls = map_num(r5layout, l);
663 strcat(strcpy(alt_layout, ls),
664 "-6");
665 layout_str = alt_layout;
666 }
667 }
668 if (raid_disks)
669 /* The final raid6->raid5 conversion
670 * will reduce the number of disks,
671 * so now we need to aim higher
672 */
673 raid_disks++;
674 } else
675 layout_str = "parity-last";
676 } else {
677 c = map_num(pers, level);
678 if (c == NULL) {
679 rv = 1;/* not possible */
680 goto release;
681 }
682 err = sysfs_set_str(sra, NULL, "level", c);
683 if (err) {
684 err = errno;
685 fprintf(stderr, Name ": %s: could not set level to %s\n",
686 devname, c);
687 if (err == EBUSY &&
688 (array.state & (1<<MD_SB_BITMAP_PRESENT)))
689 fprintf(stderr, " Bitmap must be removed before level can be changed\n");
690 rv = 1;
691 goto release;
692 }
693 orig = array;
694 orig_level = orig.level;
695 ioctl(fd, GET_ARRAY_INFO, &array);
696 if (layout_str == NULL &&
697 orig.level == 5 && level == 6 &&
698 array.layout != orig.layout)
699 layout_str = map_num(r5layout, orig.layout);
700 if (!quiet)
701 fprintf(stderr, Name " level of %s changed to %s\n",
702 devname, c);
703 changed = 1;
704 }
705 }
706
707 /* ========= set shape (chunk_size / layout / ndisks) ============== */
708 /* Check if layout change is a no-op */
709 if (layout_str) switch(array.level) {
710 case 5:
711 if (array.layout == map_name(r5layout, layout_str))
712 layout_str = NULL;
713 break;
714 case 6:
715 if (layout_str == NULL &&
716 ((chunksize && chunksize * 1024 != array.chunk_size) ||
717 (raid_disks && raid_disks != array.raid_disks)) &&
718 array.layout >= 16) {
719 fprintf(stderr, Name
720 ": %s has a non-standard layout. If you wish to preserve this\n"
721 " during the reshape, please specify --layout=preserve\n"
722 " If you want to change it, specify a layout or use --layout=normalise\n",
723 devname);
724 rv = 1;
725 goto release;
726 }
727 if (strcmp(layout_str, "normalise") == 0 ||
728 strcmp(layout_str, "normalize") == 0) {
729 char *hyphen;
730 strcpy(alt_layout, map_num(r6layout, array.layout));
731 hyphen = strrchr(alt_layout, '-');
732 if (hyphen && strcmp(hyphen, "-6") == 0) {
733 *hyphen = 0;
734 layout_str = alt_layout;
735 }
736 }
737
738 if (array.layout == map_name(r6layout, layout_str))
739 layout_str = NULL;
740 if (layout_str && strcmp(layout_str, "preserve") == 0)
741 layout_str = NULL;
742 break;
743 }
744 if (layout_str == NULL
745 && (chunksize == 0 || chunksize*1024 == array.chunk_size)
746 && (raid_disks == 0 || raid_disks == array.raid_disks)) {
747 rv = 0;
748 if (level != UnSet && level != array.level) {
749 /* Looks like this level change doesn't need
750 * a reshape after all.
751 */
752 c = map_num(pers, level);
753 if (c) {
754 rv = sysfs_set_str(sra, NULL, "level", c);
755 if (rv) {
756 int err = errno;
757 fprintf(stderr, Name ": %s: could not set level to %s\n",
758 devname, c);
759 if (err == EBUSY &&
760 (array.state & (1<<MD_SB_BITMAP_PRESENT)))
761 fprintf(stderr, " Bitmap must be removed before level can be changed\n");
762 rv = 1;
763 }
764 }
765 } else if (!changed && !quiet)
766 fprintf(stderr, Name ": %s: no change requested\n",
767 devname);
768 goto release;
769 }
770
771 c = map_num(pers, array.level);
772 if (c == NULL) c = "-unknown-";
773 switch(array.level) {
774 default: /* raid0, linear, multipath cannot be reconfigured */
775 fprintf(stderr, Name ": %s array %s cannot be reshaped.\n",
776 c, devname);
777 rv = 1;
778 break;
779
780 case LEVEL_FAULTY: /* only 'layout' change is permitted */
781
782 if (chunksize || raid_disks) {
783 fprintf(stderr, Name ": %s: Cannot change chunksize or disks of a 'faulty' array\n",
784 devname);
785 rv = 1;
786 break;
787 }
788 if (layout_str == NULL)
789 break; /* nothing to do.... */
790
791 array.layout = parse_layout_faulty(layout_str);
792 if (array.layout < 0) {
793 fprintf(stderr, Name ": %s: layout %s not understood for 'faulty' array\n",
794 devname, layout_str);
795 rv = 1;
796 break;
797 }
798 if (ioctl(fd, SET_ARRAY_INFO, &array) != 0) {
799 fprintf(stderr, Name ": Cannot set layout for %s: %s\n",
800 devname, strerror(errno));
801 rv = 1;
802 } else if (!quiet)
803 printf("layout for %s set to %d\n", devname, array.layout);
804 break;
805
806 case 1: /* only raid_disks can each be changed. */
807
808 if (chunksize || layout_str != NULL) {
809 fprintf(stderr, Name ": %s: Cannot change chunk size or layout for a RAID1 array.\n",
810 devname);
811 rv = 1;
812 break;
813 }
814 if (raid_disks > 0) {
815 array.raid_disks = raid_disks;
816 if (ioctl(fd, SET_ARRAY_INFO, &array) != 0) {
817 fprintf(stderr, Name ": Cannot set raid-devices for %s: %s\n",
818 devname, strerror(errno));
819 rv = 1;
820 }
821 }
822 break;
823
824 case 4:
825 case 5:
826 case 6:
827
828 /*
829 * layout/chunksize/raid_disks can be changed
830 * though the kernel may not support it all.
831 */
832 st = super_by_fd(fd);
833
834 /*
835 * There are three possibilities.
836 * 1/ The array will shrink.
837 * We need to ensure the reshape will pause before reaching
838 * the 'critical section'. We also need to fork and wait for
839 * that to happen. When it does we
840 * suspend/backup/complete/unfreeze
841 *
842 * 2/ The array will not change size.
843 * This requires that we keep a backup of a sliding window
844 * so that we can restore data after a crash. So we need
845 * to fork and monitor progress.
846 *
847 * 3/ The array will grow. This is relatively easy.
848 * However the kernel's restripe routines will cheerfully
849 * overwrite some early data before it is safe. So we
850 * need to make a backup of the early parts of the array
851 * and be ready to restore it if rebuild aborts very early.
852 *
853 * We backup data by writing it to one spare, or to a
854 * file which was given on command line.
855 *
856 * [FOLLOWING IS OLD AND PARTLY WRONG]
857 * So: we enumerate the devices in the array and
858 * make sure we can open all of them.
859 * Then we freeze the early part of the array and
860 * backup to the various spares.
861 * Then we request changes and start the reshape.
862 * Monitor progress until it has passed the danger zone.
863 * and finally invalidate the copied data and unfreeze the
864 * start of the array.
865 *
866 * In each case, we first make sure that storage is available
867 * for the required backup.
868 * Then we:
869 * - request the shape change.
870 * - for to handle backup etc.
871 */
872 nchunk = ochunk = array.chunk_size;
873 nlayout = olayout = array.layout;
874 ndisks = odisks = array.raid_disks;
875
876 if (chunksize) {
877 nchunk = chunksize * 1024;
878 if (size % chunksize) {
879 fprintf(stderr, Name ": component size %lluK is not"
880 " a multiple of chunksize %dK\n",
881 size, chunksize);
882 break;
883 }
884 }
885 if (layout_str != NULL)
886 switch(array.level) {
887 case 4: /* ignore layout */
888 break;
889 case 5:
890 nlayout = map_name(r5layout, layout_str);
891 if (nlayout == UnSet) {
892 fprintf(stderr, Name ": layout %s not understood for raid5.\n",
893 layout_str);
894 rv = 1;
895 goto release;
896 }
897 break;
898
899 case 6:
900 nlayout = map_name(r6layout, layout_str);
901 if (nlayout == UnSet) {
902 fprintf(stderr, Name ": layout %s not understood for raid6.\n",
903 layout_str);
904 rv = 1;
905 goto release;
906 }
907 break;
908 }
909 if (raid_disks) ndisks = raid_disks;
910
911 odata = odisks-1;
912 ndata = ndisks-1;
913 if (array.level == 6) {
914 odata--; /* number of data disks */
915 ndata--;
916 }
917
918 if (odata == ndata &&
919 get_linux_version() < 2006032) {
920 fprintf(stderr, Name ": in-place reshape is not safe before 2.6.32, sorry.\n");
921 break;
922 }
923
924 /* Check that we can hold all the data */
925 get_dev_size(fd, NULL, &array_size);
926 if (ndata * (unsigned long long)size < (array_size/1024)) {
927 fprintf(stderr, Name ": this change will reduce the size of the array.\n"
928 " use --grow --array-size first to truncate array.\n"
929 " e.g. mdadm --grow %s --array-size %llu\n",
930 devname, ndata * size);
931 rv = 1;
932 break;
933 }
934
935 /* So how much do we need to backup.
936 * We need an amount of data which is both a whole number of
937 * old stripes and a whole number of new stripes.
938 * So LCM for (chunksize*datadisks).
939 */
940 a = (ochunk/512) * odata;
941 b = (nchunk/512) * ndata;
942 /* Find GCD */
943 while (a != b) {
944 if (a < b)
945 b -= a;
946 if (b < a)
947 a -= b;
948 }
949 /* LCM == product / GCD */
950 blocks = (ochunk/512) * (nchunk/512) * odata * ndata / a;
951
952 sysfs_free(sra);
953 sra = sysfs_read(fd, 0,
954 GET_COMPONENT|GET_DEVS|GET_OFFSET|GET_STATE|
955 GET_CACHE);
956
957 if (!sra) {
958 fprintf(stderr, Name ": %s: Cannot get array details from sysfs\n",
959 devname);
960 rv = 1;
961 break;
962 }
963
964 if (ndata == odata) {
965 /* Make 'blocks' bigger for better throughput, but
966 * not so big that we reject it below.
967 * Try for 16 megabytes
968 */
969 while (blocks * 32 < sra->component_size &&
970 blocks < 16*1024*2)
971 blocks *= 2;
972 } else
973 fprintf(stderr, Name ": Need to backup %luK of critical "
974 "section..\n", blocks/2);
975
976 if (blocks >= sra->component_size/2) {
977 fprintf(stderr, Name ": %s: Something wrong - reshape aborted\n",
978 devname);
979 rv = 1;
980 break;
981 }
982 nrdisks = array.raid_disks + sra->array.spare_disks;
983 /* Now we need to open all these devices so we can read/write.
984 */
985 fdlist = malloc((1+nrdisks) * sizeof(int));
986 offsets = malloc((1+nrdisks) * sizeof(offsets[0]));
987 if (!fdlist || !offsets) {
988 fprintf(stderr, Name ": malloc failed: grow aborted\n");
989 rv = 1;
990 break;
991 }
992 for (d=0; d <= nrdisks; d++)
993 fdlist[d] = -1;
994 d = array.raid_disks;
995 for (sd = sra->devs; sd; sd=sd->next) {
996 if (sd->disk.state & (1<<MD_DISK_FAULTY))
997 continue;
998 if (sd->disk.state & (1<<MD_DISK_SYNC)) {
999 char *dn = map_dev(sd->disk.major,
1000 sd->disk.minor, 1);
1001 fdlist[sd->disk.raid_disk]
1002 = dev_open(dn, O_RDONLY);
1003 offsets[sd->disk.raid_disk] = sd->data_offset*512;
1004 if (fdlist[sd->disk.raid_disk] < 0) {
1005 fprintf(stderr, Name ": %s: cannot open component %s\n",
1006 devname, dn?dn:"-unknown-");
1007 rv = 1;
1008 goto release;
1009 }
1010 } else if (backup_file == NULL) {
1011 /* spare */
1012 char *dn = map_dev(sd->disk.major,
1013 sd->disk.minor, 1);
1014 fdlist[d] = dev_open(dn, O_RDWR);
1015 offsets[d] = (sd->data_offset + sra->component_size - blocks - 8)*512;
1016 if (fdlist[d]<0) {
1017 fprintf(stderr, Name ": %s: cannot open component %s\n",
1018 devname, dn?dn:"-unknown");
1019 rv = 1;
1020 goto release;
1021 }
1022 d++;
1023 }
1024 }
1025 if (backup_file == NULL) {
1026 if (ndata <= odata) {
1027 fprintf(stderr, Name ": %s: Cannot grow - need backup-file\n",
1028 devname);
1029 rv = 1;
1030 break;
1031 } else if (sra->array.spare_disks == 0) {
1032 fprintf(stderr, Name ": %s: Cannot grow - need a spare or "
1033 "backup-file to backup critical section\n",
1034 devname);
1035 rv = 1;
1036 break;
1037 }
1038 if (d == array.raid_disks) {
1039 fprintf(stderr, Name ": %s: No spare device for backup\n",
1040 devname);
1041 rv = 1;
1042 break;
1043 }
1044 } else {
1045 /* need to check backup file is large enough */
1046 char buf[512];
1047 fdlist[d] = open(backup_file, O_RDWR|O_CREAT|O_EXCL,
1048 S_IRUSR | S_IWUSR);
1049 offsets[d] = 8 * 512;
1050 if (fdlist[d] < 0) {
1051 fprintf(stderr, Name ": %s: cannot create backup file %s: %s\n",
1052 devname, backup_file, strerror(errno));
1053 rv = 1;
1054 break;
1055 }
1056 memset(buf, 0, 512);
1057 for (i=0; i < (signed)blocks + 8 ; i++) {
1058 if (write(fdlist[d], buf, 512) != 512) {
1059 fprintf(stderr, Name ": %s: cannot create backup file %s: %s\n",
1060 devname, backup_file, strerror(errno));
1061 rv = 1;
1062 break;
1063 }
1064 }
1065 if (fsync(fdlist[d]) != 0) {
1066 fprintf(stderr, Name ": %s: cannot create backup file %s: %s\n",
1067 devname, backup_file, strerror(errno));
1068 rv = 1;
1069 break;
1070 }
1071 d++;
1072 }
1073
1074 /* lastly, check that the internal stripe cache is
1075 * large enough, or it won't work.
1076 */
1077
1078 cache = (nchunk < ochunk) ? ochunk : nchunk;
1079 cache = cache * 4 / 4096;
1080 if (cache < blocks / 8 / odisks + 16)
1081 /* Make it big enough to hold 'blocks' */
1082 cache = blocks / 8 / odisks + 16;
1083 if (sra->cache_size < cache)
1084 sysfs_set_num(sra, NULL, "stripe_cache_size",
1085 cache+1);
1086 /* Right, everything seems fine. Let's kick things off.
1087 * If only changing raid_disks, use ioctl, else use
1088 * sysfs.
1089 */
1090 if (ochunk == nchunk && olayout == nlayout) {
1091 array.raid_disks = ndisks;
1092 if (ioctl(fd, SET_ARRAY_INFO, &array) != 0) {
1093 int err = errno;
1094 rv = 1;
1095 fprintf(stderr, Name ": Cannot set device shape for %s: %s\n",
1096 devname, strerror(errno));
1097 if (ndisks < odisks &&
1098 get_linux_version() < 2006030)
1099 fprintf(stderr, Name ": linux 2.6.30 or later required\n");
1100 if (err == EBUSY &&
1101 (array.state & (1<<MD_SB_BITMAP_PRESENT)))
1102 fprintf(stderr, " Bitmap must be removed before shape can be changed\n");
1103
1104 break;
1105 }
1106 } else {
1107 /* set them all just in case some old 'new_*' value
1108 * persists from some earlier problem
1109 */
1110 int err = err; /* only used if rv==1, and always set if
1111 * rv==1, so initialisation not needed,
1112 * despite gcc warning
1113 */
1114 if (sysfs_set_num(sra, NULL, "chunk_size", nchunk) < 0)
1115 rv = 1, err = errno;
1116 if (!rv && sysfs_set_num(sra, NULL, "layout", nlayout) < 0)
1117 rv = 1, err = errno;
1118 if (!rv && sysfs_set_num(sra, NULL, "raid_disks", ndisks) < 0)
1119 rv = 1, err = errno;
1120 if (rv) {
1121 fprintf(stderr, Name ": Cannot set device shape for %s\n",
1122 devname);
1123 if (get_linux_version() < 2006030)
1124 fprintf(stderr, Name ": linux 2.6.30 or later required\n");
1125 if (err == EBUSY &&
1126 (array.state & (1<<MD_SB_BITMAP_PRESENT)))
1127 fprintf(stderr, " Bitmap must be removed before shape can be changed\n");
1128 break;
1129 }
1130 }
1131
1132 if (ndisks == 2 && odisks == 2) {
1133 /* No reshape is needed in this trivial case */
1134 rv = 0;
1135 break;
1136 }
1137
1138 /* set up the backup-super-block. This requires the
1139 * uuid from the array.
1140 */
1141 /* Find a superblock */
1142 for (sd = sra->devs; sd; sd = sd->next) {
1143 char *dn;
1144 int devfd;
1145 int ok;
1146 if (sd->disk.state & (1<<MD_DISK_FAULTY))
1147 continue;
1148 dn = map_dev(sd->disk.major, sd->disk.minor, 1);
1149 devfd = dev_open(dn, O_RDONLY);
1150 if (devfd < 0)
1151 continue;
1152 ok = st->ss->load_super(st, devfd, NULL);
1153 close(devfd);
1154 if (ok >= 0)
1155 break;
1156 }
1157 if (!sd) {
1158 fprintf(stderr, Name ": %s: Cannot find a superblock\n",
1159 devname);
1160 rv = 1;
1161 break;
1162 }
1163
1164 memset(&bsb, 0, 512);
1165 memcpy(bsb.magic, "md_backup_data-1", 16);
1166 st->ss->uuid_from_super(st, (int*)&bsb.set_uuid);
1167 bsb.mtime = __cpu_to_le64(time(0));
1168 bsb.devstart2 = blocks;
1169 stripes = blocks / (ochunk/512) / odata;
1170 /* Now we just need to kick off the reshape and watch, while
1171 * handling backups of the data...
1172 * This is all done by a forked background process.
1173 */
1174 switch(fork()) {
1175 case 0:
1176 close(fd);
1177 if (check_env("MDADM_GROW_VERIFY"))
1178 fd = open(devname, O_RDONLY | O_DIRECT);
1179 else
1180 fd = -1;
1181 mlockall(MCL_FUTURE);
1182
1183 if (odata < ndata)
1184 done = child_grow(fd, sra, stripes,
1185 fdlist, offsets,
1186 odisks, ochunk, array.level, olayout, odata,
1187 d - odisks, fdlist+odisks, offsets+odisks);
1188 else if (odata > ndata)
1189 done = child_shrink(fd, sra, stripes,
1190 fdlist, offsets,
1191 odisks, ochunk, array.level, olayout, odata,
1192 d - odisks, fdlist+odisks, offsets+odisks);
1193 else
1194 done = child_same_size(fd, sra, stripes,
1195 fdlist, offsets,
1196 0,
1197 odisks, ochunk, array.level, olayout, odata,
1198 d - odisks, fdlist+odisks, offsets+odisks);
1199 if (backup_file && done)
1200 unlink(backup_file);
1201 if (level != UnSet && level != array.level) {
1202 /* We need to wait for the reshape to finish
1203 * (which will have happened unless odata < ndata)
1204 * and then set the level
1205 */
1206
1207 c = map_num(pers, level);
1208 if (c == NULL)
1209 exit(0);/* not possible */
1210
1211 if (odata < ndata)
1212 wait_reshape(sra);
1213 err = sysfs_set_str(sra, NULL, "level", c);
1214 if (err)
1215 fprintf(stderr, Name ": %s: could not set level to %s\n",
1216 devname, c);
1217 }
1218 exit(0);
1219 case -1:
1220 fprintf(stderr, Name ": Cannot run child to monitor reshape: %s\n",
1221 strerror(errno));
1222 rv = 1;
1223 break;
1224 default:
1225 /* The child will take care of unfreezing the array */
1226 frozen = 0;
1227 break;
1228 }
1229 break;
1230
1231 }
1232
1233 release:
1234 if (rv && orig_level != UnSet && sra) {
1235 c = map_num(pers, orig_level);
1236 if (c && sysfs_set_str(sra, NULL, "level", c) == 0)
1237 fprintf(stderr, Name ": aborting level change\n");
1238 }
1239 if (sra)
1240 unfreeze_array(sra, frozen);
1241 return rv;
1242 }
1243
1244 /*
1245 * We run a child process in the background which performs the following
1246 * steps:
1247 * - wait for resync to reach a certain point
1248 * - suspend io to the following section
1249 * - backup that section
1250 * - allow resync to proceed further
1251 * - resume io
1252 * - discard the backup.
1253 *
1254 * When are combined in slightly different ways in the three cases.
1255 * Grow:
1256 * - suspend/backup/allow/wait/resume/discard
1257 * Shrink:
1258 * - allow/wait/suspend/backup/allow/wait/resume/discard
1259 * same-size:
1260 * - wait/resume/discard/suspend/backup/allow
1261 *
1262 * suspend/backup/allow always come together
1263 * wait/resume/discard do too.
1264 * For the same-size case we have two backups to improve flow.
1265 *
1266 */
1267
1268 /* FIXME return status is never checked */
1269 int grow_backup(struct mdinfo *sra,
1270 unsigned long long offset, /* per device */
1271 unsigned long stripes, /* per device */
1272 int *sources, unsigned long long *offsets,
1273 int disks, int chunk, int level, int layout,
1274 int dests, int *destfd, unsigned long long *destoffsets,
1275 int part, int *degraded,
1276 char *buf)
1277 {
1278 /* Backup 'blocks' sectors at 'offset' on each device of the array,
1279 * to storage 'destfd' (offset 'destoffsets'), after first
1280 * suspending IO. Then allow resync to continue
1281 * over the suspended section.
1282 * Use part 'part' of the backup-super-block.
1283 */
1284 int odata = disks;
1285 int rv = 0;
1286 int i;
1287 unsigned long long ll;
1288 int new_degraded;
1289 //printf("offset %llu\n", offset);
1290 if (level >= 4)
1291 odata--;
1292 if (level == 6)
1293 odata--;
1294 sysfs_set_num(sra, NULL, "suspend_hi", (offset + stripes * (chunk/512)) * odata);
1295 /* Check that array hasn't become degraded, else we might backup the wrong data */
1296 if (sysfs_get_ll(sra, NULL, "degraded", &ll) < 0)
1297 return -1; /* FIXME this error is ignored */
1298 new_degraded = (int)ll;
1299 if (new_degraded != *degraded) {
1300 /* check each device to ensure it is still working */
1301 struct mdinfo *sd;
1302 for (sd = sra->devs ; sd ; sd = sd->next) {
1303 if (sd->disk.state & (1<<MD_DISK_FAULTY))
1304 continue;
1305 if (sd->disk.state & (1<<MD_DISK_SYNC)) {
1306 char sbuf[20];
1307 if (sysfs_get_str(sra, sd, "state", sbuf, 20) < 0 ||
1308 strstr(sbuf, "faulty") ||
1309 strstr(sbuf, "in_sync") == NULL) {
1310 /* this device is dead */
1311 sd->disk.state = (1<<MD_DISK_FAULTY);
1312 if (sd->disk.raid_disk >= 0 &&
1313 sources[sd->disk.raid_disk] >= 0) {
1314 close(sources[sd->disk.raid_disk]);
1315 sources[sd->disk.raid_disk] = -1;
1316 }
1317 }
1318 }
1319 }
1320 *degraded = new_degraded;
1321 }
1322 if (part) {
1323 bsb.arraystart2 = __cpu_to_le64(offset * odata);
1324 bsb.length2 = __cpu_to_le64(stripes * (chunk/512) * odata);
1325 } else {
1326 bsb.arraystart = __cpu_to_le64(offset * odata);
1327 bsb.length = __cpu_to_le64(stripes * (chunk/512) * odata);
1328 }
1329 if (part)
1330 bsb.magic[15] = '2';
1331 for (i = 0; i < dests; i++)
1332 if (part)
1333 lseek64(destfd[i], destoffsets[i] + __le64_to_cpu(bsb.devstart2)*512, 0);
1334 else
1335 lseek64(destfd[i], destoffsets[i], 0);
1336
1337 rv = save_stripes(sources, offsets,
1338 disks, chunk, level, layout,
1339 dests, destfd,
1340 offset*512*odata, stripes * chunk * odata,
1341 buf);
1342
1343 if (rv)
1344 return rv;
1345 bsb.mtime = __cpu_to_le64(time(0));
1346 for (i = 0; i < dests; i++) {
1347 bsb.devstart = __cpu_to_le64(destoffsets[i]/512);
1348
1349 bsb.sb_csum = bsb_csum((char*)&bsb, ((char*)&bsb.sb_csum)-((char*)&bsb));
1350 if (memcmp(bsb.magic, "md_backup_data-2", 16) == 0)
1351 bsb.sb_csum2 = bsb_csum((char*)&bsb,
1352 ((char*)&bsb.sb_csum2)-((char*)&bsb));
1353
1354 rv = -1;
1355 if ((unsigned long long)lseek64(destfd[i], destoffsets[i] - 4096, 0)
1356 != destoffsets[i] - 4096)
1357 break;
1358 if (write(destfd[i], &bsb, 512) != 512)
1359 break;
1360 if (destoffsets[i] > 4096) {
1361 if ((unsigned long long)lseek64(destfd[i], destoffsets[i]+stripes*chunk*odata, 0) !=
1362 destoffsets[i]+stripes*chunk*odata)
1363 break;
1364 if (write(destfd[i], &bsb, 512) != 512)
1365 break;
1366 }
1367 fsync(destfd[i]);
1368 rv = 0;
1369 }
1370
1371 return rv;
1372 }
1373
1374 /* in 2.6.30, the value reported by sync_completed can be
1375 * less that it should be by one stripe.
1376 * This only happens when reshape hits sync_max and pauses.
1377 * So allow wait_backup to either extent sync_max further
1378 * than strictly necessary, or return before the
1379 * sync has got quite as far as we would really like.
1380 * This is what 'blocks2' is for.
1381 * The various caller give appropriate values so that
1382 * every works.
1383 */
1384 /* FIXME return value is often ignored */
1385 int wait_backup(struct mdinfo *sra,
1386 unsigned long long offset, /* per device */
1387 unsigned long long blocks, /* per device */
1388 unsigned long long blocks2, /* per device - hack */
1389 int dests, int *destfd, unsigned long long *destoffsets,
1390 int part)
1391 {
1392 /* Wait for resync to pass the section that was backed up
1393 * then erase the backup and allow IO
1394 */
1395 int fd = sysfs_get_fd(sra, NULL, "sync_completed");
1396 unsigned long long completed;
1397 int i;
1398 int rv;
1399
1400 if (fd < 0)
1401 return -1;
1402 sysfs_set_num(sra, NULL, "sync_max", offset + blocks + blocks2);
1403 if (offset == 0)
1404 sysfs_set_str(sra, NULL, "sync_action", "reshape");
1405 do {
1406 char action[20];
1407 fd_set rfds;
1408 FD_ZERO(&rfds);
1409 FD_SET(fd, &rfds);
1410 select(fd+1, NULL, NULL, &rfds, NULL);
1411 if (sysfs_fd_get_ll(fd, &completed) < 0) {
1412 close(fd);
1413 return -1;
1414 }
1415 if (sysfs_get_str(sra, NULL, "sync_action",
1416 action, 20) > 0 &&
1417 strncmp(action, "reshape", 7) != 0)
1418 break;
1419 } while (completed < offset + blocks);
1420 close(fd);
1421
1422 if (part) {
1423 bsb.arraystart2 = __cpu_to_le64(0);
1424 bsb.length2 = __cpu_to_le64(0);
1425 } else {
1426 bsb.arraystart = __cpu_to_le64(0);
1427 bsb.length = __cpu_to_le64(0);
1428 }
1429 bsb.mtime = __cpu_to_le64(time(0));
1430 rv = 0;
1431 for (i = 0; i < dests; i++) {
1432 bsb.devstart = __cpu_to_le64(destoffsets[i]/512);
1433 bsb.sb_csum = bsb_csum((char*)&bsb, ((char*)&bsb.sb_csum)-((char*)&bsb));
1434 if (memcmp(bsb.magic, "md_backup_data-2", 16) == 0)
1435 bsb.sb_csum2 = bsb_csum((char*)&bsb,
1436 ((char*)&bsb.sb_csum2)-((char*)&bsb));
1437 if ((unsigned long long)lseek64(destfd[i], destoffsets[i]-4096, 0) !=
1438 destoffsets[i]-4096)
1439 rv = -1;
1440 if (rv == 0 &&
1441 write(destfd[i], &bsb, 512) != 512)
1442 rv = -1;
1443 fsync(destfd[i]);
1444 }
1445 return rv;
1446 }
1447
1448 static void fail(char *msg)
1449 {
1450 int rv;
1451 rv = (write(2, msg, strlen(msg)) != (int)strlen(msg));
1452 rv |= (write(2, "\n", 1) != 1);
1453 exit(rv ? 1 : 2);
1454 }
1455
1456 static char *abuf, *bbuf;
1457 static unsigned long long abuflen;
1458 static void validate(int afd, int bfd, unsigned long long offset)
1459 {
1460 /* check that the data in the backup against the array.
1461 * This is only used for regression testing and should not
1462 * be used while the array is active
1463 */
1464 if (afd < 0)
1465 return;
1466 lseek64(bfd, offset - 4096, 0);
1467 if (read(bfd, &bsb2, 512) != 512)
1468 fail("cannot read bsb");
1469 if (bsb2.sb_csum != bsb_csum((char*)&bsb2,
1470 ((char*)&bsb2.sb_csum)-((char*)&bsb2)))
1471 fail("first csum bad");
1472 if (memcmp(bsb2.magic, "md_backup_data", 14) != 0)
1473 fail("magic is bad");
1474 if (memcmp(bsb2.magic, "md_backup_data-2", 16) == 0 &&
1475 bsb2.sb_csum2 != bsb_csum((char*)&bsb2,
1476 ((char*)&bsb2.sb_csum2)-((char*)&bsb2)))
1477 fail("second csum bad");
1478
1479 if (__le64_to_cpu(bsb2.devstart)*512 != offset)
1480 fail("devstart is wrong");
1481
1482 if (bsb2.length) {
1483 unsigned long long len = __le64_to_cpu(bsb2.length)*512;
1484
1485 if (abuflen < len) {
1486 free(abuf);
1487 free(bbuf);
1488 abuflen = len;
1489 if (posix_memalign((void**)&abuf, 4096, abuflen) ||
1490 posix_memalign((void**)&bbuf, 4096, abuflen)) {
1491 abuflen = 0;
1492 /* just stop validating on mem-alloc failure */
1493 return;
1494 }
1495 }
1496
1497 lseek64(bfd, offset, 0);
1498 if ((unsigned long long)read(bfd, bbuf, len) != len) {
1499 //printf("len %llu\n", len);
1500 fail("read first backup failed");
1501 }
1502 lseek64(afd, __le64_to_cpu(bsb2.arraystart)*512, 0);
1503 if ((unsigned long long)read(afd, abuf, len) != len)
1504 fail("read first from array failed");
1505 if (memcmp(bbuf, abuf, len) != 0) {
1506 #if 0
1507 int i;
1508 printf("offset=%llu len=%llu\n",
1509 (unsigned long long)__le64_to_cpu(bsb2.arraystart)*512, len);
1510 for (i=0; i<len; i++)
1511 if (bbuf[i] != abuf[i]) {
1512 printf("first diff byte %d\n", i);
1513 break;
1514 }
1515 #endif
1516 fail("data1 compare failed");
1517 }
1518 }
1519 if (bsb2.length2) {
1520 unsigned long long len = __le64_to_cpu(bsb2.length2)*512;
1521
1522 if (abuflen < len) {
1523 free(abuf);
1524 free(bbuf);
1525 abuflen = len;
1526 abuf = malloc(abuflen);
1527 bbuf = malloc(abuflen);
1528 }
1529
1530 lseek64(bfd, offset+__le64_to_cpu(bsb2.devstart2)*512, 0);
1531 if ((unsigned long long)read(bfd, bbuf, len) != len)
1532 fail("read second backup failed");
1533 lseek64(afd, __le64_to_cpu(bsb2.arraystart2)*512, 0);
1534 if ((unsigned long long)read(afd, abuf, len) != len)
1535 fail("read second from array failed");
1536 if (memcmp(bbuf, abuf, len) != 0)
1537 fail("data2 compare failed");
1538 }
1539 }
1540
1541 static int child_grow(int afd, struct mdinfo *sra, unsigned long stripes,
1542 int *fds, unsigned long long *offsets,
1543 int disks, int chunk, int level, int layout, int data,
1544 int dests, int *destfd, unsigned long long *destoffsets)
1545 {
1546 char *buf;
1547 int degraded = 0;
1548
1549 if (posix_memalign((void**)&buf, 4096, disks * chunk))
1550 /* Don't start the 'reshape' */
1551 return 0;
1552 sysfs_set_num(sra, NULL, "suspend_hi", 0);
1553 sysfs_set_num(sra, NULL, "suspend_lo", 0);
1554 grow_backup(sra, 0, stripes,
1555 fds, offsets, disks, chunk, level, layout,
1556 dests, destfd, destoffsets,
1557 0, &degraded, buf);
1558 validate(afd, destfd[0], destoffsets[0]);
1559 wait_backup(sra, 0, stripes * (chunk / 512), stripes * (chunk / 512),
1560 dests, destfd, destoffsets,
1561 0);
1562 sysfs_set_num(sra, NULL, "suspend_lo", (stripes * (chunk/512)) * data);
1563 free(buf);
1564 /* FIXME this should probably be numeric */
1565 sysfs_set_str(sra, NULL, "sync_max", "max");
1566 return 1;
1567 }
1568
1569 static int child_shrink(int afd, struct mdinfo *sra, unsigned long stripes,
1570 int *fds, unsigned long long *offsets,
1571 int disks, int chunk, int level, int layout, int data,
1572 int dests, int *destfd, unsigned long long *destoffsets)
1573 {
1574 char *buf;
1575 unsigned long long start;
1576 int rv;
1577 int degraded = 0;
1578
1579 if (posix_memalign((void**)&buf, 4096, disks * chunk))
1580 return 0;
1581 start = sra->component_size - stripes * (chunk/512);
1582 sysfs_set_num(sra, NULL, "sync_max", start);
1583 sysfs_set_str(sra, NULL, "sync_action", "reshape");
1584 sysfs_set_num(sra, NULL, "suspend_lo", 0);
1585 sysfs_set_num(sra, NULL, "suspend_hi", 0);
1586 rv = wait_backup(sra, 0, start - stripes * (chunk/512), stripes * (chunk/512),
1587 dests, destfd, destoffsets, 0);
1588 if (rv < 0)
1589 return 0;
1590 grow_backup(sra, 0, stripes,
1591 fds, offsets,
1592 disks, chunk, level, layout,
1593 dests, destfd, destoffsets,
1594 0, &degraded, buf);
1595 validate(afd, destfd[0], destoffsets[0]);
1596 wait_backup(sra, start, stripes*(chunk/512), 0,
1597 dests, destfd, destoffsets, 0);
1598 sysfs_set_num(sra, NULL, "suspend_lo", (stripes * (chunk/512)) * data);
1599 free(buf);
1600 /* FIXME this should probably be numeric */
1601 sysfs_set_str(sra, NULL, "sync_max", "max");
1602 return 1;
1603 }
1604
1605 static int child_same_size(int afd, struct mdinfo *sra, unsigned long stripes,
1606 int *fds, unsigned long long *offsets,
1607 unsigned long long start,
1608 int disks, int chunk, int level, int layout, int data,
1609 int dests, int *destfd, unsigned long long *destoffsets)
1610 {
1611 unsigned long long size;
1612 unsigned long tailstripes = stripes;
1613 int part;
1614 char *buf;
1615 unsigned long long speed;
1616 int degraded = 0;
1617
1618
1619 if (posix_memalign((void**)&buf, 4096, disks * chunk))
1620 return 0;
1621
1622 sysfs_set_num(sra, NULL, "suspend_lo", 0);
1623 sysfs_set_num(sra, NULL, "suspend_hi", 0);
1624
1625 sysfs_get_ll(sra, NULL, "sync_speed_min", &speed);
1626 sysfs_set_num(sra, NULL, "sync_speed_min", 200000);
1627
1628 grow_backup(sra, start, stripes,
1629 fds, offsets,
1630 disks, chunk, level, layout,
1631 dests, destfd, destoffsets,
1632 0, &degraded, buf);
1633 grow_backup(sra, (start + stripes) * (chunk/512), stripes,
1634 fds, offsets,
1635 disks, chunk, level, layout,
1636 dests, destfd, destoffsets,
1637 1, &degraded, buf);
1638 validate(afd, destfd[0], destoffsets[0]);
1639 part = 0;
1640 start += stripes * 2; /* where to read next */
1641 size = sra->component_size / (chunk/512);
1642 while (start < size) {
1643 if (wait_backup(sra, (start-stripes*2)*(chunk/512),
1644 stripes*(chunk/512), 0,
1645 dests, destfd, destoffsets,
1646 part) < 0)
1647 return 0;
1648 sysfs_set_num(sra, NULL, "suspend_lo", start*(chunk/512) * data);
1649 if (start + stripes > size)
1650 tailstripes = (size - start);
1651
1652 grow_backup(sra, start*(chunk/512), tailstripes,
1653 fds, offsets,
1654 disks, chunk, level, layout,
1655 dests, destfd, destoffsets,
1656 part, &degraded, buf);
1657 start += stripes;
1658 part = 1 - part;
1659 validate(afd, destfd[0], destoffsets[0]);
1660 }
1661 if (wait_backup(sra, (start-stripes*2) * (chunk/512), stripes * (chunk/512), 0,
1662 dests, destfd, destoffsets,
1663 part) < 0)
1664 return 0;
1665 sysfs_set_num(sra, NULL, "suspend_lo", ((start-stripes)*(chunk/512)) * data);
1666 wait_backup(sra, (start-stripes) * (chunk/512), tailstripes * (chunk/512), 0,
1667 dests, destfd, destoffsets,
1668 1-part);
1669 sysfs_set_num(sra, NULL, "suspend_lo", (size*(chunk/512)) * data);
1670 sysfs_set_num(sra, NULL, "sync_speed_min", speed);
1671 free(buf);
1672 return 1;
1673 }
1674
1675 /*
1676 * If any spare contains md_back_data-1 which is recent wrt mtime,
1677 * write that data into the array and update the super blocks with
1678 * the new reshape_progress
1679 */
1680 int Grow_restart(struct supertype *st, struct mdinfo *info, int *fdlist, int cnt,
1681 char *backup_file, int verbose)
1682 {
1683 int i, j;
1684 int old_disks;
1685 unsigned long long *offsets;
1686 unsigned long long nstripe, ostripe;
1687 int ndata, odata;
1688
1689 if (info->new_level != info->array.level)
1690 return 1; /* Cannot handle level changes (they are instantaneous) */
1691
1692 odata = info->array.raid_disks - info->delta_disks - 1;
1693 if (info->array.level == 6) odata--; /* number of data disks */
1694 ndata = info->array.raid_disks - 1;
1695 if (info->new_level == 6) ndata--;
1696
1697 old_disks = info->array.raid_disks - info->delta_disks;
1698
1699 if (info->delta_disks <= 0)
1700 /* Didn't grow, so the backup file must have
1701 * been used
1702 */
1703 old_disks = cnt;
1704 for (i=old_disks-(backup_file?1:0); i<cnt; i++) {
1705 struct mdinfo dinfo;
1706 int fd;
1707 int bsbsize;
1708 char *devname, namebuf[20];
1709
1710 /* This was a spare and may have some saved data on it.
1711 * Load the superblock, find and load the
1712 * backup_super_block.
1713 * If either fail, go on to next device.
1714 * If the backup contains no new info, just return
1715 * else restore data and update all superblocks
1716 */
1717 if (i == old_disks-1) {
1718 fd = open(backup_file, O_RDONLY);
1719 if (fd<0) {
1720 fprintf(stderr, Name ": backup file %s inaccessible: %s\n",
1721 backup_file, strerror(errno));
1722 continue;
1723 }
1724 devname = backup_file;
1725 } else {
1726 fd = fdlist[i];
1727 if (fd < 0)
1728 continue;
1729 if (st->ss->load_super(st, fd, NULL))
1730 continue;
1731
1732 st->ss->getinfo_super(st, &dinfo);
1733 st->ss->free_super(st);
1734
1735 if (lseek64(fd,
1736 (dinfo.data_offset + dinfo.component_size - 8) <<9,
1737 0) < 0) {
1738 fprintf(stderr, Name ": Cannot seek on device %d\n", i);
1739 continue; /* Cannot seek */
1740 }
1741 sprintf(namebuf, "device-%d", i);
1742 devname = namebuf;
1743 }
1744 if (read(fd, &bsb, sizeof(bsb)) != sizeof(bsb)) {
1745 if (verbose)
1746 fprintf(stderr, Name ": Cannot read from %s\n", devname);
1747 continue; /* Cannot read */
1748 }
1749 if (memcmp(bsb.magic, "md_backup_data-1", 16) != 0 &&
1750 memcmp(bsb.magic, "md_backup_data-2", 16) != 0) {
1751 if (verbose)
1752 fprintf(stderr, Name ": No backup metadata on %s\n", devname);
1753 continue;
1754 }
1755 if (bsb.sb_csum != bsb_csum((char*)&bsb, ((char*)&bsb.sb_csum)-((char*)&bsb))) {
1756 if (verbose)
1757 fprintf(stderr, Name ": Bad backup-metadata checksum on %s\n", devname);
1758 continue; /* bad checksum */
1759 }
1760 if (memcmp(bsb.magic, "md_backup_data-2", 16) == 0 &&
1761 bsb.sb_csum2 != bsb_csum((char*)&bsb, ((char*)&bsb.sb_csum2)-((char*)&bsb))) {
1762 if (verbose)
1763 fprintf(stderr, Name ": Bad backup-metadata checksum2 on %s\n", devname);
1764 continue; /* Bad second checksum */
1765 }
1766 if (memcmp(bsb.set_uuid,info->uuid, 16) != 0) {
1767 if (verbose)
1768 fprintf(stderr, Name ": Wrong uuid on backup-metadata on %s\n", devname);
1769 continue; /* Wrong uuid */
1770 }
1771
1772 /* array utime and backup-mtime should be updated at much the same time, but it seems that
1773 * sometimes they aren't... So allow considerable flexability in matching, and allow
1774 * this test to be overridden by an environment variable.
1775 */
1776 if (info->array.utime > (int)__le64_to_cpu(bsb.mtime) + 2*60*60 ||
1777 info->array.utime < (int)__le64_to_cpu(bsb.mtime) - 10*60) {
1778 if (check_env("MDADM_GROW_ALLOW_OLD")) {
1779 fprintf(stderr, Name ": accepting backup with timestamp %lu "
1780 "for array with timestamp %lu\n",
1781 (unsigned long)__le64_to_cpu(bsb.mtime),
1782 (unsigned long)info->array.utime);
1783 } else {
1784 if (verbose)
1785 fprintf(stderr, Name ": too-old timestamp on "
1786 "backup-metadata on %s\n", devname);
1787 continue; /* time stamp is too bad */
1788 }
1789 }
1790
1791 if (bsb.magic[15] == '1') {
1792 if (info->delta_disks >= 0) {
1793 /* reshape_progress is increasing */
1794 if (__le64_to_cpu(bsb.arraystart) + __le64_to_cpu(bsb.length) <
1795 info->reshape_progress) {
1796 nonew:
1797 if (verbose)
1798 fprintf(stderr, Name ": backup-metadata found on %s but is not needed\n", devname);
1799 continue; /* No new data here */
1800 }
1801 } else {
1802 /* reshape_progress is decreasing */
1803 if (__le64_to_cpu(bsb.arraystart) >=
1804 info->reshape_progress)
1805 goto nonew; /* No new data here */
1806 }
1807 } else {
1808 if (info->delta_disks >= 0) {
1809 /* reshape_progress is increasing */
1810 if (__le64_to_cpu(bsb.arraystart) + __le64_to_cpu(bsb.length) <
1811 info->reshape_progress &&
1812 __le64_to_cpu(bsb.arraystart2) + __le64_to_cpu(bsb.length2) <
1813 info->reshape_progress)
1814 goto nonew; /* No new data here */
1815 } else {
1816 /* reshape_progress is decreasing */
1817 if (__le64_to_cpu(bsb.arraystart) >=
1818 info->reshape_progress &&
1819 __le64_to_cpu(bsb.arraystart2) >=
1820 info->reshape_progress)
1821 goto nonew; /* No new data here */
1822 }
1823 }
1824 if (lseek64(fd, __le64_to_cpu(bsb.devstart)*512, 0)< 0) {
1825 second_fail:
1826 if (verbose)
1827 fprintf(stderr, Name ": Failed to verify secondary backup-metadata block on %s\n",
1828 devname);
1829 continue; /* Cannot seek */
1830 }
1831 /* There should be a duplicate backup superblock 4k before here */
1832 if (lseek64(fd, -4096, 1) < 0 ||
1833 read(fd, &bsb2, sizeof(bsb2)) != sizeof(bsb2))
1834 goto second_fail; /* Cannot find leading superblock */
1835 if (bsb.magic[15] == '1')
1836 bsbsize = offsetof(struct mdp_backup_super, pad1);
1837 else
1838 bsbsize = offsetof(struct mdp_backup_super, pad);
1839 if (memcmp(&bsb2, &bsb, bsbsize) != 0)
1840 goto second_fail; /* Cannot find leading superblock */
1841
1842 /* Now need the data offsets for all devices. */
1843 offsets = malloc(sizeof(*offsets)*info->array.raid_disks);
1844 for(j=0; j<info->array.raid_disks; j++) {
1845 if (fdlist[j] < 0)
1846 continue;
1847 if (st->ss->load_super(st, fdlist[j], NULL))
1848 /* FIXME should be this be an error */
1849 continue;
1850 st->ss->getinfo_super(st, &dinfo);
1851 st->ss->free_super(st);
1852 offsets[j] = dinfo.data_offset * 512;
1853 }
1854 printf(Name ": restoring critical section\n");
1855
1856 if (restore_stripes(fdlist, offsets,
1857 info->array.raid_disks,
1858 info->new_chunk,
1859 info->new_level,
1860 info->new_layout,
1861 fd, __le64_to_cpu(bsb.devstart)*512,
1862 __le64_to_cpu(bsb.arraystart)*512,
1863 __le64_to_cpu(bsb.length)*512)) {
1864 /* didn't succeed, so giveup */
1865 if (verbose)
1866 fprintf(stderr, Name ": Error restoring backup from %s\n",
1867 devname);
1868 return 1;
1869 }
1870
1871 if (bsb.magic[15] == '2' &&
1872 restore_stripes(fdlist, offsets,
1873 info->array.raid_disks,
1874 info->new_chunk,
1875 info->new_level,
1876 info->new_layout,
1877 fd, __le64_to_cpu(bsb.devstart)*512 +
1878 __le64_to_cpu(bsb.devstart2)*512,
1879 __le64_to_cpu(bsb.arraystart2)*512,
1880 __le64_to_cpu(bsb.length2)*512)) {
1881 /* didn't succeed, so giveup */
1882 if (verbose)
1883 fprintf(stderr, Name ": Error restoring second backup from %s\n",
1884 devname);
1885 return 1;
1886 }
1887
1888
1889 /* Ok, so the data is restored. Let's update those superblocks. */
1890
1891 if (info->delta_disks >= 0) {
1892 info->reshape_progress = __le64_to_cpu(bsb.arraystart) +
1893 __le64_to_cpu(bsb.length);
1894 if (bsb.magic[15] == '2') {
1895 unsigned long long p2 = __le64_to_cpu(bsb.arraystart2) +
1896 __le64_to_cpu(bsb.length2);
1897 if (p2 > info->reshape_progress)
1898 info->reshape_progress = p2;
1899 }
1900 } else {
1901 info->reshape_progress = __le64_to_cpu(bsb.arraystart);
1902 if (bsb.magic[15] == '2') {
1903 unsigned long long p2 = __le64_to_cpu(bsb.arraystart2);
1904 if (p2 < info->reshape_progress)
1905 info->reshape_progress = p2;
1906 }
1907 }
1908 for (j=0; j<info->array.raid_disks; j++) {
1909 if (fdlist[j] < 0) continue;
1910 if (st->ss->load_super(st, fdlist[j], NULL))
1911 continue;
1912 st->ss->getinfo_super(st, &dinfo);
1913 dinfo.reshape_progress = info->reshape_progress;
1914 st->ss->update_super(st, &dinfo,
1915 "_reshape_progress",
1916 NULL,0, 0, NULL);
1917 st->ss->store_super(st, fdlist[j]);
1918 st->ss->free_super(st);
1919 }
1920 return 0;
1921 }
1922 /* Didn't find any backup data, try to see if any
1923 * was needed.
1924 */
1925 if (info->delta_disks < 0) {
1926 /* When shrinking, the critical section is at the end.
1927 * So see if we are before the critical section.
1928 */
1929 unsigned long long first_block;
1930 nstripe = ostripe = 0;
1931 first_block = 0;
1932 while (ostripe >= nstripe) {
1933 ostripe += info->array.chunk_size / 512;
1934 first_block = ostripe * odata;
1935 nstripe = first_block / ndata / (info->new_chunk/512) *
1936 (info->new_chunk/512);
1937 }
1938
1939 if (info->reshape_progress >= first_block)
1940 return 0;
1941 }
1942 if (info->delta_disks > 0) {
1943 /* See if we are beyond the critical section. */
1944 unsigned long long last_block;
1945 nstripe = ostripe = 0;
1946 last_block = 0;
1947 while (nstripe >= ostripe) {
1948 nstripe += info->new_chunk / 512;
1949 last_block = nstripe * ndata;
1950 ostripe = last_block / odata / (info->array.chunk_size/512) *
1951 (info->array.chunk_size/512);
1952 }
1953
1954 if (info->reshape_progress >= last_block)
1955 return 0;
1956 }
1957 /* needed to recover critical section! */
1958 if (verbose)
1959 fprintf(stderr, Name ": Failed to find backup of critical section\n");
1960 return 1;
1961 }
1962
1963 int Grow_continue(int mdfd, struct supertype *st, struct mdinfo *info,
1964 char *backup_file)
1965 {
1966 /* Array is assembled and ready to be started, but
1967 * monitoring is probably required.
1968 * So:
1969 * - start read-only
1970 * - set upper bound for resync
1971 * - initialise the 'suspend' boundaries
1972 * - switch to read-write
1973 * - fork and continue monitoring
1974 */
1975 int err;
1976 int backup_list[1];
1977 unsigned long long backup_offsets[1];
1978 int odisks, ndisks, ochunk, nchunk,odata,ndata;
1979 unsigned long a,b,blocks,stripes;
1980 int backup_fd;
1981 int *fds;
1982 unsigned long long *offsets;
1983 int d;
1984 struct mdinfo *sra, *sd;
1985 int rv;
1986 unsigned long cache;
1987 int done = 0;
1988
1989 err = sysfs_set_str(info, NULL, "array_state", "readonly");
1990 if (err)
1991 return err;
1992
1993 /* make sure reshape doesn't progress until we are ready */
1994 sysfs_set_str(info, NULL, "sync_max", "0");
1995 sysfs_set_str(info, NULL, "array_state", "active"); /* FIXME or clean */
1996
1997 sra = sysfs_read(-1, devname2devnum(info->sys_name),
1998 GET_COMPONENT|GET_DEVS|GET_OFFSET|GET_STATE|
1999 GET_CACHE);
2000 if (!sra)
2001 return 1;
2002
2003 /* ndisks is not growing, so raid_disks is old and +delta is new */
2004 odisks = info->array.raid_disks;
2005 ndisks = odisks + info->delta_disks;
2006 odata = odisks - 1;
2007 ndata = ndisks - 1;
2008 if (info->array.level == 6) {
2009 odata--;
2010 ndata--;
2011 }
2012 ochunk = info->array.chunk_size;
2013 nchunk = info->new_chunk;
2014
2015 a = (ochunk/512) * odata;
2016 b = (nchunk/512) * ndata;
2017 /* Find GCD */
2018 while (a != b) {
2019 if (a < b)
2020 b -= a;
2021 if (b < a)
2022 a -= b;
2023 }
2024 /* LCM == product / GCD */
2025 blocks = (ochunk/512) * (nchunk/512) * odata * ndata / a;
2026
2027 if (ndata == odata)
2028 while (blocks * 32 < sra->component_size &&
2029 blocks < 16*1024*2)
2030 blocks *= 2;
2031 stripes = blocks / (info->array.chunk_size/512) / odata;
2032
2033 /* check that the internal stripe cache is
2034 * large enough, or it won't work.
2035 */
2036 cache = (nchunk < ochunk) ? ochunk : nchunk;
2037 cache = cache * 4 / 4096;
2038 if (cache < blocks / 8 / odisks + 16)
2039 /* Make it big enough to hold 'blocks' */
2040 cache = blocks / 8 / odisks + 16;
2041 if (sra->cache_size < cache)
2042 sysfs_set_num(sra, NULL, "stripe_cache_size",
2043 cache+1);
2044
2045 memset(&bsb, 0, 512);
2046 memcpy(bsb.magic, "md_backup_data-1", 16);
2047 memcpy(&bsb.set_uuid, info->uuid, 16);
2048 bsb.mtime = __cpu_to_le64(time(0));
2049 bsb.devstart2 = blocks;
2050
2051 backup_fd = open(backup_file, O_RDWR|O_CREAT, S_IRUSR | S_IWUSR);
2052 backup_list[0] = backup_fd;
2053 backup_offsets[0] = 8 * 512;
2054 fds = malloc(odisks * sizeof(fds[0]));
2055 offsets = malloc(odisks * sizeof(offsets[0]));
2056 for (d=0; d<odisks; d++)
2057 fds[d] = -1;
2058
2059 for (sd = sra->devs; sd; sd = sd->next) {
2060 if (sd->disk.state & (1<<MD_DISK_FAULTY))
2061 continue;
2062 if (sd->disk.state & (1<<MD_DISK_SYNC)) {
2063 char *dn = map_dev(sd->disk.major,
2064 sd->disk.minor, 1);
2065 fds[sd->disk.raid_disk]
2066 = dev_open(dn, O_RDONLY);
2067 offsets[sd->disk.raid_disk] = sd->data_offset*512;
2068 if (fds[sd->disk.raid_disk] < 0) {
2069 fprintf(stderr, Name ": %s: cannot open component %s\n",
2070 info->sys_name, dn?dn:"-unknown-");
2071 rv = 1;
2072 goto release;
2073 }
2074 free(dn);
2075 }
2076 }
2077
2078 switch(fork()) {
2079 case 0:
2080 close(mdfd);
2081 mlockall(MCL_FUTURE);
2082 if (info->delta_disks < 0)
2083 done = child_shrink(-1, info, stripes,
2084 fds, offsets,
2085 info->array.raid_disks,
2086 info->array.chunk_size,
2087 info->array.level, info->array.layout,
2088 odata,
2089 1, backup_list, backup_offsets);
2090 else if (info->delta_disks == 0) {
2091 /* The 'start' is a per-device stripe number.
2092 * reshape_progress is a per-array sector number.
2093 * So divide by ndata * chunk_size
2094 */
2095 unsigned long long start = info->reshape_progress / ndata;
2096 start /= (info->array.chunk_size/512);
2097 done = child_same_size(-1, info, stripes,
2098 fds, offsets,
2099 start,
2100 info->array.raid_disks,
2101 info->array.chunk_size,
2102 info->array.level, info->array.layout,
2103 odata,
2104 1, backup_list, backup_offsets);
2105 }
2106 if (backup_file && done)
2107 unlink(backup_file);
2108 /* FIXME should I intuit a level change */
2109 exit(0);
2110 case -1:
2111 fprintf(stderr, Name ": Cannot run child to continue monitoring reshape: %s\n",
2112 strerror(errno));
2113 return 1;
2114 default:
2115 break;
2116 }
2117 release:
2118 return 0;
2119 }
2120
2121