| /fs/nfs/flexfilelayout/ |
| A D | flexfilelayoutdev.c | 290 pcred = &mirror->ro_cred; in ff_layout_get_mirror_cred()
292 pcred = &mirror->rw_cred; in ff_layout_get_mirror_cred()
310 return &mirror->fh_versions[0]; in nfs4_ff_layout_select_ds_fh()
325 if (mirror == NULL) in ff_layout_init_mirror_ds()
343 if (IS_ERR(mirror->mirror_ds)) in ff_layout_init_mirror_ds()
382 ds = mirror->mirror_ds->ds; in nfs4_ff_layout_prepare_ds()
433 if (mirror && !mirror->mirror_ds->ds_versions[0].tightly_coupled) { in ff_layout_get_ds_cred()
566 if (mirror) { in ff_read_layout_has_available_ds()
567 if (!mirror->mirror_ds) in ff_read_layout_has_available_ds()
588 if (!mirror || IS_ERR(mirror->mirror_ds)) in ff_rw_layout_has_available_ds()
[all …]
|
| A D | flexfilelayout.c | 222 mirror->layout = lo; in ff_layout_add_mirror()
224 return mirror; in ff_layout_add_mirror()
237 mirror->layout = NULL; in ff_layout_remove_mirror()
244 mirror = kzalloc(sizeof(*mirror), gfp_flags); in ff_layout_alloc_mirror()
245 if (mirror != NULL) { in ff_layout_alloc_mirror()
251 return mirror; in ff_layout_alloc_mirror()
266 kfree(mirror); in ff_layout_free_mirror()
271 if (mirror != NULL && refcount_dec_and_test(&mirror->ref)) in ff_layout_put_mirror()
683 report = nfs4_ff_layoutstat_start_io(mirror, &mirror->read_stat, now); in nfs4_ff_layout_stat_io_start_read()
714 report = nfs4_ff_layoutstat_start_io(mirror , &mirror->write_stat, now); in nfs4_ff_layout_stat_io_start_write()
[all …]
|
| A D | flexfilelayout.h | 155 struct nfs4_ff_layout_mirror *mirror = FF_LAYOUT_COMP(lseg, idx); in FF_LAYOUT_DEVID_NODE() local
157 if (mirror != NULL) { in FF_LAYOUT_DEVID_NODE()
158 struct nfs4_ff_layout_ds *mirror_ds = mirror->mirror_ds; in FF_LAYOUT_DEVID_NODE()
185 nfs4_ff_layout_ds_version(const struct nfs4_ff_layout_mirror *mirror) in nfs4_ff_layout_ds_version() argument
187 return mirror->mirror_ds->ds_versions[0].version; in nfs4_ff_layout_ds_version()
196 struct nfs4_ff_layout_mirror *mirror, u64 offset,
207 nfs4_ff_layout_select_ds_fh(struct nfs4_ff_layout_mirror *mirror);
209 nfs4_ff_layout_select_ds_stateid(const struct nfs4_ff_layout_mirror *mirror,
214 struct nfs4_ff_layout_mirror *mirror,
218 nfs4_ff_find_or_create_ds_client(struct nfs4_ff_layout_mirror *mirror,
[all …]
|
| /fs/nfs/ |
| A D | pagelist.c | 616 if (mirror->pg_count > mirror->pg_bsize) { in nfs_generic_pg_test()
630 return min(mirror->pg_bsize - mirror->pg_count, (size_t)req->wb_bytes); in nfs_generic_pg_test()
801 mirror->pg_bytes_written = 0; in nfs_pageio_mirror_init()
802 mirror->pg_count = 0; in nfs_pageio_mirror_init()
803 mirror->pg_bsize = bsize; in nfs_pageio_mirror_init()
804 mirror->pg_base = 0; in nfs_pageio_mirror_init()
805 mirror->pg_recoalesce = 0; in nfs_pageio_mirror_init()
1119 mirror->pg_count = 0; in nfs_pageio_do_add_request()
1120 mirror->pg_recoalesce = 0; in nfs_pageio_do_add_request()
1152 mirror->pg_bytes_written += mirror->pg_count; in nfs_pageio_doio()
[all …]
|
| A D | read.c | 99 struct nfs_pgio_mirror *mirror; in nfs_pageio_reset_read_mds() local
109 mirror = &pgio->pg_mirrors[0]; in nfs_pageio_reset_read_mds()
110 mirror->pg_bsize = NFS_SERVER(pgio->pg_inode)->rsize; in nfs_pageio_reset_read_mds()
|
| A D | pnfs.c | 3010 struct nfs_pgio_mirror *mirror = nfs_pgio_current_mirror(desc); in pnfs_write_through_mds() local
3013 list_splice_tail_init(&hdr->pages, &mirror->pg_list); in pnfs_write_through_mds()
3015 mirror->pg_recoalesce = 1; in pnfs_write_through_mds()
3059 struct nfs_pgio_mirror *mirror = nfs_pgio_current_mirror(desc); in pnfs_do_write() local
3060 list_splice_init(&hdr->pages, &mirror->pg_list); in pnfs_do_write()
3061 mirror->pg_recoalesce = 1; in pnfs_do_write()
3134 struct nfs_pgio_mirror *mirror = nfs_pgio_current_mirror(desc); in pnfs_read_through_mds() local
3137 list_splice_tail_init(&hdr->pages, &mirror->pg_list); in pnfs_read_through_mds()
3139 mirror->pg_recoalesce = 1; in pnfs_read_through_mds()
3205 list_splice_init(&hdr->pages, &mirror->pg_list); in pnfs_do_read()
[all …]
|
| A D | write.c | 1453 struct nfs_pgio_mirror *mirror; in nfs_pageio_reset_write_mds() local
1462 mirror = &pgio->pg_mirrors[0]; in nfs_pageio_reset_write_mds()
1463 mirror->pg_bsize = NFS_SERVER(pgio->pg_inode)->wsize; in nfs_pageio_reset_write_mds()
|
| /fs/btrfs/ |
| A D | zoned.h | 63 int btrfs_sb_log_location_bdev(struct block_device *bdev, int mirror, int rw,
65 int btrfs_sb_log_location(struct btrfs_device *device, int mirror, int rw,
67 int btrfs_advance_sb_log(struct btrfs_device *device, int mirror);
68 int btrfs_reset_sb_log_zones(struct block_device *bdev, int mirror);
142 int mirror, int rw, u64 *bytenr_ret) in btrfs_sb_log_location_bdev() argument
144 *bytenr_ret = btrfs_sb_offset(mirror); in btrfs_sb_log_location_bdev()
148 static inline int btrfs_sb_log_location(struct btrfs_device *device, int mirror, in btrfs_sb_log_location() argument
151 *bytenr_ret = btrfs_sb_offset(mirror); in btrfs_sb_log_location()
155 static inline int btrfs_advance_sb_log(struct btrfs_device *device, int mirror) in btrfs_advance_sb_log() argument
160 static inline int btrfs_reset_sb_log_zones(struct block_device *bdev, int mirror) in btrfs_reset_sb_log_zones() argument
|
| A D | bio.c | 166 int mirror = repair_bbio->mirror_num; in btrfs_end_repair_bio() local
173 mirror = next_repair_mirror(fbio, mirror); in btrfs_end_repair_bio()
174 if (mirror == fbio->bbio->mirror_num) { in btrfs_end_repair_bio()
180 btrfs_submit_bbio(repair_bbio, mirror); in btrfs_end_repair_bio()
185 mirror = prev_repair_mirror(fbio, mirror); in btrfs_end_repair_bio()
189 bvec_phys(bv), mirror); in btrfs_end_repair_bio()
190 } while (mirror != fbio->bbio->mirror_num); in btrfs_end_repair_bio()
216 int mirror; in repair_one_sector() local
247 mirror = next_repair_mirror(fbio, failed_bbio->mirror_num); in repair_one_sector()
248 btrfs_debug(fs_info, "submitting repair read to mirror %d", mirror); in repair_one_sector()
[all …]
|
| A D | disk-io.h | 36 static inline u64 btrfs_sb_offset(int mirror) in btrfs_sb_offset() argument
39 if (mirror) in btrfs_sb_offset()
40 return start << (BTRFS_SUPER_MIRROR_SHIFT * mirror); in btrfs_sb_offset()
|
| A D | scrub.c | 908 ASSERT(mirror <= num_copies); in calc_next_mirror()
909 return (mirror + 1 > num_copies) ? 1 : mirror + 1; in calc_next_mirror()
966 btrfs_submit_bbio(bbio, mirror); in scrub_stripe_submit_repair_read()
1142 int mirror; in scrub_stripe_read_repair_worker() local
1167 mirror = calc_next_mirror(mirror, num_copies)) { in scrub_stripe_read_repair_worker()
1191 i++, mirror = calc_next_mirror(mirror, num_copies)) { in scrub_stripe_read_repair_worker()
1784 int mirror = stripe->mirror_num; in scrub_submit_extent_sector_read() local
1847 btrfs_submit_bbio(bbio, mirror); in scrub_submit_extent_sector_read()
1863 int mirror = stripe->mirror_num; in scrub_submit_initial_read() local
1894 mirror = calc_next_mirror(mirror, num_copies); in scrub_submit_initial_read()
[all …]
|
| A D | zoned.c | 165 static inline u32 sb_zone_number(int shift, int mirror) in sb_zone_number() argument
169 ASSERT(mirror < BTRFS_SUPER_MIRROR_MAX); in sb_zone_number()
170 switch (mirror) { in sb_zone_number()
876 *bytenr_ret = btrfs_sb_offset(mirror); in btrfs_sb_log_location_bdev()
917 *bytenr_ret = btrfs_sb_offset(mirror); in btrfs_sb_log_location()
921 zone_num = sb_zone_number(zinfo->zone_size_shift, mirror); in btrfs_sb_log_location()
926 &zinfo->sb_zones[BTRFS_NR_SB_LOG_ZONES * mirror], in btrfs_sb_log_location()
931 int mirror) in is_sb_log_zone() argument
938 zone_num = sb_zone_number(zinfo->zone_size_shift, mirror); in is_sb_log_zone()
954 if (!is_sb_log_zone(zinfo, mirror)) in btrfs_advance_sb_log()
[all …]
|
| A D | Kconfig | 101 - RAID mirror read policy - additional read policies for balancing
|