Lines Matching full:disks
119 if (sh->qd_idx == sh->disks - 1) in raid6_d0()
130 /* When walking through the disks in a raid5, starting at raid6_d0,
131 * We need to map each disk to a 'slot', where the data disks are slot
223 for (i = sh->disks; i--; ) in do_release_stripe()
491 init_stripe_shared_pages(struct stripe_head *sh, struct r5conf *conf, int disks) in init_stripe_shared_pages() argument
500 nr_pages = (disks + cnt - 1) / cnt; in init_stripe_shared_pages()
581 sh->disks = previous ? conf->previous_raid_disks : conf->raid_disks; in init_stripe()
586 for (i = sh->disks; i--; ) { in init_stripe()
642 struct md_rdev *rdev = rcu_dereference(conf->disks[i].rdev); in raid5_calc_degraded()
644 rdev = rcu_dereference(conf->disks[i].replacement); in raid5_calc_degraded()
668 struct md_rdev *rdev = rcu_dereference(conf->disks[i].rdev); in raid5_calc_degraded()
670 rdev = rcu_dereference(conf->disks[i].replacement); in raid5_calc_degraded()
779 BUG_ON(sh->overwrite_disks > (sh->disks - sh->raid_conf->max_degraded)); in is_full_stripe_write()
780 return sh->overwrite_disks == (sh->disks - sh->raid_conf->max_degraded); in is_full_stripe_write()
1061 int i, disks = sh->disks; in ops_run_io() local
1073 for (i = disks; i--; ) { in ops_run_io()
1102 rrdev = rcu_dereference(conf->disks[i].replacement); in ops_run_io()
1104 rdev = rcu_dereference(conf->disks[i].rdev); in ops_run_io()
1381 for (i = sh->disks; i--; ) { in ops_complete_biofill()
1420 for (i = sh->disks; i--; ) { in ops_run_biofill()
1484 return (void *) (to_addr_page(percpu, i) + sh->disks + 2); in to_addr_conv()
1493 return (unsigned int *) (to_addr_conv(sh, percpu, 0) + sh->disks + 2); in to_addr_offs()
1499 int disks = sh->disks; in ops_run_compute5() local
1517 for (i = disks; i--; ) { in ops_run_compute5()
1539 * @srcs - (struct page *) array of size sh->disks
1553 int disks = sh->disks; in set_syndrome_sources() local
1554 int syndrome_disks = sh->ddf_layout ? disks : (disks - 2); in set_syndrome_sources()
1559 for (i = 0; i < disks; i++) in set_syndrome_sources()
1587 i = raid6_next_disk(i, disks); in set_syndrome_sources()
1596 int disks = sh->disks; in ops_run_compute6_1() local
1640 for (i = disks; i-- ; ) { in ops_run_compute6_1()
1660 int i, count, disks = sh->disks; in ops_run_compute6_2() local
1661 int syndrome_disks = sh->ddf_layout ? disks : disks-2; in ops_run_compute6_2()
1683 for (i = 0; i < disks ; i++) { in ops_run_compute6_2()
1699 i = raid6_next_disk(i, disks); in ops_run_compute6_2()
1711 /* Q disk is one of the missing disks */ in ops_run_compute6_2()
1733 for (i = disks; i-- ; ) { in ops_run_compute6_2()
1796 int disks = sh->disks; in ops_run_prexor5() local
1810 for (i = disks; i--; ) { in ops_run_prexor5()
1860 int disks = sh->disks; in ops_run_biodrain() local
1867 for (i = disks; i--; ) { in ops_run_biodrain()
1931 int disks = sh->disks; in ops_complete_reconstruct() local
1940 for (i = disks; i--; ) { in ops_complete_reconstruct()
1946 for (i = disks; i--; ) { in ops_complete_reconstruct()
1979 int disks = sh->disks; in ops_run_reconstruct5() local
1995 for (i = 0; i < sh->disks; i++) { in ops_run_reconstruct5()
2001 if (i >= sh->disks) { in ops_run_reconstruct5()
2018 for (i = disks; i--; ) { in ops_run_reconstruct5()
2029 for (i = disks; i--; ) { in ops_run_reconstruct5()
2088 for (i = 0; i < sh->disks; i++) { in ops_run_reconstruct6()
2094 if (i >= sh->disks) { in ops_run_reconstruct6()
2150 int disks = sh->disks; in ops_run_check_p() local
2171 for (i = disks; i--; ) { in ops_run_check_p()
2214 int overlap_clear = 0, i, disks = sh->disks; in raid_run_ops() local
2276 for (i = disks; i--; ) { in raid_run_ops()
2295 int disks, struct r5conf *conf) in alloc_stripe() argument
2311 for (i = 0; i < disks; i++) { in alloc_stripe()
2326 if (init_stripe_shared_pages(sh, conf, disks)) { in alloc_stripe()
2390 * @num: total number of disks in the array
2476 * 3/ reallocate conf->disks to be suitable bigger. If this fails, in resize_stripes()
2565 * conf->disks and the scribble region in resize_stripes()
2570 ndisks[i] = conf->disks[i]; in resize_stripes()
2584 kfree(conf->disks); in resize_stripes()
2585 conf->disks = ndisks; in resize_stripes()
2668 int disks = sh->disks, i; in raid5_end_read_request() local
2673 for (i=0 ; i<disks; i++) in raid5_end_read_request()
2680 if (i == disks) { in raid5_end_read_request()
2691 rdev = conf->disks[i].replacement; in raid5_end_read_request()
2693 rdev = conf->disks[i].rdev; in raid5_end_read_request()
2799 int disks = sh->disks, i; in raid5_end_write_request() local
2805 for (i = 0 ; i < disks; i++) { in raid5_end_write_request()
2807 rdev = conf->disks[i].rdev; in raid5_end_write_request()
2811 rdev = conf->disks[i].replacement; in raid5_end_write_request()
2819 rdev = conf->disks[i].rdev; in raid5_end_write_request()
2826 if (i == disks) { in raid5_end_write_request()
3118 int raid_disks = sh->disks; in raid5_compute_blocknr()
3248 * like to flush data in journal to RAID disks first, so complex rmw
3268 * In journal failure, we try to flush all cached data to raid disks
3295 int i, pd_idx = sh->pd_idx, qd_idx = sh->qd_idx, disks = sh->disks; in schedule_reconstruction() local
3308 for (i = disks; i--; ) { in schedule_reconstruction()
3337 if (s->locked + conf->max_degraded == disks) in schedule_reconstruction()
3347 for (i = disks; i--; ) { in schedule_reconstruction()
3449 for (i = 0; i < sh->disks; i++) { in add_stripe_bio()
3539 int disks = previous ? conf->previous_raid_disks : conf->raid_disks; in stripe_set_idx() local
3542 stripe * (disks - conf->max_degraded) in stripe_set_idx()
3550 struct stripe_head_state *s, int disks) in handle_failed_stripe() argument
3554 for (i = disks; i--; ) { in handle_failed_stripe()
3561 rdev = rcu_dereference(conf->disks[i].rdev); in handle_failed_stripe()
3687 struct md_rdev *rdev = rcu_dereference(conf->disks[i].rdev); in handle_failed_sync()
3694 rdev = rcu_dereference(conf->disks[i].replacement); in handle_failed_sync()
3716 rdev = rcu_dereference(sh->raid_conf->disks[disk_idx].replacement); in want_replace()
3728 int disk_idx, int disks) in need_this_block() argument
3835 int disk_idx, int disks) in fetch_block() argument
3840 if (need_this_block(sh, s, disk_idx, disks)) { in fetch_block()
3857 if ((s->uptodate == disks - 1) && in fetch_block()
3880 } else if (s->uptodate == disks-2 && s->failed >= 2) { in fetch_block()
3885 for (other = disks; other--; ) { in fetch_block()
3922 int disks) in handle_stripe_fill() argument
3936 * disks first, this avoids handling complex rmw of write in handle_stripe_fill()
3946 for (i = disks; i--; ) in handle_stripe_fill()
3947 if (fetch_block(sh, s, i, disks)) in handle_stripe_fill()
3962 struct stripe_head *sh, int disks) in handle_stripe_clean_event() argument
3970 for (i = disks; i--; ) in handle_stripe_clean_event()
4079 int disks) in handle_stripe_dirtying() argument
4101 } else for (i = disks; i--; ) { in handle_stripe_dirtying()
4113 rmw += 2*disks; /* cannot read it */ in handle_stripe_dirtying()
4124 rcw += 2*disks; in handle_stripe_dirtying()
4137 for (i = disks; i--; ) { in handle_stripe_dirtying()
4167 for (i = disks; i--; ) { in handle_stripe_dirtying()
4192 for (i = disks; i--; ) { in handle_stripe_dirtying()
4219 if (rcw > disks && rmw > disks && in handle_stripe_dirtying()
4241 struct stripe_head_state *s, int disks) in handle_parity_checks5() argument
4252 BUG_ON(s->uptodate != disks); in handle_parity_checks5()
4272 BUG_ON(s->uptodate != disks); in handle_parity_checks5()
4335 int disks) in handle_parity_checks6() argument
4520 for (i = 0; i < sh->disks; i++) in handle_stripe_expansion()
4585 int disks = sh->disks; in analyse_stripe() local
4600 for (i=disks; i--; ) { in analyse_stripe()
4644 rdev = rcu_dereference(conf->disks[i].replacement); in analyse_stripe()
4655 rdev = rcu_dereference(conf->disks[i].rdev); in analyse_stripe()
4703 conf->disks[i].rdev); in analyse_stripe()
4716 conf->disks[i].rdev); in analyse_stripe()
4725 conf->disks[i].replacement); in analyse_stripe()
4747 conf->disks[i].replacement); in analyse_stripe()
4852 for (i = 0; i < sh->disks; i++) { in break_stripe_batch_list()
4866 for (i = 0; i < head_sh->disks; i++) in break_stripe_batch_list()
4882 int disks = sh->disks; in handle_stripe() local
4966 * the stripe if there is data need write to raid disks in handle_stripe()
4974 handle_failed_stripe(conf, sh, &s, disks); in handle_stripe()
4997 for (i = disks; i--; ) { in handle_stripe()
5040 handle_stripe_clean_event(conf, sh, disks); in handle_stripe()
5043 r5c_handle_cached_data_endio(conf, sh, disks); in handle_stripe()
5052 || (s.syncing && (s.uptodate + s.compute < disks)) in handle_stripe()
5055 handle_stripe_fill(sh, &s, disks); in handle_stripe()
5076 handle_stripe_dirtying(conf, sh, &s, disks); in handle_stripe()
5083 disks); in handle_stripe()
5096 disks); in handle_stripe()
5113 handle_parity_checks6(conf, sh, &s, disks); in handle_stripe()
5115 handle_parity_checks5(conf, sh, &s, disks); in handle_stripe()
5194 sh->disks = conf->raid_disks; in handle_stripe()
5224 for (i = disks; i--; ) { in handle_stripe()
5229 rdev = conf->disks[i].rdev; in handle_stripe()
5236 rdev = conf->disks[i].rdev; in handle_stripe()
5242 rdev = conf->disks[i].replacement; in handle_stripe()
5245 rdev = conf->disks[i].rdev; in handle_stripe()
5425 rdev = rcu_dereference(conf->disks[dd_idx].replacement); in raid5_read_one_chunk()
5428 rdev = rcu_dereference(conf->disks[dd_idx].rdev); in raid5_read_one_chunk()
6109 for (j=sh->disks; j--;) { in reshape_request()
6286 struct md_rdev *rdev = READ_ONCE(conf->disks[i].rdev); in raid5_sync_request()
7092 if (conf->disks[i].extra_page) in free_conf()
7093 put_page(conf->disks[i].extra_page); in free_conf()
7094 kfree(conf->disks); in free_conf()
7266 conf->disks = kcalloc(max_disks, sizeof(struct disk_info), in setup_conf()
7269 if (!conf->disks) in setup_conf()
7273 conf->disks[i].extra_page = alloc_page(GFP_KERNEL); in setup_conf()
7274 if (!conf->disks[i].extra_page) in setup_conf()
7320 disk = conf->disks + raid_disk; in setup_conf()
7530 * be a multiple of the largest chunk size times new data disks. in raid5_run()
7614 rdev = conf->disks[i].rdev; in raid5_run()
7615 if (!rdev && conf->disks[i].replacement) { in raid5_run()
7617 rdev = conf->disks[i].replacement; in raid5_run()
7618 conf->disks[i].replacement = NULL; in raid5_run()
7620 conf->disks[i].rdev = rdev; in raid5_run()
7624 if (conf->disks[i].replacement && in raid5_run()
7764 * depending on which disks are used to calculate in raid5_run()
7816 struct md_rdev *rdev = rcu_dereference(conf->disks[i].rdev); in raid5_status()
7839 tmp = conf->disks + i; in print_raid5_conf()
7856 tmp = conf->disks + i; in raid5_spare_active()
7896 struct disk_info *p = conf->disks + number; in raid5_remove_disk()
8020 conf->disks[rdev->saved_raid_disk].rdev == NULL) in raid5_add_disk()
8024 p = conf->disks + disk; in raid5_add_disk()
8038 p = conf->disks + disk; in raid5_add_disk()
8192 pr_warn("md/raid:%s: array size must be reduced before number of disks\n", in raid5_start_reshape()
8341 struct md_rdev *rdev = conf->disks[d].rdev; in raid5_finish_reshape()
8344 rdev = conf->disks[d].replacement; in raid5_finish_reshape()