On 10/17/23 00:18, Roman Gushchin wrote:
> Manually inline memcg_kmem_bypass() and active_memcg() to speed up
> get_obj_cgroup_from_current() by avoiding duplicate in_task() checks
> and active_memcg() readings.
I guess the compiler could figure out most of it, except maybe the
active_memcg() after rcu_read_lock(), as I note below.
But anyway it's a single caller of memcg_kmem_bypass() so this makes sense.
> Also add a likely() macro to __get_obj_cgroup_from_memcg():
> obj_cgroup_tryget() should succeed at almost all times except a very
> unlikely race with the memcg deletion path.
>
> Signed-off-by: Roman Gushchin (Cruise) <roman.gushchin@xxxxxxxxx>
> Tested-by: Naresh Kamboju <naresh.kamboju@xxxxxxxxxx>
> Acked-by: Shakeel Butt <shakeelb@xxxxxxxxxx>
> Acked-by: Johannes Weiner <hannes@xxxxxxxxxxx>
Reviewed-by: Vlastimil Babka <vbabka@xxxxxxx>
> ---
> mm/memcontrol.c | 34 ++++++++++++++--------------------
> 1 file changed, 14 insertions(+), 20 deletions(-)
>
> diff --git a/mm/memcontrol.c b/mm/memcontrol.c
> index 9741d62d0424..16ac2a5838fb 100644
> --- a/mm/memcontrol.c
> +++ b/mm/memcontrol.c
> @@ -1068,19 +1068,6 @@ struct mem_cgroup *get_mem_cgroup_from_mm(struct mm_struct *mm)
> }
> EXPORT_SYMBOL(get_mem_cgroup_from_mm);
>
> -static __always_inline bool memcg_kmem_bypass(void)
> -{
> - /* Allow remote memcg charging from any context. */
> - if (unlikely(active_memcg()))
> - return false;
> -
> - /* Memcg to charge can't be determined. */
> - if (!in_task() || !current->mm || (current->flags & PF_KTHREAD))
> - return true;
> -
> - return false;
> -}
> -
> /**
> * mem_cgroup_iter - iterate over memory cgroup hierarchy
> * @root: hierarchy root
> @@ -3007,7 +2994,7 @@ static struct obj_cgroup *__get_obj_cgroup_from_memcg(struct mem_cgroup *memcg)
>
> for (; !mem_cgroup_is_root(memcg); memcg = parent_mem_cgroup(memcg)) {
> objcg = rcu_dereference(memcg->objcg);
> - if (objcg && obj_cgroup_tryget(objcg))
> + if (likely(objcg && obj_cgroup_tryget(objcg)))
> break;
> objcg = NULL;
> }
> @@ -3016,16 +3003,23 @@ static struct obj_cgroup *__get_obj_cgroup_from_memcg(struct mem_cgroup *memcg)
>
> __always_inline struct obj_cgroup *get_obj_cgroup_from_current(void)
> {
> - struct obj_cgroup *objcg = NULL;
> struct mem_cgroup *memcg;
> + struct obj_cgroup *objcg;
>
> - if (memcg_kmem_bypass())
> - return NULL;
> + if (in_task()) {
> + memcg = current->active_memcg;
> +
> + /* Memcg to charge can't be determined. */
> + if (likely(!memcg) && (!current->mm || (current->flags & PF_KTHREAD)))
> + return NULL;
> + } else {
> + memcg = this_cpu_read(int_active_memcg);
> + if (likely(!memcg))
> + return NULL;
> + }
>
> rcu_read_lock();
> - if (unlikely(active_memcg()))
> - memcg = active_memcg();
I guess the rcu_read_lock() has in theory prevented us from being migrated
to a different cpu after doing the !in_task()
this_cpu_read(int_active_memcg); and now we trust the reading outside of the
rcu lock, but it's ok because a) nothing prevented us from migrating cpu
after getting to the objcg anyway so we could end up with a wrong one, and
b) if we're not in_task() and thus read int_active_memcg, it means our
context is some interrupt handler that can't be migrated to another cpu
anyway, right?
> - else
> + if (!memcg)
> memcg = mem_cgroup_from_task(current);
> objcg = __get_obj_cgroup_from_memcg(memcg);
> rcu_read_unlock();
