diff options
author | Dan Williams <dan.j.williams@intel.com> | 2008-06-27 18:31:53 -0400 |
---|---|---|
committer | Neil Brown <neilb@notabene.brown> | 2008-06-27 18:31:53 -0400 |
commit | c4e5ac0a22e664eecf29249553cf16c2433f5f25 (patch) | |
tree | 898a3b7f4b80d54d15d5b415397b1f4dd588e116 /drivers | |
parent | 2b7497f0e0a0b9cf21d822e427d5399b2056501a (diff) |
md: use stripe_head_state in ops_run_io()
From: Dan Williams <dan.j.williams@intel.com>
In handle_stripe after taking sh->lock we sample some bits into 's' (struct
stripe_head_state):
s.syncing = test_bit(STRIPE_SYNCING, &sh->state);
s.expanding = test_bit(STRIPE_EXPAND_SOURCE, &sh->state);
s.expanded = test_bit(STRIPE_EXPAND_READY, &sh->state);
Use these values from 's' in ops_run_io() rather than re-sampling the bits.
This ensures a consistent snapshot (as seen under sh->lock) is used.
Signed-off-by: Dan Williams <dan.j.williams@intel.com>
Signed-off-by: Neil Brown <neilb@suse.de>
Diffstat (limited to 'drivers')
-rw-r--r-- | drivers/md/raid5.c | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/drivers/md/raid5.c b/drivers/md/raid5.c index cac97080b278..c4ef3071c290 100644 --- a/drivers/md/raid5.c +++ b/drivers/md/raid5.c | |||
@@ -390,7 +390,7 @@ raid5_end_read_request(struct bio *bi, int error); | |||
390 | static void | 390 | static void |
391 | raid5_end_write_request(struct bio *bi, int error); | 391 | raid5_end_write_request(struct bio *bi, int error); |
392 | 392 | ||
393 | static void ops_run_io(struct stripe_head *sh) | 393 | static void ops_run_io(struct stripe_head *sh, struct stripe_head_state *s) |
394 | { | 394 | { |
395 | raid5_conf_t *conf = sh->raid_conf; | 395 | raid5_conf_t *conf = sh->raid_conf; |
396 | int i, disks = sh->disks; | 396 | int i, disks = sh->disks; |
@@ -425,9 +425,7 @@ static void ops_run_io(struct stripe_head *sh) | |||
425 | rcu_read_unlock(); | 425 | rcu_read_unlock(); |
426 | 426 | ||
427 | if (rdev) { | 427 | if (rdev) { |
428 | if (test_bit(STRIPE_SYNCING, &sh->state) || | 428 | if (s->syncing || s->expanding || s->expanded) |
429 | test_bit(STRIPE_EXPAND_SOURCE, &sh->state) || | ||
430 | test_bit(STRIPE_EXPAND_READY, &sh->state)) | ||
431 | md_sync_acct(rdev->bdev, STRIPE_SECTORS); | 429 | md_sync_acct(rdev->bdev, STRIPE_SECTORS); |
432 | 430 | ||
433 | set_bit(STRIPE_IO_STARTED, &sh->state); | 431 | set_bit(STRIPE_IO_STARTED, &sh->state); |
@@ -2902,10 +2900,9 @@ static void handle_stripe5(struct stripe_head *sh) | |||
2902 | if (pending) | 2900 | if (pending) |
2903 | raid5_run_ops(sh, pending); | 2901 | raid5_run_ops(sh, pending); |
2904 | 2902 | ||
2905 | ops_run_io(sh); | 2903 | ops_run_io(sh, &s); |
2906 | 2904 | ||
2907 | return_io(return_bi); | 2905 | return_io(return_bi); |
2908 | |||
2909 | } | 2906 | } |
2910 | 2907 | ||
2911 | static void handle_stripe6(struct stripe_head *sh, struct page *tmp_page) | 2908 | static void handle_stripe6(struct stripe_head *sh, struct page *tmp_page) |