diff options
Diffstat (limited to 'drivers/md/raid10.c')
-rw-r--r-- | drivers/md/raid10.c | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/drivers/md/raid10.c b/drivers/md/raid10.c index f730a144baf1..4e53792aa520 100644 --- a/drivers/md/raid10.c +++ b/drivers/md/raid10.c | |||
@@ -917,6 +917,13 @@ static int make_request(struct request_queue *q, struct bio * bio) | |||
917 | bio_list_add(&bl, mbio); | 917 | bio_list_add(&bl, mbio); |
918 | } | 918 | } |
919 | 919 | ||
920 | if (unlikely(!atomic_read(&r10_bio->remaining))) { | ||
921 | /* the array is dead */ | ||
922 | md_write_end(mddev); | ||
923 | raid_end_bio_io(r10_bio); | ||
924 | return 0; | ||
925 | } | ||
926 | |||
920 | bitmap_startwrite(mddev->bitmap, bio->bi_sector, r10_bio->sectors, 0); | 927 | bitmap_startwrite(mddev->bitmap, bio->bi_sector, r10_bio->sectors, 0); |
921 | spin_lock_irqsave(&conf->device_lock, flags); | 928 | spin_lock_irqsave(&conf->device_lock, flags); |
922 | bio_list_merge(&conf->pending_bio_list, &bl); | 929 | bio_list_merge(&conf->pending_bio_list, &bl); |
@@ -1557,7 +1564,6 @@ static void raid10d(mddev_t *mddev) | |||
1557 | bio = r10_bio->devs[r10_bio->read_slot].bio; | 1564 | bio = r10_bio->devs[r10_bio->read_slot].bio; |
1558 | r10_bio->devs[r10_bio->read_slot].bio = | 1565 | r10_bio->devs[r10_bio->read_slot].bio = |
1559 | mddev->ro ? IO_BLOCKED : NULL; | 1566 | mddev->ro ? IO_BLOCKED : NULL; |
1560 | bio_put(bio); | ||
1561 | mirror = read_balance(conf, r10_bio); | 1567 | mirror = read_balance(conf, r10_bio); |
1562 | if (mirror == -1) { | 1568 | if (mirror == -1) { |
1563 | printk(KERN_ALERT "raid10: %s: unrecoverable I/O" | 1569 | printk(KERN_ALERT "raid10: %s: unrecoverable I/O" |
@@ -1565,8 +1571,10 @@ static void raid10d(mddev_t *mddev) | |||
1565 | bdevname(bio->bi_bdev,b), | 1571 | bdevname(bio->bi_bdev,b), |
1566 | (unsigned long long)r10_bio->sector); | 1572 | (unsigned long long)r10_bio->sector); |
1567 | raid_end_bio_io(r10_bio); | 1573 | raid_end_bio_io(r10_bio); |
1574 | bio_put(bio); | ||
1568 | } else { | 1575 | } else { |
1569 | const int do_sync = bio_sync(r10_bio->master_bio); | 1576 | const int do_sync = bio_sync(r10_bio->master_bio); |
1577 | bio_put(bio); | ||
1570 | rdev = conf->mirrors[mirror].rdev; | 1578 | rdev = conf->mirrors[mirror].rdev; |
1571 | if (printk_ratelimit()) | 1579 | if (printk_ratelimit()) |
1572 | printk(KERN_ERR "raid10: %s: redirecting sector %llu to" | 1580 | printk(KERN_ERR "raid10: %s: redirecting sector %llu to" |