Commit a9ae93c8 authored by NeilBrown's avatar NeilBrown Committed by Shaohua Li
Browse files

md/raid10: abort delayed writes when device fails. 



When writing to an array with a bitmap enabled, the writes are grouped
in batches which are preceded by an update to the bitmap.

It is quite likely if that a drive develops a problem which is not
media related, that the bitmap write will be the first to report an
error and cause the device to be marked faulty (as the bitmap write is
at the start of a batch).

In this case, there is point submiting the subsequent writes to the
failed device - that just wastes times.

So re-check the Faulty state of a device before submitting a
delayed write.

This requires that we keep the 'rdev', rather than the 'bdev' in the
bio, then swap in the bdev just before final submission.

Reported-by: default avatarHannes Reinecke <hare@suse.com>
Signed-off-by: default avatarNeilBrown <neilb@suse.com>
Signed-off-by: default avatarShaohua Li <shli@fb.com>
parent 5e2c7a36

drivers/md/raid10.c

+16 −6
Original line number Diff line number Diff line
@@ -858,8 +858,13 @@ static void flush_pending_writes(struct r10conf *conf) 


		while (bio) { /* submit pending writes */

			struct bio *next = bio->bi_next;

			struct md_rdev *rdev = (void*)bio->bi_bdev;

			bio->bi_next = NULL;

			if (unlikely((bio_op(bio) ==  REQ_OP_DISCARD) &&

			bio->bi_bdev = rdev->bdev;

			if (test_bit(Faulty, &rdev->flags)) {

				bio->bi_error = -EIO;

				bio_endio(bio);

			} else if (unlikely((bio_op(bio) ==  REQ_OP_DISCARD) &&

					    !blk_queue_discard(bdev_get_queue(bio->bi_bdev))))

				/* Just ignore it */

				bio_endio(bio);
@@ -1036,8 +1041,13 @@ static void raid10_unplug(struct blk_plug_cb *cb, bool from_schedule) 


	while (bio) { /* submit pending writes */

		struct bio *next = bio->bi_next;

		struct md_rdev *rdev = (void*)bio->bi_bdev;

		bio->bi_next = NULL;

		if (unlikely((bio_op(bio) ==  REQ_OP_DISCARD) &&

		bio->bi_bdev = rdev->bdev;

		if (test_bit(Faulty, &rdev->flags)) {

			bio->bi_error = -EIO;

			bio_endio(bio);

		} else if (unlikely((bio_op(bio) ==  REQ_OP_DISCARD) &&

				    !blk_queue_discard(bdev_get_queue(bio->bi_bdev))))

			/* Just ignore it */

			bio_endio(bio);
@@ -1357,7 +1367,7 @@ retry_write: 
			mbio->bi_iter.bi_sector	= (r10_bio->devs[i].addr+

					   choose_data_offset(r10_bio,

							      rdev));

			mbio->bi_bdev = rdev->bdev;

			mbio->bi_bdev = (void*)rdev;

			mbio->bi_end_io	= raid10_end_write_request;

			bio_set_op_attrs(mbio, op, do_sync | do_fua);

			mbio->bi_private = r10_bio;
@@ -1399,7 +1409,7 @@ retry_write: 
			mbio->bi_iter.bi_sector	= (r10_bio->devs[i].addr +

					   choose_data_offset(

						   r10_bio, rdev));

			mbio->bi_bdev = rdev->bdev;

			mbio->bi_bdev = (void*)rdev;

			mbio->bi_end_io	= raid10_end_write_request;

			bio_set_op_attrs(mbio, op, do_sync | do_fua);

			mbio->bi_private = r10_bio;

CRA Git | Maintained and supported by SUSTech CRA and CCSE