diff options
Diffstat (limited to 'drivers')
-rw-r--r-- | drivers/block/drbd/drbd_int.h | 10 | ||||
-rw-r--r-- | drivers/block/drbd/drbd_nl.c | 8 |
2 files changed, 12 insertions, 6 deletions
diff --git a/drivers/block/drbd/drbd_int.h b/drivers/block/drbd/drbd_int.h index 5136510ec8be..2704af2ccf61 100644 --- a/drivers/block/drbd/drbd_int.h +++ b/drivers/block/drbd/drbd_int.h | |||
@@ -2421,15 +2421,17 @@ static inline void dec_ap_bio(struct drbd_conf *mdev) | |||
2421 | int ap_bio = atomic_dec_return(&mdev->ap_bio_cnt); | 2421 | int ap_bio = atomic_dec_return(&mdev->ap_bio_cnt); |
2422 | 2422 | ||
2423 | D_ASSERT(ap_bio >= 0); | 2423 | D_ASSERT(ap_bio >= 0); |
2424 | |||
2425 | if (ap_bio == 0 && test_bit(BITMAP_IO, &mdev->flags)) { | ||
2426 | if (!test_and_set_bit(BITMAP_IO_QUEUED, &mdev->flags)) | ||
2427 | drbd_queue_work(&mdev->data.work, &mdev->bm_io_work.w); | ||
2428 | } | ||
2429 | |||
2424 | /* this currently does wake_up for every dec_ap_bio! | 2430 | /* this currently does wake_up for every dec_ap_bio! |
2425 | * maybe rather introduce some type of hysteresis? | 2431 | * maybe rather introduce some type of hysteresis? |
2426 | * e.g. (ap_bio == mxb/2 || ap_bio == 0) ? */ | 2432 | * e.g. (ap_bio == mxb/2 || ap_bio == 0) ? */ |
2427 | if (ap_bio < mxb) | 2433 | if (ap_bio < mxb) |
2428 | wake_up(&mdev->misc_wait); | 2434 | wake_up(&mdev->misc_wait); |
2429 | if (ap_bio == 0 && test_bit(BITMAP_IO, &mdev->flags)) { | ||
2430 | if (!test_and_set_bit(BITMAP_IO_QUEUED, &mdev->flags)) | ||
2431 | drbd_queue_work(&mdev->data.work, &mdev->bm_io_work.w); | ||
2432 | } | ||
2433 | } | 2435 | } |
2434 | 2436 | ||
2435 | static inline int drbd_set_ed_uuid(struct drbd_conf *mdev, u64 val) | 2437 | static inline int drbd_set_ed_uuid(struct drbd_conf *mdev, u64 val) |
diff --git a/drivers/block/drbd/drbd_nl.c b/drivers/block/drbd/drbd_nl.c index a68d9bfb731c..c47df7cf7f80 100644 --- a/drivers/block/drbd/drbd_nl.c +++ b/drivers/block/drbd/drbd_nl.c | |||
@@ -1977,9 +1977,11 @@ static int drbd_nl_invalidate(struct drbd_conf *mdev, struct drbd_nl_cfg_req *nl | |||
1977 | int retcode; | 1977 | int retcode; |
1978 | 1978 | ||
1979 | /* If there is still bitmap IO pending, probably because of a previous | 1979 | /* If there is still bitmap IO pending, probably because of a previous |
1980 | * resync just being finished, wait for it before requesting a new resync. */ | 1980 | * resync just being finished, wait for it before requesting a new resync. |
1981 | * Also wait for it's after_state_ch(). */ | ||
1981 | drbd_suspend_io(mdev); | 1982 | drbd_suspend_io(mdev); |
1982 | wait_event(mdev->misc_wait, !test_bit(BITMAP_IO, &mdev->flags)); | 1983 | wait_event(mdev->misc_wait, !test_bit(BITMAP_IO, &mdev->flags)); |
1984 | drbd_flush_workqueue(mdev); | ||
1983 | 1985 | ||
1984 | retcode = _drbd_request_state(mdev, NS(conn, C_STARTING_SYNC_T), CS_ORDERED); | 1986 | retcode = _drbd_request_state(mdev, NS(conn, C_STARTING_SYNC_T), CS_ORDERED); |
1985 | 1987 | ||
@@ -2018,9 +2020,11 @@ static int drbd_nl_invalidate_peer(struct drbd_conf *mdev, struct drbd_nl_cfg_re | |||
2018 | int retcode; | 2020 | int retcode; |
2019 | 2021 | ||
2020 | /* If there is still bitmap IO pending, probably because of a previous | 2022 | /* If there is still bitmap IO pending, probably because of a previous |
2021 | * resync just being finished, wait for it before requesting a new resync. */ | 2023 | * resync just being finished, wait for it before requesting a new resync. |
2024 | * Also wait for it's after_state_ch(). */ | ||
2022 | drbd_suspend_io(mdev); | 2025 | drbd_suspend_io(mdev); |
2023 | wait_event(mdev->misc_wait, !test_bit(BITMAP_IO, &mdev->flags)); | 2026 | wait_event(mdev->misc_wait, !test_bit(BITMAP_IO, &mdev->flags)); |
2027 | drbd_flush_workqueue(mdev); | ||
2024 | 2028 | ||
2025 | retcode = _drbd_request_state(mdev, NS(conn, C_STARTING_SYNC_S), CS_ORDERED); | 2029 | retcode = _drbd_request_state(mdev, NS(conn, C_STARTING_SYNC_S), CS_ORDERED); |
2026 | 2030 | ||