Orange Pi5 kernel

Deprecated Linux kernel 5.10.110 for OrangePi 5/5B/5+ boards

3 Commits   0 Branches   0 Tags
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   1) // SPDX-License-Identifier: GPL-2.0-or-later
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   2) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   3)  * multipath.c : Multiple Devices driver for Linux
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   4)  *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   5)  * Copyright (C) 1999, 2000, 2001 Ingo Molnar, Red Hat
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   6)  *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   7)  * Copyright (C) 1996, 1997, 1998 Ingo Molnar, Miguel de Icaza, Gadi Oxman
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   8)  *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   9)  * MULTIPATH management functions.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  10)  *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  11)  * derived from raid1.c.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  12)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  13) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  14) #include <linux/blkdev.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  15) #include <linux/module.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  16) #include <linux/raid/md_u.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  17) #include <linux/seq_file.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  18) #include <linux/slab.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  19) #include "md.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  20) #include "md-multipath.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  21) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  22) #define MAX_WORK_PER_DISK 128
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  23) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  24) #define	NR_RESERVED_BUFS	32
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  25) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  26) static int multipath_map (struct mpconf *conf)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  27) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  28) 	int i, disks = conf->raid_disks;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  29) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  30) 	/*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  31) 	 * Later we do read balancing on the read side
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  32) 	 * now we use the first available disk.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  33) 	 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  34) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  35) 	rcu_read_lock();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  36) 	for (i = 0; i < disks; i++) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  37) 		struct md_rdev *rdev = rcu_dereference(conf->multipaths[i].rdev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  38) 		if (rdev && test_bit(In_sync, &rdev->flags) &&
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  39) 		    !test_bit(Faulty, &rdev->flags)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  40) 			atomic_inc(&rdev->nr_pending);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  41) 			rcu_read_unlock();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  42) 			return i;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  43) 		}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  44) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  45) 	rcu_read_unlock();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  46) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  47) 	pr_crit_ratelimited("multipath_map(): no more operational IO paths?\n");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  48) 	return (-1);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  49) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  50) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  51) static void multipath_reschedule_retry (struct multipath_bh *mp_bh)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  52) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  53) 	unsigned long flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  54) 	struct mddev *mddev = mp_bh->mddev;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  55) 	struct mpconf *conf = mddev->private;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  56) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  57) 	spin_lock_irqsave(&conf->device_lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  58) 	list_add(&mp_bh->retry_list, &conf->retry_list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  59) 	spin_unlock_irqrestore(&conf->device_lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  60) 	md_wakeup_thread(mddev->thread);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  61) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  62) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  63) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  64)  * multipath_end_bh_io() is called when we have finished servicing a multipathed
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  65)  * operation and are ready to return a success/failure code to the buffer
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  66)  * cache layer.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  67)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  68) static void multipath_end_bh_io(struct multipath_bh *mp_bh, blk_status_t status)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  69) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  70) 	struct bio *bio = mp_bh->master_bio;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  71) 	struct mpconf *conf = mp_bh->mddev->private;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  72) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  73) 	bio->bi_status = status;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  74) 	bio_endio(bio);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  75) 	mempool_free(mp_bh, &conf->pool);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  76) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  77) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  78) static void multipath_end_request(struct bio *bio)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  79) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  80) 	struct multipath_bh *mp_bh = bio->bi_private;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  81) 	struct mpconf *conf = mp_bh->mddev->private;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  82) 	struct md_rdev *rdev = conf->multipaths[mp_bh->path].rdev;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  83) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  84) 	if (!bio->bi_status)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  85) 		multipath_end_bh_io(mp_bh, 0);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  86) 	else if (!(bio->bi_opf & REQ_RAHEAD)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  87) 		/*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  88) 		 * oops, IO error:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  89) 		 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  90) 		char b[BDEVNAME_SIZE];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  91) 		md_error (mp_bh->mddev, rdev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  92) 		pr_info("multipath: %s: rescheduling sector %llu\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  93) 			bdevname(rdev->bdev,b),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  94) 			(unsigned long long)bio->bi_iter.bi_sector);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  95) 		multipath_reschedule_retry(mp_bh);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  96) 	} else
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  97) 		multipath_end_bh_io(mp_bh, bio->bi_status);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  98) 	rdev_dec_pending(rdev, conf->mddev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  99) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 100) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 101) static bool multipath_make_request(struct mddev *mddev, struct bio * bio)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 102) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 103) 	struct mpconf *conf = mddev->private;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 104) 	struct multipath_bh * mp_bh;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 105) 	struct multipath_info *multipath;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 106) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 107) 	if (unlikely(bio->bi_opf & REQ_PREFLUSH)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 108) 	    && md_flush_request(mddev, bio))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 109) 		return true;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 110) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 111) 	mp_bh = mempool_alloc(&conf->pool, GFP_NOIO);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 112) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 113) 	mp_bh->master_bio = bio;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 114) 	mp_bh->mddev = mddev;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 115) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 116) 	mp_bh->path = multipath_map(conf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 117) 	if (mp_bh->path < 0) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 118) 		bio_io_error(bio);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 119) 		mempool_free(mp_bh, &conf->pool);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 120) 		return true;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 121) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 122) 	multipath = conf->multipaths + mp_bh->path;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 123) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 124) 	bio_init(&mp_bh->bio, NULL, 0);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 125) 	__bio_clone_fast(&mp_bh->bio, bio);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 126) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 127) 	mp_bh->bio.bi_iter.bi_sector += multipath->rdev->data_offset;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 128) 	bio_set_dev(&mp_bh->bio, multipath->rdev->bdev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 129) 	mp_bh->bio.bi_opf |= REQ_FAILFAST_TRANSPORT;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 130) 	mp_bh->bio.bi_end_io = multipath_end_request;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 131) 	mp_bh->bio.bi_private = mp_bh;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 132) 	mddev_check_writesame(mddev, &mp_bh->bio);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 133) 	mddev_check_write_zeroes(mddev, &mp_bh->bio);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 134) 	submit_bio_noacct(&mp_bh->bio);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 135) 	return true;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 136) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 137) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 138) static void multipath_status(struct seq_file *seq, struct mddev *mddev)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 139) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 140) 	struct mpconf *conf = mddev->private;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 141) 	int i;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 142) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 143) 	seq_printf (seq, " [%d/%d] [", conf->raid_disks,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 144) 		    conf->raid_disks - mddev->degraded);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 145) 	rcu_read_lock();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 146) 	for (i = 0; i < conf->raid_disks; i++) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 147) 		struct md_rdev *rdev = rcu_dereference(conf->multipaths[i].rdev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 148) 		seq_printf (seq, "%s", rdev && test_bit(In_sync, &rdev->flags) ? "U" : "_");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 149) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 150) 	rcu_read_unlock();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 151) 	seq_putc(seq, ']');
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 152) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 153) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 154) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 155)  * Careful, this can execute in IRQ contexts as well!
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 156)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 157) static void multipath_error (struct mddev *mddev, struct md_rdev *rdev)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 158) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 159) 	struct mpconf *conf = mddev->private;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 160) 	char b[BDEVNAME_SIZE];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 161) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 162) 	if (conf->raid_disks - mddev->degraded <= 1) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 163) 		/*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 164) 		 * Uh oh, we can do nothing if this is our last path, but
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 165) 		 * first check if this is a queued request for a device
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 166) 		 * which has just failed.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 167) 		 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 168) 		pr_warn("multipath: only one IO path left and IO error.\n");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 169) 		/* leave it active... it's all we have */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 170) 		return;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 171) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 172) 	/*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 173) 	 * Mark disk as unusable
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 174) 	 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 175) 	if (test_and_clear_bit(In_sync, &rdev->flags)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 176) 		unsigned long flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 177) 		spin_lock_irqsave(&conf->device_lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 178) 		mddev->degraded++;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 179) 		spin_unlock_irqrestore(&conf->device_lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 180) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 181) 	set_bit(Faulty, &rdev->flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 182) 	set_bit(MD_SB_CHANGE_DEVS, &mddev->sb_flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 183) 	pr_err("multipath: IO failure on %s, disabling IO path.\n"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 184) 	       "multipath: Operation continuing on %d IO paths.\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 185) 	       bdevname(rdev->bdev, b),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 186) 	       conf->raid_disks - mddev->degraded);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 187) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 188) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 189) static void print_multipath_conf (struct mpconf *conf)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 190) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 191) 	int i;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 192) 	struct multipath_info *tmp;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 193) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 194) 	pr_debug("MULTIPATH conf printout:\n");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 195) 	if (!conf) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 196) 		pr_debug("(conf==NULL)\n");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 197) 		return;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 198) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 199) 	pr_debug(" --- wd:%d rd:%d\n", conf->raid_disks - conf->mddev->degraded,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 200) 		 conf->raid_disks);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 201) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 202) 	for (i = 0; i < conf->raid_disks; i++) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 203) 		char b[BDEVNAME_SIZE];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 204) 		tmp = conf->multipaths + i;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 205) 		if (tmp->rdev)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 206) 			pr_debug(" disk%d, o:%d, dev:%s\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 207) 				 i,!test_bit(Faulty, &tmp->rdev->flags),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 208) 				 bdevname(tmp->rdev->bdev,b));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 209) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 210) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 211) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 212) static int multipath_add_disk(struct mddev *mddev, struct md_rdev *rdev)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 213) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 214) 	struct mpconf *conf = mddev->private;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 215) 	int err = -EEXIST;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 216) 	int path;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 217) 	struct multipath_info *p;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 218) 	int first = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 219) 	int last = mddev->raid_disks - 1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 220) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 221) 	if (rdev->raid_disk >= 0)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 222) 		first = last = rdev->raid_disk;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 223) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 224) 	print_multipath_conf(conf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 225) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 226) 	for (path = first; path <= last; path++)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 227) 		if ((p=conf->multipaths+path)->rdev == NULL) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 228) 			disk_stack_limits(mddev->gendisk, rdev->bdev,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 229) 					  rdev->data_offset << 9);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 230) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 231) 			err = md_integrity_add_rdev(rdev, mddev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 232) 			if (err)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 233) 				break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 234) 			spin_lock_irq(&conf->device_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 235) 			mddev->degraded--;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 236) 			rdev->raid_disk = path;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 237) 			set_bit(In_sync, &rdev->flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 238) 			spin_unlock_irq(&conf->device_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 239) 			rcu_assign_pointer(p->rdev, rdev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 240) 			err = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 241) 			break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 242) 		}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 243) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 244) 	print_multipath_conf(conf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 245) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 246) 	return err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 247) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 248) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 249) static int multipath_remove_disk(struct mddev *mddev, struct md_rdev *rdev)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 250) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 251) 	struct mpconf *conf = mddev->private;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 252) 	int err = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 253) 	int number = rdev->raid_disk;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 254) 	struct multipath_info *p = conf->multipaths + number;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 255) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 256) 	print_multipath_conf(conf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 257) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 258) 	if (rdev == p->rdev) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 259) 		if (test_bit(In_sync, &rdev->flags) ||
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 260) 		    atomic_read(&rdev->nr_pending)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 261) 			pr_warn("hot-remove-disk, slot %d is identified but is still operational!\n", number);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 262) 			err = -EBUSY;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 263) 			goto abort;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 264) 		}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 265) 		p->rdev = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 266) 		if (!test_bit(RemoveSynchronized, &rdev->flags)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 267) 			synchronize_rcu();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 268) 			if (atomic_read(&rdev->nr_pending)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 269) 				/* lost the race, try later */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 270) 				err = -EBUSY;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 271) 				p->rdev = rdev;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 272) 				goto abort;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 273) 			}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 274) 		}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 275) 		err = md_integrity_register(mddev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 276) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 277) abort:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 278) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 279) 	print_multipath_conf(conf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 280) 	return err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 281) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 282) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 283) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 284)  * This is a kernel thread which:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 285)  *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 286)  *	1.	Retries failed read operations on working multipaths.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 287)  *	2.	Updates the raid superblock when problems encounter.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 288)  *	3.	Performs writes following reads for array syncronising.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 289)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 290) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 291) static void multipathd(struct md_thread *thread)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 292) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 293) 	struct mddev *mddev = thread->mddev;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 294) 	struct multipath_bh *mp_bh;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 295) 	struct bio *bio;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 296) 	unsigned long flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 297) 	struct mpconf *conf = mddev->private;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 298) 	struct list_head *head = &conf->retry_list;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 299) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 300) 	md_check_recovery(mddev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 301) 	for (;;) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 302) 		char b[BDEVNAME_SIZE];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 303) 		spin_lock_irqsave(&conf->device_lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 304) 		if (list_empty(head))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 305) 			break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 306) 		mp_bh = list_entry(head->prev, struct multipath_bh, retry_list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 307) 		list_del(head->prev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 308) 		spin_unlock_irqrestore(&conf->device_lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 309) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 310) 		bio = &mp_bh->bio;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 311) 		bio->bi_iter.bi_sector = mp_bh->master_bio->bi_iter.bi_sector;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 312) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 313) 		if ((mp_bh->path = multipath_map (conf))<0) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 314) 			pr_err("multipath: %s: unrecoverable IO read error for block %llu\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 315) 			       bio_devname(bio, b),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 316) 			       (unsigned long long)bio->bi_iter.bi_sector);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 317) 			multipath_end_bh_io(mp_bh, BLK_STS_IOERR);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 318) 		} else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 319) 			pr_err("multipath: %s: redirecting sector %llu to another IO path\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 320) 			       bio_devname(bio, b),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 321) 			       (unsigned long long)bio->bi_iter.bi_sector);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 322) 			*bio = *(mp_bh->master_bio);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 323) 			bio->bi_iter.bi_sector +=
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 324) 				conf->multipaths[mp_bh->path].rdev->data_offset;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 325) 			bio_set_dev(bio, conf->multipaths[mp_bh->path].rdev->bdev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 326) 			bio->bi_opf |= REQ_FAILFAST_TRANSPORT;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 327) 			bio->bi_end_io = multipath_end_request;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 328) 			bio->bi_private = mp_bh;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 329) 			submit_bio_noacct(bio);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 330) 		}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 331) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 332) 	spin_unlock_irqrestore(&conf->device_lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 333) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 334) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 335) static sector_t multipath_size(struct mddev *mddev, sector_t sectors, int raid_disks)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 336) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 337) 	WARN_ONCE(sectors || raid_disks,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 338) 		  "%s does not support generic reshape\n", __func__);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 339) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 340) 	return mddev->dev_sectors;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 341) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 342) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 343) static int multipath_run (struct mddev *mddev)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 344) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 345) 	struct mpconf *conf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 346) 	int disk_idx;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 347) 	struct multipath_info *disk;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 348) 	struct md_rdev *rdev;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 349) 	int working_disks;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 350) 	int ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 351) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 352) 	if (md_check_no_bitmap(mddev))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 353) 		return -EINVAL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 354) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 355) 	if (mddev->level != LEVEL_MULTIPATH) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 356) 		pr_warn("multipath: %s: raid level not set to multipath IO (%d)\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 357) 			mdname(mddev), mddev->level);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 358) 		goto out;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 359) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 360) 	/*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 361) 	 * copy the already verified devices into our private MULTIPATH
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 362) 	 * bookkeeping area. [whatever we allocate in multipath_run(),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 363) 	 * should be freed in multipath_free()]
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 364) 	 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 365) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 366) 	conf = kzalloc(sizeof(struct mpconf), GFP_KERNEL);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 367) 	mddev->private = conf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 368) 	if (!conf)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 369) 		goto out;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 370) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 371) 	conf->multipaths = kcalloc(mddev->raid_disks,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 372) 				   sizeof(struct multipath_info),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 373) 				   GFP_KERNEL);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 374) 	if (!conf->multipaths)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 375) 		goto out_free_conf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 376) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 377) 	working_disks = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 378) 	rdev_for_each(rdev, mddev) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 379) 		disk_idx = rdev->raid_disk;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 380) 		if (disk_idx < 0 ||
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 381) 		    disk_idx >= mddev->raid_disks)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 382) 			continue;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 383) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 384) 		disk = conf->multipaths + disk_idx;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 385) 		disk->rdev = rdev;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 386) 		disk_stack_limits(mddev->gendisk, rdev->bdev,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 387) 				  rdev->data_offset << 9);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 388) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 389) 		if (!test_bit(Faulty, &rdev->flags))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 390) 			working_disks++;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 391) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 392) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 393) 	conf->raid_disks = mddev->raid_disks;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 394) 	conf->mddev = mddev;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 395) 	spin_lock_init(&conf->device_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 396) 	INIT_LIST_HEAD(&conf->retry_list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 397) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 398) 	if (!working_disks) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 399) 		pr_warn("multipath: no operational IO paths for %s\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 400) 			mdname(mddev));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 401) 		goto out_free_conf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 402) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 403) 	mddev->degraded = conf->raid_disks - working_disks;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 404) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 405) 	ret = mempool_init_kmalloc_pool(&conf->pool, NR_RESERVED_BUFS,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 406) 					sizeof(struct multipath_bh));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 407) 	if (ret)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 408) 		goto out_free_conf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 409) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 410) 	mddev->thread = md_register_thread(multipathd, mddev,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 411) 					   "multipath");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 412) 	if (!mddev->thread)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 413) 		goto out_free_conf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 414) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 415) 	pr_info("multipath: array %s active with %d out of %d IO paths\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 416) 		mdname(mddev), conf->raid_disks - mddev->degraded,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 417) 		mddev->raid_disks);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 418) 	/*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 419) 	 * Ok, everything is just fine now
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 420) 	 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 421) 	md_set_array_sectors(mddev, multipath_size(mddev, 0, 0));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 422) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 423) 	if (md_integrity_register(mddev))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 424) 		goto out_free_conf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 425) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 426) 	return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 427) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 428) out_free_conf:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 429) 	mempool_exit(&conf->pool);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 430) 	kfree(conf->multipaths);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 431) 	kfree(conf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 432) 	mddev->private = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 433) out:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 434) 	return -EIO;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 435) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 436) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 437) static void multipath_free(struct mddev *mddev, void *priv)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 438) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 439) 	struct mpconf *conf = priv;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 440) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 441) 	mempool_exit(&conf->pool);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 442) 	kfree(conf->multipaths);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 443) 	kfree(conf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 444) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 445) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 446) static struct md_personality multipath_personality =
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 447) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 448) 	.name		= "multipath",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 449) 	.level		= LEVEL_MULTIPATH,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 450) 	.owner		= THIS_MODULE,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 451) 	.make_request	= multipath_make_request,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 452) 	.run		= multipath_run,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 453) 	.free		= multipath_free,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 454) 	.status		= multipath_status,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 455) 	.error_handler	= multipath_error,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 456) 	.hot_add_disk	= multipath_add_disk,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 457) 	.hot_remove_disk= multipath_remove_disk,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 458) 	.size		= multipath_size,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 459) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 460) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 461) static int __init multipath_init (void)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 462) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 463) 	return register_md_personality (&multipath_personality);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 464) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 465) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 466) static void __exit multipath_exit (void)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 467) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 468) 	unregister_md_personality (&multipath_personality);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 469) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 470) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 471) module_init(multipath_init);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 472) module_exit(multipath_exit);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 473) MODULE_LICENSE("GPL");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 474) MODULE_DESCRIPTION("simple multi-path personality for MD");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 475) MODULE_ALIAS("md-personality-7"); /* MULTIPATH */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 476) MODULE_ALIAS("md-multipath");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 477) MODULE_ALIAS("md-level--4");