]> git.ipfire.org Git - thirdparty/mdadm.git/blobdiff - super-intel.c
Fix mdstat_wait_fd
[thirdparty/mdadm.git] / super-intel.c
index 7ea91917aa673a4f0717fd6c6506fcf2afa97257..0b902edf71f1edafaaf5cd3d1d65a34af67401ef 100644 (file)
@@ -68,8 +68,10 @@ struct imsm_map {
        __u8  num_members;      /* number of member disks */
        __u8  reserved[3];
        __u32 filler[7];        /* expansion area */
+#define IMSM_ORD_REBUILD (1 << 24)
        __u32 disk_ord_tbl[1];  /* disk_ord_tbl[num_members],
-                                  top byte special */
+                                * top byte contains some flags
+                                */
 } __attribute__ ((packed));
 
 struct imsm_vol {
@@ -195,8 +197,8 @@ struct imsm_update_activate_spare {
 
 struct imsm_update_create_array {
        enum imsm_update_type type;
-       struct imsm_dev dev;
        int dev_idx;
+       struct imsm_dev dev;
 };
 
 static int imsm_env_devname_as_serial(void)
@@ -339,10 +341,24 @@ static __u32 get_imsm_disk_idx(struct imsm_map *map, int slot)
 {
        __u32 *ord_tbl = &map->disk_ord_tbl[slot];
 
-       /* top byte is 'special' */
+       /* top byte identifies disk under rebuild
+        * why not just use the USABLE bit... oh well.
+        */
        return __le32_to_cpu(*ord_tbl & ~(0xff << 24));
 }
 
+static __u32 get_imsm_ord_tbl_ent(struct imsm_dev *dev, int slot)
+{
+       struct imsm_map *map;
+
+       if (dev->vol.migr_state)
+               map = get_imsm_map(dev, 0);
+       else
+               map = get_imsm_map(dev, 1);
+
+       return map->disk_ord_tbl[slot];
+}
+
 static int get_imsm_raid_level(struct imsm_map *map)
 {
        if (map->raid_level == 1) {
@@ -1590,7 +1606,7 @@ static int write_super_imsm_spares(struct intel_super *super, int doclose)
                        fprintf(stderr, "%s: failed for device %d:%d %s\n",
                                __func__, d->major, d->minor, strerror(errno));
                        *mpb = mpb_save;
-                       return 0;
+                       return 1;
                }
                if (doclose) {
                        close(d->fd);
@@ -1599,7 +1615,7 @@ static int write_super_imsm_spares(struct intel_super *super, int doclose)
        }
 
        *mpb = mpb_save;
-       return 1;
+       return 0;
 }
 
 static int write_super_imsm(struct intel_super *super, int doclose)
@@ -1630,7 +1646,7 @@ static int write_super_imsm(struct intel_super *super, int doclose)
        if (raid_disks != mpb->num_disks) {
                fprintf(stderr, "%s: expected %d disks only found %d\n",
                        __func__, mpb->num_disks, raid_disks);
-               return 0;
+               return 1;
        }
 
        for (i = 0; i < mpb->num_raid_devs; i++) {
@@ -1653,7 +1669,7 @@ static int write_super_imsm(struct intel_super *super, int doclose)
                if (store_imsm_mpb(d->fd, super)) {
                        fprintf(stderr, "%s: failed for device %d:%d %s\n",
                                __func__, d->major, d->minor, strerror(errno));
-                       return 0;
+                       return 1;
                }
                if (doclose) {
                        close(d->fd);
@@ -1664,7 +1680,7 @@ static int write_super_imsm(struct intel_super *super, int doclose)
        if (spares)
                return write_super_imsm_spares(super, doclose);
 
-       return 1;
+       return 0;
 }
 
 static int write_init_super_imsm(struct supertype *st)
@@ -1994,7 +2010,6 @@ static struct mdinfo *container_content_imsm(struct supertype *st)
                this = malloc(sizeof(*this));
                memset(this, 0, sizeof(*this));
                this->next = rest;
-               rest = this;
 
                this->array.level = get_imsm_raid_level(map);
                this->array.raid_disks = map->num_members;
@@ -2005,7 +2020,8 @@ static struct mdinfo *container_content_imsm(struct supertype *st)
                this->array.chunk_size = __le16_to_cpu(map->blocks_per_strip) << 9;
                this->array.state = !vol->dirty;
                this->container_member = i;
-               if (map->map_state == IMSM_T_STATE_UNINITIALIZED || dev->vol.dirty)
+               if (map->map_state == IMSM_T_STATE_UNINITIALIZED ||
+                   dev->vol.dirty || dev->vol.migr_state)
                        this->resync_start = 0;
                else
                        this->resync_start = ~0ULL;
@@ -2025,32 +2041,55 @@ static struct mdinfo *container_content_imsm(struct supertype *st)
                        struct mdinfo *info_d;
                        struct dl *d;
                        int idx;
+                       int skip;
                        __u32 s;
+                       __u32 ord;
 
+                       skip = 0;
                        idx = get_imsm_disk_idx(map, slot);
+                       ord = get_imsm_ord_tbl_ent(dev, slot); 
                        for (d = super->disks; d ; d = d->next)
                                if (d->index == idx)
                                         break;
 
                        if (d == NULL)
-                               break; /* shouldn't this be continue ?? */
+                               skip = 1;
+
+                       s = d ? __le32_to_cpu(d->disk.status) : 0;
+                       if (s & FAILED_DISK)
+                               skip = 1;
+                       if (!(s & USABLE_DISK))
+                               skip = 1;
+                       if (ord & IMSM_ORD_REBUILD)
+                               skip = 1;
+
+                       /* 
+                        * if we skip some disks the array will be assmebled degraded;
+                        * reset resync start to avoid a dirty-degraded situation
+                        *
+                        * FIXME handle dirty degraded
+                        */
+                       if (skip && !dev->vol.dirty)
+                               this->resync_start = ~0ULL;
+                       if (skip)
+                               continue;
 
                        info_d = malloc(sizeof(*info_d));
-                       if (!info_d)
-                               break; /* ditto ?? */
+                       if (!info_d) {
+                               fprintf(stderr, Name ": failed to allocate disk"
+                                       " for volume %s\n", (char *) dev->volume);
+                               free(this);
+                               this = rest;
+                               break;
+                       }
                        memset(info_d, 0, sizeof(*info_d));
                        info_d->next = this->devs;
                        this->devs = info_d;
 
-                       s = __le32_to_cpu(d->disk.status);
-
                        info_d->disk.number = d->index;
                        info_d->disk.major = d->major;
                        info_d->disk.minor = d->minor;
                        info_d->disk.raid_disk = slot;
-                       info_d->disk.state  = s & CONFIGURED_DISK ? (1 << MD_DISK_ACTIVE) : 0;
-                       info_d->disk.state |= s & FAILED_DISK ? (1 << MD_DISK_FAULTY) : 0;
-                       info_d->disk.state |= s & USABLE_DISK ? (1 << MD_DISK_SYNC) : 0;
 
                        this->array.working_disks++;
 
@@ -2060,6 +2099,7 @@ static struct mdinfo *container_content_imsm(struct supertype *st)
                        if (d->devname)
                                strcpy(info_d->name, d->devname);
                }
+               rest = this;
        }
 
        return rest;
@@ -2156,12 +2196,14 @@ static int imsm_count_failed(struct intel_super *super, struct imsm_map *map)
                disk = get_imsm_disk(super, idx);
                if (__le32_to_cpu(disk->status) & FAILED_DISK)
                        failed++;
+               else if (!(__le32_to_cpu(disk->status) & USABLE_DISK))
+                       failed++;
        }
 
        return failed;
 }
 
-static void imsm_set_array_state(struct active_array *a, int consistent)
+static int imsm_set_array_state(struct active_array *a, int consistent)
 {
        int inst = a->info.container_member;
        struct intel_super *super = a->container->sb;
@@ -2177,6 +2219,8 @@ static void imsm_set_array_state(struct active_array *a, int consistent)
        if (consistent && !dev->vol.dirty &&
            (dev->vol.migr_state || map_state != IMSM_T_STATE_NORMAL))
                a->resync_start = 0ULL;
+       if (consistent == 2 && a->resync_start != ~0ULL)
+               consistent = 0;
 
        if (a->resync_start == ~0ULL) {
                /* complete recovery or initial resync */
@@ -2211,6 +2255,7 @@ static void imsm_set_array_state(struct active_array *a, int consistent)
                dev->vol.dirty = dirty;
                super->updates_pending++;
        }
+       return consistent;
 }
 
 static void imsm_set_disk(struct active_array *a, int n, int state)
@@ -2350,6 +2395,7 @@ static struct dl *imsm_add_spare(struct intel_super *super, int idx, struct acti
        int j;
        int found;
        __u32 array_start;
+       __u32 status;
        struct dl *dl;
 
        for (dl = super->disks; dl; dl = dl->next) {
@@ -2363,6 +2409,16 @@ static struct dl *imsm_add_spare(struct intel_super *super, int idx, struct acti
                if (d)
                        continue;
 
+               /* skip marked in use or failed drives */
+               status = __le32_to_cpu(dl->disk.status);
+               if (status & FAILED_DISK || status & CONFIGURED_DISK) {
+                       dprintf("%x:%x status ( %s%s)\n",
+                       dl->major, dl->minor,
+                       status & FAILED_DISK ? "failed " : "",
+                       status & CONFIGURED_DISK ? "configured " : "");
+                       continue;
+               }
+
                /* Does this unused device have the requisite free space?
                 * We need a->info.component_size sectors
                 */
@@ -2652,8 +2708,8 @@ static void imsm_process_update(struct supertype *st,
 
                /* check update is next in sequence */
                if (u->dev_idx != mpb->num_raid_devs) {
-                       dprintf("%s: can not create arrays out of sequence\n",
-                               __func__);
+                       dprintf("%s: can not create array %d expected index %d\n",
+                               __func__, u->dev_idx, mpb->num_raid_devs);
                        return;
                }