diff options
Diffstat (limited to 'mm/backing-dev.c')
| -rw-r--r-- | mm/backing-dev.c | 20 |
1 files changed, 7 insertions, 13 deletions
diff --git a/mm/backing-dev.c b/mm/backing-dev.c index 347cc834c04a..2e5d3df0853d 100644 --- a/mm/backing-dev.c +++ b/mm/backing-dev.c | |||
| @@ -359,15 +359,8 @@ static void wb_shutdown(struct bdi_writeback *wb) | |||
| 359 | spin_lock_bh(&wb->work_lock); | 359 | spin_lock_bh(&wb->work_lock); |
| 360 | if (!test_and_clear_bit(WB_registered, &wb->state)) { | 360 | if (!test_and_clear_bit(WB_registered, &wb->state)) { |
| 361 | spin_unlock_bh(&wb->work_lock); | 361 | spin_unlock_bh(&wb->work_lock); |
| 362 | /* | ||
| 363 | * Wait for wb shutdown to finish if someone else is just | ||
| 364 | * running wb_shutdown(). Otherwise we could proceed to wb / | ||
| 365 | * bdi destruction before wb_shutdown() is finished. | ||
| 366 | */ | ||
| 367 | wait_on_bit(&wb->state, WB_shutting_down, TASK_UNINTERRUPTIBLE); | ||
| 368 | return; | 362 | return; |
| 369 | } | 363 | } |
| 370 | set_bit(WB_shutting_down, &wb->state); | ||
| 371 | spin_unlock_bh(&wb->work_lock); | 364 | spin_unlock_bh(&wb->work_lock); |
| 372 | 365 | ||
| 373 | cgwb_remove_from_bdi_list(wb); | 366 | cgwb_remove_from_bdi_list(wb); |
| @@ -379,12 +372,6 @@ static void wb_shutdown(struct bdi_writeback *wb) | |||
| 379 | mod_delayed_work(bdi_wq, &wb->dwork, 0); | 372 | mod_delayed_work(bdi_wq, &wb->dwork, 0); |
| 380 | flush_delayed_work(&wb->dwork); | 373 | flush_delayed_work(&wb->dwork); |
| 381 | WARN_ON(!list_empty(&wb->work_list)); | 374 | WARN_ON(!list_empty(&wb->work_list)); |
| 382 | /* | ||
| 383 | * Make sure bit gets cleared after shutdown is finished. Matches with | ||
| 384 | * the barrier provided by test_and_clear_bit() above. | ||
| 385 | */ | ||
| 386 | smp_wmb(); | ||
| 387 | clear_and_wake_up_bit(WB_shutting_down, &wb->state); | ||
| 388 | } | 375 | } |
| 389 | 376 | ||
| 390 | static void wb_exit(struct bdi_writeback *wb) | 377 | static void wb_exit(struct bdi_writeback *wb) |
| @@ -508,10 +495,12 @@ static void cgwb_release_workfn(struct work_struct *work) | |||
| 508 | struct bdi_writeback *wb = container_of(work, struct bdi_writeback, | 495 | struct bdi_writeback *wb = container_of(work, struct bdi_writeback, |
| 509 | release_work); | 496 | release_work); |
| 510 | 497 | ||
| 498 | mutex_lock(&wb->bdi->cgwb_release_mutex); | ||
| 511 | wb_shutdown(wb); | 499 | wb_shutdown(wb); |
| 512 | 500 | ||
| 513 | css_put(wb->memcg_css); | 501 | css_put(wb->memcg_css); |
| 514 | css_put(wb->blkcg_css); | 502 | css_put(wb->blkcg_css); |
| 503 | mutex_unlock(&wb->bdi->cgwb_release_mutex); | ||
| 515 | 504 | ||
| 516 | fprop_local_destroy_percpu(&wb->memcg_completions); | 505 | fprop_local_destroy_percpu(&wb->memcg_completions); |
| 517 | percpu_ref_exit(&wb->refcnt); | 506 | percpu_ref_exit(&wb->refcnt); |
| @@ -697,6 +686,7 @@ static int cgwb_bdi_init(struct backing_dev_info *bdi) | |||
| 697 | 686 | ||
| 698 | INIT_RADIX_TREE(&bdi->cgwb_tree, GFP_ATOMIC); | 687 | INIT_RADIX_TREE(&bdi->cgwb_tree, GFP_ATOMIC); |
| 699 | bdi->cgwb_congested_tree = RB_ROOT; | 688 | bdi->cgwb_congested_tree = RB_ROOT; |
| 689 | mutex_init(&bdi->cgwb_release_mutex); | ||
| 700 | 690 | ||
| 701 | ret = wb_init(&bdi->wb, bdi, 1, GFP_KERNEL); | 691 | ret = wb_init(&bdi->wb, bdi, 1, GFP_KERNEL); |
| 702 | if (!ret) { | 692 | if (!ret) { |
| @@ -717,7 +707,10 @@ static void cgwb_bdi_unregister(struct backing_dev_info *bdi) | |||
| 717 | spin_lock_irq(&cgwb_lock); | 707 | spin_lock_irq(&cgwb_lock); |
| 718 | radix_tree_for_each_slot(slot, &bdi->cgwb_tree, &iter, 0) | 708 | radix_tree_for_each_slot(slot, &bdi->cgwb_tree, &iter, 0) |
| 719 | cgwb_kill(*slot); | 709 | cgwb_kill(*slot); |
| 710 | spin_unlock_irq(&cgwb_lock); | ||
| 720 | 711 | ||
| 712 | mutex_lock(&bdi->cgwb_release_mutex); | ||
| 713 | spin_lock_irq(&cgwb_lock); | ||
| 721 | while (!list_empty(&bdi->wb_list)) { | 714 | while (!list_empty(&bdi->wb_list)) { |
| 722 | wb = list_first_entry(&bdi->wb_list, struct bdi_writeback, | 715 | wb = list_first_entry(&bdi->wb_list, struct bdi_writeback, |
| 723 | bdi_node); | 716 | bdi_node); |
| @@ -726,6 +719,7 @@ static void cgwb_bdi_unregister(struct backing_dev_info *bdi) | |||
| 726 | spin_lock_irq(&cgwb_lock); | 719 | spin_lock_irq(&cgwb_lock); |
| 727 | } | 720 | } |
| 728 | spin_unlock_irq(&cgwb_lock); | 721 | spin_unlock_irq(&cgwb_lock); |
| 722 | mutex_unlock(&bdi->cgwb_release_mutex); | ||
| 729 | } | 723 | } |
| 730 | 724 | ||
| 731 | /** | 725 | /** |
