]> git.ipfire.org Git - thirdparty/mdadm.git/blobdiff - Create.c
Introduce pr_err for printing error messages.
[thirdparty/mdadm.git] / Create.c
index 60e53f3642b0b4d54f1c740a8d8a27e5d924b6ae..f150954b7157b0202e7e540c8d79da397b506f08 100644 (file)
--- a/Create.c
+++ b/Create.c
@@ -31,8 +31,8 @@ static int default_layout(struct supertype *st, int level, int verbose)
 {
        int layout = UnSet;
 
-       if (st && st->ss->default_layout)
-               layout = st->ss->default_layout(level);
+       if (st && st->ss->default_geometry)
+               st->ss->default_geometry(st, &level, &layout, NULL);
 
        if (layout == UnSet)
                switch(level) {
@@ -42,22 +42,19 @@ static int default_layout(struct supertype *st, int level, int verbose)
                case 10:
                        layout = 0x102; /* near=2, far=1 */
                        if (verbose > 0)
-                               fprintf(stderr,
-                                       Name ": layout defaults to n1\n");
+                               pr_err("layout defaults to n2\n");
                        break;
                case 5:
                case 6:
                        layout = map_name(r5layout, "default");
                        if (verbose > 0)
-                               fprintf(stderr,
-                                       Name ": layout defaults to %s\n", map_num(r5layout, layout));
+                               pr_err("layout defaults to %s\n", map_num(r5layout, layout));
                        break;
                case LEVEL_FAULTY:
                        layout = map_name(faultylayout, "default");
 
                        if (verbose > 0)
-                               fprintf(stderr,
-                                       Name ": layout defaults to %s\n", map_num(faultylayout, layout));
+                               pr_err("layout defaults to %s\n", map_num(faultylayout, layout));
                        break;
                }
 
@@ -66,11 +63,13 @@ static int default_layout(struct supertype *st, int level, int verbose)
 
 
 int Create(struct supertype *st, char *mddev,
-          int chunk, int level, int layout, unsigned long long size, int raiddisks, int sparedisks,
+          int chunk, int level, int layout, unsigned long long size,
+          int raiddisks, int sparedisks,
           char *name, char *homehost, int *uuid,
-          int subdevs, mddev_dev_t devlist,
+          int subdevs, struct mddev_dev *devlist,
           int runstop, int verbose, int force, int assume_clean,
-          char *bitmap_file, int bitmap_chunk, int write_behind, int delay, int autof)
+          char *bitmap_file, int bitmap_chunk, int write_behind,
+          int delay, int autof)
 {
        /*
         * Create a new raid array.
@@ -93,7 +92,7 @@ int Create(struct supertype *st, char *mddev,
        char *mindisc = NULL;
        char *maxdisc = NULL;
        int dnum;
-       mddev_dev_t dv;
+       struct mddev_dev *dv;
        int fail=0, warn=0;
        struct stat stb;
        int first_missing = subdevs * 2;
@@ -112,6 +111,7 @@ int Create(struct supertype *st, char *mddev,
        struct mdinfo info, *infos;
        int did_default = 0;
        int do_default_layout = 0;
+       int do_default_chunk = 0;
        unsigned long safe_mode_delay = 0;
        char chosen_name[1024];
        struct map_ent *map = NULL;
@@ -120,38 +120,26 @@ int Create(struct supertype *st, char *mddev,
        int major_num = BITMAP_MAJOR_HI;
 
        memset(&info, 0, sizeof(info));
-
-       if (level == UnSet) {
-               /* "ddf" and "imsm" metadata only supports one level - should possibly
-                * push this into metadata handler??
-                */
-               if (st && (st->ss == &super_ddf || st->ss == &super_imsm))
-                       level = LEVEL_CONTAINER;
-       }
-
+       if (level == UnSet && st && st->ss->default_geometry)
+               st->ss->default_geometry(st, &level, NULL, NULL);
        if (level == UnSet) {
-               fprintf(stderr,
-                       Name ": a RAID level is needed to create an array.\n");
+               pr_err("a RAID level is needed to create an array.\n");
                return 1;
        }
        if (raiddisks < 4 && level == 6) {
-               fprintf(stderr,
-                       Name ": at least 4 raid-devices needed for level 6\n");
+               pr_err("at least 4 raid-devices needed for level 6\n");
                return 1;
        }
        if (raiddisks > 256 && level == 6) {
-               fprintf(stderr,
-                       Name ": no more than 256 raid-devices supported for level 6\n");
+               pr_err("no more than 256 raid-devices supported for level 6\n");
                return 1;
        }
        if (raiddisks < 2 && level >= 4) {
-               fprintf(stderr,
-                       Name ": at least 2 raid-devices needed for level 4 or 5\n");
+               pr_err("at least 2 raid-devices needed for level 4 or 5\n");
                return 1;
        }
        if (level <= 0 && sparedisks) {
-               fprintf(stderr,
-                       Name ": This level does not support spare devices\n");
+               pr_err("This level does not support spare devices\n");
                return 1;
        }
 
@@ -169,15 +157,15 @@ int Create(struct supertype *st, char *mddev,
                    inf.raid_disks == 0) {
                        /* yep, looks like a container */
                        if (st) {
-                               rv = st->ss->load_super(st, fd,
-                                                       devlist->devname);
+                               rv = st->ss->load_container(st, fd,
+                                                           devlist->devname);
                                if (rv == 0)
                                        have_container = 1;
                        } else {
-                               st = guess_super(fd);
+                               st = super_by_fd(fd, NULL);
                                if (st && !(rv = st->ss->
-                                           load_super(st, fd,
-                                                      devlist->devname)))
+                                           load_container(st, fd,
+                                                          devlist->devname)))
                                        have_container = 1;
                                else
                                        st = NULL;
@@ -193,21 +181,20 @@ int Create(struct supertype *st, char *mddev,
                        close(fd);
        }
        if (st && st->ss->external && sparedisks) {
-               fprintf(stderr,
-                       Name ": This metadata type does not support "
-                       "spare disks at create time\n");
+               pr_err("This metadata type does not support "
+                      "spare disks at create time\n");
                return 1;
        }
        if (subdevs > raiddisks+sparedisks) {
-               fprintf(stderr, Name ": You have listed more devices (%d) than are in the array(%d)!\n", subdevs, raiddisks+sparedisks);
+               pr_err("You have listed more devices (%d) than are in the array(%d)!\n", subdevs, raiddisks+sparedisks);
                return 1;
        }
        if (!have_container && subdevs < raiddisks+sparedisks) {
-               fprintf(stderr, Name ": You haven't given enough devices (real or missing) to create this array\n");
+               pr_err("You haven't given enough devices (real or missing) to create this array\n");
                return 1;
        }
        if (bitmap_file && level <= 0) {
-               fprintf(stderr, Name ": bitmaps not meaningful with level %s\n",
+               pr_err("bitmaps not meaningful with level %s\n",
                        map_num(pers, level)?:"given");
                return 1;
        }
@@ -223,7 +210,7 @@ int Create(struct supertype *st, char *mddev,
        if (level == 10)
                /* check layout fits in array*/
                if ((layout&255) * ((layout>>8)&255) > raiddisks) {
-                       fprintf(stderr, Name ": that layout requires at least %d devices\n",
+                       pr_err("that layout requires at least %d devices\n",
                                (layout&255) * ((layout>>8)&255));
                        return 1;
                }
@@ -234,10 +221,10 @@ int Create(struct supertype *st, char *mddev,
        case 10:
        case 6:
        case 0:
-               if (chunk == 0) {
-                       chunk = 512;
-                       if (verbose > 0)
-                               fprintf(stderr, Name ": chunk size defaults to 512K\n");
+               if (chunk == 0 || chunk == UnSet) {
+                       chunk = UnSet;
+                       do_default_chunk = 1;
+                       /* chunk will be set later */
                }
                break;
        case LEVEL_LINEAR:
@@ -245,7 +232,7 @@ int Create(struct supertype *st, char *mddev,
                if (get_linux_version() < 2006016 && chunk == 0) {
                        chunk = 64;
                        if (verbose > 0)
-                               fprintf(stderr, Name ": chunk size defaults to 64K\n");
+                               pr_err("chunk size defaults to 64K\n");
                }
                break;
        case 1:
@@ -255,24 +242,44 @@ int Create(struct supertype *st, char *mddev,
                if (chunk) {
                        chunk = 0;
                        if (verbose > 0)
-                               fprintf(stderr, Name ": chunk size ignored for this level\n");
+                               pr_err("chunk size ignored for this level\n");
                }
                break;
        default:
-               fprintf(stderr, Name ": unknown level %d\n", level);
+               pr_err("unknown level %d\n", level);
                return 1;
        }
        
-       if (size && chunk)
+       if (size && chunk && chunk != UnSet)
                size &= ~(unsigned long long)(chunk - 1);
        newsize = size * 2;
        if (st && ! st->ss->validate_geometry(st, level, layout, raiddisks,
-                                             chunk, size*2, NULL, &newsize, verbose>=0))
+                                             &chunk, size*2, NULL, &newsize, verbose>=0))
                return 1;
+
+       if (chunk && chunk != UnSet) {
+               newsize &= ~(unsigned long long)(chunk*2 - 1);
+               if (do_default_chunk) {
+                       /* default chunk was just set */
+                       if (verbose > 0)
+                               pr_err("chunk size "
+                                       "defaults to %dK\n", chunk);
+                       size &= ~(unsigned long long)(chunk - 1);
+                       do_default_chunk = 0;
+               }
+       }
+
        if (size == 0) {
                size = newsize / 2;
+               if (level == 1)
+                       /* If this is ever reshaped to RAID5, we will
+                        * need a chunksize.  So round it off a bit
+                        * now just to be safe
+                        */
+                       size &= ~(64ULL-1);
+
                if (size && verbose > 0)
-                       fprintf(stderr, Name ": setting size to %lluK\n",
+                       pr_err("setting size to %lluK\n",
                                (unsigned long long)size);
        }
 
@@ -283,6 +290,8 @@ int Create(struct supertype *st, char *mddev,
        for (dv=devlist; dv && !have_container; dv=dv->next, dnum++) {
                char *dname = dv->devname;
                unsigned long long freesize;
+               int dfd;
+
                if (strcasecmp(dname, "missing")==0) {
                        if (first_missing > dnum)
                                first_missing = dnum;
@@ -291,6 +300,20 @@ int Create(struct supertype *st, char *mddev,
                        missing_disks ++;
                        continue;
                }
+               dfd = open(dname, O_RDONLY);
+               if (dfd < 0) {
+                       pr_err("cannot open %s: %s\n",
+                               dname, strerror(errno));
+                       exit(2);
+               }
+               if (fstat(dfd, &stb) != 0 ||
+                   (stb.st_mode & S_IFMT) != S_IFBLK) {
+                       close(dfd);
+                       pr_err("%s is not a block device\n",
+                               dname);
+                       exit(2);
+               }
+               close(dfd);
                info.array.working_disks++;
                if (dnum < raiddisks)
                        info.array.active_disks++;
@@ -307,17 +330,36 @@ int Create(struct supertype *st, char *mddev,
                        char *name = "default";
                        for(i=0; !st && superlist[i]; i++) {
                                st = superlist[i]->match_metadata_desc(name);
+                               if (!st)
+                                       continue;
                                if (do_default_layout)
                                        layout = default_layout(st, level, verbose);
-                               if (st && !st->ss->validate_geometry
-                                               (st, level, layout, raiddisks,
-                                                chunk, size*2, dname, &freesize,
-                                                verbose > 0))
+                               switch (st->ss->validate_geometry(
+                                               st, level, layout, raiddisks,
+                                               &chunk, size*2, dname, &freesize,
+                                               verbose > 0)) {
+                               case -1: /* Not valid, message printed, and not
+                                         * worth checking any further */
+                                       exit(2);
+                                       break;
+                               case 0: /* Geometry not valid */
+                                       free(st);
                                        st = NULL;
+                                       chunk = do_default_chunk ? UnSet : chunk;
+                                       break;
+                               case 1: /* All happy */
+                                       break;
+                               }
                        }
 
                        if (!st) {
-                               fprintf(stderr, Name ": device %s not suitable "
+                               int dfd = open(dname, O_RDONLY|O_EXCL);
+                               if (dfd < 0) {
+                                       pr_err("cannot open %s: %s\n",
+                                               dname, strerror(errno));
+                                       exit(2);
+                               }
+                               pr_err("device %s not suitable "
                                        "for any style of array\n",
                                        dname);
                                exit(2);
@@ -327,30 +369,37 @@ int Create(struct supertype *st, char *mddev,
                                did_default = 1;
                } else {
                        if (do_default_layout)
-                               layout = default_layout(st, level, verbose);
+                               layout = default_layout(st, level, 0);
                        if (!st->ss->validate_geometry(st, level, layout,
                                                       raiddisks,
-                                                      chunk, size*2, dname,
+                                                      &chunk, size*2, dname,
                                                       &freesize,
                                                       verbose >= 0)) {
 
-                               fprintf(stderr,
-                                       Name ": %s is not suitable for "
-                                       "this array.\n",
-                                       dname);
+                               pr_err("%s is not suitable for "
+                                      "this array.\n",
+                                      dname);
                                fail = 1;
                                continue;
                        }
                }
 
                freesize /= 2; /* convert to K */
-               if (chunk) {
+               if (chunk && chunk != UnSet) {
                        /* round to chunk size */
                        freesize = freesize & ~(chunk-1);
+                       if (do_default_chunk) {
+                               /* default chunk was just set */
+                               if (verbose > 0)
+                                       pr_err("chunk size "
+                                               "defaults to %dK\n", chunk);
+                               size &= ~(unsigned long long)(chunk - 1);
+                               do_default_chunk = 0;
+                       }
                }
 
                if (size && freesize < size) {
-                       fprintf(stderr, Name ": %s is smaller than given size."
+                       pr_err("%s is smaller than given size."
                                " %lluK < %lluK + metadata\n",
                                dname, freesize, size);
                        fail = 1;
@@ -367,7 +416,7 @@ int Create(struct supertype *st, char *mddev,
                if (runstop != 1 || verbose >= 0) {
                        int fd = open(dname, O_RDONLY);
                        if (fd <0 ) {
-                               fprintf(stderr, Name ": Cannot open %s: %s\n",
+                               pr_err("Cannot open %s: %s\n",
                                        dname, strerror(errno));
                                fail=1;
                                continue;
@@ -375,18 +424,47 @@ int Create(struct supertype *st, char *mddev,
                        warn |= check_ext2(fd, dname);
                        warn |= check_reiser(fd, dname);
                        warn |= check_raid(fd, dname);
+                       if (strcmp(st->ss->name, "1.x") == 0 &&
+                           st->minor_version >= 1)
+                               /* metadata at front */
+                               warn |= check_partitions(fd, dname, 0, 0);
+                       else if (level == 1 || level == LEVEL_CONTAINER
+                                   || (level == 0 && raiddisks == 1))
+                               /* partitions could be meaningful */
+                               warn |= check_partitions(fd, dname, freesize*2, size*2);
+                       else
+                               /* partitions cannot be meaningful */
+                               warn |= check_partitions(fd, dname, 0, 0);
+                       if (strcmp(st->ss->name, "1.x") == 0 &&
+                           st->minor_version >= 1 &&
+                           did_default &&
+                           level == 1 &&
+                           (warn & 1024) == 0) {
+                               warn |= 1024;
+                               pr_err("Note: this array has metadata at the start and\n"
+                                       "    may not be suitable as a boot device.  If you plan to\n"
+                                       "    store '/boot' on this device please ensure that\n"
+                                       "    your boot-loader understands md/v1.x metadata, or use\n"
+                                       "    --metadata=0.90\n");
+                       }
                        close(fd);
                }
        }
+       if (raiddisks + sparedisks > st->max_devs) {
+               pr_err("Too many devices:"
+                       " %s metadata only supports %d\n",
+                       st->ss->name, st->max_devs);
+               return 1;
+       }
        if (have_container)
                info.array.working_disks = raiddisks;
        if (fail) {
-               fprintf(stderr, Name ": create aborted\n");
+               pr_err("create aborted\n");
                return 1;
        }
        if (size == 0) {
                if (mindisc == NULL && !have_container) {
-                       fprintf(stderr, Name ": no size and no drives given - aborting create.\n");
+                       pr_err("no size and no drives given - aborting create.\n");
                        return 1;
                }
                if (level > 0 || level == LEVEL_MULTIPATH
@@ -395,26 +473,32 @@ int Create(struct supertype *st, char *mddev,
                        /* size is meaningful */
                        if (!st->ss->validate_geometry(st, level, layout,
                                                       raiddisks,
-                                                      chunk, minsize*2,
+                                                      &chunk, minsize*2,
                                                       NULL, NULL, 0)) {
-                               fprintf(stderr, Name ": devices too large for RAID level %d\n", level);
+                               pr_err("devices too large for RAID level %d\n", level);
                                return 1;
                        }
                        size = minsize;
+                       if (level == 1)
+                               /* If this is ever reshaped to RAID5, we will
+                                * need a chunksize.  So round it off a bit
+                                * now just to be safe
+                                */
+                               size &= ~(64ULL-1);
                        if (verbose > 0)
-                               fprintf(stderr, Name ": size set to %lluK\n", size);
+                               pr_err("size set to %lluK\n", size);
                }
        }
        if (!have_container && level > 0 && ((maxsize-size)*100 > maxsize)) {
                if (runstop != 1 || verbose >= 0)
-                       fprintf(stderr, Name ": largest drive (%s) exceeds size (%lluK) by more than 1%%\n",
+                       pr_err("largest drive (%s) exceeds size (%lluK) by more than 1%%\n",
                                maxdisc, size);
                warn = 1;
        }
 
        if (st->ss->detail_platform && st->ss->detail_platform(0, 1) != 0) {
                if (runstop != 1 || verbose >= 0)
-                       fprintf(stderr, Name ": %s unable to enumerate platform support\n"
+                       pr_err("%s unable to enumerate platform support\n"
                                "    array may not be compatible with hardware/firmware\n",
                                st->ss->name);
                warn = 1;
@@ -423,12 +507,12 @@ int Create(struct supertype *st, char *mddev,
        if (warn) {
                if (runstop!= 1) {
                        if (!ask("Continue creating array? ")) {
-                               fprintf(stderr, Name ": create aborted.\n");
+                               pr_err("create aborted.\n");
                                return 1;
                        }
                } else {
                        if (verbose > 0)
-                               fprintf(stderr, Name ": creation continuing despite oddities due to --run\n");
+                               pr_err("creation continuing despite oddities due to --run\n");
                }
        }
 
@@ -465,30 +549,43 @@ int Create(struct supertype *st, char *mddev,
        }
 
        if (level <= 0 && first_missing < subdevs * 2) {
-               fprintf(stderr,
-                       Name ": This level does not support missing devices\n");
+               pr_err("This level does not support missing devices\n");
                return 1;
        }
 
        /* We need to create the device */
        map_lock(&map);
        mdfd = create_mddev(mddev, name, autof, LOCAL, chosen_name);
-       if (mdfd < 0)
+       if (mdfd < 0) {
+               map_unlock(&map);
+               return 1;
+       }
+       /* verify if chosen_name is not in use,
+        * it could be in conflict with already existing device
+        * e.g. container, array
+        */
+       if (strncmp(chosen_name, "/dev/md/", 8) == 0
+           && map_by_name(&map, chosen_name+8) != NULL) {
+               pr_err("Array name %s is in use already.\n",
+                       chosen_name);
+               close(mdfd);
+               map_unlock(&map);
                return 1;
+       }
        mddev = chosen_name;
 
        vers = md_get_version(mdfd);
        if (vers < 9000) {
-               fprintf(stderr, Name ": Create requires md driver version 0.90.0 or later\n");
-               goto abort;
+               pr_err("Create requires md driver version 0.90.0 or later\n");
+               goto abort_locked;
        } else {
                mdu_array_info_t inf;
                memset(&inf, 0, sizeof(inf));
                ioctl(mdfd, GET_ARRAY_INFO, &inf);
                if (inf.working_disks != 0) {
-                       fprintf(stderr, Name ": another array by this name"
+                       pr_err("another array by this name"
                                " is already running.\n");
-                       goto abort;
+                       goto abort_locked;
                }
        }
 
@@ -516,7 +613,7 @@ int Create(struct supertype *st, char *mddev,
             assume_clean
                ) {
                info.array.state = 1; /* clean, but one+ drive will be missing*/
-               info.resync_start = ~0ULL;
+               info.resync_start = MaxSector;
        } else {
                info.array.state = 0; /* not clean, but no errors */
                info.resync_start = 0;
@@ -584,11 +681,11 @@ int Create(struct supertype *st, char *mddev,
                }
        }
        if (!st->ss->init_super(st, &info.array, size, name, homehost, uuid))
-               goto abort;
+               goto abort_locked;
 
        total_slots = info.array.nr_disks;
+       st->ss->getinfo_super(st, &info, NULL);
        sysfs_init(&info, mdfd, 0);
-       st->ss->getinfo_super(st, &info);
 
        if (did_default && verbose >= 0) {
                if (is_subarray(info.text_version)) {
@@ -603,12 +700,12 @@ int Create(struct supertype *st, char *mddev,
 
                        mdi = sysfs_read(-1, dnum, GET_VERSION);
 
-                       fprintf(stderr, Name ": Creating array inside "
+                       pr_err("Creating array inside "
                                "%s container %s\n", 
                                mdi?mdi->text_version:"managed", path);
                        sysfs_free(mdi);
                } else
-                       fprintf(stderr, Name ": Defaulting to version"
+                       pr_err("Defaulting to version"
                                " %s metadata\n", info.text_version);
        }
 
@@ -619,20 +716,25 @@ int Create(struct supertype *st, char *mddev,
        if (bitmap_file && vers < 9003) {
                major_num = BITMAP_MAJOR_HOSTENDIAN;
 #ifdef __BIG_ENDIAN
-               fprintf(stderr, Name ": Warning - bitmaps created on this kernel are not portable\n"
+               pr_err("Warning - bitmaps created on this kernel are not portable\n"
                        "  between different architectured.  Consider upgrading the Linux kernel.\n");
 #endif
        }
 
        if (bitmap_file && strcmp(bitmap_file, "internal")==0) {
                if ((vers%100) < 2) {
-                       fprintf(stderr, Name ": internal bitmaps not supported by this kernel.\n");
+                       pr_err("internal bitmaps not supported by this kernel.\n");
+                       goto abort;
+               }
+               if (!st->ss->add_internal_bitmap) {
+                       pr_err("internal bitmaps not supported with %s metadata\n",
+                               st->ss->name);
                        goto abort;
                }
                if (!st->ss->add_internal_bitmap(st, &bitmap_chunk,
                                                 delay, write_behind,
                                                 bitmapsize, 1, major_num)) {
-                       fprintf(stderr, Name ": Given bitmap chunk size not supported.\n");
+                       pr_err("Given bitmap chunk size not supported.\n");
                        goto abort;
                }
                bitmap_file = NULL;
@@ -641,7 +743,7 @@ int Create(struct supertype *st, char *mddev,
 
        sysfs_init(&info, mdfd, 0);
 
-       if (st->ss->external && st->subarray[0]) {
+       if (st->ss->external && st->container_dev != NoMdDev) {
                /* member */
 
                /* When creating a member, we need to be careful
@@ -658,13 +760,13 @@ int Create(struct supertype *st, char *mddev,
                 */
                container_fd = open_dev_excl(st->container_dev);
                if (container_fd < 0) {
-                       fprintf(stderr, Name ": Cannot get exclusive "
+                       pr_err("Cannot get exclusive "
                                "open on container - weird.\n");
                        goto abort;
                }
                if (mdmon_running(st->container_dev)) {
                        if (verbose)
-                               fprintf(stderr, Name ": reusing mdmon "
+                               pr_err("reusing mdmon "
                                        "for %s.\n",
                                        devnum2devname(st->container_dev));
                        st->update_tail = &st->updates;
@@ -673,7 +775,7 @@ int Create(struct supertype *st, char *mddev,
        }
        rv = set_array_info(mdfd, st, &info);
        if (rv) {
-               fprintf(stderr, Name ": failed to set array info for %s: %s\n",
+               pr_err("failed to set array info for %s: %s\n",
                        mddev, strerror(errno));
                goto abort;
        }
@@ -690,21 +792,25 @@ int Create(struct supertype *st, char *mddev,
                }
                bitmap_fd = open(bitmap_file, O_RDWR);
                if (bitmap_fd < 0) {
-                       fprintf(stderr, Name ": weird: %s cannot be openned\n",
+                       pr_err("weird: %s cannot be openned\n",
                                bitmap_file);
                        goto abort;
                }
                if (ioctl(mdfd, SET_BITMAP_FILE, bitmap_fd) < 0) {
-                       fprintf(stderr, Name ": Cannot set bitmap file for %s: %s\n",
+                       pr_err("Cannot set bitmap file for %s: %s\n",
                                mddev, strerror(errno));
                        goto abort;
                }
        }
 
        infos = malloc(sizeof(*infos) * total_slots);
+       if (!infos) {
+               pr_err("Unable to allocate memory\n");
+               goto abort;
+       }
 
        for (pass=1; pass <=2 ; pass++) {
-               mddev_dev_t moved_disk = NULL; /* the disk that was moved out of the insert point */
+               struct mddev_dev *moved_disk = NULL; /* the disk that was moved out of the insert point */
 
                for (dnum=0, dv = devlist ; dv ;
                     dv=(dv->next)?(dv->next):moved_disk, dnum++) {
@@ -744,13 +850,14 @@ int Create(struct supertype *st, char *mddev,
                                if (have_container)
                                        fd = -1;
                                else {
-                                       if (st->ss->external && st->subarray[0])
+                                       if (st->ss->external &&
+                                           st->container_dev != NoMdDev)
                                                fd = open(dv->devname, O_RDWR);
                                        else
                                                fd = open(dv->devname, O_RDWR|O_EXCL);
 
                                        if (fd < 0) {
-                                               fprintf(stderr, Name ": failed to open %s "
+                                               pr_err("failed to open %s "
                                                        "after earlier success - aborting\n",
                                                        dv->devname);
                                                goto abort;
@@ -762,13 +869,15 @@ int Create(struct supertype *st, char *mddev,
                                if (fd >= 0)
                                        remove_partitions(fd);
                                if (st->ss->add_to_super(st, &inf->disk,
-                                                        fd, dv->devname))
+                                                        fd, dv->devname)) {
+                                       ioctl(mdfd, STOP_ARRAY, NULL);
                                        goto abort;
-                               st->ss->getinfo_super(st, inf);
+                               }
+                               st->ss->getinfo_super(st, inf, NULL);
                                safe_mode_delay = inf->safe_mode_delay;
 
                                if (have_container && verbose > 0)
-                                       fprintf(stderr, Name ": Using %s for device %d\n",
+                                       pr_err("Using %s for device %d\n",
                                                map_dev(inf->disk.major,
                                                        inf->disk.minor,
                                                        0), dnum);
@@ -781,16 +890,13 @@ int Create(struct supertype *st, char *mddev,
                                break;
                        case 2:
                                inf->errors = 0;
-                               rv = 0;
 
                                rv = add_disk(mdfd, st, &info, inf);
 
                                if (rv) {
-                                       fprintf(stderr,
-                                               Name ": ADD_NEW_DISK for %s "
-                                               "failed: %s\n",
-                                               dv->devname, strerror(errno));
-                                       st->ss->free_super(st);
+                                       pr_err("ADD_NEW_DISK for %s "
+                                              "failed: %s\n",
+                                              dv->devname, strerror(errno));
                                        goto abort;
                                }
                                break;
@@ -809,7 +915,7 @@ int Create(struct supertype *st, char *mddev,
                         * again returns container info.
                         */
                        map_lock(&map);
-                       st->ss->getinfo_super(st, &info_new);
+                       st->ss->getinfo_super(st, &info_new, NULL);
                        if (st->ss->external && level != LEVEL_CONTAINER &&
                            !same_uuid(info_new.uuid, info.uuid, 0)) {
                                map_update(&map, fd2devnum(mdfd),
@@ -818,13 +924,16 @@ int Create(struct supertype *st, char *mddev,
                                me = map_by_devnum(&map, st->container_dev);
                        }
 
-                       st->ss->write_init_super(st);
+                       if (st->ss->write_init_super(st)) {
+                               st->ss->free_super(st);
+                               goto abort_locked;
+                       }
 
                        /* update parent container uuid */
                        if (me) {
                                char *path = strdup(me->path);
 
-                               st->ss->getinfo_super(st, &info_new);
+                               st->ss->getinfo_super(st, &info_new, NULL);
                                map_update(&map, st->container_dev,
                                           info_new.text_version,
                                           info_new.uuid, path);
@@ -833,61 +942,77 @@ int Create(struct supertype *st, char *mddev,
                        map_unlock(&map);
 
                        flush_metadata_updates(st);
+                       st->ss->free_super(st);
                }
        }
        free(infos);
-       st->ss->free_super(st);
 
        if (level == LEVEL_CONTAINER) {
                /* No need to start.  But we should signal udev to
                 * create links */
                sysfs_uevent(&info, "change");
                if (verbose >= 0)
-                       fprintf(stderr, Name ": container %s prepared.\n", mddev);
+                       pr_err("container %s prepared.\n", mddev);
                wait_for(chosen_name, mdfd);
        } else if (runstop == 1 || subdevs >= raiddisks) {
                if (st->ss->external) {
+                       int err;
                        switch(level) {
                        case LEVEL_LINEAR:
                        case LEVEL_MULTIPATH:
                        case 0:
-                               sysfs_set_str(&info, NULL, "array_state",
-                                             "active");
+                               err = sysfs_set_str(&info, NULL, "array_state",
+                                                   "active");
                                need_mdmon = 0;
                                break;
                        default:
-                               sysfs_set_str(&info, NULL, "array_state",
-                                             "readonly");
+                               err = sysfs_set_str(&info, NULL, "array_state",
+                                                   "readonly");
                                break;
                        }
                        sysfs_set_safemode(&info, safe_mode_delay);
+                       if (err) {
+                               pr_err("failed to"
+                                      " activate array.\n");
+                               ioctl(mdfd, STOP_ARRAY, NULL);
+                               goto abort;
+                       }
                } else {
                        /* param is not actually used */
                        mdu_param_t param;
                        if (ioctl(mdfd, RUN_ARRAY, &param)) {
-                               fprintf(stderr, Name ": RUN_ARRAY failed: %s\n",
+                               pr_err("RUN_ARRAY failed: %s\n",
                                        strerror(errno));
-                               Manage_runstop(mddev, mdfd, -1, 0);
+                               if (info.array.chunk_size & (info.array.chunk_size-1)) {
+                                       cont_err("Problem may be that "
+                                                "chunk size is not a power of 2\n");
+                               }
+                               ioctl(mdfd, STOP_ARRAY, NULL);
                                goto abort;
                        }
                }
                if (verbose >= 0)
-                       fprintf(stderr, Name ": array %s started.\n", mddev);
-               if (st->ss->external && st->subarray[0]) {
+                       pr_err("array %s started.\n", mddev);
+               if (st->ss->external && st->container_dev != NoMdDev) {
                        if (need_mdmon)
                                start_mdmon(st->container_dev);
 
-                       ping_monitor(devnum2devname(st->container_dev));
+                       ping_monitor_by_id(st->container_dev);
                        close(container_fd);
                }
                wait_for(chosen_name, mdfd);
        } else {
-               fprintf(stderr, Name ": not starting array - not enough devices.\n");
+               pr_err("not starting array - not enough devices.\n");
        }
        close(mdfd);
        return 0;
 
  abort:
+       map_lock(&map);
+ abort_locked:
+       map_remove(&map, fd2devnum(mdfd));
+       map_unlock(&map);
+
        if (mdfd >= 0)
                close(mdfd);
        return 1;