aboutsummaryrefslogtreecommitdiffstats
path: root/mm
diff options
context:
space:
mode:
Diffstat (limited to 'mm')
-rw-r--r--mm/memcontrol.c152
1 files changed, 44 insertions, 108 deletions
diff --git a/mm/memcontrol.c b/mm/memcontrol.c
index e0ac636315f8..07908ea954b6 100644
--- a/mm/memcontrol.c
+++ b/mm/memcontrol.c
@@ -2570,9 +2570,8 @@ static int mem_cgroup_try_charge(struct mem_cgroup *memcg,
2570 unsigned long nr_reclaimed; 2570 unsigned long nr_reclaimed;
2571 unsigned long flags = 0; 2571 unsigned long flags = 0;
2572 unsigned long long size; 2572 unsigned long long size;
2573 int ret = 0;
2573 2574
2574 if (mem_cgroup_is_root(memcg))
2575 goto done;
2576retry: 2575retry:
2577 if (consume_stock(memcg, nr_pages)) 2576 if (consume_stock(memcg, nr_pages))
2578 goto done; 2577 goto done;
@@ -2650,13 +2649,15 @@ nomem:
2650 if (!(gfp_mask & __GFP_NOFAIL)) 2649 if (!(gfp_mask & __GFP_NOFAIL))
2651 return -ENOMEM; 2650 return -ENOMEM;
2652bypass: 2651bypass:
2653 return -EINTR; 2652 memcg = root_mem_cgroup;
2653 ret = -EINTR;
2654 goto retry;
2654 2655
2655done_restock: 2656done_restock:
2656 if (batch > nr_pages) 2657 if (batch > nr_pages)
2657 refill_stock(memcg, batch - nr_pages); 2658 refill_stock(memcg, batch - nr_pages);
2658done: 2659done:
2659 return 0; 2660 return ret;
2660} 2661}
2661 2662
2662/** 2663/**
@@ -2695,13 +2696,11 @@ static struct mem_cgroup *mem_cgroup_try_charge_mm(struct mm_struct *mm,
2695static void __mem_cgroup_cancel_charge(struct mem_cgroup *memcg, 2696static void __mem_cgroup_cancel_charge(struct mem_cgroup *memcg,
2696 unsigned int nr_pages) 2697 unsigned int nr_pages)
2697{ 2698{
2698 if (!mem_cgroup_is_root(memcg)) { 2699 unsigned long bytes = nr_pages * PAGE_SIZE;
2699 unsigned long bytes = nr_pages * PAGE_SIZE;
2700 2700
2701 res_counter_uncharge(&memcg->res, bytes); 2701 res_counter_uncharge(&memcg->res, bytes);
2702 if (do_swap_account) 2702 if (do_swap_account)
2703 res_counter_uncharge(&memcg->memsw, bytes); 2703 res_counter_uncharge(&memcg->memsw, bytes);
2704 }
2705} 2704}
2706 2705
2707/* 2706/*
@@ -2713,9 +2712,6 @@ static void __mem_cgroup_cancel_local_charge(struct mem_cgroup *memcg,
2713{ 2712{
2714 unsigned long bytes = nr_pages * PAGE_SIZE; 2713 unsigned long bytes = nr_pages * PAGE_SIZE;
2715 2714
2716 if (mem_cgroup_is_root(memcg))
2717 return;
2718
2719 res_counter_uncharge_until(&memcg->res, memcg->res.parent, bytes); 2715 res_counter_uncharge_until(&memcg->res, memcg->res.parent, bytes);
2720 if (do_swap_account) 2716 if (do_swap_account)
2721 res_counter_uncharge_until(&memcg->memsw, 2717 res_counter_uncharge_until(&memcg->memsw,
@@ -3943,7 +3939,7 @@ __mem_cgroup_uncharge_common(struct page *page, enum charge_type ctype,
3943 * replacement page, so leave it alone when phasing out the 3939 * replacement page, so leave it alone when phasing out the
3944 * page that is unused after the migration. 3940 * page that is unused after the migration.
3945 */ 3941 */
3946 if (!end_migration && !mem_cgroup_is_root(memcg)) 3942 if (!end_migration)
3947 mem_cgroup_do_uncharge(memcg, nr_pages, ctype); 3943 mem_cgroup_do_uncharge(memcg, nr_pages, ctype);
3948 3944
3949 return memcg; 3945 return memcg;
@@ -4076,8 +4072,7 @@ void mem_cgroup_uncharge_swap(swp_entry_t ent)
4076 * We uncharge this because swap is freed. This memcg can 4072 * We uncharge this because swap is freed. This memcg can
4077 * be obsolete one. We avoid calling css_tryget_online(). 4073 * be obsolete one. We avoid calling css_tryget_online().
4078 */ 4074 */
4079 if (!mem_cgroup_is_root(memcg)) 4075 res_counter_uncharge(&memcg->memsw, PAGE_SIZE);
4080 res_counter_uncharge(&memcg->memsw, PAGE_SIZE);
4081 mem_cgroup_swap_statistics(memcg, false); 4076 mem_cgroup_swap_statistics(memcg, false);
4082 css_put(&memcg->css); 4077 css_put(&memcg->css);
4083 } 4078 }
@@ -4767,78 +4762,24 @@ out:
4767 return retval; 4762 return retval;
4768} 4763}
4769 4764
4770
4771static unsigned long mem_cgroup_recursive_stat(struct mem_cgroup *memcg,
4772 enum mem_cgroup_stat_index idx)
4773{
4774 struct mem_cgroup *iter;
4775 long val = 0;
4776
4777 /* Per-cpu values can be negative, use a signed accumulator */
4778 for_each_mem_cgroup_tree(iter, memcg)
4779 val += mem_cgroup_read_stat(iter, idx);
4780
4781 if (val < 0) /* race ? */
4782 val = 0;
4783 return val;
4784}
4785
4786static inline u64 mem_cgroup_usage(struct mem_cgroup *memcg, bool swap)
4787{
4788 u64 val;
4789
4790 if (!mem_cgroup_is_root(memcg)) {
4791 if (!swap)
4792 return res_counter_read_u64(&memcg->res, RES_USAGE);
4793 else
4794 return res_counter_read_u64(&memcg->memsw, RES_USAGE);
4795 }
4796
4797 /*
4798 * Transparent hugepages are still accounted for in MEM_CGROUP_STAT_RSS
4799 * as well as in MEM_CGROUP_STAT_RSS_HUGE.
4800 */
4801 val = mem_cgroup_recursive_stat(memcg, MEM_CGROUP_STAT_CACHE);
4802 val += mem_cgroup_recursive_stat(memcg, MEM_CGROUP_STAT_RSS);
4803
4804 if (swap)
4805 val += mem_cgroup_recursive_stat(memcg, MEM_CGROUP_STAT_SWAP);
4806
4807 return val << PAGE_SHIFT;
4808}
4809
4810static u64 mem_cgroup_read_u64(struct cgroup_subsys_state *css, 4765static u64 mem_cgroup_read_u64(struct cgroup_subsys_state *css,
4811 struct cftype *cft) 4766 struct cftype *cft)
4812{ 4767{
4813 struct mem_cgroup *memcg = mem_cgroup_from_css(css); 4768 struct mem_cgroup *memcg = mem_cgroup_from_css(css);
4814 u64 val; 4769 enum res_type type = MEMFILE_TYPE(cft->private);
4815 int name; 4770 int name = MEMFILE_ATTR(cft->private);
4816 enum res_type type;
4817
4818 type = MEMFILE_TYPE(cft->private);
4819 name = MEMFILE_ATTR(cft->private);
4820 4771
4821 switch (type) { 4772 switch (type) {
4822 case _MEM: 4773 case _MEM:
4823 if (name == RES_USAGE) 4774 return res_counter_read_u64(&memcg->res, name);
4824 val = mem_cgroup_usage(memcg, false);
4825 else
4826 val = res_counter_read_u64(&memcg->res, name);
4827 break;
4828 case _MEMSWAP: 4775 case _MEMSWAP:
4829 if (name == RES_USAGE) 4776 return res_counter_read_u64(&memcg->memsw, name);
4830 val = mem_cgroup_usage(memcg, true);
4831 else
4832 val = res_counter_read_u64(&memcg->memsw, name);
4833 break;
4834 case _KMEM: 4777 case _KMEM:
4835 val = res_counter_read_u64(&memcg->kmem, name); 4778 return res_counter_read_u64(&memcg->kmem, name);
4836 break; 4779 break;
4837 default: 4780 default:
4838 BUG(); 4781 BUG();
4839 } 4782 }
4840
4841 return val;
4842} 4783}
4843 4784
4844#ifdef CONFIG_MEMCG_KMEM 4785#ifdef CONFIG_MEMCG_KMEM
@@ -5300,7 +5241,10 @@ static void __mem_cgroup_threshold(struct mem_cgroup *memcg, bool swap)
5300 if (!t) 5241 if (!t)
5301 goto unlock; 5242 goto unlock;
5302 5243
5303 usage = mem_cgroup_usage(memcg, swap); 5244 if (!swap)
5245 usage = res_counter_read_u64(&memcg->res, RES_USAGE);
5246 else
5247 usage = res_counter_read_u64(&memcg->memsw, RES_USAGE);
5304 5248
5305 /* 5249 /*
5306 * current_threshold points to threshold just below or equal to usage. 5250 * current_threshold points to threshold just below or equal to usage.
@@ -5396,15 +5340,15 @@ static int __mem_cgroup_usage_register_event(struct mem_cgroup *memcg,
5396 5340
5397 mutex_lock(&memcg->thresholds_lock); 5341 mutex_lock(&memcg->thresholds_lock);
5398 5342
5399 if (type == _MEM) 5343 if (type == _MEM) {
5400 thresholds = &memcg->thresholds; 5344 thresholds = &memcg->thresholds;
5401 else if (type == _MEMSWAP) 5345 usage = res_counter_read_u64(&memcg->res, RES_USAGE);
5346 } else if (type == _MEMSWAP) {
5402 thresholds = &memcg->memsw_thresholds; 5347 thresholds = &memcg->memsw_thresholds;
5403 else 5348 usage = res_counter_read_u64(&memcg->memsw, RES_USAGE);
5349 } else
5404 BUG(); 5350 BUG();
5405 5351
5406 usage = mem_cgroup_usage(memcg, type == _MEMSWAP);
5407
5408 /* Check if a threshold crossed before adding a new one */ 5352 /* Check if a threshold crossed before adding a new one */
5409 if (thresholds->primary) 5353 if (thresholds->primary)
5410 __mem_cgroup_threshold(memcg, type == _MEMSWAP); 5354 __mem_cgroup_threshold(memcg, type == _MEMSWAP);
@@ -5484,18 +5428,19 @@ static void __mem_cgroup_usage_unregister_event(struct mem_cgroup *memcg,
5484 int i, j, size; 5428 int i, j, size;
5485 5429
5486 mutex_lock(&memcg->thresholds_lock); 5430 mutex_lock(&memcg->thresholds_lock);
5487 if (type == _MEM) 5431
5432 if (type == _MEM) {
5488 thresholds = &memcg->thresholds; 5433 thresholds = &memcg->thresholds;
5489 else if (type == _MEMSWAP) 5434 usage = res_counter_read_u64(&memcg->res, RES_USAGE);
5435 } else if (type == _MEMSWAP) {
5490 thresholds = &memcg->memsw_thresholds; 5436 thresholds = &memcg->memsw_thresholds;
5491 else 5437 usage = res_counter_read_u64(&memcg->memsw, RES_USAGE);
5438 } else
5492 BUG(); 5439 BUG();
5493 5440
5494 if (!thresholds->primary) 5441 if (!thresholds->primary)
5495 goto unlock; 5442 goto unlock;
5496 5443
5497 usage = mem_cgroup_usage(memcg, type == _MEMSWAP);
5498
5499 /* Check if a threshold crossed before removing */ 5444 /* Check if a threshold crossed before removing */
5500 __mem_cgroup_threshold(memcg, type == _MEMSWAP); 5445 __mem_cgroup_threshold(memcg, type == _MEMSWAP);
5501 5446
@@ -6249,9 +6194,9 @@ mem_cgroup_css_online(struct cgroup_subsys_state *css)
6249 * core guarantees its existence. 6194 * core guarantees its existence.
6250 */ 6195 */
6251 } else { 6196 } else {
6252 res_counter_init(&memcg->res, NULL); 6197 res_counter_init(&memcg->res, &root_mem_cgroup->res);
6253 res_counter_init(&memcg->memsw, NULL); 6198 res_counter_init(&memcg->memsw, &root_mem_cgroup->memsw);
6254 res_counter_init(&memcg->kmem, NULL); 6199 res_counter_init(&memcg->kmem, &root_mem_cgroup->kmem);
6255 /* 6200 /*
6256 * Deeper hierachy with use_hierarchy == false doesn't make 6201 * Deeper hierachy with use_hierarchy == false doesn't make
6257 * much sense so let cgroup subsystem know about this 6202 * much sense so let cgroup subsystem know about this
@@ -6387,13 +6332,7 @@ static void mem_cgroup_css_reset(struct cgroup_subsys_state *css)
6387/* Handlers for move charge at task migration. */ 6332/* Handlers for move charge at task migration. */
6388static int mem_cgroup_do_precharge(unsigned long count) 6333static int mem_cgroup_do_precharge(unsigned long count)
6389{ 6334{
6390 int ret = 0; 6335 int ret;
6391
6392 if (mem_cgroup_is_root(mc.to)) {
6393 mc.precharge += count;
6394 /* we don't need css_get for root */
6395 return ret;
6396 }
6397 6336
6398 /* Try a single bulk charge without reclaim first */ 6337 /* Try a single bulk charge without reclaim first */
6399 ret = mem_cgroup_try_charge(mc.to, GFP_KERNEL & ~__GFP_WAIT, count); 6338 ret = mem_cgroup_try_charge(mc.to, GFP_KERNEL & ~__GFP_WAIT, count);
@@ -6700,21 +6639,18 @@ static void __mem_cgroup_clear_mc(void)
6700 /* we must fixup refcnts and charges */ 6639 /* we must fixup refcnts and charges */
6701 if (mc.moved_swap) { 6640 if (mc.moved_swap) {
6702 /* uncharge swap account from the old cgroup */ 6641 /* uncharge swap account from the old cgroup */
6703 if (!mem_cgroup_is_root(mc.from)) 6642 res_counter_uncharge(&mc.from->memsw,
6704 res_counter_uncharge(&mc.from->memsw, 6643 PAGE_SIZE * mc.moved_swap);
6705 PAGE_SIZE * mc.moved_swap);
6706 6644
6707 for (i = 0; i < mc.moved_swap; i++) 6645 for (i = 0; i < mc.moved_swap; i++)
6708 css_put(&mc.from->css); 6646 css_put(&mc.from->css);
6709 6647
6710 if (!mem_cgroup_is_root(mc.to)) { 6648 /*
6711 /* 6649 * we charged both to->res and to->memsw, so we should
6712 * we charged both to->res and to->memsw, so we should 6650 * uncharge to->res.
6713 * uncharge to->res. 6651 */
6714 */ 6652 res_counter_uncharge(&mc.to->res,
6715 res_counter_uncharge(&mc.to->res, 6653 PAGE_SIZE * mc.moved_swap);
6716 PAGE_SIZE * mc.moved_swap);
6717 }
6718 /* we've already done css_get(mc.to) */ 6654 /* we've already done css_get(mc.to) */
6719 mc.moved_swap = 0; 6655 mc.moved_swap = 0;
6720 } 6656 }