diff options
Diffstat (limited to 'drivers/md/dm-raid1.c')
| -rw-r--r-- | drivers/md/dm-raid1.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/drivers/md/dm-raid1.c b/drivers/md/dm-raid1.c index 7c081bcbc3cf..19a59b041c27 100644 --- a/drivers/md/dm-raid1.c +++ b/drivers/md/dm-raid1.c | |||
| @@ -259,7 +259,7 @@ static int mirror_flush(struct dm_target *ti) | |||
| 259 | struct dm_io_region io[ms->nr_mirrors]; | 259 | struct dm_io_region io[ms->nr_mirrors]; |
| 260 | struct mirror *m; | 260 | struct mirror *m; |
| 261 | struct dm_io_request io_req = { | 261 | struct dm_io_request io_req = { |
| 262 | .bi_rw = WRITE_BARRIER, | 262 | .bi_rw = WRITE_FLUSH, |
| 263 | .mem.type = DM_IO_KMEM, | 263 | .mem.type = DM_IO_KMEM, |
| 264 | .mem.ptr.bvec = NULL, | 264 | .mem.ptr.bvec = NULL, |
| 265 | .client = ms->io_client, | 265 | .client = ms->io_client, |
| @@ -629,7 +629,7 @@ static void do_write(struct mirror_set *ms, struct bio *bio) | |||
| 629 | struct dm_io_region io[ms->nr_mirrors], *dest = io; | 629 | struct dm_io_region io[ms->nr_mirrors], *dest = io; |
| 630 | struct mirror *m; | 630 | struct mirror *m; |
| 631 | struct dm_io_request io_req = { | 631 | struct dm_io_request io_req = { |
| 632 | .bi_rw = WRITE | (bio->bi_rw & WRITE_BARRIER), | 632 | .bi_rw = WRITE | (bio->bi_rw & WRITE_FLUSH_FUA), |
| 633 | .mem.type = DM_IO_BVEC, | 633 | .mem.type = DM_IO_BVEC, |
| 634 | .mem.ptr.bvec = bio->bi_io_vec + bio->bi_idx, | 634 | .mem.ptr.bvec = bio->bi_io_vec + bio->bi_idx, |
| 635 | .notify.fn = write_callback, | 635 | .notify.fn = write_callback, |
| @@ -670,7 +670,7 @@ static void do_writes(struct mirror_set *ms, struct bio_list *writes) | |||
| 670 | bio_list_init(&requeue); | 670 | bio_list_init(&requeue); |
| 671 | 671 | ||
| 672 | while ((bio = bio_list_pop(writes))) { | 672 | while ((bio = bio_list_pop(writes))) { |
| 673 | if (unlikely(bio_empty_barrier(bio))) { | 673 | if (bio->bi_rw & REQ_FLUSH) { |
| 674 | bio_list_add(&sync, bio); | 674 | bio_list_add(&sync, bio); |
| 675 | continue; | 675 | continue; |
| 676 | } | 676 | } |
| @@ -1203,7 +1203,7 @@ static int mirror_end_io(struct dm_target *ti, struct bio *bio, | |||
| 1203 | * We need to dec pending if this was a write. | 1203 | * We need to dec pending if this was a write. |
| 1204 | */ | 1204 | */ |
| 1205 | if (rw == WRITE) { | 1205 | if (rw == WRITE) { |
| 1206 | if (likely(!bio_empty_barrier(bio))) | 1206 | if (!(bio->bi_rw & REQ_FLUSH)) |
| 1207 | dm_rh_dec(ms->rh, map_context->ll); | 1207 | dm_rh_dec(ms->rh, map_context->ll); |
| 1208 | return error; | 1208 | return error; |
| 1209 | } | 1209 | } |
