]> git.ipfire.org Git - thirdparty/mdadm.git/blobdiff - Assemble.c
main: remove use of uninitialized 'rv'.
[thirdparty/mdadm.git] / Assemble.c
index 46ab72e48eb06f307ceafbf709720f28fe510a16..be4d8c962722731f7f587150619544490216844c 100644 (file)
 #include       "mdadm.h"
 #include       <ctype.h>
 
-static int name_matches(char *found, char *required, char *homehost)
+static int name_matches(char *found, char *required, char *homehost, int require_homehost)
 {
        /* See if the name found matches the required name, possibly
         * prefixed with 'homehost'
         */
-       char fnd[33];
+       char *sep;
+       unsigned int l;
 
-       strncpy(fnd, found, 32);
-       fnd[32] = 0;
        if (strcmp(found, required)==0)
                return 1;
-       if (homehost) {
-               int l = strlen(homehost);
-               if (l < 32 && fnd[l] == ':' &&
-                   strcmp(fnd+l+1, required)==0)
+       sep = strchr(found, ':');
+       if (!sep)
+               return 0;
+       l = sep - found;
+       if (strncmp(found, "any:", 4) == 0 ||
+           (homehost && strcmp(homehost, "any") == 0) ||
+           !require_homehost ||
+           (homehost && strlen(homehost) == l &&
+            strncmp(found, homehost, l) == 0)) {
+               /* matching homehost */
+               if (strcmp(sep+1, required) == 0)
                        return 1;
        }
        return 0;
@@ -73,7 +79,7 @@ static int is_member_busy(char *metadata_version)
 static int ident_matches(struct mddev_ident *ident,
                         struct mdinfo *content,
                         struct supertype *tst,
-                        char *homehost,
+                        char *homehost, int require_homehost,
                         char *update, char *devname)
 {
 
@@ -85,7 +91,7 @@ static int ident_matches(struct mddev_ident *ident,
                return 0;
        }
        if (ident->name[0] && (!update || strcmp(update, "name")!= 0) &&
-           name_matches(content->name, ident->name, homehost)==0) {
+           name_matches(content->name, ident->name, homehost, require_homehost)==0) {
                if (devname)
                        pr_err("%s has wrong name.\n", devname);
                return 0;
@@ -244,7 +250,9 @@ static int select_devices(struct mddev_dev *devlist,
                                        pr_err("no recogniseable superblock on %s\n",
                                               devname);
                                tmpdev->used = 2;
-                       } else if (tst->ss->load_super(tst,dfd, NULL)) {
+                       } else if ((tst->ignore_hw_compat = 0),
+                                  tst->ss->load_super(tst, dfd,
+                                                      report_mismatch ? devname : NULL)) {
                                if (report_mismatch)
                                        pr_err("no RAID superblock on %s\n",
                                               devname);
@@ -325,7 +333,8 @@ static int select_devices(struct mddev_dev *devlist,
                             content = content->next) {
 
                                if (!ident_matches(ident, content, tst,
-                                                  c->homehost, c->update,
+                                                  c->homehost, c->require_homehost,
+                                                  c->update,
                                                   report_mismatch ? devname : NULL))
                                        /* message already printed */;
                                else if (is_member_busy(content->text_version)) {
@@ -367,7 +376,8 @@ static int select_devices(struct mddev_dev *devlist,
                        tst->ss->getinfo_super(tst, content, NULL);
 
                        if (!ident_matches(ident, content, tst,
-                                          c->homehost, c->update,
+                                          c->homehost, c->require_homehost,
+                                          c->update,
                                           report_mismatch ? devname : NULL))
                                goto loop;
 
@@ -391,7 +401,8 @@ static int select_devices(struct mddev_dev *devlist,
                                        goto loop;
                                }
                                if (match && !ident_matches(match, content, tst,
-                                                           c->homehost, c->update,
+                                                           c->homehost, c->require_homehost,
+                                                           c->update,
                                                            report_mismatch ? devname : NULL))
                                        /* Array exists  in mdadm.conf but some
                                         * details don't match, so reject it
@@ -626,7 +637,13 @@ static int load_devices(struct devs *devices, char *devmap,
 
                        if (strcmp(c->update, "byteorder") == 0)
                                err = 0;
-                       else
+                       else if (strcmp(c->update, "home-cluster") == 0) {
+                               tst->cluster_name = c->homecluster;
+                               tst->ss->write_bitmap(tst, dfd, NameUpdate);
+                       } else if (strcmp(c->update, "nodes") == 0) {
+                               tst->nodes = c->nodes;
+                               err = tst->ss->write_bitmap(tst, dfd, NodeNumUpdate);
+                       } else
                                err = tst->ss->update_super(tst, content, c->update,
                                                            devname, c->verbose,
                                                            ident->uuid_set,
@@ -817,12 +834,37 @@ static int force_array(struct mdinfo *content,
                     i < content->array.raid_disks * 2 && i < bestcnt;
                     i += 2) {
                        int j = best[i];
-                       if (j>=0 &&
-                           !devices[j].uptodate &&
-                           devices[j].i.recovery_start == MaxSector &&
-                           (chosen_drive < 0 ||
+                       if (j < 0)
+                               continue;
+                       if (devices[j].uptodate)
+                               continue;
+                       if (devices[j].i.recovery_start != MaxSector) {
+                               int delta;
+                               if (!devices[j].i.reshape_active ||
+                                   devices[j].i.delta_disks <= 0)
+                                       continue;
+                               /* When increasing number of devices, an
+                                * added device also appears to be
+                                * recovering.  It is safe to include it
+                                * as long as it won't be a source of
+                                * data.
+                                * For now, just allow for last data
+                                * devices in RAID4 or last devices in RAID4/5/6.
+                                */
+                               delta = devices[j].i.delta_disks;
+                               if (devices[j].i.array.level >= 4 &&
+                                   devices[j].i.array.level <= 6 &&
+                                   i/2 >= content->array.raid_disks - delta)
+                                       /* OK */;
+                               else if (devices[j].i.array.level == 4 &&
+                                        i/2 >= content->array.raid_disks - delta - 1)
+                                       /* OK */;
+                               else
+                                       continue;
+                       }
+                       if (chosen_drive < 0 ||
                             devices[j].i.events
-                            > devices[chosen_drive].i.events))
+                           > devices[chosen_drive].i.events)
                                chosen_drive = j;
                }
                if (chosen_drive < 0)
@@ -1084,12 +1126,16 @@ static int start_array(int mdfd,
                                /* might need to increase the size
                                 * of the stripe cache - default is 256
                                 */
-                               if (256 < 4 * (content->array.chunk_size/4096)) {
+                               int chunk_size = content->array.chunk_size;
+                               if (content->reshape_active &&
+                                   content->new_chunk > chunk_size)
+                                       chunk_size = content->new_chunk;
+                               if (256 < 4 * ((chunk_size+4065)/4096)) {
                                        struct mdinfo *sra = sysfs_read(mdfd, NULL, 0);
                                        if (sra)
                                                sysfs_set_num(sra, NULL,
                                                              "stripe_cache_size",
-                                                             (4 * content->array.chunk_size / 4096) + 1);
+                                                             (4 * chunk_size / 4096) + 1);
                                        sysfs_free(sra);
                                }
                        }
@@ -1299,7 +1345,7 @@ try_again:
                       mddev ? mddev : "further assembly");
 
        content = &info;
-       if (st)
+       if (st && c->force)
                st->ignore_hw_compat = 1;
        num_devs = select_devices(devlist, ident, &st, &content, c,
                                  inargv, auto_assem);
@@ -1323,7 +1369,10 @@ try_again:
         */
        if (map_lock(&map))
                pr_err("failed to get exclusive lock on mapfile - continue anyway...\n");
-       mp = map_by_uuid(&map, content->uuid);
+       if (c->update && strcmp(c->update,"uuid") == 0)
+               mp = NULL;
+       else
+               mp = map_by_uuid(&map, content->uuid);
        if (mp) {
                struct mdinfo *dv;
                /* array already exists. */