hugetlb_cgroup: use helper for_each_hstate and hstate_index
[linux-2.6-block.git] / mm / hugetlb_cgroup.c
CommitLineData
2bc64a20
AK
1/*
2 *
3 * Copyright IBM Corporation, 2012
4 * Author Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
5 *
faced7e0
GS
6 * Cgroup v2
7 * Copyright (C) 2019 Red Hat, Inc.
8 * Author: Giuseppe Scrivano <gscrivan@redhat.com>
9 *
2bc64a20
AK
10 * This program is free software; you can redistribute it and/or modify it
11 * under the terms of version 2.1 of the GNU Lesser General Public License
12 * as published by the Free Software Foundation.
13 *
14 * This program is distributed in the hope that it would be useful, but
15 * WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
17 *
18 */
19
20#include <linux/cgroup.h>
71f87bee 21#include <linux/page_counter.h>
2bc64a20
AK
22#include <linux/slab.h>
23#include <linux/hugetlb.h>
24#include <linux/hugetlb_cgroup.h>
25
abb8206c
AK
26#define MEMFILE_PRIVATE(x, val) (((x) << 16) | (val))
27#define MEMFILE_IDX(val) (((val) >> 16) & 0xffff)
28#define MEMFILE_ATTR(val) ((val) & 0xffff)
29
2bc64a20
AK
30static struct hugetlb_cgroup *root_h_cgroup __read_mostly;
31
cdc2fcfe 32static inline struct page_counter *
1adc4d41
MA
33__hugetlb_cgroup_counter_from_cgroup(struct hugetlb_cgroup *h_cg, int idx,
34 bool rsvd)
cdc2fcfe
MA
35{
36 if (rsvd)
37 return &h_cg->rsvd_hugepage[idx];
38 return &h_cg->hugepage[idx];
39}
40
1adc4d41
MA
41static inline struct page_counter *
42hugetlb_cgroup_counter_from_cgroup(struct hugetlb_cgroup *h_cg, int idx)
43{
44 return __hugetlb_cgroup_counter_from_cgroup(h_cg, idx, false);
45}
46
47static inline struct page_counter *
48hugetlb_cgroup_counter_from_cgroup_rsvd(struct hugetlb_cgroup *h_cg, int idx)
49{
50 return __hugetlb_cgroup_counter_from_cgroup(h_cg, idx, true);
51}
52
2bc64a20
AK
53static inline
54struct hugetlb_cgroup *hugetlb_cgroup_from_css(struct cgroup_subsys_state *s)
55{
a7c6d554 56 return s ? container_of(s, struct hugetlb_cgroup, css) : NULL;
2bc64a20
AK
57}
58
2bc64a20
AK
59static inline
60struct hugetlb_cgroup *hugetlb_cgroup_from_task(struct task_struct *task)
61{
073219e9 62 return hugetlb_cgroup_from_css(task_css(task, hugetlb_cgrp_id));
2bc64a20
AK
63}
64
65static inline bool hugetlb_cgroup_is_root(struct hugetlb_cgroup *h_cg)
66{
67 return (h_cg == root_h_cgroup);
68}
69
3f798518
TH
70static inline struct hugetlb_cgroup *
71parent_hugetlb_cgroup(struct hugetlb_cgroup *h_cg)
2bc64a20 72{
5c9d535b 73 return hugetlb_cgroup_from_css(h_cg->css.parent);
2bc64a20
AK
74}
75
3f798518 76static inline bool hugetlb_cgroup_have_usage(struct hugetlb_cgroup *h_cg)
2bc64a20 77{
c37213c5 78 struct hstate *h;
2bc64a20 79
c37213c5 80 for_each_hstate(h) {
1adc4d41 81 if (page_counter_read(
c37213c5 82 hugetlb_cgroup_counter_from_cgroup(h_cg, hstate_index(h))))
2bc64a20
AK
83 return true;
84 }
85 return false;
86}
87
297880f4
DR
88static void hugetlb_cgroup_init(struct hugetlb_cgroup *h_cgroup,
89 struct hugetlb_cgroup *parent_h_cgroup)
90{
91 int idx;
92
93 for (idx = 0; idx < HUGE_MAX_HSTATE; idx++) {
1adc4d41
MA
94 struct page_counter *fault_parent = NULL;
95 struct page_counter *rsvd_parent = NULL;
297880f4
DR
96 unsigned long limit;
97 int ret;
98
1adc4d41
MA
99 if (parent_h_cgroup) {
100 fault_parent = hugetlb_cgroup_counter_from_cgroup(
101 parent_h_cgroup, idx);
102 rsvd_parent = hugetlb_cgroup_counter_from_cgroup_rsvd(
103 parent_h_cgroup, idx);
104 }
105 page_counter_init(hugetlb_cgroup_counter_from_cgroup(h_cgroup,
106 idx),
107 fault_parent);
108 page_counter_init(
109 hugetlb_cgroup_counter_from_cgroup_rsvd(h_cgroup, idx),
110 rsvd_parent);
297880f4
DR
111
112 limit = round_down(PAGE_COUNTER_MAX,
8938494c 113 pages_per_huge_page(&hstates[idx]));
1adc4d41
MA
114
115 ret = page_counter_set_max(
116 hugetlb_cgroup_counter_from_cgroup(h_cgroup, idx),
117 limit);
118 VM_BUG_ON(ret);
119 ret = page_counter_set_max(
120 hugetlb_cgroup_counter_from_cgroup_rsvd(h_cgroup, idx),
121 limit);
297880f4
DR
122 VM_BUG_ON(ret);
123 }
124}
125
f4776199
MA
126static void hugetlb_cgroup_free(struct hugetlb_cgroup *h_cgroup)
127{
128 int node;
129
130 for_each_node(node)
131 kfree(h_cgroup->nodeinfo[node]);
132 kfree(h_cgroup);
133}
134
eb95419b
TH
135static struct cgroup_subsys_state *
136hugetlb_cgroup_css_alloc(struct cgroup_subsys_state *parent_css)
2bc64a20 137{
eb95419b
TH
138 struct hugetlb_cgroup *parent_h_cgroup = hugetlb_cgroup_from_css(parent_css);
139 struct hugetlb_cgroup *h_cgroup;
f4776199
MA
140 int node;
141
142 h_cgroup = kzalloc(struct_size(h_cgroup, nodeinfo, nr_node_ids),
143 GFP_KERNEL);
2bc64a20 144
2bc64a20
AK
145 if (!h_cgroup)
146 return ERR_PTR(-ENOMEM);
147
297880f4 148 if (!parent_h_cgroup)
2bc64a20 149 root_h_cgroup = h_cgroup;
297880f4 150
f4776199
MA
151 /*
152 * TODO: this routine can waste much memory for nodes which will
153 * never be onlined. It's better to use memory hotplug callback
154 * function.
155 */
156 for_each_node(node) {
99249387 157 /* Set node_to_alloc to NUMA_NO_NODE for offline nodes. */
f4776199 158 int node_to_alloc =
99249387 159 node_state(node, N_NORMAL_MEMORY) ? node : NUMA_NO_NODE;
f4776199
MA
160 h_cgroup->nodeinfo[node] =
161 kzalloc_node(sizeof(struct hugetlb_cgroup_per_node),
162 GFP_KERNEL, node_to_alloc);
163 if (!h_cgroup->nodeinfo[node])
164 goto fail_alloc_nodeinfo;
165 }
166
297880f4 167 hugetlb_cgroup_init(h_cgroup, parent_h_cgroup);
2bc64a20 168 return &h_cgroup->css;
f4776199
MA
169
170fail_alloc_nodeinfo:
171 hugetlb_cgroup_free(h_cgroup);
172 return ERR_PTR(-ENOMEM);
2bc64a20
AK
173}
174
eb95419b 175static void hugetlb_cgroup_css_free(struct cgroup_subsys_state *css)
2bc64a20 176{
f4776199 177 hugetlb_cgroup_free(hugetlb_cgroup_from_css(css));
2bc64a20
AK
178}
179
da1def55
AK
180/*
181 * Should be called with hugetlb_lock held.
182 * Since we are holding hugetlb_lock, pages cannot get moved from
183 * active list or uncharged from the cgroup, So no need to get
184 * page reference and test for page active here. This function
185 * cannot fail.
186 */
3f798518 187static void hugetlb_cgroup_move_parent(int idx, struct hugetlb_cgroup *h_cg,
da1def55
AK
188 struct page *page)
189{
71f87bee
JW
190 unsigned int nr_pages;
191 struct page_counter *counter;
da1def55 192 struct hugetlb_cgroup *page_hcg;
3f798518 193 struct hugetlb_cgroup *parent = parent_hugetlb_cgroup(h_cg);
da1def55
AK
194
195 page_hcg = hugetlb_cgroup_from_page(page);
196 /*
197 * We can have pages in active list without any cgroup
198 * ie, hugepage with less than 3 pages. We can safely
199 * ignore those pages.
200 */
201 if (!page_hcg || page_hcg != h_cg)
202 goto out;
203
d8c6546b 204 nr_pages = compound_nr(page);
da1def55
AK
205 if (!parent) {
206 parent = root_h_cgroup;
207 /* root has no limit */
71f87bee 208 page_counter_charge(&parent->hugepage[idx], nr_pages);
da1def55
AK
209 }
210 counter = &h_cg->hugepage[idx];
71f87bee
JW
211 /* Take the pages off the local counter */
212 page_counter_cancel(counter, nr_pages);
da1def55
AK
213
214 set_hugetlb_cgroup(page, parent);
215out:
216 return;
217}
218
219/*
220 * Force the hugetlb cgroup to empty the hugetlb resources by moving them to
221 * the parent cgroup.
222 */
eb95419b 223static void hugetlb_cgroup_css_offline(struct cgroup_subsys_state *css)
2bc64a20 224{
eb95419b 225 struct hugetlb_cgroup *h_cg = hugetlb_cgroup_from_css(css);
da1def55
AK
226 struct hstate *h;
227 struct page *page;
da1def55
AK
228
229 do {
da1def55 230 for_each_hstate(h) {
db71ef79 231 spin_lock_irq(&hugetlb_lock);
da1def55 232 list_for_each_entry(page, &h->hugepage_activelist, lru)
c37213c5 233 hugetlb_cgroup_move_parent(hstate_index(h), h_cg, page);
da1def55 234
db71ef79 235 spin_unlock_irq(&hugetlb_lock);
da1def55
AK
236 }
237 cond_resched();
3f798518 238 } while (hugetlb_cgroup_have_usage(h_cg));
2bc64a20
AK
239}
240
faced7e0
GS
241static inline void hugetlb_event(struct hugetlb_cgroup *hugetlb, int idx,
242 enum hugetlb_memory_event event)
243{
244 atomic_long_inc(&hugetlb->events_local[idx][event]);
245 cgroup_file_notify(&hugetlb->events_local_file[idx]);
246
247 do {
248 atomic_long_inc(&hugetlb->events[idx][event]);
249 cgroup_file_notify(&hugetlb->events_file[idx]);
250 } while ((hugetlb = parent_hugetlb_cgroup(hugetlb)) &&
251 !hugetlb_cgroup_is_root(hugetlb));
252}
253
1adc4d41
MA
254static int __hugetlb_cgroup_charge_cgroup(int idx, unsigned long nr_pages,
255 struct hugetlb_cgroup **ptr,
256 bool rsvd)
6d76dcf4
AK
257{
258 int ret = 0;
71f87bee 259 struct page_counter *counter;
6d76dcf4 260 struct hugetlb_cgroup *h_cg = NULL;
6d76dcf4
AK
261
262 if (hugetlb_cgroup_disabled())
263 goto done;
264 /*
265 * We don't charge any cgroup if the compound page have less
266 * than 3 pages.
267 */
268 if (huge_page_order(&hstates[idx]) < HUGETLB_CGROUP_MIN_ORDER)
269 goto done;
270again:
271 rcu_read_lock();
272 h_cg = hugetlb_cgroup_from_task(current);
0362f326 273 if (!css_tryget(&h_cg->css)) {
6d76dcf4
AK
274 rcu_read_unlock();
275 goto again;
276 }
277 rcu_read_unlock();
278
1adc4d41
MA
279 if (!page_counter_try_charge(
280 __hugetlb_cgroup_counter_from_cgroup(h_cg, idx, rsvd),
281 nr_pages, &counter)) {
6071ca52 282 ret = -ENOMEM;
726b7bbe 283 hugetlb_event(h_cg, idx, HUGETLB_MAX);
1adc4d41
MA
284 css_put(&h_cg->css);
285 goto done;
faced7e0 286 }
1adc4d41
MA
287 /* Reservations take a reference to the css because they do not get
288 * reparented.
289 */
290 if (!rsvd)
291 css_put(&h_cg->css);
6d76dcf4
AK
292done:
293 *ptr = h_cg;
294 return ret;
295}
296
1adc4d41
MA
297int hugetlb_cgroup_charge_cgroup(int idx, unsigned long nr_pages,
298 struct hugetlb_cgroup **ptr)
299{
300 return __hugetlb_cgroup_charge_cgroup(idx, nr_pages, ptr, false);
301}
302
303int hugetlb_cgroup_charge_cgroup_rsvd(int idx, unsigned long nr_pages,
304 struct hugetlb_cgroup **ptr)
305{
306 return __hugetlb_cgroup_charge_cgroup(idx, nr_pages, ptr, true);
307}
308
94ae8ba7 309/* Should be called with hugetlb_lock held */
1adc4d41
MA
310static void __hugetlb_cgroup_commit_charge(int idx, unsigned long nr_pages,
311 struct hugetlb_cgroup *h_cg,
312 struct page *page, bool rsvd)
6d76dcf4
AK
313{
314 if (hugetlb_cgroup_disabled() || !h_cg)
315 return;
316
1adc4d41 317 __set_hugetlb_cgroup(page, h_cg, rsvd);
f4776199
MA
318 if (!rsvd) {
319 unsigned long usage =
320 h_cg->nodeinfo[page_to_nid(page)]->usage[idx];
321 /*
322 * This write is not atomic due to fetching usage and writing
323 * to it, but that's fine because we call this with
324 * hugetlb_lock held anyway.
325 */
326 WRITE_ONCE(h_cg->nodeinfo[page_to_nid(page)]->usage[idx],
327 usage + nr_pages);
328 }
6d76dcf4
AK
329}
330
1adc4d41
MA
331void hugetlb_cgroup_commit_charge(int idx, unsigned long nr_pages,
332 struct hugetlb_cgroup *h_cg,
333 struct page *page)
334{
335 __hugetlb_cgroup_commit_charge(idx, nr_pages, h_cg, page, false);
336}
337
338void hugetlb_cgroup_commit_charge_rsvd(int idx, unsigned long nr_pages,
339 struct hugetlb_cgroup *h_cg,
340 struct page *page)
341{
342 __hugetlb_cgroup_commit_charge(idx, nr_pages, h_cg, page, true);
343}
344
6d76dcf4
AK
345/*
346 * Should be called with hugetlb_lock held
347 */
1adc4d41
MA
348static void __hugetlb_cgroup_uncharge_page(int idx, unsigned long nr_pages,
349 struct page *page, bool rsvd)
6d76dcf4
AK
350{
351 struct hugetlb_cgroup *h_cg;
6d76dcf4
AK
352
353 if (hugetlb_cgroup_disabled())
354 return;
7ea8574e 355 lockdep_assert_held(&hugetlb_lock);
1adc4d41 356 h_cg = __hugetlb_cgroup_from_page(page, rsvd);
6d76dcf4
AK
357 if (unlikely(!h_cg))
358 return;
1adc4d41
MA
359 __set_hugetlb_cgroup(page, NULL, rsvd);
360
361 page_counter_uncharge(__hugetlb_cgroup_counter_from_cgroup(h_cg, idx,
362 rsvd),
363 nr_pages);
364
365 if (rsvd)
366 css_put(&h_cg->css);
f4776199
MA
367 else {
368 unsigned long usage =
369 h_cg->nodeinfo[page_to_nid(page)]->usage[idx];
370 /*
371 * This write is not atomic due to fetching usage and writing
372 * to it, but that's fine because we call this with
373 * hugetlb_lock held anyway.
374 */
375 WRITE_ONCE(h_cg->nodeinfo[page_to_nid(page)]->usage[idx],
376 usage - nr_pages);
377 }
6d76dcf4
AK
378}
379
1adc4d41
MA
380void hugetlb_cgroup_uncharge_page(int idx, unsigned long nr_pages,
381 struct page *page)
382{
383 __hugetlb_cgroup_uncharge_page(idx, nr_pages, page, false);
384}
385
386void hugetlb_cgroup_uncharge_page_rsvd(int idx, unsigned long nr_pages,
387 struct page *page)
388{
389 __hugetlb_cgroup_uncharge_page(idx, nr_pages, page, true);
390}
391
392static void __hugetlb_cgroup_uncharge_cgroup(int idx, unsigned long nr_pages,
393 struct hugetlb_cgroup *h_cg,
394 bool rsvd)
6d76dcf4 395{
6d76dcf4
AK
396 if (hugetlb_cgroup_disabled() || !h_cg)
397 return;
398
399 if (huge_page_order(&hstates[idx]) < HUGETLB_CGROUP_MIN_ORDER)
400 return;
401
1adc4d41
MA
402 page_counter_uncharge(__hugetlb_cgroup_counter_from_cgroup(h_cg, idx,
403 rsvd),
404 nr_pages);
405
406 if (rsvd)
407 css_put(&h_cg->css);
408}
409
410void hugetlb_cgroup_uncharge_cgroup(int idx, unsigned long nr_pages,
411 struct hugetlb_cgroup *h_cg)
412{
413 __hugetlb_cgroup_uncharge_cgroup(idx, nr_pages, h_cg, false);
414}
415
416void hugetlb_cgroup_uncharge_cgroup_rsvd(int idx, unsigned long nr_pages,
417 struct hugetlb_cgroup *h_cg)
418{
419 __hugetlb_cgroup_uncharge_cgroup(idx, nr_pages, h_cg, true);
420}
421
e9fe92ae
MA
422void hugetlb_cgroup_uncharge_counter(struct resv_map *resv, unsigned long start,
423 unsigned long end)
1adc4d41 424{
e9fe92ae
MA
425 if (hugetlb_cgroup_disabled() || !resv || !resv->reservation_counter ||
426 !resv->css)
1adc4d41
MA
427 return;
428
e9fe92ae
MA
429 page_counter_uncharge(resv->reservation_counter,
430 (end - start) * resv->pages_per_hpage);
431 css_put(resv->css);
6d76dcf4
AK
432}
433
075a61d0
MA
434void hugetlb_cgroup_uncharge_file_region(struct resv_map *resv,
435 struct file_region *rg,
d85aecf2
ML
436 unsigned long nr_pages,
437 bool region_del)
075a61d0
MA
438{
439 if (hugetlb_cgroup_disabled() || !resv || !rg || !nr_pages)
440 return;
441
862f7f65 442 if (rg->reservation_counter && resv->pages_per_hpage &&
075a61d0
MA
443 !resv->reservation_counter) {
444 page_counter_uncharge(rg->reservation_counter,
445 nr_pages * resv->pages_per_hpage);
d85aecf2
ML
446 /*
447 * Only do css_put(rg->css) when we delete the entire region
448 * because one file_region must hold exactly one css reference.
449 */
450 if (region_del)
451 css_put(rg->css);
075a61d0
MA
452 }
453}
454
71f87bee
JW
455enum {
456 RES_USAGE,
cdc2fcfe 457 RES_RSVD_USAGE,
71f87bee 458 RES_LIMIT,
cdc2fcfe 459 RES_RSVD_LIMIT,
71f87bee 460 RES_MAX_USAGE,
cdc2fcfe 461 RES_RSVD_MAX_USAGE,
71f87bee 462 RES_FAILCNT,
cdc2fcfe 463 RES_RSVD_FAILCNT,
71f87bee
JW
464};
465
f4776199
MA
466static int hugetlb_cgroup_read_numa_stat(struct seq_file *seq, void *dummy)
467{
468 int nid;
469 struct cftype *cft = seq_cft(seq);
470 int idx = MEMFILE_IDX(cft->private);
471 bool legacy = MEMFILE_ATTR(cft->private);
472 struct hugetlb_cgroup *h_cg = hugetlb_cgroup_from_css(seq_css(seq));
473 struct cgroup_subsys_state *css;
474 unsigned long usage;
475
476 if (legacy) {
477 /* Add up usage across all nodes for the non-hierarchical total. */
478 usage = 0;
479 for_each_node_state(nid, N_MEMORY)
480 usage += READ_ONCE(h_cg->nodeinfo[nid]->usage[idx]);
481 seq_printf(seq, "total=%lu", usage * PAGE_SIZE);
482
483 /* Simply print the per-node usage for the non-hierarchical total. */
484 for_each_node_state(nid, N_MEMORY)
485 seq_printf(seq, " N%d=%lu", nid,
486 READ_ONCE(h_cg->nodeinfo[nid]->usage[idx]) *
487 PAGE_SIZE);
488 seq_putc(seq, '\n');
489 }
490
491 /*
492 * The hierarchical total is pretty much the value recorded by the
493 * counter, so use that.
494 */
495 seq_printf(seq, "%stotal=%lu", legacy ? "hierarchical_" : "",
496 page_counter_read(&h_cg->hugepage[idx]) * PAGE_SIZE);
497
498 /*
499 * For each node, transverse the css tree to obtain the hierarchical
500 * node usage.
501 */
502 for_each_node_state(nid, N_MEMORY) {
503 usage = 0;
504 rcu_read_lock();
505 css_for_each_descendant_pre(css, &h_cg->css) {
506 usage += READ_ONCE(hugetlb_cgroup_from_css(css)
507 ->nodeinfo[nid]
508 ->usage[idx]);
509 }
510 rcu_read_unlock();
511 seq_printf(seq, " N%d=%lu", nid, usage * PAGE_SIZE);
512 }
513
514 seq_putc(seq, '\n');
515
516 return 0;
517}
518
716f479d
TH
519static u64 hugetlb_cgroup_read_u64(struct cgroup_subsys_state *css,
520 struct cftype *cft)
abb8206c 521{
71f87bee 522 struct page_counter *counter;
cdc2fcfe 523 struct page_counter *rsvd_counter;
182446d0 524 struct hugetlb_cgroup *h_cg = hugetlb_cgroup_from_css(css);
abb8206c 525
71f87bee 526 counter = &h_cg->hugepage[MEMFILE_IDX(cft->private)];
cdc2fcfe 527 rsvd_counter = &h_cg->rsvd_hugepage[MEMFILE_IDX(cft->private)];
abb8206c 528
71f87bee
JW
529 switch (MEMFILE_ATTR(cft->private)) {
530 case RES_USAGE:
531 return (u64)page_counter_read(counter) * PAGE_SIZE;
cdc2fcfe
MA
532 case RES_RSVD_USAGE:
533 return (u64)page_counter_read(rsvd_counter) * PAGE_SIZE;
71f87bee 534 case RES_LIMIT:
bbec2e15 535 return (u64)counter->max * PAGE_SIZE;
cdc2fcfe
MA
536 case RES_RSVD_LIMIT:
537 return (u64)rsvd_counter->max * PAGE_SIZE;
71f87bee
JW
538 case RES_MAX_USAGE:
539 return (u64)counter->watermark * PAGE_SIZE;
cdc2fcfe
MA
540 case RES_RSVD_MAX_USAGE:
541 return (u64)rsvd_counter->watermark * PAGE_SIZE;
71f87bee
JW
542 case RES_FAILCNT:
543 return counter->failcnt;
cdc2fcfe
MA
544 case RES_RSVD_FAILCNT:
545 return rsvd_counter->failcnt;
71f87bee
JW
546 default:
547 BUG();
548 }
abb8206c
AK
549}
550
faced7e0
GS
551static int hugetlb_cgroup_read_u64_max(struct seq_file *seq, void *v)
552{
553 int idx;
554 u64 val;
555 struct cftype *cft = seq_cft(seq);
556 unsigned long limit;
557 struct page_counter *counter;
558 struct hugetlb_cgroup *h_cg = hugetlb_cgroup_from_css(seq_css(seq));
559
560 idx = MEMFILE_IDX(cft->private);
561 counter = &h_cg->hugepage[idx];
562
563 limit = round_down(PAGE_COUNTER_MAX,
8938494c 564 pages_per_huge_page(&hstates[idx]));
faced7e0
GS
565
566 switch (MEMFILE_ATTR(cft->private)) {
cdc2fcfe
MA
567 case RES_RSVD_USAGE:
568 counter = &h_cg->rsvd_hugepage[idx];
e4a9bc58 569 fallthrough;
faced7e0
GS
570 case RES_USAGE:
571 val = (u64)page_counter_read(counter);
572 seq_printf(seq, "%llu\n", val * PAGE_SIZE);
573 break;
cdc2fcfe
MA
574 case RES_RSVD_LIMIT:
575 counter = &h_cg->rsvd_hugepage[idx];
e4a9bc58 576 fallthrough;
faced7e0
GS
577 case RES_LIMIT:
578 val = (u64)counter->max;
579 if (val == limit)
580 seq_puts(seq, "max\n");
581 else
582 seq_printf(seq, "%llu\n", val * PAGE_SIZE);
583 break;
584 default:
585 BUG();
586 }
587
588 return 0;
589}
590
71f87bee
JW
591static DEFINE_MUTEX(hugetlb_limit_mutex);
592
451af504 593static ssize_t hugetlb_cgroup_write(struct kernfs_open_file *of,
faced7e0
GS
594 char *buf, size_t nbytes, loff_t off,
595 const char *max)
abb8206c 596{
71f87bee
JW
597 int ret, idx;
598 unsigned long nr_pages;
451af504 599 struct hugetlb_cgroup *h_cg = hugetlb_cgroup_from_css(of_css(of));
cdc2fcfe 600 bool rsvd = false;
abb8206c 601
71f87bee
JW
602 if (hugetlb_cgroup_is_root(h_cg)) /* Can't set limit on root */
603 return -EINVAL;
604
451af504 605 buf = strstrip(buf);
faced7e0 606 ret = page_counter_memparse(buf, max, &nr_pages);
71f87bee
JW
607 if (ret)
608 return ret;
609
451af504 610 idx = MEMFILE_IDX(of_cft(of)->private);
8938494c 611 nr_pages = round_down(nr_pages, pages_per_huge_page(&hstates[idx]));
abb8206c 612
71f87bee 613 switch (MEMFILE_ATTR(of_cft(of)->private)) {
cdc2fcfe
MA
614 case RES_RSVD_LIMIT:
615 rsvd = true;
e4a9bc58 616 fallthrough;
abb8206c 617 case RES_LIMIT:
71f87bee 618 mutex_lock(&hugetlb_limit_mutex);
cdc2fcfe 619 ret = page_counter_set_max(
1adc4d41 620 __hugetlb_cgroup_counter_from_cgroup(h_cg, idx, rsvd),
cdc2fcfe 621 nr_pages);
71f87bee 622 mutex_unlock(&hugetlb_limit_mutex);
abb8206c
AK
623 break;
624 default:
625 ret = -EINVAL;
626 break;
627 }
451af504 628 return ret ?: nbytes;
abb8206c
AK
629}
630
faced7e0
GS
631static ssize_t hugetlb_cgroup_write_legacy(struct kernfs_open_file *of,
632 char *buf, size_t nbytes, loff_t off)
633{
634 return hugetlb_cgroup_write(of, buf, nbytes, off, "-1");
635}
636
637static ssize_t hugetlb_cgroup_write_dfl(struct kernfs_open_file *of,
638 char *buf, size_t nbytes, loff_t off)
639{
640 return hugetlb_cgroup_write(of, buf, nbytes, off, "max");
641}
642
6770c64e
TH
643static ssize_t hugetlb_cgroup_reset(struct kernfs_open_file *of,
644 char *buf, size_t nbytes, loff_t off)
abb8206c 645{
71f87bee 646 int ret = 0;
cdc2fcfe 647 struct page_counter *counter, *rsvd_counter;
6770c64e 648 struct hugetlb_cgroup *h_cg = hugetlb_cgroup_from_css(of_css(of));
abb8206c 649
71f87bee 650 counter = &h_cg->hugepage[MEMFILE_IDX(of_cft(of)->private)];
cdc2fcfe 651 rsvd_counter = &h_cg->rsvd_hugepage[MEMFILE_IDX(of_cft(of)->private)];
abb8206c 652
71f87bee 653 switch (MEMFILE_ATTR(of_cft(of)->private)) {
abb8206c 654 case RES_MAX_USAGE:
71f87bee 655 page_counter_reset_watermark(counter);
abb8206c 656 break;
cdc2fcfe
MA
657 case RES_RSVD_MAX_USAGE:
658 page_counter_reset_watermark(rsvd_counter);
659 break;
abb8206c 660 case RES_FAILCNT:
71f87bee 661 counter->failcnt = 0;
abb8206c 662 break;
cdc2fcfe
MA
663 case RES_RSVD_FAILCNT:
664 rsvd_counter->failcnt = 0;
665 break;
abb8206c
AK
666 default:
667 ret = -EINVAL;
668 break;
669 }
6770c64e 670 return ret ?: nbytes;
abb8206c
AK
671}
672
673static char *mem_fmt(char *buf, int size, unsigned long hsize)
674{
abfb09e2
ML
675 if (hsize >= SZ_1G)
676 snprintf(buf, size, "%luGB", hsize / SZ_1G);
677 else if (hsize >= SZ_1M)
678 snprintf(buf, size, "%luMB", hsize / SZ_1M);
abb8206c 679 else
abfb09e2 680 snprintf(buf, size, "%luKB", hsize / SZ_1K);
abb8206c
AK
681 return buf;
682}
683
faced7e0
GS
684static int __hugetlb_events_show(struct seq_file *seq, bool local)
685{
686 int idx;
687 long max;
688 struct cftype *cft = seq_cft(seq);
689 struct hugetlb_cgroup *h_cg = hugetlb_cgroup_from_css(seq_css(seq));
690
691 idx = MEMFILE_IDX(cft->private);
692
693 if (local)
694 max = atomic_long_read(&h_cg->events_local[idx][HUGETLB_MAX]);
695 else
696 max = atomic_long_read(&h_cg->events[idx][HUGETLB_MAX]);
697
698 seq_printf(seq, "max %lu\n", max);
699
700 return 0;
701}
702
703static int hugetlb_events_show(struct seq_file *seq, void *v)
704{
705 return __hugetlb_events_show(seq, false);
706}
707
708static int hugetlb_events_local_show(struct seq_file *seq, void *v)
709{
710 return __hugetlb_events_show(seq, true);
711}
712
713static void __init __hugetlb_cgroup_file_dfl_init(int idx)
abb8206c
AK
714{
715 char buf[32];
716 struct cftype *cft;
717 struct hstate *h = &hstates[idx];
718
719 /* format the size */
cdc2fcfe 720 mem_fmt(buf, sizeof(buf), huge_page_size(h));
abb8206c
AK
721
722 /* Add the limit file */
faced7e0
GS
723 cft = &h->cgroup_files_dfl[0];
724 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.max", buf);
725 cft->private = MEMFILE_PRIVATE(idx, RES_LIMIT);
726 cft->seq_show = hugetlb_cgroup_read_u64_max;
727 cft->write = hugetlb_cgroup_write_dfl;
728 cft->flags = CFTYPE_NOT_ON_ROOT;
729
cdc2fcfe 730 /* Add the reservation limit file */
faced7e0 731 cft = &h->cgroup_files_dfl[1];
cdc2fcfe
MA
732 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.rsvd.max", buf);
733 cft->private = MEMFILE_PRIVATE(idx, RES_RSVD_LIMIT);
734 cft->seq_show = hugetlb_cgroup_read_u64_max;
735 cft->write = hugetlb_cgroup_write_dfl;
736 cft->flags = CFTYPE_NOT_ON_ROOT;
737
738 /* Add the current usage file */
739 cft = &h->cgroup_files_dfl[2];
faced7e0
GS
740 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.current", buf);
741 cft->private = MEMFILE_PRIVATE(idx, RES_USAGE);
742 cft->seq_show = hugetlb_cgroup_read_u64_max;
743 cft->flags = CFTYPE_NOT_ON_ROOT;
744
cdc2fcfe
MA
745 /* Add the current reservation usage file */
746 cft = &h->cgroup_files_dfl[3];
747 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.rsvd.current", buf);
748 cft->private = MEMFILE_PRIVATE(idx, RES_RSVD_USAGE);
749 cft->seq_show = hugetlb_cgroup_read_u64_max;
750 cft->flags = CFTYPE_NOT_ON_ROOT;
751
faced7e0 752 /* Add the events file */
cdc2fcfe 753 cft = &h->cgroup_files_dfl[4];
faced7e0
GS
754 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.events", buf);
755 cft->private = MEMFILE_PRIVATE(idx, 0);
756 cft->seq_show = hugetlb_events_show;
d5a16959 757 cft->file_offset = offsetof(struct hugetlb_cgroup, events_file[idx]);
faced7e0
GS
758 cft->flags = CFTYPE_NOT_ON_ROOT;
759
760 /* Add the events.local file */
cdc2fcfe 761 cft = &h->cgroup_files_dfl[5];
faced7e0
GS
762 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.events.local", buf);
763 cft->private = MEMFILE_PRIVATE(idx, 0);
764 cft->seq_show = hugetlb_events_local_show;
765 cft->file_offset = offsetof(struct hugetlb_cgroup,
d5a16959 766 events_local_file[idx]);
faced7e0
GS
767 cft->flags = CFTYPE_NOT_ON_ROOT;
768
f4776199 769 /* Add the numa stat file */
cdc2fcfe 770 cft = &h->cgroup_files_dfl[6];
f4776199 771 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.numa_stat", buf);
2727cfe4 772 cft->private = MEMFILE_PRIVATE(idx, 0);
f4776199
MA
773 cft->seq_show = hugetlb_cgroup_read_numa_stat;
774 cft->flags = CFTYPE_NOT_ON_ROOT;
775
776 /* NULL terminate the last cft */
777 cft = &h->cgroup_files_dfl[7];
faced7e0
GS
778 memset(cft, 0, sizeof(*cft));
779
780 WARN_ON(cgroup_add_dfl_cftypes(&hugetlb_cgrp_subsys,
781 h->cgroup_files_dfl));
782}
783
784static void __init __hugetlb_cgroup_file_legacy_init(int idx)
785{
786 char buf[32];
787 struct cftype *cft;
788 struct hstate *h = &hstates[idx];
789
790 /* format the size */
cdc2fcfe 791 mem_fmt(buf, sizeof(buf), huge_page_size(h));
faced7e0
GS
792
793 /* Add the limit file */
794 cft = &h->cgroup_files_legacy[0];
abb8206c
AK
795 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.limit_in_bytes", buf);
796 cft->private = MEMFILE_PRIVATE(idx, RES_LIMIT);
716f479d 797 cft->read_u64 = hugetlb_cgroup_read_u64;
faced7e0 798 cft->write = hugetlb_cgroup_write_legacy;
abb8206c 799
cdc2fcfe 800 /* Add the reservation limit file */
faced7e0 801 cft = &h->cgroup_files_legacy[1];
cdc2fcfe
MA
802 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.rsvd.limit_in_bytes", buf);
803 cft->private = MEMFILE_PRIVATE(idx, RES_RSVD_LIMIT);
804 cft->read_u64 = hugetlb_cgroup_read_u64;
805 cft->write = hugetlb_cgroup_write_legacy;
806
807 /* Add the usage file */
808 cft = &h->cgroup_files_legacy[2];
abb8206c
AK
809 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.usage_in_bytes", buf);
810 cft->private = MEMFILE_PRIVATE(idx, RES_USAGE);
716f479d 811 cft->read_u64 = hugetlb_cgroup_read_u64;
abb8206c 812
cdc2fcfe
MA
813 /* Add the reservation usage file */
814 cft = &h->cgroup_files_legacy[3];
815 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.rsvd.usage_in_bytes", buf);
816 cft->private = MEMFILE_PRIVATE(idx, RES_RSVD_USAGE);
817 cft->read_u64 = hugetlb_cgroup_read_u64;
818
abb8206c 819 /* Add the MAX usage file */
cdc2fcfe 820 cft = &h->cgroup_files_legacy[4];
abb8206c
AK
821 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.max_usage_in_bytes", buf);
822 cft->private = MEMFILE_PRIVATE(idx, RES_MAX_USAGE);
6770c64e 823 cft->write = hugetlb_cgroup_reset;
716f479d 824 cft->read_u64 = hugetlb_cgroup_read_u64;
abb8206c 825
cdc2fcfe
MA
826 /* Add the MAX reservation usage file */
827 cft = &h->cgroup_files_legacy[5];
828 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.rsvd.max_usage_in_bytes", buf);
829 cft->private = MEMFILE_PRIVATE(idx, RES_RSVD_MAX_USAGE);
830 cft->write = hugetlb_cgroup_reset;
831 cft->read_u64 = hugetlb_cgroup_read_u64;
832
abb8206c 833 /* Add the failcntfile */
cdc2fcfe 834 cft = &h->cgroup_files_legacy[6];
abb8206c 835 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.failcnt", buf);
cdc2fcfe
MA
836 cft->private = MEMFILE_PRIVATE(idx, RES_FAILCNT);
837 cft->write = hugetlb_cgroup_reset;
838 cft->read_u64 = hugetlb_cgroup_read_u64;
839
840 /* Add the reservation failcntfile */
841 cft = &h->cgroup_files_legacy[7];
842 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.rsvd.failcnt", buf);
843 cft->private = MEMFILE_PRIVATE(idx, RES_RSVD_FAILCNT);
6770c64e 844 cft->write = hugetlb_cgroup_reset;
716f479d 845 cft->read_u64 = hugetlb_cgroup_read_u64;
abb8206c 846
f4776199 847 /* Add the numa stat file */
cdc2fcfe 848 cft = &h->cgroup_files_legacy[8];
f4776199
MA
849 snprintf(cft->name, MAX_CFTYPE_NAME, "%s.numa_stat", buf);
850 cft->private = MEMFILE_PRIVATE(idx, 1);
851 cft->seq_show = hugetlb_cgroup_read_numa_stat;
852
853 /* NULL terminate the last cft */
854 cft = &h->cgroup_files_legacy[9];
abb8206c
AK
855 memset(cft, 0, sizeof(*cft));
856
2cf669a5 857 WARN_ON(cgroup_add_legacy_cftypes(&hugetlb_cgrp_subsys,
faced7e0
GS
858 h->cgroup_files_legacy));
859}
860
861static void __init __hugetlb_cgroup_file_init(int idx)
862{
863 __hugetlb_cgroup_file_dfl_init(idx);
864 __hugetlb_cgroup_file_legacy_init(idx);
7179e7bf
JW
865}
866
867void __init hugetlb_cgroup_file_init(void)
868{
869 struct hstate *h;
870
871 for_each_hstate(h) {
872 /*
873 * Add cgroup control files only if the huge page consists
874 * of more than two normal pages. This is because we use
1d798ca3 875 * page[2].private for storing cgroup details.
7179e7bf
JW
876 */
877 if (huge_page_order(h) >= HUGETLB_CGROUP_MIN_ORDER)
878 __hugetlb_cgroup_file_init(hstate_index(h));
879 }
abb8206c
AK
880}
881
75754681
AK
882/*
883 * hugetlb_lock will make sure a parallel cgroup rmdir won't happen
884 * when we migrate hugepages
885 */
8e6ac7fa
AK
886void hugetlb_cgroup_migrate(struct page *oldhpage, struct page *newhpage)
887{
888 struct hugetlb_cgroup *h_cg;
1adc4d41 889 struct hugetlb_cgroup *h_cg_rsvd;
94ae8ba7 890 struct hstate *h = page_hstate(oldhpage);
8e6ac7fa
AK
891
892 if (hugetlb_cgroup_disabled())
893 return;
894
db71ef79 895 spin_lock_irq(&hugetlb_lock);
8e6ac7fa 896 h_cg = hugetlb_cgroup_from_page(oldhpage);
1adc4d41 897 h_cg_rsvd = hugetlb_cgroup_from_page_rsvd(oldhpage);
8e6ac7fa 898 set_hugetlb_cgroup(oldhpage, NULL);
9808895e 899 set_hugetlb_cgroup_rsvd(oldhpage, NULL);
8e6ac7fa
AK
900
901 /* move the h_cg details to new cgroup */
9808895e 902 set_hugetlb_cgroup(newhpage, h_cg);
1adc4d41 903 set_hugetlb_cgroup_rsvd(newhpage, h_cg_rsvd);
94ae8ba7 904 list_move(&newhpage->lru, &h->hugepage_activelist);
db71ef79 905 spin_unlock_irq(&hugetlb_lock);
8e6ac7fa
AK
906 return;
907}
908
faced7e0
GS
909static struct cftype hugetlb_files[] = {
910 {} /* terminate */
911};
912
073219e9 913struct cgroup_subsys hugetlb_cgrp_subsys = {
92fb9748
TH
914 .css_alloc = hugetlb_cgroup_css_alloc,
915 .css_offline = hugetlb_cgroup_css_offline,
916 .css_free = hugetlb_cgroup_css_free,
faced7e0
GS
917 .dfl_cftypes = hugetlb_files,
918 .legacy_cftypes = hugetlb_files,
2bc64a20 919};