Lines Matching refs:mirror
50 struct mirror { struct
91 struct mirror mirror[]; member
151 struct mirror *m;
167 static struct mirror *bio_get_m(struct bio *bio) in bio_get_m()
169 return (struct mirror *) bio->bi_next; in bio_get_m()
172 static void bio_set_m(struct bio *bio, struct mirror *m) in bio_set_m()
177 static struct mirror *get_default_mirror(struct mirror_set *ms) in get_default_mirror()
179 return &ms->mirror[atomic_read(&ms->default_mirror)]; in get_default_mirror()
182 static void set_default_mirror(struct mirror *m) in set_default_mirror()
185 struct mirror *m0 = &(ms->mirror[0]); in set_default_mirror()
190 static struct mirror *get_valid_mirror(struct mirror_set *ms) in get_valid_mirror()
192 struct mirror *m; in get_valid_mirror()
194 for (m = ms->mirror; m < ms->mirror + ms->nr_mirrors; m++) in get_valid_mirror()
215 static void fail_mirror(struct mirror *m, enum dm_raid1_error error_type) in fail_mirror()
218 struct mirror *new; in fail_mirror()
265 struct mirror *m; in mirror_flush()
273 for (i = 0, m = ms->mirror; i < ms->nr_mirrors; i++, m++) { in mirror_flush()
284 fail_mirror(ms->mirror + i, in mirror_flush()
322 if (&ms->mirror[m] == get_default_mirror(ms)) in recovery_complete()
325 fail_mirror(ms->mirror + m, in recovery_complete()
338 struct mirror *m; in recover()
360 if (&ms->mirror[i] == get_default_mirror(ms)) in recover()
363 m = ms->mirror + i; in recover()
384 atomic_set(&(ms->mirror[m].error_count), 0); in reset_ms_flags()
385 ms->mirror[m].error_type = 0; in reset_ms_flags()
422 static struct mirror *choose_mirror(struct mirror_set *ms, sector_t sector) in choose_mirror()
424 struct mirror *m = get_default_mirror(ms); in choose_mirror()
430 if (m-- == ms->mirror) in choose_mirror()
437 static int default_ok(struct mirror *m) in default_ok()
439 struct mirror *default_mirror = get_default_mirror(m->ms); in default_ok()
458 static sector_t map_sector(struct mirror *m, struct bio *bio) in map_sector()
465 static void map_bio(struct mirror *m, struct bio *bio) in map_bio()
471 static void map_region(struct dm_io_region *io, struct mirror *m, in map_region()
517 struct mirror *m; in read_callback()
542 static void read_async_bio(struct mirror *m, struct bio *bio) in read_async_bio()
570 struct mirror *m; in do_reads()
637 fail_mirror(ms->mirror + i, DM_RAID1_WRITE_ERROR); in write_callback()
657 struct mirror *m; in do_write()
674 for (i = 0, m = ms->mirror; i < ms->nr_mirrors; i++, m++) in do_write()
893 kzalloc(struct_size(ms, mirror, nr_mirrors), GFP_KERNEL); in alloc_context()
940 dm_put_device(ti, ms->mirror[m].dev); in free_context()
948 unsigned int mirror, char **argv) in get_mirror() argument
961 &ms->mirror[mirror].dev); in get_mirror()
967 ms->mirror[mirror].ms = ms; in get_mirror()
968 atomic_set(&(ms->mirror[mirror].error_count), 0); in get_mirror()
969 ms->mirror[mirror].error_type = 0; in get_mirror()
970 ms->mirror[mirror].offset = offset; in get_mirror()
1198 struct mirror *m; in mirror_map()
1249 struct mirror *m = NULL; in mirror_end_io()
1392 static char device_status_char(struct mirror *m) in device_status_char()
1417 DMEMIT("%s ", ms->mirror[m].dev->name); in mirror_status()
1418 buffer[m] = device_status_char(&(ms->mirror[m])); in mirror_status()
1435 DMEMIT(" %s %llu", ms->mirror[m].dev->name, in mirror_status()
1436 (unsigned long long)ms->mirror[m].offset); in mirror_status()
1454 DMEMIT(",mirror_device_%d=%s", m, ms->mirror[m].dev->name); in mirror_status()
1456 m, device_status_char(&(ms->mirror[m]))); in mirror_status()
1477 ret = fn(ti, ms->mirror[i].dev, in mirror_iterate_devices()
1478 ms->mirror[i].offset, ti->len, data); in mirror_iterate_devices()