Lines Matching refs:mp_bh
58 static void multipath_reschedule_retry (struct multipath_bh *mp_bh) in multipath_reschedule_retry() argument
61 struct mddev *mddev = mp_bh->mddev; in multipath_reschedule_retry()
65 list_add(&mp_bh->retry_list, &conf->retry_list); in multipath_reschedule_retry()
75 static void multipath_end_bh_io (struct multipath_bh *mp_bh, int err) in multipath_end_bh_io() argument
77 struct bio *bio = mp_bh->master_bio; in multipath_end_bh_io()
78 struct mpconf *conf = mp_bh->mddev->private; in multipath_end_bh_io()
81 mempool_free(mp_bh, conf->pool); in multipath_end_bh_io()
87 struct multipath_bh *mp_bh = bio->bi_private; in multipath_end_request() local
88 struct mpconf *conf = mp_bh->mddev->private; in multipath_end_request()
89 struct md_rdev *rdev = conf->multipaths[mp_bh->path].rdev; in multipath_end_request()
92 multipath_end_bh_io(mp_bh, 0); in multipath_end_request()
98 md_error (mp_bh->mddev, rdev); in multipath_end_request()
102 multipath_reschedule_retry(mp_bh); in multipath_end_request()
104 multipath_end_bh_io(mp_bh, error); in multipath_end_request()
111 struct multipath_bh * mp_bh; in multipath_make_request() local
119 mp_bh = mempool_alloc(conf->pool, GFP_NOIO); in multipath_make_request()
121 mp_bh->master_bio = bio; in multipath_make_request()
122 mp_bh->mddev = mddev; in multipath_make_request()
124 mp_bh->path = multipath_map(conf); in multipath_make_request()
125 if (mp_bh->path < 0) { in multipath_make_request()
127 mempool_free(mp_bh, conf->pool); in multipath_make_request()
130 multipath = conf->multipaths + mp_bh->path; in multipath_make_request()
132 bio_init(&mp_bh->bio); in multipath_make_request()
133 __bio_clone_fast(&mp_bh->bio, bio); in multipath_make_request()
135 mp_bh->bio.bi_iter.bi_sector += multipath->rdev->data_offset; in multipath_make_request()
136 mp_bh->bio.bi_bdev = multipath->rdev->bdev; in multipath_make_request()
137 mp_bh->bio.bi_rw |= REQ_FAILFAST_TRANSPORT; in multipath_make_request()
138 mp_bh->bio.bi_end_io = multipath_end_request; in multipath_make_request()
139 mp_bh->bio.bi_private = mp_bh; in multipath_make_request()
140 generic_make_request(&mp_bh->bio); in multipath_make_request()
334 struct multipath_bh *mp_bh; in multipathd() local
346 mp_bh = list_entry(head->prev, struct multipath_bh, retry_list); in multipathd()
350 bio = &mp_bh->bio; in multipathd()
351 bio->bi_iter.bi_sector = mp_bh->master_bio->bi_iter.bi_sector; in multipathd()
353 if ((mp_bh->path = multipath_map (conf))<0) { in multipathd()
358 multipath_end_bh_io(mp_bh, -EIO); in multipathd()
364 *bio = *(mp_bh->master_bio); in multipathd()
366 conf->multipaths[mp_bh->path].rdev->data_offset; in multipathd()
367 bio->bi_bdev = conf->multipaths[mp_bh->path].rdev->bdev; in multipathd()
370 bio->bi_private = mp_bh; in multipathd()