]> git.ipfire.org Git - thirdparty/mdadm.git/blob - Incremental.c
Factor out add-disk code
[thirdparty/mdadm.git] / Incremental.c
1 /*
2 * Incremental.c - support --incremental. Part of:
3 * mdadm - manage Linux "md" devices aka RAID arrays.
4 *
5 * Copyright (C) 2006 Neil Brown <neilb@suse.de>
6 *
7 *
8 * This program is free software; you can redistribute it and/or modify
9 * it under the terms of the GNU General Public License as published by
10 * the Free Software Foundation; either version 2 of the License, or
11 * (at your option) any later version.
12 *
13 * This program is distributed in the hope that it will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 * GNU General Public License for more details.
17 *
18 * You should have received a copy of the GNU General Public License
19 * along with this program; if not, write to the Free Software
20 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
21 *
22 * Author: Neil Brown
23 * Email: <neilb@suse.de>
24 * Paper: Neil Brown
25 * Novell Inc
26 * GPO Box Q1283
27 * QVB Post Office, NSW 1230
28 * Australia
29 */
30
31 #include "mdadm.h"
32
33 static int count_active(struct supertype *st, int mdfd, char **availp,
34 struct mdinfo *info);
35 static void find_reject(int mdfd, struct supertype *st, struct mdinfo *sra,
36 int number, __u64 events, int verbose,
37 char *array_name);
38
39 int Incremental(char *devname, int verbose, int runstop,
40 struct supertype *st, char *homehost, int autof)
41 {
42 /* Add this device to an array, creating the array if necessary
43 * and starting the array if sensible or - if runstop>0 - if possible.
44 *
45 * This has several steps:
46 *
47 * 1/ Check if device is permitted by mdadm.conf, reject if not.
48 * 2/ Find metadata, reject if none appropriate (check
49 * version/name from args)
50 * 3/ Check if there is a match in mdadm.conf
51 * 3a/ if not, check for homehost match. If no match, reject.
52 * 4/ Determine device number.
53 * - If in mdadm.conf with std name, use that
54 * - UUID in /var/run/mdadm.map use that
55 * - If name is suggestive, use that. unless in use with different uuid.
56 * - Choose a free, high number.
57 * - Use a partitioned device unless strong suggestion not to.
58 * e.g. auto=md
59 * 5/ Find out if array already exists
60 * 5a/ if it does not
61 * - choose a name, from mdadm.conf or 'name' field in array.
62 * - create the array
63 * - add the device
64 * 5b/ if it does
65 * - check one drive in array to make sure metadata is a reasonably
66 * close match. Reject if not (e.g. different type)
67 * - add the device
68 * 6/ Make sure /var/run/mdadm.map contains this array.
69 * 7/ Is there enough devices to possibly start the array?
70 * 7a/ if not, finish with success.
71 * 7b/ if yes,
72 * - read all metadata and arrange devices like -A does
73 * - if number of OK devices match expected, or -R and there are enough,
74 * start the array (auto-readonly).
75 */
76 struct stat stb;
77 struct mdinfo info, info2;
78 struct mddev_ident_s *array_list, *match;
79 char chosen_name[1024];
80 int rv;
81 int devnum;
82 struct map_ent *mp, *map = NULL;
83 int dfd, mdfd;
84 char *avail;
85 int active_disks;
86
87
88 struct createinfo *ci = conf_get_create_info();
89
90 if (autof == 0)
91 autof = ci->autof;
92
93 /* 1/ Check if devices is permitted by mdadm.conf */
94
95 if (!conf_test_dev(devname)) {
96 if (verbose >= 0)
97 fprintf(stderr, Name
98 ": %s not permitted by mdadm.conf.\n",
99 devname);
100 return 1;
101 }
102
103 /* 2/ Find metadata, reject if none appropriate (check
104 * version/name from args) */
105
106 dfd = dev_open(devname, O_RDONLY|O_EXCL);
107 if (dfd < 0) {
108 if (verbose >= 0)
109 fprintf(stderr, Name ": cannot open %s: %s.\n",
110 devname, strerror(errno));
111 return 1;
112 }
113 if (fstat(dfd, &stb) < 0) {
114 if (verbose >= 0)
115 fprintf(stderr, Name ": fstat failed for %s: %s.\n",
116 devname, strerror(errno));
117 close(dfd);
118 return 1;
119 }
120 if ((stb.st_mode & S_IFMT) != S_IFBLK) {
121 if (verbose >= 0)
122 fprintf(stderr, Name ": %s is not a block device.\n",
123 devname);
124 close(dfd);
125 return 1;
126 }
127
128 if (st == NULL && (st = guess_super(dfd)) == NULL) {
129 if (verbose >= 0)
130 fprintf(stderr, Name
131 ": no recognisable superblock on %s.\n",
132 devname);
133 close(dfd);
134 return 1;
135 }
136 if (st->ss->load_super(st, dfd, NULL)) {
137 if (verbose >= 0)
138 fprintf(stderr, Name ": no RAID superblock on %s.\n",
139 devname);
140 close(dfd);
141 return 1;
142 }
143 close (dfd);
144
145 if (st->ss->container_content) {
146 /* This is a pre-built container array, so we do something
147 * rather different.
148 */
149 return Incremental_container(st, devname, verbose, runstop,
150 autof);
151 }
152
153 st->ss->getinfo_super(st, &info);
154 /* 3/ Check if there is a match in mdadm.conf */
155
156 array_list = conf_get_ident(NULL);
157 match = NULL;
158 for (; array_list; array_list = array_list->next) {
159 if (array_list->uuid_set &&
160 same_uuid(array_list->uuid, info.uuid, st->ss->swapuuid)
161 == 0) {
162 if (verbose >= 2)
163 fprintf(stderr, Name
164 ": UUID differs from %s.\n",
165 array_list->devname);
166 continue;
167 }
168 if (array_list->name[0] &&
169 strcasecmp(array_list->name, info.name) != 0) {
170 if (verbose >= 2)
171 fprintf(stderr, Name
172 ": Name differs from %s.\n",
173 array_list->devname);
174 continue;
175 }
176 if (array_list->devices &&
177 !match_oneof(array_list->devices, devname)) {
178 if (verbose >= 2)
179 fprintf(stderr, Name
180 ": Not a listed device for %s.\n",
181 array_list->devname);
182 continue;
183 }
184 if (array_list->super_minor != UnSet &&
185 array_list->super_minor != info.array.md_minor) {
186 if (verbose >= 2)
187 fprintf(stderr, Name
188 ": Different super-minor to %s.\n",
189 array_list->devname);
190 continue;
191 }
192 if (!array_list->uuid_set &&
193 !array_list->name[0] &&
194 !array_list->devices &&
195 array_list->super_minor == UnSet) {
196 if (verbose >= 2)
197 fprintf(stderr, Name
198 ": %s doesn't have any identifying information.\n",
199 array_list->devname);
200 continue;
201 }
202 /* FIXME, should I check raid_disks and level too?? */
203
204 if (match) {
205 if (verbose >= 0)
206 fprintf(stderr, Name
207 ": we match both %s and %s - cannot decide which to use.\n",
208 match->devname, array_list->devname);
209 return 2;
210 }
211 match = array_list;
212 }
213
214 /* 3a/ if not, check for homehost match. If no match, reject. */
215 if (!match) {
216 if (homehost == NULL ||
217 st->ss->match_home(st, homehost) == 0) {
218 if (verbose >= 0)
219 fprintf(stderr, Name
220 ": not found in mdadm.conf and not identified by homehost.\n");
221 return 2;
222 }
223 }
224 /* 4/ Determine device number. */
225 /* - If in mdadm.conf with std name, use that */
226 /* - UUID in /var/run/mdadm.map use that */
227 /* - If name is suggestive, use that. unless in use with */
228 /* different uuid. */
229 /* - Choose a free, high number. */
230 /* - Use a partitioned device unless strong suggestion not to. */
231 /* e.g. auto=md */
232 if (match && is_standard(match->devname, &devnum))
233 /* We have devnum now */;
234 else if ((mp = map_by_uuid(&map, info.uuid)) != NULL)
235 devnum = mp->devnum;
236 else {
237 /* Have to guess a bit. */
238 int use_partitions = 1;
239 char *np, *ep;
240 char *nm, nbuf[1024];
241 if ((autof&7) == 3 || (autof&7) == 5)
242 use_partitions = 0;
243 np = strchr(info.name, ':');
244 if (np)
245 np++;
246 else
247 np = info.name;
248 devnum = strtoul(np, &ep, 10);
249 if (ep > np && *ep == 0) {
250 /* This is a number. Let check that it is unused. */
251 if (mddev_busy(use_partitions ? (-1-devnum) : devnum))
252 devnum = -1;
253 } else
254 devnum = -1;
255
256 if (match)
257 nm = match->devname;
258 else {
259 sprintf(nbuf, "/dev/md/%s", np);
260 nm = nbuf;
261 }
262 if (stat(nm, &stb) == 0 &&
263 S_ISBLK(stb.st_mode) &&
264 major(stb.st_rdev) == (use_partitions ?
265 get_mdp_major() : MD_MAJOR)) {
266 if (use_partitions)
267 devnum = minor(stb.st_rdev) >> MdpMinorShift;
268 else
269 devnum = minor(stb.st_rdev);
270 if (mddev_busy(use_partitions ? (-1-devnum) : devnum))
271 devnum = -1;
272 }
273
274 if (devnum < 0) {
275 /* Haven't found anything yet, choose something free */
276 devnum = find_free_devnum(use_partitions);
277
278 if (devnum == NoMdDev) {
279 fprintf(stderr, Name
280 ": No spare md devices!!\n");
281 return 2;
282 }
283 } else
284 devnum = use_partitions ? (-1-devnum) : devnum;
285 }
286 mdfd = open_mddev_devnum(match ? match->devname : NULL,
287 devnum,
288 info.name,
289 chosen_name, autof >> 3);
290 if (mdfd < 0) {
291 fprintf(stderr, Name ": failed to open %s: %s.\n",
292 chosen_name, strerror(errno));
293 return 2;
294 }
295 /* 5/ Find out if array already exists */
296 if (! mddev_busy(devnum)) {
297 /* 5a/ if it does not */
298 /* - choose a name, from mdadm.conf or 'name' field in array. */
299 /* - create the array */
300 /* - add the device */
301 mdu_array_info_t ainf;
302 struct mdinfo *sra;
303
304 memset(&ainf, 0, sizeof(ainf));
305 ainf.major_version = info.array.major_version;
306 ainf.minor_version = info.array.minor_version;
307 if (ioctl(mdfd, SET_ARRAY_INFO, &ainf) != 0) {
308 fprintf(stderr, Name
309 ": SET_ARRAY_INFO failed for %s: %s\b",
310 chosen_name, strerror(errno));
311 close(mdfd);
312 return 2;
313 }
314 sra = sysfs_read(mdfd, devnum, GET_VERSION);
315 sysfs_set_str(sra, NULL, "metadata_version", info.text_version);
316
317 st->ss->getinfo_super(st, &info);
318 info.disk.major = major(stb.st_rdev);
319 info.disk.minor = minor(stb.st_rdev);
320 if (add_disk(mdfd, st, sra, &info) != 0) {
321 fprintf(stderr, Name ": failed to add %s to %s: %s.\n",
322 devname, chosen_name, strerror(errno));
323 ioctl(mdfd, STOP_ARRAY, 0);
324 close(mdfd);
325 sysfs_free(sra);
326 return 2;
327 }
328 sysfs_free(sra);
329 sra = sysfs_read(mdfd, devnum, GET_DEVS);
330 if (!sra || !sra->devs || sra->devs->disk.raid_disk >= 0) {
331 /* It really should be 'none' - must be old buggy
332 * kernel, and mdadm -I may not be able to complete.
333 * So reject it.
334 */
335 ioctl(mdfd, STOP_ARRAY, NULL);
336 fprintf(stderr, Name
337 ": You have an old buggy kernel which cannot support\n"
338 " --incremental reliably. Aborting.\n");
339 close(mdfd);
340 sysfs_free(sra);
341 return 2;
342 }
343 } else {
344 /* 5b/ if it does */
345 /* - check one drive in array to make sure metadata is a reasonably */
346 /* close match. Reject if not (e.g. different type) */
347 /* - add the device */
348 char dn[20];
349 int dfd2;
350 int err;
351 struct mdinfo *sra;
352 struct supertype *st2;
353 sra = sysfs_read(mdfd, devnum, (GET_DEVS | GET_STATE));
354
355 sprintf(dn, "%d:%d", sra->devs->disk.major,
356 sra->devs->disk.minor);
357 dfd2 = dev_open(dn, O_RDONLY);
358 st2 = dup_super(st);
359 if (st2->ss->load_super(st2, dfd2, NULL) ||
360 st->ss->compare_super(st, st2) != 0) {
361 fprintf(stderr, Name
362 ": metadata mismatch between %s and "
363 "chosen array %s\n",
364 devname, chosen_name);
365 close(mdfd);
366 close(dfd2);
367 return 2;
368 }
369 close(dfd2);
370 st2->ss->getinfo_super(st2, &info2);
371 st2->ss->free_super(st2);
372 if (info.array.level != info2.array.level ||
373 memcmp(info.uuid, info2.uuid, 16) != 0 ||
374 info.array.raid_disks != info2.array.raid_disks) {
375 fprintf(stderr, Name
376 ": unexpected difference between %s and %s.\n",
377 chosen_name, devname);
378 close(mdfd);
379 return 2;
380 }
381 info2.disk.major = major(stb.st_rdev);
382 info2.disk.minor = minor(stb.st_rdev);
383 err = add_disk(mdfd, st2, sra, &info2);
384 if (err < 0 && errno == EBUSY) {
385 /* could be another device present with the same
386 * disk.number. Find and reject any such
387 */
388 find_reject(mdfd, st, sra, info.disk.number,
389 info.events, verbose, chosen_name);
390 err = add_disk(mdfd, st2, sra, &info2);
391 }
392 if (err < 0) {
393 fprintf(stderr, Name ": failed to add %s to %s: %s.\n",
394 devname, chosen_name, strerror(errno));
395 close(mdfd);
396 return 2;
397 }
398 }
399 /* 6/ Make sure /var/run/mdadm.map contains this array. */
400 map_update(&map, devnum,
401 info.text_version,
402 info.uuid, chosen_name);
403
404 /* 7/ Is there enough devices to possibly start the array? */
405 /* 7a/ if not, finish with success. */
406 avail = NULL;
407 active_disks = count_active(st, mdfd, &avail, &info);
408 if (enough(info.array.level, info.array.raid_disks,
409 info.array.layout, info.array.state & 1,
410 avail, active_disks) == 0) {
411 free(avail);
412 if (verbose >= 0)
413 fprintf(stderr, Name
414 ": %s attached to %s, not enough to start (%d).\n",
415 devname, chosen_name, active_disks);
416 close(mdfd);
417 return 0;
418 }
419 free(avail);
420
421 /* 7b/ if yes, */
422 /* - if number of OK devices match expected, or -R and there */
423 /* are enough, */
424 /* + add any bitmap file */
425 /* + start the array (auto-readonly). */
426 {
427 mdu_array_info_t ainf;
428
429 if (ioctl(mdfd, GET_ARRAY_INFO, &ainf) == 0) {
430 if (verbose >= 0)
431 fprintf(stderr, Name
432 ": %s attached to %s which is already active.\n",
433 devname, chosen_name);
434 close (mdfd);
435 return 0;
436 }
437 }
438 if (runstop > 0 || active_disks >= info.array.working_disks) {
439 struct mdinfo *sra;
440 /* Let's try to start it */
441 if (match && match->bitmap_file) {
442 int bmfd = open(match->bitmap_file, O_RDWR);
443 if (bmfd < 0) {
444 fprintf(stderr, Name
445 ": Could not open bitmap file %s.\n",
446 match->bitmap_file);
447 close(mdfd);
448 return 1;
449 }
450 if (ioctl(mdfd, SET_BITMAP_FILE, bmfd) != 0) {
451 close(bmfd);
452 fprintf(stderr, Name
453 ": Failed to set bitmapfile for %s.\n",
454 chosen_name);
455 close(mdfd);
456 return 1;
457 }
458 close(bmfd);
459 }
460 sra = sysfs_read(mdfd, devnum, 0);
461 if (sra == NULL || active_disks >= info.array.working_disks)
462 rv = ioctl(mdfd, RUN_ARRAY, NULL);
463 else
464 rv = sysfs_set_str(sra, NULL,
465 "array_state", "read-auto");
466 if (rv == 0) {
467 if (verbose >= 0)
468 fprintf(stderr, Name
469 ": %s attached to %s, which has been started.\n",
470 devname, chosen_name);
471 rv = 0;
472 } else {
473 fprintf(stderr, Name
474 ": %s attached to %s, but failed to start: %s.\n",
475 devname, chosen_name, strerror(errno));
476 rv = 1;
477 }
478 } else {
479 if (verbose >= 0)
480 fprintf(stderr, Name
481 ": %s attached to %s, not enough to start safely.\n",
482 devname, chosen_name);
483 rv = 0;
484 }
485 close(mdfd);
486 return rv;
487 }
488
489 static void find_reject(int mdfd, struct supertype *st, struct mdinfo *sra,
490 int number, __u64 events, int verbose,
491 char *array_name)
492 {
493 /* Find a device attached to this array with a disk.number of number
494 * and events less than the passed events, and remove the device.
495 */
496 struct mdinfo *d;
497 mdu_array_info_t ra;
498
499 if (ioctl(mdfd, GET_ARRAY_INFO, &ra) == 0)
500 return; /* not safe to remove from active arrays
501 * without thinking more */
502
503 for (d = sra->devs; d ; d = d->next) {
504 char dn[10];
505 int dfd;
506 struct mdinfo info;
507 sprintf(dn, "%d:%d", d->disk.major, d->disk.minor);
508 dfd = dev_open(dn, O_RDONLY);
509 if (dfd < 0)
510 continue;
511 if (st->ss->load_super(st, dfd, NULL)) {
512 close(dfd);
513 continue;
514 }
515 st->ss->getinfo_super(st, &info);
516 st->ss->free_super(st);
517 close(dfd);
518
519 if (info.disk.number != number ||
520 info.events >= events)
521 continue;
522
523 if (d->disk.raid_disk > -1)
524 sysfs_set_str(sra, d, "slot", "none");
525 if (sysfs_set_str(sra, d, "state", "remove") == 0)
526 if (verbose >= 0)
527 fprintf(stderr, Name
528 ": removing old device %s from %s\n",
529 d->sys_name+4, array_name);
530 }
531 }
532
533 static int count_active(struct supertype *st, int mdfd, char **availp,
534 struct mdinfo *bestinfo)
535 {
536 /* count how many devices in sra think they are active */
537 struct mdinfo *d;
538 int cnt = 0, cnt1 = 0;
539 __u64 max_events = 0;
540 struct mdinfo *sra = sysfs_read(mdfd, -1, GET_DEVS | GET_STATE);
541 char *avail = NULL;
542
543 for (d = sra->devs ; d ; d = d->next) {
544 char dn[30];
545 int dfd;
546 int ok;
547 struct mdinfo info;
548
549 sprintf(dn, "%d:%d", d->disk.major, d->disk.minor);
550 dfd = dev_open(dn, O_RDONLY);
551 if (dfd < 0)
552 continue;
553 ok = st->ss->load_super(st, dfd, NULL);
554 close(dfd);
555 if (ok != 0)
556 continue;
557 st->ss->getinfo_super(st, &info);
558 if (info.disk.state & (1<<MD_DISK_SYNC))
559 {
560 if (avail == NULL) {
561 avail = malloc(info.array.raid_disks);
562 memset(avail, 0, info.array.raid_disks);
563 }
564 if (cnt == 0) {
565 cnt++;
566 max_events = info.events;
567 avail[info.disk.raid_disk] = 2;
568 st->ss->getinfo_super(st, bestinfo);
569 } else if (info.events == max_events) {
570 cnt++;
571 avail[info.disk.raid_disk] = 2;
572 } else if (info.events == max_events-1) {
573 cnt1++;
574 avail[info.disk.raid_disk] = 1;
575 } else if (info.events < max_events - 1)
576 ;
577 else if (info.events == max_events+1) {
578 int i;
579 cnt1 = cnt;
580 cnt = 1;
581 max_events = info.events;
582 for (i=0; i<info.array.raid_disks; i++)
583 if (avail[i])
584 avail[i]--;
585 avail[info.disk.raid_disk] = 2;
586 st->ss->getinfo_super(st, bestinfo);
587 } else { /* info.events much bigger */
588 cnt = 1; cnt1 = 0;
589 memset(avail, 0, info.disk.raid_disk);
590 max_events = info.events;
591 st->ss->getinfo_super(st, bestinfo);
592 }
593 }
594 st->ss->free_super(st);
595 }
596 return cnt + cnt1;
597 }
598
599 void RebuildMap(void)
600 {
601 struct mdstat_ent *mdstat = mdstat_read(0, 0);
602 struct mdstat_ent *md;
603 struct map_ent *map = NULL;
604 int mdp = get_mdp_major();
605
606 for (md = mdstat ; md ; md = md->next) {
607 struct mdinfo *sra = sysfs_read(-1, md->devnum, GET_DEVS);
608 struct mdinfo *sd;
609
610 for (sd = sra->devs ; sd ; sd = sd->next) {
611 char dn[30];
612 int dfd;
613 int ok;
614 struct supertype *st;
615 char *path;
616 struct mdinfo info;
617
618 sprintf(dn, "%d:%d", sd->disk.major, sd->disk.minor);
619 dfd = dev_open(dn, O_RDONLY);
620 if (dfd < 0)
621 continue;
622 st = guess_super(dfd);
623 if ( st == NULL)
624 ok = -1;
625 else
626 ok = st->ss->load_super(st, dfd, NULL);
627 close(dfd);
628 if (ok != 0)
629 continue;
630 st->ss->getinfo_super(st, &info);
631 if (md->devnum > 0)
632 path = map_dev(MD_MAJOR, md->devnum, 0);
633 else
634 path = map_dev(mdp, (-1-md->devnum)<< 6, 0);
635 map_add(&map, md->devnum,
636 info.text_version,
637 info.uuid, path ? : "/unknown");
638 st->ss->free_super(st);
639 break;
640 }
641 }
642 map_write(map);
643 map_free(map);
644 }
645
646 int IncrementalScan(int verbose)
647 {
648 /* look at every device listed in the 'map' file.
649 * If one is found that is not running then:
650 * look in mdadm.conf for bitmap file.
651 * if one exists, but array has none, add it.
652 * try to start array in auto-readonly mode
653 */
654 struct map_ent *mapl = NULL;
655 struct map_ent *me;
656 mddev_ident_t devs, mddev;
657 int rv = 0;
658
659 map_read(&mapl);
660 devs = conf_get_ident(NULL);
661
662 for (me = mapl ; me ; me = me->next) {
663 char path[1024];
664 mdu_array_info_t array;
665 mdu_bitmap_file_t bmf;
666 struct mdinfo *sra;
667 int mdfd = open_mddev_devnum(me->path, me->devnum,
668 NULL, path, 0);
669 if (mdfd < 0)
670 continue;
671 if (ioctl(mdfd, GET_ARRAY_INFO, &array) == 0 ||
672 errno != ENODEV) {
673 close(mdfd);
674 continue;
675 }
676 /* Ok, we can try this one. Maybe it needs a bitmap */
677 for (mddev = devs ; mddev ; mddev = mddev->next)
678 if (strcmp(mddev->devname, me->path) == 0)
679 break;
680 if (mddev && mddev->bitmap_file) {
681 /*
682 * Note: early kernels will wrongly fail this, so it
683 * is a hint only
684 */
685 int added = -1;
686 if (ioctl(mdfd, GET_ARRAY_INFO, &bmf) < 0) {
687 int bmfd = open(mddev->bitmap_file, O_RDWR);
688 if (bmfd >= 0) {
689 added = ioctl(mdfd, SET_BITMAP_FILE,
690 bmfd);
691 close(bmfd);
692 }
693 }
694 if (verbose >= 0) {
695 if (added == 0)
696 fprintf(stderr, Name
697 ": Added bitmap %s to %s\n",
698 mddev->bitmap_file, me->path);
699 else if (errno != EEXIST)
700 fprintf(stderr, Name
701 ": Failed to add bitmap to %s: %s\n",
702 me->path, strerror(errno));
703 }
704 }
705 sra = sysfs_read(mdfd, 0, 0);
706 if (sra) {
707 if (sysfs_set_str(sra, NULL,
708 "array_state", "read-auto") == 0) {
709 if (verbose >= 0)
710 fprintf(stderr, Name
711 ": started array %s\n",
712 me->path);
713 } else {
714 fprintf(stderr, Name
715 ": failed to start array %s: %s\n",
716 me->path, strerror(errno));
717 rv = 1;
718 }
719 }
720 }
721 return rv;
722 }
723
724 static char *container2devname(char *devname)
725 {
726 int fd = open(devname, O_RDONLY);
727 char *mdname = NULL;
728
729 if (fd >= 0) {
730 mdname = devnum2devname(fd2devnum(fd));
731 close(fd);
732 }
733
734 return mdname;
735 }
736
737 int Incremental_container(struct supertype *st, char *devname, int verbose,
738 int runstop, int autof)
739 {
740 /* Collect the contents of this container and for each
741 * array, choose a device name and assemble the array.
742 */
743
744 struct mdinfo *list = st->ss->container_content(st);
745 struct mdinfo *ra;
746 char *mdname = container2devname(devname);
747
748 if (!mdname) {
749 fprintf(stderr, Name": failed to determine device name\n");
750 return 2;
751 }
752
753 for (ra = list ; ra ; ra = ra->next) {
754 struct mdinfo *sra;
755 struct mdinfo *dev;
756 int devnum = -1;
757 int mdfd;
758 char chosen_name[1024];
759 int usepart = 1;
760 char *n;
761 int working = 0;
762 char ver[100];
763
764 if ((autof&7) == 3 || (autof&7) == 5)
765 usepart = 0;
766
767 n = ra->name;
768 if (*n == 'd')
769 n++;
770 if (*n) {
771 devnum = strtoul(n, &n, 10);
772 if (devnum >= 0 && (*n == 0 || *n == ' ')) {
773 /* Use this devnum */
774 usepart = (ra->name[0] == 'd');
775 if (mddev_busy(usepart ? (-1-devnum) : devnum))
776 devnum = -1;
777 } else
778 devnum = -1;
779 }
780
781 if (devnum < 0) {
782 char *nm = ra->name;
783 char nbuf[1024];
784 struct stat stb;
785 if (strchr(nm, ':'))
786 nm = strchr(nm, ':')+1;
787 sprintf(nbuf, "/dev/md/%s", nm);
788
789 if (stat(nbuf, &stb) == 0 &&
790 S_ISBLK(stb.st_mode) &&
791 major(stb.st_rdev) == (usepart ?
792 get_mdp_major() : MD_MAJOR)){
793 if (usepart)
794 devnum = minor(stb.st_rdev)
795 >> MdpMinorShift;
796 else
797 devnum = minor(stb.st_rdev);
798 if (mddev_busy(usepart ? (-1-devnum) : devnum))
799 devnum = -1;
800 }
801 }
802
803 if (devnum >= 0)
804 devnum = usepart ? (-1-devnum) : devnum;
805 else
806 devnum = find_free_devnum(usepart);
807 mdfd = open_mddev_devnum(NULL, devnum, ra->name,
808 chosen_name, autof>>3);
809
810 if (mdfd < 0) {
811 fprintf(stderr, Name ": failed to open %s: %s.\n",
812 chosen_name, strerror(errno));
813 return 2;
814 }
815
816 sra = sysfs_read(mdfd, 0, 0);
817
818 sprintf(ver, "external:%s", ra->text_version);
819 sysfs_set_str(sra, NULL, "metadata_version", ver);
820
821 sysfs_set_array(sra, ra);
822 for (dev = ra->devs; dev; dev = dev->next)
823 if (sysfs_add_disk(sra, dev) == 0)
824 working++;
825
826 if (runstop > 0 || working >= ra->array.working_disks) {
827 switch(ra->array.level) {
828 case LEVEL_LINEAR:
829 case LEVEL_MULTIPATH:
830 case 0:
831 sysfs_set_str(sra, NULL, "array_state",
832 "active");
833 break;
834 default:
835 sysfs_set_str(sra, NULL, "array_state",
836 "readonly");
837 /* start mdmon if needed. */
838 if (!mdmon_running(st->container_dev))
839 start_mdmon(st->container_dev);
840 ping_monitor(devnum2devname(st->container_dev));
841 break;
842 }
843 sysfs_set_safemode(sra, ra->safe_mode_delay);
844 if (verbose >= 0)
845 printf("Started %s with %d devices\n",
846 chosen_name, working);
847 /* FIXME should have an O_EXCL and wait for read-auto */
848 } else
849 if (verbose >= 0)
850 printf("%s assembled with %d devices but "
851 "not started\n",
852 chosen_name, working);
853 close(mdfd);
854 }
855 return 0;
856 }