Received: by 2002:a05:6a10:f347:0:0:0:0 with SMTP id d7csp209817pxu; Tue, 1 Dec 2020 09:21:53 -0800 (PST) X-Google-Smtp-Source: ABdhPJyEE3oYRDepFT0UapAwjx1EmsS8P9HVWMzEfhaJU2okqpmRGG/iqoTDnV6NRNoEc/p0Y88d X-Received: by 2002:a50:fb1a:: with SMTP id d26mr4107653edq.101.1606843313076; Tue, 01 Dec 2020 09:21:53 -0800 (PST) ARC-Seal: i=1; a=rsa-sha256; t=1606843313; cv=none; d=google.com; s=arc-20160816; b=KVvo5c80TDxBFNkhIZS03F0fzLnV2SXtI+odJyhkRkc3IkY5Vl++dxBo1jKdCnAApE Y+cLQ6jbRjZXmRlc1xXjhueDztA0K8Ir0fHFGB1R0d9ur/GBODE7ur+SpgRNGVtQDRHy J8JbVQFZ8dhpLTW07KM4OdgaBQaqO+p6OzOiu8YKiiDriNEuChqdWtI8ruwhZooPtOZa gOb+HGFIhkd6Skk43q6mMXUMeCC/c5PsPv/pJ29Q5801iPdlyauqzWG8onXq8zHZBwRk m4qtWw2Zw5NM8Q8lC2o19kRMEMTFyMBXr2JZvIHNHVnkoNXtUeJgIBeCXQDWejrQMwoH ZQwg== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20160816; h=list-id:precedence:cc:to:subject:message-id:date:from:in-reply-to :references:mime-version:dkim-signature; bh=y2jTly3ENaKEx3SqUjHFPVg+PFOmzg8pGS/LRtuXVZs=; b=ki3Cr5SiZ0HGEfJpeK3whJ9zdblEoIM/HpRYH0rLwIOUZ9AuNYu7eSm6vVhkskErxp 7pRqSCHy9nvW0dDZDFFb+MmmyZvLqrH0XmFJN7fFqIojYxdiChRh5kEfWb9ApYOof5rA oGyocV6xEgU6+OWpWmhQMmMcsplmVcpgdVwEoOT0TdIHvepZPjiHuFwfa5mE3SJNNAv6 KYgyBiK65ZyoYCjPijhAnRq/v9dWpQMCPBlPUf0XxFch/6RveKLTeSlUn34wRRxwpkCJ jGmjwPLR4LzlWU5r1nqlCmzfoBqWWjjgxYoeysyDCXPGCOswkrkuPJeHH0iPbvpz9Ywr Lp0g== ARC-Authentication-Results: i=1; mx.google.com; dkim=pass header.i=@gmail.com header.s=20161025 header.b=dVVIH+7F; 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=NONE sp=QUARANTINE dis=NONE) header.from=gmail.com Return-Path: Received: from vger.kernel.org (vger.kernel.org. [23.128.96.18]) by mx.google.com with ESMTP id p90si286989edd.341.2020.12.01.09.21.12; Tue, 01 Dec 2020 09:21:53 -0800 (PST) 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=@gmail.com header.s=20161025 header.b=dVVIH+7F; 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=NONE sp=QUARANTINE dis=NONE) header.from=gmail.com Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1729452AbgLARQc (ORCPT + 99 others); Tue, 1 Dec 2020 12:16:32 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:43950 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1726303AbgLARQc (ORCPT ); Tue, 1 Dec 2020 12:16:32 -0500 Received: from mail-ej1-x641.google.com (mail-ej1-x641.google.com [IPv6:2a00:1450:4864:20::641]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 04ACAC0613D6 for ; Tue, 1 Dec 2020 09:15:46 -0800 (PST) Received: by mail-ej1-x641.google.com with SMTP id f9so5693485ejw.4 for ; Tue, 01 Dec 2020 09:15:45 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:references:in-reply-to:from:date:message-id:subject:to :cc; bh=y2jTly3ENaKEx3SqUjHFPVg+PFOmzg8pGS/LRtuXVZs=; b=dVVIH+7FJr+MsHaWRrFWrAHNoNSVT6Y9G6PxetQvCbjj1U/EqMlCsSA5ap8KrFJYji 2/uRQ4RHR5PjFnJFrntbKRpGQuBoPYOO6x2JdfSsCqEjb5urh6jRQ52HuQa/Ex3r3PqT hgsbbCPgkmGkw/aH0jvzdZQ1leUZvCHeLxojGogSI/LkddM8XuumBBSbmfF97J6NmvpO bmjNR802aYTR1H7DGqXNFefGw351lXjdjWt84wSVMqU8R7ki4JpOS63B4XWVStbxamw/ YbdhubF2C+LZlzI2CYRPdViw2XDpH7S3/fCRPjgr0Q+WP6mYIB6F9oUSHIsQtfzd8S1N D7Rw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:references:in-reply-to:from:date :message-id:subject:to:cc; bh=y2jTly3ENaKEx3SqUjHFPVg+PFOmzg8pGS/LRtuXVZs=; b=sJE4PT37SNt1IjmIS8RSYBtSA5EMBn5IkMCi+uSW4QQBUt3KSd86kvOr3jK+C5a7pr ohvl5HrBqBVDDlVAI/I38NQOZkhb8uzJDKw8gMr4eEtw1AKgROKFdp8togS3i9y43d1o VMdpWjpfJPgYiLu02gX1W+0Ugdh88kWHXyVa/aTJPMSM/+osK5mJwmO+DY/zg5uiQuFY jBxqtWDgJs5mBnnE6aalAKsg1kkcZHfxUAnr8Lfy6W9I89CxMjQJ5mizZXXzad6C3KQu 6X67csTYsjxq84FC+WdKKVB4LJL5wAjeeVEa+6jJMXUtqcipWk9CKMAwmPVSawlE3vmt sU4Q== X-Gm-Message-State: AOAM530hpB0zTBOkRAuOeKRhbsJ1E/Qg2rqjusvjmTMrlNjvLGJM3j3i YW+MeBdaJiTgjKT3VxTEo13Jw3BXqyOKkvdrl0A= X-Received: by 2002:a17:907:20a4:: with SMTP id pw4mr2947872ejb.499.1606842944712; Tue, 01 Dec 2020 09:15:44 -0800 (PST) MIME-Version: 1.0 References: <20201130184514.551950-1-shy828301@gmail.com> <20201130200936.GA1354703@carbon.DHCP.thefacebook.com> In-Reply-To: From: Yang Shi Date: Tue, 1 Dec 2020 09:15:32 -0800 Message-ID: Subject: Re: [PATCH] mm: list_lru: hold nlru lock to avoid reading transient negative nr_items To: Kirill Tkhai Cc: Roman Gushchin , Vladimir Davydov , Shakeel Butt , Andrew Morton , Linux MM , Linux Kernel Mailing List Content-Type: text/plain; charset="UTF-8" Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org On Tue, Dec 1, 2020 at 2:25 AM Kirill Tkhai wrote: > > On 30.11.2020 23:09, Roman Gushchin wrote: > > On Mon, Nov 30, 2020 at 10:45:14AM -0800, Yang Shi wrote: > >> When investigating a slab cache bloat problem, significant amount of > >> negative dentry cache was seen, but confusingly they neither got shrunk > >> by reclaimer (the host has very tight memory) nor be shrunk by dropping > >> cache. The vmcore shows there are over 14M negative dentry objects on lru, > >> but tracing result shows they were even not scanned at all. The further > >> investigation shows the memcg's vfs shrinker_map bit is not set. So the > >> reclaimer or dropping cache just skip calling vfs shrinker. So we have > >> to reboot the hosts to get the memory back. > >> > >> I didn't manage to come up with a reproducer in test environment, and the > >> problem can't be reproduced after rebooting. But it seems there is race > >> between shrinker map bit clear and reparenting by code inspection. The > >> hypothesis is elaborated as below. > >> > >> The memcg hierarchy on our production environment looks like: > >> root > >> / \ > >> system user > >> > >> The main workloads are running under user slice's children, and it creates > >> and removes memcg frequently. So reparenting happens very often under user > >> slice, but no task is under user slice directly. > >> > >> So with the frequent reparenting and tight memory pressure, the below > >> hypothetical race condition may happen: > >> > >> CPU A CPU B CPU C > >> reparent > >> dst->nr_items == 0 > >> shrinker: > >> total_objects == 0 > >> add src->nr_items to dst > >> set_bit > >> retrun SHRINK_EMPTY > >> clear_bit > >> list_lru_del() > >> reparent again > >> dst->nr_items may go negative > >> due to current list_lru_del() > >> on CPU C > >> The second run of shrinker: > >> read nr_items without any > >> synchronization, so it may > >> see intermediate negative > >> nr_items then total_objects > >> may return 0 conincidently > >> > >> keep the bit cleared > >> dst->nr_items != 0 > >> skip set_bit > >> add scr->nr_item to dst > >> > >> After this point dst->nr_item may never go zero, so reparenting will not > >> set shrinker_map bit anymore. And since there is no task under user > >> slice directly, so no new object will be added to its lru to set the > >> shrinker map bit either. That bit is kept cleared forever. > >> > >> How does list_lru_del() race with reparenting? It is because > >> reparenting replaces childen's kmemcg_id to parent's without protecting > >> from nlru->lock, so list_lru_del() may see parent's kmemcg_id but > >> actually deleting items from child's lru, but dec'ing parent's nr_items, > >> so the parent's nr_items may go negative as commit > >> 2788cf0c401c268b4819c5407493a8769b7007aa ("memcg: reparent list_lrus and > >> free kmemcg_id on css offline") says. > >> > >> Can we move kmemcg_id replacement after reparenting? No, because the > >> race with list_lru_del() may result in negative src->nr_items, but it > >> will never be fixed. So the shrinker may never return SHRINK_EMPTY then > >> keep the shrinker map bit set always. The shrinker will be always > >> called for nonsense. > >> > >> Can we synchronize list_lru_del() and reparenting? Yes, it could be > >> done. But it seems we need introduce a new lock or use nlru->lock. But > >> it sounds complicated to move kmemcg_id replacement code under nlru->lock. > >> And list_lru_del() may be called quite often to exacerbate some hot > >> path, i.e. dentry kill. > >> > >> So, it sounds acceptable to synchronize reading nr_items to avoid seeing > >> intermediate negative nr_items given the simplicity and it is typically > >> just called by shrinkers when counting the freeable objects. > >> > >> The patch is tested with some shrinker intensive workloads, no > >> noticeable regression is soptted. > > > > Hi Yang! > > > > It's really tricky, thank you for digging in! It's a perfect analysis! > > > > I wonder though, if it's better to just always set the shrinker bit on reparenting > > if we do reparent some items? Then we'll avoid adding new synchronization > > to the hot path. What do you think? > > > > -- > > > > @@ -534,7 +534,6 @@ static void memcg_drain_list_lru_node(struct list_lru *lru, int nid, > > struct list_lru_node *nlru = &lru->node[nid]; > > int dst_idx = dst_memcg->kmemcg_id; > > struct list_lru_one *src, *dst; > > - bool set; > > > > /* > > * Since list_lru_{add,del} may be called under an IRQ-safe lock, > > @@ -546,9 +545,8 @@ static void memcg_drain_list_lru_node(struct list_lru *lru, int nid, > > dst = list_lru_from_memcg_idx(nlru, dst_idx); > > > > list_splice_init(&src->list, &dst->list); > > - set = (!dst->nr_items && src->nr_items); > > dst->nr_items += src->nr_items; > > - if (set) > > + if (src->nr_items) > > memcg_set_shrinker_bit(dst_memcg, nid, lru_shrinker_id(lru)); > > src->nr_items = 0; > > This looks like a good fix. > > To make a code more clear, we may also want to group neighbouring lines > under the same "if" branch in Yang's v2 resend. You mean something like the below (diff based on Roman's proposal)? diff --git a/mm/list_lru.c b/mm/list_lru.c index 127c2cf9f831..fe230081690b 100644 --- a/mm/list_lru.c +++ b/mm/list_lru.c @@ -545,10 +545,12 @@ static void memcg_drain_list_lru_node(struct list_lru *lru, int nid, dst = list_lru_from_memcg_idx(nlru, dst_idx); list_splice_init(&src->list, &dst->list); - dst->nr_items += src->nr_items; - if (src->nr_items) + + if (src->nr_items) { + dst->nr_items += src->nr_items; memcg_set_shrinker_bit(dst_memcg, nid, lru_shrinker_id(lru)); - src->nr_items = 0; + src->nr_items = 0; + } spin_unlock_irq(&nlru->lock); > > Thanks, > Kirill