]> git.ipfire.org Git - thirdparty/mdadm.git/blobdiff - Assemble.c
Change MAJOR() etc to major() etc
[thirdparty/mdadm.git] / Assemble.c
index cddb76fafbc56897ea0135ea1e827c618d795c4b..4003e06a547bd89b257840c2bf1171270c64530b 100644 (file)
@@ -98,8 +98,8 @@ int Assemble(char *mddev, int mdfd,
        mdp_super_t first_super, super;
        struct {
                char *devname;
-               int major, minor;
-               int oldmajor, oldminor;
+               unsigned int major, minor;
+               unsigned int oldmajor, oldminor;
                long long events;
                time_t utime;
                int uptodate;
@@ -107,16 +107,17 @@ int Assemble(char *mddev, int mdfd,
                int raid_disk;
        } *devices;
        int *best = NULL; /* indexed by raid_disk */
-       int bestcnt = 0;
-       int devcnt = 0, okcnt, sparecnt;
-       int req_cnt;
-       int i;
+       unsigned int bestcnt = 0;
+       int devcnt = 0;
+       unsigned int okcnt, sparecnt;
+       unsigned int req_cnt;
+       unsigned int i;
        int most_recent = 0;
        int chosen_drive;
        int change = 0;
        int inargv = 0;
        int start_partial_ok = force || devlist==NULL;
-       int num_devs;
+       unsigned int num_devs;
        mddev_dev_t tmpdev;
        
        vers = md_get_version(mdfd);
@@ -224,21 +225,21 @@ int Assemble(char *mddev, int mdfd,
                                        devname);
                        continue;
                }
-               if (ident->super_minor >= 0 &&
+               if (ident->super_minor != UnSet &&
                    (!havesuper || ident->super_minor != super.md_minor)) {
                        if (inargv || verbose)
                                fprintf(stderr, Name ": %s has wrong super-minor.\n",
                                        devname);
                        continue;
                }
-               if (ident->level != -10 &&
-                   (!havesuper|| ident->level != super.level)) {
+               if (ident->level != UnSet &&
+                   (!havesuper|| ident->level != (int)super.level)) {
                        if (inargv || verbose)
                                fprintf(stderr, Name ": %s has wrong raid level.\n",
                                        devname);
                        continue;
                }
-               if (ident->raid_disks != -1 &&
+               if (ident->raid_disks != UnSet &&
                    (!havesuper || ident->raid_disks!= super.raid_disks)) {
                        if (inargv || verbose)
                                fprintf(stderr, Name ": %s requires wrong number of drives.\n",
@@ -287,11 +288,43 @@ int Assemble(char *mddev, int mdfd,
                        if (strcmp(update, "super-minor") ==0) {
                                struct stat stb2;
                                fstat(mdfd, &stb2);
-                               super.md_minor = MINOR(stb2.st_rdev);
+                               super.md_minor = minor(stb2.st_rdev);
                                if (verbose)
                                        fprintf(stderr, Name ": updating superblock of %s with minor number %d\n",
                                                devname, super.md_minor);
                        }
+                       if (strcmp(update, "summaries") == 0) {
+                               /* set nr_disks, active_disks, working_disks,
+                                * failed_disks, spare_disks based on disks[] 
+                                * array in superblock.
+                                * Also make sure extra slots aren't 'failed'
+                                */
+                               super.nr_disks = super.active_disks =
+                                       super.working_disks = super.failed_disks =
+                                       super.spare_disks = 0;
+                               for (i=0; i < MD_SB_DISKS ; i++) 
+                                       if (super.disks[i].major ||
+                                           super.disks[i].minor) {
+                                               int state = super.disks[i].state;
+                                               if (state & (1<<MD_DISK_REMOVED))
+                                                       continue;
+                                               super.nr_disks++;
+                                               if (state & (1<<MD_DISK_ACTIVE))
+                                                       super.active_disks++;
+                                               if (state & (1<<MD_DISK_FAULTY))
+                                                       super.failed_disks++;
+                                               else
+                                                       super.working_disks++;
+                                               if (state == 0)
+                                                       super.spare_disks++;
+                                       } else if (i >= super.raid_disks && super.disks[i].number == 0)
+                                               super.disks[i].state = 0;
+                       }
+                       if (strcmp(update, "resync") == 0) {
+                               /* make sure resync happens */
+                               super.state &= ~(1<<MD_SB_CLEAN);
+                               super.recovery_cp = 0;
+                       }
                        super.sb_csum = calc_sb_csum(&super);
                        dfd = open(devname, O_RDWR, 0);
                        if (dfd < 0) 
@@ -308,8 +341,8 @@ int Assemble(char *mddev, int mdfd,
                        fprintf(stderr, Name ": %s is identified as a member of %s, slot %d.\n",
                                devname, mddev, super.this_disk.raid_disk);
                devices[devcnt].devname = devname;
-               devices[devcnt].major = MAJOR(stb.st_rdev);
-               devices[devcnt].minor = MINOR(stb.st_rdev);
+               devices[devcnt].major = major(stb.st_rdev);
+               devices[devcnt].minor = minor(stb.st_rdev);
                devices[devcnt].oldmajor = super.this_disk.major;
                devices[devcnt].oldminor = super.this_disk.minor;
                devices[devcnt].events = md_event(&super);
@@ -322,16 +355,16 @@ int Assemble(char *mddev, int mdfd,
                            > devices[most_recent].events)
                                most_recent = devcnt;
                }
-               if (super.level == -4) 
+               if ((int)super.level == -4) 
                        /* with multipath, the raid_disk from the superblock is meaningless */
                        i = devcnt;
                else
                        i = devices[devcnt].raid_disk;
-               if (i>=0 && i < 10000) {
+               if (i < 10000) {
                        if (i >= bestcnt) {
-                               int newbestcnt = i+10;
+                               unsigned int newbestcnt = i+10;
                                int *newbest = malloc(sizeof(int)*newbestcnt);
-                               int c;
+                               unsigned int c;
                                for (c=0; c < newbestcnt; c++)
                                        if (c < bestcnt)
                                                newbest[c] = best[c];
@@ -365,7 +398,7 @@ int Assemble(char *mddev, int mdfd,
                /* note: we ignore error flags in multipath arrays
                 * as they don't make sense
                 */
-               if (first_super.level != -4)
+               if ((int)first_super.level != -4)
                        if (!(devices[j].state & (1<<MD_DISK_SYNC))) {
                                if (!(devices[j].state & (1<<MD_DISK_FAULTY)))
                                        sparecnt++;
@@ -467,7 +500,7 @@ int Assemble(char *mddev, int mdfd,
 
        for (i=0; i<bestcnt; i++) {
                int j = best[i];
-               int desired_state;
+               unsigned int desired_state;
 
                if (i < super.raid_disks)
                        desired_state = (1<<MD_DISK_ACTIVE) | (1<<MD_DISK_SYNC);
@@ -632,7 +665,7 @@ This doesnt work yet
                 * so we can just start the array
                 */
                unsigned long dev;
-               dev = MKDEV(devices[chosen_drive].major,
+               dev = makedev(devices[chosen_drive].major,
                            devices[chosen_drive].minor);
                if (ioctl(mdfd, START_ARRAY, dev)) {
                    fprintf(stderr, Name ": Cannot start array: %s\n",