Browse Source

Reload superblock if METADATA_UPDATED is received

Re-reads the devices by invalidating the cache.
Since we don't write to faulty devices, this is detected using
events recorded in the devices. If it is old as compared to the mddev
mark it is faulty.

Signed-off-by: Goldwyn Rodrigues <rgoldwyn@suse.com>
Goldwyn Rodrigues 11 năm trước cách đây
mục cha
commit
1d7e3e9611
3 tập tin đã thay đổi với 24 bổ sung0 xóa
  1. 1 0
      drivers/md/md-cluster.c
  2. 22 0
      drivers/md/md.c
  3. 1 0
      drivers/md/md.h

+ 1 - 0
drivers/md/md-cluster.c

@@ -320,6 +320,7 @@ static void process_recvd_msg(struct mddev *mddev, struct cluster_msg *msg)
 	case METADATA_UPDATED:
 	case METADATA_UPDATED:
 		pr_info("%s: %d Received message: METADATA_UPDATE from %d\n",
 		pr_info("%s: %d Received message: METADATA_UPDATE from %d\n",
 			__func__, __LINE__, msg->slot);
 			__func__, __LINE__, msg->slot);
+		md_reload_sb(mddev);
 		break;
 		break;
 	case RESYNCING:
 	case RESYNCING:
 		pr_info("%s: %d Received message: RESYNCING from %d\n",
 		pr_info("%s: %d Received message: RESYNCING from %d\n",

+ 22 - 0
drivers/md/md.c

@@ -8788,6 +8788,28 @@ err_wq:
 	return ret;
 	return ret;
 }
 }
 
 
+void md_reload_sb(struct mddev *mddev)
+{
+	struct md_rdev *rdev, *tmp;
+
+	rdev_for_each_safe(rdev, tmp, mddev) {
+		rdev->sb_loaded = 0;
+		ClearPageUptodate(rdev->sb_page);
+	}
+	mddev->raid_disks = 0;
+	analyze_sbs(mddev);
+	rdev_for_each_safe(rdev, tmp, mddev) {
+		struct mdp_superblock_1 *sb = page_address(rdev->sb_page);
+		/* since we don't write to faulty devices, we figure out if the
+		 *  disk is faulty by comparing events
+		 */
+		if (mddev->events > sb->events)
+			set_bit(Faulty, &rdev->flags);
+	}
+
+}
+EXPORT_SYMBOL(md_reload_sb);
+
 #ifndef MODULE
 #ifndef MODULE
 
 
 /*
 /*

+ 1 - 0
drivers/md/md.h

@@ -665,6 +665,7 @@ extern struct bio *bio_alloc_mddev(gfp_t gfp_mask, int nr_iovecs,
 				   struct mddev *mddev);
 				   struct mddev *mddev);
 
 
 extern void md_unplug(struct blk_plug_cb *cb, bool from_schedule);
 extern void md_unplug(struct blk_plug_cb *cb, bool from_schedule);
+extern void md_reload_sb(struct mddev *mddev);
 static inline int mddev_check_plugged(struct mddev *mddev)
 static inline int mddev_check_plugged(struct mddev *mddev)
 {
 {
 	return !!blk_check_plugged(md_unplug, mddev,
 	return !!blk_check_plugged(md_unplug, mddev,