]> git.ipfire.org Git - thirdparty/mdadm.git/blobdiff - mdadm.c
Kill subarray v2
[thirdparty/mdadm.git] / mdadm.c
diff --git a/mdadm.c b/mdadm.c
index a77c4ad846676973eb2735146c74b8faae900812..446fab824e9728b861938728b3fdacfef816f173 100644 (file)
--- a/mdadm.c
+++ b/mdadm.c
@@ -1,7 +1,7 @@
 /*
  * mdadm - manage Linux "md" devices aka RAID arrays.
  *
- * Copyright (C) 2001-2006 Neil Brown <neilb@suse.de>
+ * Copyright (C) 2001-2009 Neil Brown <neilb@suse.de>
  *
  *
  *    This program is free software; you can redistribute it and/or modify
  *    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  *
  *    Author: Neil Brown
- *    Email: <neilb@cse.unsw.edu.au>
- *    Paper: Neil Brown
- *           School of Computer Science and Engineering
- *           The University of New South Wales
- *           Sydney, 2052
- *           Australia
+ *    Email: <neilb@suse.de>
  *
  *    Additions for bitmap and write-behind RAID options, Copyright (C) 2003-2004,
  *    Paul Clements, SteelEye Technology, Inc.
@@ -96,6 +91,7 @@ int main(int argc, char *argv[])
        int require_homehost = 1;
        char *mailaddr = NULL;
        char *program = NULL;
+       int increments = 20;
        int delay = 0;
        int daemonise = 0;
        char *pidfile = NULL;
@@ -107,6 +103,7 @@ int main(int argc, char *argv[])
        int dosyslog = 0;
        int rebuild_map = 0;
        int auto_update_home = 0;
+       char *subarray = NULL;
 
        int print_help = 0;
        FILE *outf;
@@ -155,13 +152,10 @@ int main(int argc, char *argv[])
                        continue;
 
                case 'b':
-                       if (mode == ASSEMBLE || mode == BUILD || mode == CREATE || mode == GROW)
+                       if (mode == ASSEMBLE || mode == BUILD || mode == CREATE || mode == GROW ||
+                           mode == INCREMENTAL || mode == MANAGE)
                                break; /* b means bitmap */
                        brief = 1;
-                       if (optarg) {
-                               fprintf(stderr, Name ": -b cannot have any extra immediately after it, sorry.\n");
-                               exit(2);
-                       }
                        continue;
 
                case 'Y': export++;
@@ -223,6 +217,9 @@ int main(int argc, char *argv[])
                case 'W':
                case Waitclean:
                case DetailPlatform:
+               case KillSubarray:
+                       if (opt == KillSubarray)
+                               subarray = optarg;
                case 'K': if (!mode) newmode = MISC; break;
                }
                if (mode && newmode == mode) {
@@ -271,7 +268,8 @@ int main(int argc, char *argv[])
                                        continue;
                                }
                                /* No mode yet, and this is the second device ... */
-                               fprintf(stderr, Name ": An option must be given to set the mode before a second device is listed\n");
+                               fprintf(stderr, Name ": An option must be given to set the mode before a second device\n"
+                                       "       (%s) is listed\n", optarg);
                                exit(2);
                        }
                        if (option_index >= 0)
@@ -329,6 +327,7 @@ int main(int argc, char *argv[])
                 * could depend on the mode */
 #define O(a,b) ((a<<8)|b)
                switch (O(mode,opt)) {
+               case O(GROW,'c'):
                case O(CREATE,'c'):
                case O(BUILD,'c'): /* chunk or rounding */
                        if (chunk) {
@@ -344,9 +343,11 @@ int main(int argc, char *argv[])
                        }
                        continue;
 
+#if 0
                case O(ASSEMBLE,AutoHomeHost):
                        auto_update_home = 1;
                        continue;
+#endif
                case O(INCREMENTAL, 'e'):
                case O(CREATE,'e'):
                case O(ASSEMBLE,'e'):
@@ -418,7 +419,7 @@ int main(int argc, char *argv[])
                        }
                        continue;
 
-               case O(GROW,'l'): /* hack - needed to understand layout */
+               case O(GROW,'l'):
                case O(CREATE,'l'):
                case O(BUILD,'l'): /* set raid level*/
                        if (level != UnSet) {
@@ -432,7 +433,10 @@ int main(int argc, char *argv[])
                                        optarg);
                                exit(2);
                        }
-                       if (level != 0 && level != -1 && level != 1 && level != -4 && level != -5 && mode == BUILD) {
+                       if (level != 0 && level != LEVEL_LINEAR && level != 1 &&
+                           level != LEVEL_MULTIPATH && level != LEVEL_FAULTY &&
+                           level != 10 &&
+                           mode == BUILD) {
                                fprintf(stderr, Name ": Raid level %s not permitted with --build.\n",
                                        optarg);
                                exit(2);
@@ -713,6 +717,14 @@ int main(int argc, char *argv[])
                                program = optarg;
                        continue;
 
+               case O(MONITOR,'r'): /* rebuild increments */
+                       increments = atoi(optarg);
+                       if (increments>99 || increments<1) {
+                               fprintf(stderr, Name ": please specify positive integer between 1 and 99 as rebuild increments.\n");
+                               exit(2);
+                       }
+                       continue;
+
                case O(MONITOR,'d'): /* delay in seconds */
                case O(GROW, 'd'):
                case O(BUILD,'d'): /* delay for bitmap updates */
@@ -799,6 +811,7 @@ int main(int argc, char *argv[])
                case O(MISC,'W'):
                case O(MISC, Waitclean):
                case O(MISC, DetailPlatform):
+               case O(MISC, KillSubarray):
                        if (devmode && devmode != opt &&
                            (devmode == 'E' || (opt == 'E' && devmode != 'Q'))) {
                                fprintf(stderr, Name ": --examine/-E cannot be given with -%c\n",
@@ -864,7 +877,8 @@ int main(int argc, char *argv[])
                                continue;
                        }
                        /* probable typo */
-                       fprintf(stderr, Name ": bitmap file must contain a '/', or be 'internal', or 'none'\n");
+                       fprintf(stderr, Name ": bitmap file must contain a '/', or be 'internal', or 'none'\n"
+                               "       not '%s'\n", optarg);
                        exit(2);
 
                case O(GROW,BitmapChunk):
@@ -1037,6 +1051,12 @@ int main(int argc, char *argv[])
                }
        }
 
+       if ((mode != MISC || devmode != 'E') &&
+           geteuid() != 0) {
+               fprintf(stderr, Name ": must be super-user to perform this action\n");
+               exit(1);
+       }
+
        ident.autof = autof;
 
        rv = 0;
@@ -1105,9 +1125,10 @@ int main(int argc, char *argv[])
                                               verbose-quiet, force);
                        }
                } else {
-                       mddev_ident_t array_list =  conf_get_ident(NULL);
+                       mddev_ident_t a, array_list =  conf_get_ident(NULL);
                        mddev_dev_t devlist = conf_get_devs();
                        int cnt = 0;
+                       int failures, successes;
                        if (devlist == NULL) {
                                fprintf(stderr, Name ": No devices listed in conf file were found.\n");
                                exit(1);
@@ -1120,21 +1141,38 @@ int main(int argc, char *argv[])
                                fprintf(stderr, Name ": --backup_file not meaningful with a --scan assembly.\n");
                                exit(1);
                        }
-                       for (; array_list; array_list = array_list->next) {
-                               if (array_list->devname &&
-                                   strcasecmp(array_list->devname, "<ignore>") == 0)
-                                       continue;
-                               if (array_list->autof == 0)
-                                       array_list->autof = autof;
+                       for (a = array_list; a ; a = a->next) {
+                               a->assembled = 0;
+                               if (a->autof == 0)
+                                       a->autof = autof;
+                       }
+                       do {
+                               failures = 0;
+                               successes = 0;
+                               rv = 0;
+                               for (a = array_list; a ; a = a->next) {
+                                       int r;
+                                       if (a->assembled)
+                                               continue;
+                                       if (a->devname &&
+                                           strcasecmp(a->devname, "<ignore>") == 0)
+                                               continue;
                                
-                               rv |= Assemble(ss, array_list->devname,
-                                              array_list,
-                                              NULL, NULL,
-                                              readonly, runstop, NULL,
-                                              homehost, require_homehost,
-                                              verbose-quiet, force);
-                               cnt++;
-                       }
+                                       r = Assemble(ss, a->devname,
+                                                    a,
+                                                    NULL, NULL,
+                                                    readonly, runstop, NULL,
+                                                    homehost, require_homehost,
+                                                    verbose-quiet, force);
+                                       if (r == 0) {
+                                               a->assembled = 1;
+                                               successes++;
+                                       } else
+                                               failures++;
+                                       rv |= r;
+                                       cnt++;
+                               }
+                       } while (failures && successes);
                        if (homehost && cnt == 0) {
                                /* Maybe we can auto-assemble something.
                                 * Repeatedly call Assemble in auto-assemble mode
@@ -1165,6 +1203,7 @@ int main(int argc, char *argv[])
                                        } while (rv2!=2);
                                        /* Incase there are stacked devices, we need to go around again */
                                } while (acnt);
+#if 0
                                if (cnt == 0 && auto_update_home && homehost) {
                                        /* Nothing found, maybe we need to bootstrap homehost info */
                                        do {
@@ -1184,6 +1223,7 @@ int main(int argc, char *argv[])
                                                /* Incase there are stacked devices, we need to go around again */
                                        } while (acnt);
                                }
+#endif
                                if (cnt == 0 && rv == 0) {
                                        fprintf(stderr, Name ": No arrays found in config file or automatically\n");
                                        rv = 1;
@@ -1267,11 +1307,18 @@ int main(int argc, char *argv[])
                                        struct mdstat_ent *ms = mdstat_read(0, 1);
                                        struct mdstat_ent *e;
                                        struct map_ent *map = NULL;
+                                       int members;
                                        int v = verbose>1?0:verbose+1;
 
+                                       for (members = 0; members <= 1; members++) {
                                        for (e=ms ; e ; e=e->next) {
                                                char *name;
                                                struct map_ent *me;
+                                               int member = e->metadata_version &&
+                                                       strncmp(e->metadata_version,
+                                                               "external:/", 10) == 0;
+                                               if (members != member)
+                                                       continue;
                                                me = map_by_devnum(&map, e->devnum);
                                                if (me && me->path
                                                    && strcmp(me->path, "/unknown") != 0)
@@ -1289,9 +1336,10 @@ int main(int argc, char *argv[])
                                                                     export, test,
                                                                     homehost);
                                                else
-                                                       rv |= WaitClean(name, v);
+                                                       rv |= WaitClean(name, -1, v);
                                                put_md_name(name);
                                        }
+                                       }
                                        free_mdstat(ms);
                                } else  if (devmode == 'S' && scan) {
                                        /* apply --stop to all devices in /proc/mdstat */
@@ -1341,7 +1389,16 @@ int main(int argc, char *argv[])
                                                     export, test, homehost);
                                        continue;
                                case 'K': /* Zero superblock */
-                                       rv |= Kill(dv->devname, force, quiet,0);
+                                       if (ss)
+                                               rv |= Kill(dv->devname, ss, force, quiet,0);
+                                       else {
+                                               int q = quiet;
+                                               do {
+                                                       rv |= Kill(dv->devname, NULL, force, q, 0);
+                                                       q = 1;
+                                               } while (rv == 0);
+                                               rv &= ~2;
+                                       }
                                        continue;
                                case 'Q':
                                        rv |= Query(dv->devname); continue;
@@ -1350,7 +1407,10 @@ int main(int argc, char *argv[])
                                case 'W':
                                        rv |= Wait(dv->devname); continue;
                                case Waitclean:
-                                       rv |= WaitClean(dv->devname, verbose-quiet); continue;
+                                       rv |= WaitClean(dv->devname, -1, verbose-quiet); continue;
+                               case KillSubarray:
+                                       rv |= Kill_subarray(dv->devname, subarray, quiet);
+                                       continue;
                                }
                                mdfd = open_mddev(dv->devname, 1);
                                if (mdfd>=0) {
@@ -1381,18 +1441,34 @@ int main(int argc, char *argv[])
                        rv = 1;
                        break;
                }
+               if (delay == 0) {
+                       if (get_linux_version() > 20616)
+                               /* mdstat responds to poll */
+                               delay = 1000;
+                       else
+                               delay = 60;
+               }
                rv= Monitor(devlist, mailaddr, program,
                            delay?delay:60, daemonise, scan, oneshot,
-                           dosyslog, test, pidfile);
+                           dosyslog, test, pidfile, increments);
                break;
 
        case GROW:
                if (array_size >= 0) {
                        /* alway impose array size first, independent of
                         * anything else
+                        * Do not allow level or raid_disks changes at the
+                        * same time as that can be irreversibly destructive.
                         */
                        struct mdinfo sra;
                        int err;
+                       if (raiddisks || level != UnSet) {
+                               fprintf(stderr, Name ": cannot change array size in same operation "
+                                       "as changing raiddisks or level.\n"
+                                       "    Change size first, then check that data is still intact.\n");
+                               rv = 1;
+                               break;
+                       }
                        sysfs_init(&sra, mdfd, 0);
                        if (array_size == 0)
                                err = sysfs_set_str(&sra, NULL, "array_size", "default");
@@ -1412,8 +1488,8 @@ int main(int argc, char *argv[])
                if (devs_found > 1) {
 
                        /* must be '-a'. */
-                       if (size >= 0 || raiddisks) {
-                               fprintf(stderr, Name ": --size, --raiddisks, and --add are exclusing in --grow mode\n");
+                       if (size >= 0 || raiddisks || chunk || layout_str != NULL || bitmap_file) {
+                               fprintf(stderr, Name ": --add cannot be used with other geometry changes in --grow mode\n");
                                rv = 1;
                                break;
                        }
@@ -1422,17 +1498,20 @@ int main(int argc, char *argv[])
                                if (rv)
                                        break;
                        }
-               } else if ((size >= 0) + (raiddisks != 0) +  (layout_str != NULL) + (bitmap_file != NULL)> 1) {
-                       fprintf(stderr, Name ": can change at most one of size, raiddisks, bitmap, and layout\n");
-                       rv = 1;
-                       break;
-               } else if (size >= 0 || raiddisks || layout_str != NULL)
-                       rv = Grow_reshape(devlist->devname, mdfd, quiet, backup_file,
-                                         size, level, layout_str, chunk, raiddisks);
-               else if (bitmap_file) {
-                       if (delay == 0) delay = DEFAULT_BITMAP_DELAY;
+               } else if (bitmap_file) {
+                       if (size >= 0 || raiddisks || chunk || layout_str != NULL) {
+                               fprintf(stderr, Name ": --bitmap changes cannot be used with other geometry changes in --grow mode\n");
+                               rv = 1;
+                               break;
+                       }
+                       if (delay == 0)
+                               delay = DEFAULT_BITMAP_DELAY;
                        rv = Grow_addbitmap(devlist->devname, mdfd, bitmap_file,
                                            bitmap_chunk, delay, write_behind, force);
+               } else if (size >= 0 || raiddisks != 0 || layout_str != NULL
+                          || chunk != 0 || level != UnSet) {
+                       rv = Grow_reshape(devlist->devname, mdfd, quiet, backup_file,
+                                         size, level, layout_str, chunk, raiddisks);
                } else if (array_size < 0)
                        fprintf(stderr, Name ": no changes to --grow\n");
                break;