Lines Matching defs:rdev
201 rdev_dec_pending(conf->mirrors[i].rdev, r1_bio->mddev);
285 !test_bit(Faulty, &conf->mirrors[mirror].rdev->flags)))
299 bdevname(conf->mirrors[mirror].rdev->bdev,b), (unsigned long long)r1_bio->sector);
303 rdev_dec_pending(conf->mirrors[mirror].rdev, conf->mddev);
323 set_bit(BarriersNotsupp, &conf->mirrors[mirror].rdev->flags);
334 md_error(r1_bio->mddev, conf->mirrors[mirror].rdev);
352 if (test_bit(WriteMostly, &conf->mirrors[mirror].rdev->flags))
373 rdev_dec_pending(conf->mirrors[mirror].rdev, conf->mddev);
420 * The rdev for the device selected will have nr_pending incremented.
429 mdk_rdev_t *rdev;
443 for (rdev = rcu_dereference(conf->mirrors[new_disk].rdev);
445 !rdev || !test_bit(In_sync, &rdev->flags)
446 || test_bit(WriteMostly, &rdev->flags);
447 rdev = rcu_dereference(conf->mirrors[++new_disk].rdev)) {
449 if (rdev && test_bit(In_sync, &rdev->flags) &&
463 for (rdev = rcu_dereference(conf->mirrors[new_disk].rdev);
465 !rdev || !test_bit(In_sync, &rdev->flags) ||
466 test_bit(WriteMostly, &rdev->flags);
467 rdev = rcu_dereference(conf->mirrors[new_disk].rdev)) {
469 if (rdev && test_bit(In_sync, &rdev->flags) &&
505 rdev = rcu_dereference(conf->mirrors[disk].rdev);
507 if (!rdev || r1_bio->bios[disk] == IO_BLOCKED ||
508 !test_bit(In_sync, &rdev->flags) ||
509 test_bit(WriteMostly, &rdev->flags))
512 if (!atomic_read(&rdev->nr_pending)) {
527 rdev = rcu_dereference(conf->mirrors[new_disk].rdev);
528 if (!rdev)
530 atomic_inc(&rdev->nr_pending);
531 if (!test_bit(In_sync, &rdev->flags)) {
535 rdev_dec_pending(rdev, conf->mddev);
553 mdk_rdev_t *rdev = rcu_dereference(conf->mirrors[i].rdev);
554 if (rdev && !test_bit(Faulty, &rdev->flags) && atomic_read(&rdev->nr_pending)) {
555 request_queue_t *r_queue = bdev_get_queue(rdev->bdev);
557 atomic_inc(&rdev->nr_pending);
563 rdev_dec_pending(rdev, mddev);
587 mdk_rdev_t *rdev = rcu_dereference(conf->mirrors[i].rdev);
588 if (rdev && !test_bit(Faulty, &rdev->flags)) {
589 struct block_device *bdev = rdev->bdev;
595 atomic_inc(&rdev->nr_pending);
599 rdev_dec_pending(rdev, mddev);
616 mdk_rdev_t *rdev = rcu_dereference(conf->mirrors[i].rdev);
617 if (rdev && !test_bit(Faulty, &rdev->flags)) {
618 request_queue_t *q = bdev_get_queue(rdev->bdev);
776 mdk_rdev_t *rdev;
840 read_bio->bi_sector = r1_bio->sector + mirror->rdev->data_offset;
841 read_bio->bi_bdev = mirror->rdev->bdev;
854 * inc refcount on their rdev. Record them by setting
860 if ((rdev=rcu_dereference(conf->mirrors[i].rdev)) != NULL &&
861 !test_bit(Faulty, &rdev->flags)) {
862 atomic_inc(&rdev->nr_pending);
863 if (test_bit(Faulty, &rdev->flags)) {
864 rdev_dec_pending(rdev, mddev);
904 mbio->bi_sector = r1_bio->sector + conf->mirrors[i].rdev->data_offset;
905 mbio->bi_bdev = conf->mirrors[i].rdev->bdev;
923 if (test_bit(WriteMostly, &conf->mirrors[i].rdev->flags))
957 mdk_rdev_t *rdev = rcu_dereference(conf->mirrors[i].rdev);
959 rdev && test_bit(In_sync, &rdev->flags) ? "U" : "_");
966 static void error(mddev_t *mddev, mdk_rdev_t *rdev)
977 if (test_bit(In_sync, &rdev->flags)
984 if (test_and_clear_bit(In_sync, &rdev->flags)) {
988 set_bit(Faulty, &rdev->flags);
995 set_bit(Faulty, &rdev->flags);
999 bdevname(rdev->bdev,b), conf->raid_disks - mddev->degraded);
1017 mdk_rdev_t *rdev = rcu_dereference(conf->mirrors[i].rdev);
1018 if (rdev)
1020 i, !test_bit(In_sync, &rdev->flags),
1021 !test_bit(Faulty, &rdev->flags),
1022 bdevname(rdev->bdev,b));
1047 mdk_rdev_t *rdev = conf->mirrors[i].rdev;
1048 if (rdev
1049 && !test_bit(Faulty, &rdev->flags)
1050 && !test_and_set_bit(In_sync, &rdev->flags)) {
1063 static int raid1_add_disk(mddev_t *mddev, mdk_rdev_t *rdev)
1071 if ( !(p=conf->mirrors+mirror)->rdev) {
1074 rdev->bdev->bd_disk->queue);
1079 if (rdev->bdev->bd_disk->queue->merge_bvec_fn &&
1084 rdev->raid_disk = mirror;
1089 if (rdev->saved_raid_disk < 0)
1091 rcu_assign_pointer(p->rdev, rdev);
1103 mdk_rdev_t *rdev;
1107 rdev = p->rdev;
1108 if (rdev) {
1109 if (test_bit(In_sync, &rdev->flags) ||
1110 atomic_read(&rdev->nr_pending)) {
1114 p->rdev = NULL;
1116 if (atomic_read(&rdev->nr_pending)) {
1119 p->rdev = rdev;
1183 md_error(mddev, conf->mirrors[mirror].rdev);
1217 md_error(mddev, conf->mirrors[i].rdev);
1227 rdev_dec_pending(conf->mirrors[primary].rdev, mddev);
1254 rdev_dec_pending(conf->mirrors[i].rdev, mddev);
1268 conf->mirrors[i].rdev->data_offset;
1269 sbio->bi_bdev = conf->mirrors[i].rdev->bdev;
1296 mdk_rdev_t *rdev;
1306 rdev = conf->mirrors[d].rdev;
1307 if (sync_page_io(rdev->bdev,
1308 sect + rdev->data_offset,
1331 rdev = conf->mirrors[d].rdev;
1332 atomic_add(s, &rdev->corrected_errors);
1333 if (sync_page_io(rdev->bdev,
1334 sect + rdev->data_offset,
1338 md_error(mddev, rdev);
1347 rdev = conf->mirrors[d].rdev;
1348 if (sync_page_io(rdev->bdev,
1349 sect + rdev->data_offset,
1353 md_error(mddev, rdev);
1358 md_error(mddev, conf->mirrors[r1_bio->read_disk].rdev);
1388 md_sync_acct(conf->mirrors[i].rdev->bdev, wbio->bi_size >> 9);
1417 mdk_rdev_t *rdev;
1428 rdev = conf->mirrors[d].rdev;
1429 if (rdev &&
1430 test_bit(In_sync, &rdev->flags) &&
1431 sync_page_io(rdev->bdev,
1432 sect + rdev->data_offset,
1445 md_error(mddev, conf->mirrors[read_disk].rdev);
1454 rdev = conf->mirrors[d].rdev;
1455 if (rdev &&
1456 test_bit(In_sync, &rdev->flags)) {
1457 if (sync_page_io(rdev->bdev,
1458 sect + rdev->data_offset,
1462 md_error(mddev, rdev);
1471 rdev = conf->mirrors[d].rdev;
1472 if (rdev &&
1473 test_bit(In_sync, &rdev->flags)) {
1474 if (sync_page_io(rdev->bdev,
1475 sect + rdev->data_offset,
1479 md_error(mddev, rdev);
1481 atomic_add(s, &rdev->corrected_errors);
1487 rdev->data_offset),
1488 bdevname(rdev->bdev, b));
1505 mdk_rdev_t *rdev;
1571 conf->mirrors[i].rdev->data_offset;
1572 bio->bi_bdev = conf->mirrors[i].rdev->bdev;
1613 rdev = conf->mirrors[disk].rdev;
1617 bdevname(rdev->bdev,b),
1619 bio->bi_sector = r1_bio->sector + rdev->data_offset;
1620 bio->bi_bdev = rdev->bdev;
1744 mdk_rdev_t *rdev;
1759 rdev = rcu_dereference(conf->mirrors[i].rdev);
1760 if (rdev == NULL ||
1761 test_bit(Faulty, &rdev->flags)) {
1764 } else if (!test_bit(In_sync, &rdev->flags)) {
1772 if (test_bit(WriteMostly, &rdev->flags)) {
1781 atomic_inc(&rdev->nr_pending);
1782 bio->bi_sector = sector_nr + rdev->data_offset;
1783 bio->bi_bdev = rdev->bdev;
1880 mdk_rdev_t *rdev;
1923 ITERATE_RDEV(mddev, rdev, tmp) {
1924 disk_idx = rdev->raid_disk;
1930 disk->rdev = rdev;
1933 rdev->bdev->bd_disk->queue);
1938 if (rdev->bdev->bd_disk->queue->merge_bvec_fn &&
1961 if (!disk->rdev ||
1962 !test_bit(In_sync, &disk->rdev->flags)) {
1981 (!conf->mirrors[j].rdev ||
1982 !test_bit(In_sync, &conf->mirrors[j].rdev->flags)) ; j++)
2115 if (conf->mirrors[d].rdev)
2147 if (conf->mirrors[d].rdev) {
2148 conf->mirrors[d].rdev->raid_disk = d2;
2149 newmirrors[d2++].rdev = conf->mirrors[d].rdev;