Received: by 2002:a05:6a10:22f:0:0:0:0 with SMTP id 15csp4173188pxk; Tue, 29 Sep 2020 17:01:25 -0700 (PDT) X-Google-Smtp-Source: ABdhPJyv09OfTeaiNs8WciRqbuisZqQhF8TSVoc09A+wc2BMyUdNvtLuXnXQDkyXD6vLH+6/AryB X-Received: by 2002:a50:e807:: with SMTP id e7mr6110386edn.84.1601424084969; Tue, 29 Sep 2020 17:01:24 -0700 (PDT) ARC-Seal: i=1; a=rsa-sha256; t=1601424084; cv=none; d=google.com; s=arc-20160816; b=bSYW+W7DrIiFlVqCVFq9DHLT/mHhjvPXNVkPr+nONeUeZWFj4KBfG1Yx3Vag/Lst2O B1wQPRwblYglwwmTQsUmuLg22vxCiMLo+lIyQCb3mB+tNoL/As2PiOtWwAHN5zxd33rb n2MoW1GQN8tsJXxAKfbED2tzN42Vq5XEdsvpUISyXGcXEwN/mZqMAHdMXPtda/yI/4tV Tjvv37f+m/0qm7zL3UTjPQeP1Yxv0qBrZBuz1xA0VYDqpTUfNGbIUfYPBR+PeHsYRToJ ZWV0ZTS0PZOh0i1ig6hs3kwJ1RQ3ccaaSIgAFT6OeudlTAn+7G0Vv4f0od4+3/roLrvh SGtw== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20160816; h=list-id:precedence:content-transfer-encoding:mime-version :references:in-reply-to:message-id:date:subject:cc:to:from :dkim-signature; bh=xQ07DZ6YVT+kiKig7H1ea/qrBewORu/Ppkkb3lHRKyI=; b=wtPpCyge/gLnhnFAqNMSLluhbv7Y/j61I58NmtpZYZVpi+20gmvWVDYKv/qaMPNOK4 RIBT1ikuPZ6YTw5WE9VSY9kxo68+byTsCWWJJe6O+2HEoqyLzTKZW5dnjRdeWvVNNY8n rzrcn4U4V9GWJBIsQdX6W2hBwzno8jIFuxEoDzJnpUwFU6wtnqSX7sUTpQhD42nE16o6 a3RQIkltTgx4hjz7yPnfH0j1uksmqr159p3JXv01TzVp9WQS/k6Q8tYJ2FnDgh0j9upn vtipwA06z9RCI+Izcz0uYT2w9SIedJH1b99gzSOeGFOmq997ZT09dGXdHr0KRInuU+oW JW8A== ARC-Authentication-Results: i=1; mx.google.com; dkim=pass header.i=@fb.com header.s=facebook header.b=HzXsKbZO; spf=pass (google.com: domain of linux-kernel-owner@vger.kernel.org designates 23.128.96.18 as permitted sender) smtp.mailfrom=linux-kernel-owner@vger.kernel.org; dmarc=pass (p=REJECT sp=REJECT dis=NONE) header.from=fb.com Return-Path: Received: from vger.kernel.org (vger.kernel.org. [23.128.96.18]) by mx.google.com with ESMTP id v9si3821300edj.607.2020.09.29.17.01.02; Tue, 29 Sep 2020 17:01:24 -0700 (PDT) Received-SPF: pass (google.com: domain of linux-kernel-owner@vger.kernel.org designates 23.128.96.18 as permitted sender) client-ip=23.128.96.18; Authentication-Results: mx.google.com; dkim=pass header.i=@fb.com header.s=facebook header.b=HzXsKbZO; spf=pass (google.com: domain of linux-kernel-owner@vger.kernel.org designates 23.128.96.18 as permitted sender) smtp.mailfrom=linux-kernel-owner@vger.kernel.org; dmarc=pass (p=REJECT sp=REJECT dis=NONE) header.from=fb.com Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1729448AbgI2X7k (ORCPT + 99 others); Tue, 29 Sep 2020 19:59:40 -0400 Received: from mx0a-00082601.pphosted.com ([67.231.145.42]:38884 "EHLO mx0a-00082601.pphosted.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1728192AbgI2X7g (ORCPT ); Tue, 29 Sep 2020 19:59:36 -0400 Received: from pps.filterd (m0148461.ppops.net [127.0.0.1]) by mx0a-00082601.pphosted.com (8.16.0.42/8.16.0.42) with SMTP id 08TNsiBK028846 for ; Tue, 29 Sep 2020 16:59:32 -0700 DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=fb.com; h=from : to : cc : subject : date : message-id : in-reply-to : references : mime-version : content-transfer-encoding : content-type; s=facebook; bh=xQ07DZ6YVT+kiKig7H1ea/qrBewORu/Ppkkb3lHRKyI=; b=HzXsKbZOEazRoesCrsirholyCqI+0x4ip3d3xFfPg3sJ4o3zifrNH2GcqfN9YmQzE/ZG OneHn4Jn0ukBGj80Hlp/UdybyA9IIPv5SqAZx9dD6S23kOzz6VB76Frkc+4XI2beYXz/ ULUFGX708/PwAskAZ9oYr26eqxtMbc+t2MU= Received: from maileast.thefacebook.com ([163.114.130.16]) by mx0a-00082601.pphosted.com with ESMTP id 33v6jxax2h-2 (version=TLSv1.2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128 verify=NOT) for ; Tue, 29 Sep 2020 16:59:32 -0700 Received: from intmgw003.06.prn3.facebook.com (2620:10d:c0a8:1b::d) by mail.thefacebook.com (2620:10d:c0a8:82::f) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256) id 15.1.1979.3; Tue, 29 Sep 2020 16:59:30 -0700 Received: by devvm1755.vll0.facebook.com (Postfix, from userid 111017) id 6676ED62152; Tue, 29 Sep 2020 16:59:21 -0700 (PDT) From: Roman Gushchin To: Andrew Morton CC: Shakeel Butt , Johannes Weiner , Michal Hocko , , , , Roman Gushchin Subject: [PATCH v3 1/4] mm: memcontrol: use helpers to access page's memcg data Date: Tue, 29 Sep 2020 16:59:17 -0700 Message-ID: <20200929235920.537849-2-guro@fb.com> X-Mailer: git-send-email 2.24.1 In-Reply-To: <20200929235920.537849-1-guro@fb.com> References: <20200929235920.537849-1-guro@fb.com> MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable X-FB-Internal: Safe Content-Type: text/plain X-Proofpoint-Virus-Version: vendor=fsecure engine=2.50.10434:6.0.235,18.0.687 definitions=2020-09-29_14:2020-09-29,2020-09-29 signatures=0 X-Proofpoint-Spam-Details: rule=fb_default_notspam policy=fb_default score=0 adultscore=0 bulkscore=0 priorityscore=1501 impostorscore=0 phishscore=0 malwarescore=0 suspectscore=2 lowpriorityscore=0 mlxlogscore=999 spamscore=0 clxscore=1015 mlxscore=0 classifier=spam adjust=0 reason=mlx scancount=1 engine=8.12.0-2006250000 definitions=main-2009290203 X-FB-Internal: deliver Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Currently there are many open-coded reads and writes of the page->mem_cgroup pointer, as well as a couple of read helpers, which are barely used. It creates an obstacle on a way to reuse some bits of the pointer for storing additional bits of information. In fact, we already do this for slab pages, where the last bit indicates that a pointer has an attached vector of objcg pointers instead of a regular memcg pointer. This commits uses 2 existing helpers and introduces 3 new helpers to converts all raw accesses to page->mem_cgroup to calls of these helpers: struct mem_cgroup *page_memcg(struct page *page); struct mem_cgroup *page_memcg_rcu(struct page *page); struct mem_cgroup *page_memcg_check(struct page *page); void set_page_memcg(struct page *page, struct mem_cgroup *memcg); void clear_page_memcg(struct page *page); page_memcg_check() is intended to be used in cases when the page can be a slab page and have a memcg pointer pointing at objcg vector. It does check the lowest bit, and if set, returns NULL. page_memcg() contains a VM_BUG_ON_PAGE() check for the page not being a slab page. So do set_page_memcg() and clear_page_memcg(). To make sure nobody uses a direct access, struct page's mem_cgroup/obj_cgroups is converted to unsigned long memcg_data. Only new helpers and a couple of slab-accounting related functions access this field directly. Signed-off-by: Roman Gushchin --- fs/buffer.c | 2 +- fs/iomap/buffered-io.c | 2 +- include/linux/memcontrol.h | 153 +++++++++++++++++++++++++++++-- include/linux/mm.h | 22 ----- include/linux/mm_types.h | 5 +- include/trace/events/writeback.h | 2 +- kernel/fork.c | 7 +- mm/debug.c | 4 +- mm/huge_memory.c | 4 +- mm/memcontrol.c | 121 +++++++++++------------- mm/page_alloc.c | 4 +- mm/page_io.c | 6 +- mm/slab.h | 9 +- mm/workingset.c | 2 +- 14 files changed, 223 insertions(+), 120 deletions(-) diff --git a/fs/buffer.c b/fs/buffer.c index bf4d8037f91b..64564ac7dcc5 100644 --- a/fs/buffer.c +++ b/fs/buffer.c @@ -657,7 +657,7 @@ int __set_page_dirty_buffers(struct page *page) } while (bh !=3D head); } /* - * Lock out page->mem_cgroup migration to keep PageDirty + * Lock out page's memcg migration to keep PageDirty * synchronized with per-memcg dirty page counters. */ lock_page_memcg(page); diff --git a/fs/iomap/buffered-io.c b/fs/iomap/buffered-io.c index 897ab9a26a74..71381931f2c3 100644 --- a/fs/iomap/buffered-io.c +++ b/fs/iomap/buffered-io.c @@ -669,7 +669,7 @@ iomap_set_page_dirty(struct page *page) return !TestSetPageDirty(page); =20 /* - * Lock out page->mem_cgroup migration to keep PageDirty + * Lock out page's memcg migration to keep PageDirty * synchronized with per-memcg dirty page counters. */ lock_page_memcg(page); diff --git a/include/linux/memcontrol.h b/include/linux/memcontrol.h index e391e3c56de5..31ab1639e0fe 100644 --- a/include/linux/memcontrol.h +++ b/include/linux/memcontrol.h @@ -343,6 +343,109 @@ struct mem_cgroup { =20 extern struct mem_cgroup *root_mem_cgroup; =20 +/* + * page_memcg - get the memory cgroup associated with a page + * @page: a pointer to the page struct + * + * Returns a pointer to the memory cgroup associated with the page, + * or NULL. This function assumes that the page is known to have a + * proper memory cgroup pointer. It's not safe to call this function + * against some type of pages, e.g. slab pages or ex-slab pages. + * + * Any of the following ensures page and memcg binding stability: + * - the page lock + * - LRU isolation + * - lock_page_memcg() + * - exclusive reference + */ +static inline struct mem_cgroup *page_memcg(struct page *page) +{ + VM_BUG_ON_PAGE(PageSlab(page), page); + return (struct mem_cgroup *)page->memcg_data; +} + +/* + * page_memcg_rcu - locklessly get the memory cgroup associated with a p= age + * @page: a pointer to the page struct + * + * Returns a pointer to the memory cgroup associated with the page, + * or NULL. This function assumes that the page is known to have a + * proper memory cgroup pointer. It's not safe to call this function + * against some type of pages, e.g. slab pages or ex-slab pages. + */ +static inline struct mem_cgroup *page_memcg_rcu(struct page *page) +{ + VM_BUG_ON_PAGE(PageSlab(page), page); + WARN_ON_ONCE(!rcu_read_lock_held()); + + return (struct mem_cgroup *)READ_ONCE(page->memcg_data); +} + +/* + * page_memcg_check - get the memory cgroup associated with a page + * @page: a pointer to the page struct + * + * Returns a pointer to the memory cgroup associated with the page, + * or NULL. This function unlike page_memcg() can take any page + * as an argument. It has to be used in cases when it's not known if a p= age + * has an associated memory cgroup pointer or an object cgroups vector. + * + * Any of the following ensures page and memcg binding stability: + * - the page lock + * - LRU isolation + * - lock_page_memcg() + * - exclusive reference + */ +static inline struct mem_cgroup *page_memcg_check(struct page *page) +{ + /* + * Because page->memcg_data might be changed asynchronously + * for slab pages, READ_ONCE() should be used here. + */ + unsigned long memcg_data =3D READ_ONCE(page->memcg_data); + + /* + * The lowest bit set means that memcg isn't a valid + * memcg pointer, but a obj_cgroups pointer. + * In this case the page is shared and doesn't belong + * to any specific memory cgroup. + */ + if (memcg_data & 0x1UL) + return NULL; + + return (struct mem_cgroup *)memcg_data; +} + +/* + * set_page_memcg - associate a page with a memory cgroup + * @page: a pointer to the page struct + * @memcg: a pointer to the memory cgroup + * + * Associates a page with a memory cgroup. + */ +static inline void set_page_memcg(struct page *page, struct mem_cgroup *= memcg) +{ + VM_BUG_ON_PAGE(PageSlab(page), page); + + /* + * Please, refer to page_memcg()'s description for the page and memcg + * binding stability requirements. + */ + page->memcg_data =3D (unsigned long)memcg; +} + +/* + * clear_page_memcg - clear an association of a page with a memory cgrou= p + * @page: a pointer to the page struct + * + * Clears an association of a page with a memory cgroup. + */ +static inline void clear_page_memcg(struct page *page) +{ + VM_BUG_ON_PAGE(PageSlab(page), page); + page->memcg_data =3D 0; +} + static __always_inline bool memcg_stat_item_in_bytes(int idx) { if (idx =3D=3D MEMCG_PERCPU_B) @@ -743,15 +846,19 @@ static inline void mod_memcg_state(struct mem_cgrou= p *memcg, static inline void __mod_memcg_page_state(struct page *page, int idx, int val) { - if (page->mem_cgroup) - __mod_memcg_state(page->mem_cgroup, idx, val); + struct mem_cgroup *memcg =3D page_memcg(page); + + if (memcg) + __mod_memcg_state(memcg, idx, val); } =20 static inline void mod_memcg_page_state(struct page *page, int idx, int val) { - if (page->mem_cgroup) - mod_memcg_state(page->mem_cgroup, idx, val); + struct mem_cgroup *memcg =3D page_memcg(page); + + if (memcg) + mod_memcg_state(memcg, idx, val); } =20 static inline unsigned long lruvec_page_state(struct lruvec *lruvec, @@ -834,16 +941,17 @@ static inline void __mod_lruvec_page_state(struct p= age *page, enum node_stat_item idx, int val) { struct page *head =3D compound_head(page); /* rmap on tail pages */ + struct mem_cgroup *memcg =3D page_memcg(head); pg_data_t *pgdat =3D page_pgdat(page); struct lruvec *lruvec; =20 /* Untracked pages have no memcg, no lruvec. Update only the node */ - if (!head->mem_cgroup) { + if (!memcg) { __mod_node_page_state(pgdat, idx, val); return; } =20 - lruvec =3D mem_cgroup_lruvec(head->mem_cgroup, pgdat); + lruvec =3D mem_cgroup_lruvec(memcg, pgdat); __mod_lruvec_state(lruvec, idx, val); } =20 @@ -878,8 +986,10 @@ static inline void count_memcg_events(struct mem_cgr= oup *memcg, static inline void count_memcg_page_event(struct page *page, enum vm_event_item idx) { - if (page->mem_cgroup) - count_memcg_events(page->mem_cgroup, idx, 1); + struct mem_cgroup *memcg =3D page_memcg(page); + + if (memcg) + count_memcg_events(memcg, idx, 1); } =20 static inline void count_memcg_event_mm(struct mm_struct *mm, @@ -941,6 +1051,31 @@ void mem_cgroup_split_huge_fixup(struct page *head)= ; =20 struct mem_cgroup; =20 +static inline struct mem_cgroup *page_memcg(struct page *page) +{ + return NULL; +} + +static inline struct mem_cgroup *page_memcg_rcu(struct page *page) +{ + WARN_ON_ONCE(!rcu_read_lock_held()); + return NULL; +} + +static inline struct mem_cgroup *page_memcg_check(struct page *page) +{ + return NULL; +} + +static inline void set_page_memcg(struct page *page, + struct mem_cgroup *memcg) +{ +} + +static inline void clear_page_memcg(struct page *page) +{ +} + static inline bool mem_cgroup_is_root(struct mem_cgroup *memcg) { return true; @@ -1430,7 +1565,7 @@ static inline void mem_cgroup_track_foreign_dirty(s= truct page *page, if (mem_cgroup_disabled()) return; =20 - if (unlikely(&page->mem_cgroup->css !=3D wb->memcg_css)) + if (unlikely(&page_memcg(page)->css !=3D wb->memcg_css)) mem_cgroup_track_foreign_dirty_slowpath(page, wb); } =20 diff --git a/include/linux/mm.h b/include/linux/mm.h index 17e712207d74..5e24ff2ffec9 100644 --- a/include/linux/mm.h +++ b/include/linux/mm.h @@ -1476,28 +1476,6 @@ static inline void set_page_links(struct page *pag= e, enum zone_type zone, #endif } =20 -#ifdef CONFIG_MEMCG -static inline struct mem_cgroup *page_memcg(struct page *page) -{ - return page->mem_cgroup; -} -static inline struct mem_cgroup *page_memcg_rcu(struct page *page) -{ - WARN_ON_ONCE(!rcu_read_lock_held()); - return READ_ONCE(page->mem_cgroup); -} -#else -static inline struct mem_cgroup *page_memcg(struct page *page) -{ - return NULL; -} -static inline struct mem_cgroup *page_memcg_rcu(struct page *page) -{ - WARN_ON_ONCE(!rcu_read_lock_held()); - return NULL; -} -#endif - /* * Some inline functions in vmstat.h depend on page_zone() */ diff --git a/include/linux/mm_types.h b/include/linux/mm_types.h index 496c3ff97cce..4856d23b1161 100644 --- a/include/linux/mm_types.h +++ b/include/linux/mm_types.h @@ -199,10 +199,7 @@ struct page { atomic_t _refcount; =20 #ifdef CONFIG_MEMCG - union { - struct mem_cgroup *mem_cgroup; - struct obj_cgroup **obj_cgroups; - }; + unsigned long memcg_data; #endif =20 /* diff --git a/include/trace/events/writeback.h b/include/trace/events/writ= eback.h index e7cbccc7c14c..39a40dfb578a 100644 --- a/include/trace/events/writeback.h +++ b/include/trace/events/writeback.h @@ -257,7 +257,7 @@ TRACE_EVENT(track_foreign_dirty, __entry->ino =3D inode ? inode->i_ino : 0; __entry->memcg_id =3D wb->memcg_css->id; __entry->cgroup_ino =3D __trace_wb_assign_cgroup(wb); - __entry->page_cgroup_ino =3D cgroup_ino(page->mem_cgroup->css.cgroup); + __entry->page_cgroup_ino =3D cgroup_ino(page_memcg(page)->css.cgroup); ), =20 TP_printk("bdi %s[%llu]: ino=3D%lu memcg_id=3D%u cgroup_ino=3D%lu page_= cgroup_ino=3D%lu", diff --git a/kernel/fork.c b/kernel/fork.c index 138cd6ca50da..ecbd44831130 100644 --- a/kernel/fork.c +++ b/kernel/fork.c @@ -403,9 +403,10 @@ static int memcg_charge_kernel_stack(struct task_str= uct *tsk) =20 for (i =3D 0; i < THREAD_SIZE / PAGE_SIZE; i++) { /* - * If memcg_kmem_charge_page() fails, page->mem_cgroup - * pointer is NULL, and memcg_kmem_uncharge_page() in - * free_thread_stack() will ignore this page. + * If memcg_kmem_charge_page() fails, page's + * memory cgroup pointer is NULL, and + * memcg_kmem_uncharge_page() in free_thread_stack() + * will ignore this page. */ ret =3D memcg_kmem_charge_page(vm->pages[i], GFP_KERNEL, 0); diff --git a/mm/debug.c b/mm/debug.c index ccca576b2899..8a40b3fefbeb 100644 --- a/mm/debug.c +++ b/mm/debug.c @@ -182,8 +182,8 @@ void __dump_page(struct page *page, const char *reaso= n) pr_warn("page dumped because: %s\n", reason); =20 #ifdef CONFIG_MEMCG - if (!page_poisoned && page->mem_cgroup) - pr_warn("page->mem_cgroup:%px\n", page->mem_cgroup); + if (!page_poisoned && page->memcg_data) + pr_warn("pages's memcg:%lx\n", page->memcg_data); #endif } =20 diff --git a/mm/huge_memory.c b/mm/huge_memory.c index b1c7dc8a6f96..6df8a80b5bc9 100644 --- a/mm/huge_memory.c +++ b/mm/huge_memory.c @@ -470,7 +470,7 @@ pmd_t maybe_pmd_mkwrite(pmd_t pmd, struct vm_area_str= uct *vma) #ifdef CONFIG_MEMCG static inline struct deferred_split *get_deferred_split_queue(struct pag= e *page) { - struct mem_cgroup *memcg =3D compound_head(page)->mem_cgroup; + struct mem_cgroup *memcg =3D page_memcg(compound_head(page)); struct pglist_data *pgdat =3D NODE_DATA(page_to_nid(page)); =20 if (memcg) @@ -2735,7 +2735,7 @@ void deferred_split_huge_page(struct page *page) { struct deferred_split *ds_queue =3D get_deferred_split_queue(page); #ifdef CONFIG_MEMCG - struct mem_cgroup *memcg =3D compound_head(page)->mem_cgroup; + struct mem_cgroup *memcg =3D page_memcg(compound_head(page)); #endif unsigned long flags; =20 diff --git a/mm/memcontrol.c b/mm/memcontrol.c index 9c4a0851348f..dfb10eccb0e5 100644 --- a/mm/memcontrol.c +++ b/mm/memcontrol.c @@ -533,7 +533,7 @@ struct cgroup_subsys_state *mem_cgroup_css_from_page(= struct page *page) { struct mem_cgroup *memcg; =20 - memcg =3D page->mem_cgroup; + memcg =3D page_memcg(page); =20 if (!memcg || !cgroup_subsys_on_dfl(memory_cgrp_subsys)) memcg =3D root_mem_cgroup; @@ -560,16 +560,7 @@ ino_t page_cgroup_ino(struct page *page) unsigned long ino =3D 0; =20 rcu_read_lock(); - memcg =3D page->mem_cgroup; - - /* - * The lowest bit set means that memcg isn't a valid - * memcg pointer, but a obj_cgroups pointer. - * In this case the page is shared and doesn't belong - * to any specific memory cgroup. - */ - if ((unsigned long) memcg & 0x1UL) - memcg =3D NULL; + memcg =3D page_memcg_check(page); =20 while (memcg && !(memcg->css.flags & CSS_ONLINE)) memcg =3D parent_mem_cgroup(memcg); @@ -1050,7 +1041,7 @@ EXPORT_SYMBOL(get_mem_cgroup_from_mm); */ struct mem_cgroup *get_mem_cgroup_from_page(struct page *page) { - struct mem_cgroup *memcg =3D page->mem_cgroup; + struct mem_cgroup *memcg =3D page_memcg(page); =20 if (mem_cgroup_disabled()) return NULL; @@ -1349,7 +1340,7 @@ struct lruvec *mem_cgroup_page_lruvec(struct page *= page, struct pglist_data *pgd goto out; } =20 - memcg =3D page->mem_cgroup; + memcg =3D page_memcg(page); /* * Swapcache readahead pages are added to the LRU - and * possibly migrated - before they are charged. @@ -2105,7 +2096,7 @@ void mem_cgroup_print_oom_group(struct mem_cgroup *= memcg) } =20 /** - * lock_page_memcg - lock a page->mem_cgroup binding + * lock_page_memcg - lock a page and memcg binding * @page: the page * * This function protects unlocked LRU pages from being moved to @@ -2137,7 +2128,7 @@ struct mem_cgroup *lock_page_memcg(struct page *pag= e) if (mem_cgroup_disabled()) return NULL; again: - memcg =3D head->mem_cgroup; + memcg =3D page_memcg(head); if (unlikely(!memcg)) return NULL; =20 @@ -2145,7 +2136,7 @@ struct mem_cgroup *lock_page_memcg(struct page *pag= e) return memcg; =20 spin_lock_irqsave(&memcg->move_lock, flags); - if (memcg !=3D head->mem_cgroup) { + if (memcg !=3D page_memcg(head)) { spin_unlock_irqrestore(&memcg->move_lock, flags); goto again; } @@ -2183,14 +2174,14 @@ void __unlock_page_memcg(struct mem_cgroup *memcg= ) } =20 /** - * unlock_page_memcg - unlock a page->mem_cgroup binding + * unlock_page_memcg - unlock a page and memcg binding * @page: the page */ void unlock_page_memcg(struct page *page) { struct page *head =3D compound_head(page); =20 - __unlock_page_memcg(head->mem_cgroup); + __unlock_page_memcg(page_memcg(head)); } EXPORT_SYMBOL(unlock_page_memcg); =20 @@ -2880,7 +2871,7 @@ static void cancel_charge(struct mem_cgroup *memcg,= unsigned int nr_pages) =20 static void commit_charge(struct page *page, struct mem_cgroup *memcg) { - VM_BUG_ON_PAGE(page->mem_cgroup, page); + VM_BUG_ON_PAGE(page_memcg(page), page); /* * Any of the following ensures page->mem_cgroup stability: * @@ -2889,7 +2880,7 @@ static void commit_charge(struct page *page, struct= mem_cgroup *memcg) * - lock_page_memcg() * - exclusive reference */ - page->mem_cgroup =3D memcg; + set_page_memcg(page, memcg); } =20 #ifdef CONFIG_MEMCG_KMEM @@ -2904,8 +2895,7 @@ int memcg_alloc_page_obj_cgroups(struct page *page,= struct kmem_cache *s, if (!vec) return -ENOMEM; =20 - if (cmpxchg(&page->obj_cgroups, NULL, - (struct obj_cgroup **) ((unsigned long)vec | 0x1UL))) + if (cmpxchg(&page->memcg_data, 0, (unsigned long)vec | 0x1UL)) kfree(vec); else kmemleak_not_leak(vec); @@ -2916,6 +2906,12 @@ int memcg_alloc_page_obj_cgroups(struct page *page= , struct kmem_cache *s, /* * Returns a pointer to the memory cgroup to which the kernel object is = charged. * + * A passed kernel object can be a slab object or a generic kernel page,= so + * different mechanisms for getting the memory cgroup pointer should be = used. + * In certain cases (e.g. kernel stacks or large kmallocs with SLUB) the= caller + * can not know for sure how the kernel object is implemented. + * mem_cgroup_from_obj() can be safely used in such cases. + * * The caller must ensure the memcg lifetime, e.g. by taking rcu_read_lo= ck(), * cgroup_mutex, etc. */ @@ -2928,17 +2924,6 @@ struct mem_cgroup *mem_cgroup_from_obj(void *p) =20 page =3D virt_to_head_page(p); =20 - /* - * If page->mem_cgroup is set, it's either a simple mem_cgroup pointer - * or a pointer to obj_cgroup vector. In the latter case the lowest - * bit of the pointer is set. - * The page->mem_cgroup pointer can be asynchronously changed - * from NULL to (obj_cgroup_vec | 0x1UL), but can't be changed - * from a valid memcg pointer to objcg vector or back. - */ - if (!page->mem_cgroup) - return NULL; - /* * Slab objects are accounted individually, not per-page. * Memcg membership data for each individual object is saved in @@ -2956,8 +2941,14 @@ struct mem_cgroup *mem_cgroup_from_obj(void *p) return NULL; } =20 - /* All other pages use page->mem_cgroup */ - return page->mem_cgroup; + /* + * page_memcg_check() is used here, because page_has_obj_cgroups() + * check above could fail because the object cgroups vector wasn't set + * at that moment, but it can be set concurrently. + * page_memcg_check(page) will guarantee that a proper memory + * cgroup pointer or NULL will be returned. + */ + return page_memcg_check(page); } =20 __always_inline struct obj_cgroup *get_obj_cgroup_from_current(void) @@ -3095,7 +3086,7 @@ int __memcg_kmem_charge_page(struct page *page, gfp= _t gfp, int order) if (memcg && !mem_cgroup_is_root(memcg)) { ret =3D __memcg_kmem_charge(memcg, gfp, 1 << order); if (!ret) { - page->mem_cgroup =3D memcg; + set_page_memcg(page, memcg); __SetPageKmemcg(page); return 0; } @@ -3111,7 +3102,7 @@ int __memcg_kmem_charge_page(struct page *page, gfp= _t gfp, int order) */ void __memcg_kmem_uncharge_page(struct page *page, int order) { - struct mem_cgroup *memcg =3D page->mem_cgroup; + struct mem_cgroup *memcg =3D page_memcg(page); unsigned int nr_pages =3D 1 << order; =20 if (!memcg) @@ -3119,7 +3110,7 @@ void __memcg_kmem_uncharge_page(struct page *page, = int order) =20 VM_BUG_ON_PAGE(mem_cgroup_is_root(memcg), page); __memcg_kmem_uncharge(memcg, nr_pages); - page->mem_cgroup =3D NULL; + clear_page_memcg(page); css_put(&memcg->css); =20 /* slab pages do not have PageKmemcg flag set */ @@ -3270,7 +3261,7 @@ void obj_cgroup_uncharge(struct obj_cgroup *objcg, = size_t size) */ void mem_cgroup_split_huge_fixup(struct page *head) { - struct mem_cgroup *memcg =3D head->mem_cgroup; + struct mem_cgroup *memcg =3D page_memcg(head); int i; =20 if (mem_cgroup_disabled()) @@ -3278,7 +3269,7 @@ void mem_cgroup_split_huge_fixup(struct page *head) =20 for (i =3D 1; i < HPAGE_PMD_NR; i++) { css_get(&memcg->css); - head[i].mem_cgroup =3D memcg; + set_page_memcg(&head[i], memcg); } } #endif /* CONFIG_TRANSPARENT_HUGEPAGE */ @@ -4654,7 +4645,7 @@ void mem_cgroup_wb_stats(struct bdi_writeback *wb, = unsigned long *pfilepages, void mem_cgroup_track_foreign_dirty_slowpath(struct page *page, struct bdi_writeback *wb) { - struct mem_cgroup *memcg =3D page->mem_cgroup; + struct mem_cgroup *memcg =3D page_memcg(page); struct memcg_cgwb_frn *frn; u64 now =3D get_jiffies_64(); u64 oldest_at =3D now; @@ -5623,14 +5614,14 @@ static int mem_cgroup_move_account(struct page *p= age, =20 /* * Prevent mem_cgroup_migrate() from looking at - * page->mem_cgroup of its source page while we change it. + * page's memory cgroup of its source page while we change it. */ ret =3D -EBUSY; if (!trylock_page(page)) goto out; =20 ret =3D -EINVAL; - if (page->mem_cgroup !=3D from) + if (page_memcg(page) !=3D from) goto out_unlock; =20 pgdat =3D page_pgdat(page); @@ -5685,13 +5676,13 @@ static int mem_cgroup_move_account(struct page *p= age, /* * All state has been migrated, let's switch to the new memcg. * - * It is safe to change page->mem_cgroup here because the page + * It is safe to change page's memcg here because the page * is referenced, charged, isolated, and locked: we can't race * with (un)charging, migration, LRU putback, or anything else - * that would rely on a stable page->mem_cgroup. + * that would rely on a stable page's memory cgroup. * * Note that lock_page_memcg is a memcg lock, not a page lock, - * to save space. As soon as we switch page->mem_cgroup to a + * to save space. As soon as we switch page's memory cgroup to a * new memcg that isn't locked, the above state can change * concurrently again. Make sure we're truly done with it. */ @@ -5700,7 +5691,7 @@ static int mem_cgroup_move_account(struct page *pag= e, css_get(&to->css); css_put(&from->css); =20 - page->mem_cgroup =3D to; + set_page_memcg(page, to); =20 __unlock_page_memcg(from); =20 @@ -5766,7 +5757,7 @@ static enum mc_target_type get_mctgt_type(struct vm= _area_struct *vma, * mem_cgroup_move_account() checks the page is valid or * not under LRU exclusion. */ - if (page->mem_cgroup =3D=3D mc.from) { + if (page_memcg(page) =3D=3D mc.from) { ret =3D MC_TARGET_PAGE; if (is_device_private_page(page)) ret =3D MC_TARGET_DEVICE; @@ -5810,7 +5801,7 @@ static enum mc_target_type get_mctgt_type_thp(struc= t vm_area_struct *vma, VM_BUG_ON_PAGE(!page || !PageHead(page), page); if (!(mc.flags & MOVE_ANON)) return ret; - if (page->mem_cgroup =3D=3D mc.from) { + if (page_memcg(page) =3D=3D mc.from) { ret =3D MC_TARGET_PAGE; if (target) { get_page(page); @@ -6793,12 +6784,12 @@ int mem_cgroup_charge(struct page *page, struct m= m_struct *mm, gfp_t gfp_mask) /* * Every swap fault against a single page tries to charge the * page, bail as early as possible. shmem_unuse() encounters - * already charged pages, too. page->mem_cgroup is protected - * by the page lock, which serializes swap cache removal, which - * in turn serializes uncharging. + * already charged pages, too. page and memcg binding is + * protected by the page lock, which serializes swap cache + * removal, which in turn serializes uncharging. */ VM_BUG_ON_PAGE(!PageLocked(page), page); - if (compound_head(page)->mem_cgroup) + if (page_memcg(compound_head(page))) goto out; =20 id =3D lookup_swap_cgroup_id(ent); @@ -6882,21 +6873,21 @@ static void uncharge_page(struct page *page, stru= ct uncharge_gather *ug) =20 VM_BUG_ON_PAGE(PageLRU(page), page); =20 - if (!page->mem_cgroup) + if (!page_memcg(page)) return; =20 /* * Nobody should be changing or seriously looking at - * page->mem_cgroup at this point, we have fully + * page_memcg(page) at this point, we have fully * exclusive access to the page. */ =20 - if (ug->memcg !=3D page->mem_cgroup) { + if (ug->memcg !=3D page_memcg(page)) { if (ug->memcg) { uncharge_batch(ug); uncharge_gather_clear(ug); } - ug->memcg =3D page->mem_cgroup; + ug->memcg =3D page_memcg(page); =20 /* pairs with css_put in uncharge_batch */ css_get(&ug->memcg->css); @@ -6913,7 +6904,7 @@ static void uncharge_page(struct page *page, struct= uncharge_gather *ug) } =20 ug->dummy_page =3D page; - page->mem_cgroup =3D NULL; + clear_page_memcg(page); css_put(&ug->memcg->css); } =20 @@ -6956,7 +6947,7 @@ void mem_cgroup_uncharge(struct page *page) return; =20 /* Don't touch page->lru of any random page, pre-check: */ - if (!page->mem_cgroup) + if (!page_memcg(page)) return; =20 uncharge_gather_clear(&ug); @@ -7006,11 +6997,11 @@ void mem_cgroup_migrate(struct page *oldpage, str= uct page *newpage) return; =20 /* Page cache replacement: new page already charged? */ - if (newpage->mem_cgroup) + if (page_memcg(newpage)) return; =20 /* Swapcache readahead pages can get replaced before being charged */ - memcg =3D oldpage->mem_cgroup; + memcg =3D page_memcg(oldpage); if (!memcg) return; =20 @@ -7205,7 +7196,7 @@ void mem_cgroup_swapout(struct page *page, swp_entr= y_t entry) if (cgroup_subsys_on_dfl(memory_cgrp_subsys)) return; =20 - memcg =3D page->mem_cgroup; + memcg =3D page_memcg(page); =20 /* Readahead page, never charged */ if (!memcg) @@ -7226,7 +7217,7 @@ void mem_cgroup_swapout(struct page *page, swp_entr= y_t entry) VM_BUG_ON_PAGE(oldid, page); mod_memcg_state(swap_memcg, MEMCG_SWAP, nr_entries); =20 - page->mem_cgroup =3D NULL; + clear_page_memcg(page); =20 if (!mem_cgroup_is_root(memcg)) page_counter_uncharge(&memcg->memory, nr_entries); @@ -7269,7 +7260,7 @@ int mem_cgroup_try_charge_swap(struct page *page, s= wp_entry_t entry) if (!cgroup_subsys_on_dfl(memory_cgrp_subsys)) return 0; =20 - memcg =3D page->mem_cgroup; + memcg =3D page_memcg(page); =20 /* Readahead page, never charged */ if (!memcg) @@ -7350,7 +7341,7 @@ bool mem_cgroup_swap_full(struct page *page) if (cgroup_memory_noswap || !cgroup_subsys_on_dfl(memory_cgrp_subsys)) return false; =20 - memcg =3D page->mem_cgroup; + memcg =3D page_memcg(page); if (!memcg) return false; =20 diff --git a/mm/page_alloc.c b/mm/page_alloc.c index 6b1b4a331792..377d65f25d7d 100644 --- a/mm/page_alloc.c +++ b/mm/page_alloc.c @@ -1056,7 +1056,7 @@ static inline bool page_expected_state(struct page = *page, if (unlikely((unsigned long)page->mapping | page_ref_count(page) | #ifdef CONFIG_MEMCG - (unsigned long)page->mem_cgroup | + (unsigned long)page_memcg(page) | #endif (page->flags & check_flags))) return false; @@ -1081,7 +1081,7 @@ static const char *page_bad_reason(struct page *pag= e, unsigned long flags) bad_reason =3D "PAGE_FLAGS_CHECK_AT_FREE flag(s) set"; } #ifdef CONFIG_MEMCG - if (unlikely(page->mem_cgroup)) + if (unlikely(page_memcg(page))) bad_reason =3D "page still charged to cgroup"; #endif return bad_reason; diff --git a/mm/page_io.c b/mm/page_io.c index dc6de6962612..4e12c7bbddcb 100644 --- a/mm/page_io.c +++ b/mm/page_io.c @@ -281,12 +281,14 @@ static inline void count_swpout_vm_event(struct pag= e *page) static void bio_associate_blkg_from_page(struct bio *bio, struct page *p= age) { struct cgroup_subsys_state *css; + struct mem_cgroup *memcg; =20 - if (!page->mem_cgroup) + memcg =3D page_memcg(page); + if (!memcg) return; =20 rcu_read_lock(); - css =3D cgroup_e_css(page->mem_cgroup->css.cgroup, &io_cgrp_subsys); + css =3D cgroup_e_css(memcg->css.cgroup, &io_cgrp_subsys); bio_associate_blkg_from_css(bio, css); rcu_read_unlock(); } diff --git a/mm/slab.h b/mm/slab.h index 4a24e1702923..5ac89260f329 100644 --- a/mm/slab.h +++ b/mm/slab.h @@ -242,18 +242,17 @@ static inline bool kmem_cache_debug_flags(struct km= em_cache *s, slab_flags_t fla static inline struct obj_cgroup **page_obj_cgroups(struct page *page) { /* - * page->mem_cgroup and page->obj_cgroups are sharing the same + * Page's memory cgroup and obj_cgroups vector are sharing the same * space. To distinguish between them in case we don't know for sure * that the page is a slab page (e.g. page_cgroup_ino()), let's * always set the lowest bit of obj_cgroups. */ - return (struct obj_cgroup **) - ((unsigned long)page->obj_cgroups & ~0x1UL); + return (struct obj_cgroup **)(page->memcg_data & ~0x1UL); } =20 static inline bool page_has_obj_cgroups(struct page *page) { - return ((unsigned long)page->obj_cgroups & 0x1UL); + return page->memcg_data & 0x1UL; } =20 int memcg_alloc_page_obj_cgroups(struct page *page, struct kmem_cache *s= , @@ -262,7 +261,7 @@ int memcg_alloc_page_obj_cgroups(struct page *page, s= truct kmem_cache *s, static inline void memcg_free_page_obj_cgroups(struct page *page) { kfree(page_obj_cgroups(page)); - page->obj_cgroups =3D NULL; + page->memcg_data =3D 0; } =20 static inline size_t obj_full_size(struct kmem_cache *s) diff --git a/mm/workingset.c b/mm/workingset.c index 8ed8e6296d8c..ef563f94a0e3 100644 --- a/mm/workingset.c +++ b/mm/workingset.c @@ -257,7 +257,7 @@ void *workingset_eviction(struct page *page, struct m= em_cgroup *target_memcg) struct lruvec *lruvec; int memcgid; =20 - /* Page is fully exclusive and pins page->mem_cgroup */ + /* Page is fully exclusive and pins page's memory cgroup pointer */ VM_BUG_ON_PAGE(PageLRU(page), page); VM_BUG_ON_PAGE(page_count(page), page); VM_BUG_ON_PAGE(!PageLocked(page), page); --=20 2.26.2