diff options
Diffstat (limited to 'drivers/md/raid1.c')
| -rw-r--r-- | drivers/md/raid1.c | 38 |
1 files changed, 30 insertions, 8 deletions
diff --git a/drivers/md/raid1.c b/drivers/md/raid1.c index 6e0f59ed3d80..39c10a65683d 100644 --- a/drivers/md/raid1.c +++ b/drivers/md/raid1.c | |||
| @@ -1253,6 +1253,7 @@ static void sync_request_write(mddev_t *mddev, r1bio_t *r1_bio) | |||
| 1253 | } while (!success && d != r1_bio->read_disk); | 1253 | } while (!success && d != r1_bio->read_disk); |
| 1254 | 1254 | ||
| 1255 | if (success) { | 1255 | if (success) { |
| 1256 | int start = d; | ||
| 1256 | /* write it back and re-read */ | 1257 | /* write it back and re-read */ |
| 1257 | set_bit(R1BIO_Uptodate, &r1_bio->state); | 1258 | set_bit(R1BIO_Uptodate, &r1_bio->state); |
| 1258 | while (d != r1_bio->read_disk) { | 1259 | while (d != r1_bio->read_disk) { |
| @@ -1266,14 +1267,23 @@ static void sync_request_write(mddev_t *mddev, r1bio_t *r1_bio) | |||
| 1266 | sect + rdev->data_offset, | 1267 | sect + rdev->data_offset, |
| 1267 | s<<9, | 1268 | s<<9, |
| 1268 | bio->bi_io_vec[idx].bv_page, | 1269 | bio->bi_io_vec[idx].bv_page, |
| 1269 | WRITE) == 0 || | 1270 | WRITE) == 0) |
| 1270 | sync_page_io(rdev->bdev, | 1271 | md_error(mddev, rdev); |
| 1272 | } | ||
| 1273 | d = start; | ||
| 1274 | while (d != r1_bio->read_disk) { | ||
| 1275 | if (d == 0) | ||
| 1276 | d = conf->raid_disks; | ||
| 1277 | d--; | ||
| 1278 | if (r1_bio->bios[d]->bi_end_io != end_sync_read) | ||
| 1279 | continue; | ||
| 1280 | rdev = conf->mirrors[d].rdev; | ||
| 1281 | if (sync_page_io(rdev->bdev, | ||
| 1271 | sect + rdev->data_offset, | 1282 | sect + rdev->data_offset, |
| 1272 | s<<9, | 1283 | s<<9, |
| 1273 | bio->bi_io_vec[idx].bv_page, | 1284 | bio->bi_io_vec[idx].bv_page, |
| 1274 | READ) == 0) { | 1285 | READ) == 0) |
| 1275 | md_error(mddev, rdev); | 1286 | md_error(mddev, rdev); |
| 1276 | } | ||
| 1277 | } | 1287 | } |
| 1278 | } else { | 1288 | } else { |
| 1279 | char b[BDEVNAME_SIZE]; | 1289 | char b[BDEVNAME_SIZE]; |
| @@ -1445,6 +1455,7 @@ static void raid1d(mddev_t *mddev) | |||
| 1445 | 1455 | ||
| 1446 | if (success) { | 1456 | if (success) { |
| 1447 | /* write it back and re-read */ | 1457 | /* write it back and re-read */ |
| 1458 | int start = d; | ||
| 1448 | while (d != r1_bio->read_disk) { | 1459 | while (d != r1_bio->read_disk) { |
| 1449 | if (d==0) | 1460 | if (d==0) |
| 1450 | d = conf->raid_disks; | 1461 | d = conf->raid_disks; |
| @@ -1454,13 +1465,24 @@ static void raid1d(mddev_t *mddev) | |||
| 1454 | test_bit(In_sync, &rdev->flags)) { | 1465 | test_bit(In_sync, &rdev->flags)) { |
| 1455 | if (sync_page_io(rdev->bdev, | 1466 | if (sync_page_io(rdev->bdev, |
| 1456 | sect + rdev->data_offset, | 1467 | sect + rdev->data_offset, |
| 1457 | s<<9, conf->tmppage, WRITE) == 0 || | 1468 | s<<9, conf->tmppage, WRITE) == 0) |
| 1458 | sync_page_io(rdev->bdev, | 1469 | /* Well, this device is dead */ |
| 1470 | md_error(mddev, rdev); | ||
| 1471 | } | ||
| 1472 | } | ||
| 1473 | d = start; | ||
| 1474 | while (d != r1_bio->read_disk) { | ||
| 1475 | if (d==0) | ||
| 1476 | d = conf->raid_disks; | ||
| 1477 | d--; | ||
| 1478 | rdev = conf->mirrors[d].rdev; | ||
| 1479 | if (rdev && | ||
| 1480 | test_bit(In_sync, &rdev->flags)) { | ||
| 1481 | if (sync_page_io(rdev->bdev, | ||
| 1459 | sect + rdev->data_offset, | 1482 | sect + rdev->data_offset, |
| 1460 | s<<9, conf->tmppage, READ) == 0) { | 1483 | s<<9, conf->tmppage, READ) == 0) |
| 1461 | /* Well, this device is dead */ | 1484 | /* Well, this device is dead */ |
| 1462 | md_error(mddev, rdev); | 1485 | md_error(mddev, rdev); |
| 1463 | } | ||
| 1464 | } | 1486 | } |
| 1465 | } | 1487 | } |
| 1466 | } else { | 1488 | } else { |