|
@@ -4529,11 +4529,12 @@ static sector_t reshape_request(struct mddev *mddev, sector_t sector_nr,
|
|
|
allow_barrier(conf);
|
|
|
}
|
|
|
|
|
|
+ raise_barrier(conf, 0);
|
|
|
read_more:
|
|
|
/* Now schedule reads for blocks from sector_nr to last */
|
|
|
r10_bio = raid10_alloc_init_r10buf(conf);
|
|
|
r10_bio->state = 0;
|
|
|
- raise_barrier(conf, sectors_done != 0);
|
|
|
+ raise_barrier(conf, 1);
|
|
|
atomic_set(&r10_bio->remaining, 0);
|
|
|
r10_bio->mddev = mddev;
|
|
|
r10_bio->sector = sector_nr;
|
|
@@ -4629,6 +4630,8 @@ read_more:
|
|
|
if (sector_nr <= last)
|
|
|
goto read_more;
|
|
|
|
|
|
+ lower_barrier(conf);
|
|
|
+
|
|
|
/* Now that we have done the whole section we can
|
|
|
* update reshape_progress
|
|
|
*/
|