]> git.ipfire.org Git - thirdparty/mdadm.git/blobdiff - Grow.c
remove ANNOUNCE-2.0-devel-?
[thirdparty/mdadm.git] / Grow.c
diff --git a/Grow.c b/Grow.c
index 82283bc8a580698cfde856ae181b80f3cedc20f9..623daf3fe910ec08c3fb16e1f203eaca9f6a6b68 100644 (file)
--- a/Grow.c
+++ b/Grow.c
@@ -45,20 +45,27 @@ int Grow_Add_device(char *devname, int fd, char *newdev)
         * all other devices.
         * This means that we need to *find* all other devices.
         */
-       mdu_array_info_t array;
-       mdu_disk_info_t disk;
-       mdp_super_t super;
+       struct mdinfo info;
+
+       void *super = NULL;
        struct stat stb;
        int nfd, fd2;
        int d, nd;
+       struct supertype *st = NULL;
        
 
-       if (ioctl(fd, GET_ARRAY_INFO, &array) < 0) {
+       if (ioctl(fd, GET_ARRAY_INFO, &info.array) < 0) {
                fprintf(stderr, Name ": cannot get array info for %s\n", devname);
                return 1;
        }
 
-       if (array.level != -1) {
+       st = super_by_version(info.array.major_version, info.array.minor_version);
+       if (!st) {
+               fprintf(stderr, Name ": cannot handle arrays with superblock version %d\n", info.array.major_version);
+               return 1;
+       }
+
+       if (info.array.level != -1) {
                fprintf(stderr, Name ": can only add devices to linear arrays\n");
                return 1;
        }
@@ -75,7 +82,7 @@ int Grow_Add_device(char *devname, int fd, char *newdev)
                return 1;
        }
        /* now check out all the devices and make sure we can read the superblock */
-       for (d=0 ; d < array.raid_disks ; d++) {
+       for (d=0 ; d < info.array.raid_disks ; d++) {
                mdu_disk_info_t disk;
                char *dv;
 
@@ -96,7 +103,9 @@ int Grow_Add_device(char *devname, int fd, char *newdev)
                        fprintf(stderr, Name ": cannot open device file %s\n", dv);
                        return 1;
                }
-               if (load_super(fd2, &super)) {
+               if (super) free(super);
+               super= NULL;
+               if (st->ss->load_super(st, fd2, &super, NULL)) {
                        fprintf(stderr, Name ": cannot find super block on %s\n", dv);
                        close(fd2);
                        return 1;
@@ -107,27 +116,21 @@ int Grow_Add_device(char *devname, int fd, char *newdev)
         * newdev.
         */
        
-       memset(&super.disks[d], 0, sizeof(super.disks[d]));
-       super.disks[d].number = d;
-       super.disks[d].major = MAJOR(stb.st_rdev);
-       super.disks[d].minor = MINOR(stb.st_rdev);
-       super.disks[d].raid_disk = d;
-       super.disks[d].state = (1 << MD_DISK_SYNC) | (1 << MD_DISK_ACTIVE);
-
-       super.this_disk = super.disks[d];
-       super.sb_csum = calc_sb_csum(&super);
-       if (store_super(nfd, &super)) {
+       info.disk.number = d;
+       info.disk.major = major(stb.st_rdev);
+       info.disk.minor = minor(stb.st_rdev);
+       info.disk.raid_disk = d;
+       info.disk.state = (1 << MD_DISK_SYNC) | (1 << MD_DISK_ACTIVE);
+       st->ss->update_super(&info, super, "grow", newdev, 0);
+
+       if (st->ss->store_super(st, nfd, super)) {
                fprintf(stderr, Name ": Cannot store new superblock on %s\n", newdev);
                close(nfd);
                return 1;
        }
-       disk.number = d;
-       disk.major = MAJOR(stb.st_rdev);
-       disk.minor = MINOR(stb.st_rdev);
-       disk.raid_disk = d;
-       disk.state = (1 << MD_DISK_SYNC) | (1 << MD_DISK_ACTIVE);
        close(nfd);
-       if (ioctl(fd, ADD_NEW_DISK, &disk) != 0) {
+
+       if (ioctl(fd, ADD_NEW_DISK, &info.disk) != 0) {
                fprintf(stderr, Name ": Cannot add new disk to this array\n");
                return 1;
        }
@@ -135,13 +138,13 @@ int Grow_Add_device(char *devname, int fd, char *newdev)
         * Now go through and update all superblocks
         */
 
-       if (ioctl(fd, GET_ARRAY_INFO, &array) < 0) {
+       if (ioctl(fd, GET_ARRAY_INFO, &info.array) < 0) {
                fprintf(stderr, Name ": cannot get array info for %s\n", devname);
                return 1;
        }
 
        nd = d;
-       for (d=0 ; d < array.raid_disks ; d++) {
+       for (d=0 ; d < info.array.raid_disks ; d++) {
                mdu_disk_info_t disk;
                char *dv;
 
@@ -162,25 +165,23 @@ int Grow_Add_device(char *devname, int fd, char *newdev)
                        fprintf(stderr, Name ": cannot open device file %s\n", dv);
                        return 1;
                }
-               if (load_super(fd2, &super)) {
+               if (st->ss->load_super(st, fd2, &super, NULL)) {
                        fprintf(stderr, Name ": cannot find super block on %s\n", dv);
                        close(fd);
                        return 1;
                }
-               super.raid_disks = nd+1;
-               super.nr_disks = nd+1;
-               super.active_disks = nd+1;
-               super.working_disks = nd+1;
-               memset(&super.disks[nd], 0, sizeof(super.disks[nd]));
-               super.disks[nd].number = nd;
-               super.disks[nd].major = MAJOR(stb.st_rdev);
-               super.disks[nd].minor = MINOR(stb.st_rdev);
-               super.disks[nd].raid_disk = nd;
-               super.disks[nd].state = (1 << MD_DISK_SYNC) | (1 << MD_DISK_ACTIVE);
-
-               super.this_disk = super.disks[d];
-               super.sb_csum = calc_sb_csum(&super);
-               if (store_super(fd2, &super)) {
+               info.array.raid_disks = nd+1;
+               info.array.nr_disks = nd+1;
+               info.array.active_disks = nd+1;
+               info.array.working_disks = nd+1;
+               info.disk.number = nd;
+               info.disk.major = major(stb.st_rdev);
+               info.disk.minor = minor(stb.st_rdev);
+               info.disk.raid_disk = nd;
+               info.disk.state = (1 << MD_DISK_SYNC) | (1 << MD_DISK_ACTIVE);
+               st->ss->update_super(&info, super, "grow", dv, 0);
+               
+               if (st->ss->store_super(st, fd2, super)) {
                        fprintf(stderr, Name ": Cannot store new superblock on %s\n", dv);
                        close(fd2);
                        return 1;
@@ -190,3 +191,154 @@ int Grow_Add_device(char *devname, int fd, char *newdev)
 
        return 0;
 }
+
+int Grow_addbitmap(char *devname, int fd, char *file, int chunk, int delay, int write_behind)
+{
+       /*
+        * First check that array doesn't have a bitmap
+        * Then create the bitmap
+        * Then add it
+        *
+        * For internal bitmaps, we need to check the version,
+        * find all the active devices, and write the bitmap block
+        * to all devices
+        */
+       mdu_bitmap_file_t bmf;
+       mdu_array_info_t array;
+       struct supertype *st;
+
+       if (ioctl(fd, GET_BITMAP_FILE, &bmf) != 0) {
+               if (errno == ENOMEM) 
+                       fprintf(stderr, Name ": Memory allocation failure.\n");
+               else
+                       fprintf(stderr, Name ": bitmaps not supported by this kernel.\n");
+               return 1;
+       }
+       if (bmf.pathname[0]) {
+               if (strcmp(file,"none")==0) {
+                       if (ioctl(fd, SET_BITMAP_FILE, -1)!= 0) {
+                               fprintf(stderr, Name ": failed to remove bitmap %s\n",
+                                       bmf.pathname);
+                               return 1;
+                       }
+                       return 0;
+               }
+               fprintf(stderr, Name ": %s already has a bitmap (%s)\n",
+                       devname, bmf.pathname);
+               return 1;
+       }
+       if (ioctl(fd, GET_ARRAY_INFO, &array) != 0) {
+               fprintf(stderr, Name ": cannot get array status for %s\n", devname);
+               return 1;
+       }
+       if (array.state & (1<<MD_SB_BITMAP_PRESENT)) {
+               if (strcmp(file, "none")==0) {
+                       array.state &= ~(1<<MD_SB_BITMAP_PRESENT);
+                       if (ioctl(fd, SET_ARRAY_INFO, &array)!= 0) {
+                               fprintf(stderr, Name ": failed to remove internal bitmap.\n");
+                               return 1;
+                       }
+                       return 0;
+               }
+               fprintf(stderr, Name ": Internal bitmap already present on %s\n",
+                       devname);
+               return 1;
+       }
+       st = super_by_version(array.major_version, array.minor_version);
+       if (!st) {
+               fprintf(stderr, Name ": Cannot understand version %d.%d\n",
+                       array.major_version, array.minor_version);
+               return 1;
+       }
+       if (strcmp(file, "none") == 0) {
+               fprintf(stderr, Name ": no bitmap found on %s\n", devname);
+               return 1;
+       } else if (strcmp(file, "internal") == 0) {
+               int d;
+               for (d=0; d< st->max_devs; d++) {
+                       mdu_disk_info_t disk;
+                       char *dv;
+                       disk.number = d;
+                       if (ioctl(fd, GET_DISK_INFO, &disk) < 0)
+                               continue;
+                       if (disk.major == 0 &&
+                           disk.minor == 0)
+                               continue;
+                       if ((disk.state & (1<<MD_DISK_SYNC))==0)
+                               continue;
+                       dv = map_dev(disk.major, disk.minor);
+                       if (dv) {
+                               void *super;
+                               int fd2 = open(dv, O_RDWR);
+                               if (fd2 < 0)
+                                       continue;
+                               if (st->ss->load_super(st, fd2, &super, NULL)==0) {
+                                       st->ss->add_internal_bitmap(st, super,
+                                                                   chunk, delay, write_behind,
+                                                                   array.size);
+                                       st->ss->write_bitmap(st, fd2, super);
+                               }
+                               close(fd2);
+                       }
+               }
+               array.state |= (1<<MD_SB_BITMAP_PRESENT);
+               if (ioctl(fd, SET_ARRAY_INFO, &array)!= 0) {
+                       fprintf(stderr, Name ": failed to set internal bitmap.\n");
+                       return 1;
+               }
+       } else {
+               int uuid[4];
+               int bitmap_fd;
+               int d;
+               int max_devs = st->max_devs;
+               void *super = NULL;
+               if (chunk == UnSet)
+                       chunk = DEFAULT_BITMAP_CHUNK;
+
+               /* try to load a superblock */
+               for (d=0; d<max_devs; d++) {
+                       mdu_disk_info_t disk;
+                       char *dv;
+                       int fd2;
+                       disk.number = d;
+                       if (ioctl(fd, GET_DISK_INFO, &disk) < 0)
+                               continue;
+                       if ((disk.major==0 && disk.minor==0) ||
+                           (disk.state & (1<<MD_DISK_REMOVED)))
+                               continue;
+                       dv = map_dev(disk.major, disk.minor);
+                       if (!dv) continue;
+                       fd2 = open(dv, O_RDONLY);
+                       if (fd2 >= 0 &&
+                           st->ss->load_super(st, fd2, &super, NULL) == 0) {
+                               close(fd2);
+                               st->ss->uuid_from_super(uuid, super);
+                               break;
+                       }
+                       close(fd2);
+               }
+               if (d == max_devs) {
+                       fprintf(stderr, Name ": cannot find UUID for array!\n");
+                       return 1;
+               }
+               if (CreateBitmap(file, 0, (char*)uuid, chunk,
+                                delay, write_behind, array.size*2ULL)) {
+                       return 1;
+               }
+               bitmap_fd = open(file, O_RDWR);
+               if (bitmap_fd < 0) {
+                       fprintf(stderr, Name ": weird: %s cannot be openned\n",
+                               file);
+                       return 1;
+               }
+               if (ioctl(fd, SET_BITMAP_FILE, bitmap_fd) < 0) {
+                       fprintf(stderr, Name ": Cannot set bitmap file for %s: %s\n",
+                               devname, strerror(errno));
+                       return 1;
+               }
+       }
+
+       return 0;
+}
+
+