From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org X-Spam-Level: X-Spam-Status: No, score=-7.7 required=3.0 tests=BAYES_00,DKIM_SIGNED, DKIM_VALID,DKIM_VALID_AU,FREEMAIL_FORGED_FROMDOMAIN,FREEMAIL_FROM, HEADER_FROM_DIFFERENT_DOMAINS,MAILING_LIST_MULTI,MENTIONS_GIT_HOSTING, SPF_HELO_NONE,SPF_PASS,URIBL_BLOCKED autolearn=no autolearn_force=no version=3.4.0 Received: from mail.kernel.org (mail.kernel.org [198.145.29.99]) by smtp.lore.kernel.org (Postfix) with ESMTP id E4955C433E9 for ; Tue, 26 Jan 2021 16:22:51 +0000 (UTC) Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by mail.kernel.org (Postfix) with ESMTP id B5E5220735 for ; Tue, 26 Jan 2021 16:22:51 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S2404626AbhAZQWb (ORCPT ); Tue, 26 Jan 2021 11:22:31 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:41980 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S2392867AbhAZQWT (ORCPT ); Tue, 26 Jan 2021 11:22:19 -0500 Received: from mail-io1-xd33.google.com (mail-io1-xd33.google.com [IPv6:2607:f8b0:4864:20::d33]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 2328BC0613D6 for ; Tue, 26 Jan 2021 08:21:39 -0800 (PST) Received: by mail-io1-xd33.google.com with SMTP id d13so34695885ioy.4 for ; Tue, 26 Jan 2021 08:21:39 -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=Ntku7N088RI9HeUGoV4shsGhiUevdphg81xyzWFer/U=; b=l5BZxRxnz8tVRqGd9wBjh/9yxHz1mbQPWq9yH6fEJ26/yVz5mbO7Eeny/SaZOVN7CD 10ukUc6YIc88ytn58Uu4kK522jOmDBIm0ojxXuBs0N0Fw9vBM1KgGPxeyOQEKSPJN/EZ QG46ndqMEbrM0K+ny5R1bZbcGJ5M/7Ep5wnX4Oo7eTmJCWgpAspaE1yASSELiuLQE5ue cXJaVygiHF964+X89rfmy+TtfbLRg/0dLliOrCSlSMNT6tWafs+2FHRAIeSaRm5XuaJw 3L9GlkokFHNnvIBmHfZAZkZPmXbWkLXpNXzLLpuPjvBLAwqZHp0YBU43tzMRD5jWI/Kl fisw== 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=Ntku7N088RI9HeUGoV4shsGhiUevdphg81xyzWFer/U=; b=pywAVMHxsC3vHQaL+ZfcfL9LlbcoH3AND/7STAS1CrRGhrg2Tgwf9DcbaTu+8tDP+V 2R6e/s6nh6MSLh/7HlmFhunBXBl6F6tkCOlxk7zbC+Id2YEdUJj4nFffKhgT8y5NIRSG SwIE9w0aX4iNoRWZHxZF2PnZAvJgk3IqnCqdso9Gbxs9vO7T7FfANJsmWRYYWI6V5x9F TAZ0ZG7WSwbVsQ77nlaVz84TuuNgGiKCOmIGnKoBhWMvmBhEblVsSUCmA0mrFz+pgrM8 T4KV8ar78RBTMk1kmX00xj0DbMICQu5P2SdovEqxLIsMx5FYjzHzWnOLT5PzsibZhZtY 0cLg== X-Gm-Message-State: AOAM532eJnyRETkfp6i94isR/qh3++igfjCpT73uV5PT5th5modiwI/l 4uDtBswhMbDyxcS+WvNplLAxbJwvI1LvVLgTeWE= X-Google-Smtp-Source: ABdhPJzFyxpviA0LRjmyiGeFjFSwO1o7N88kqtqW++0NBOu97/dnkvZJGIgFbxvbVtvN7FvFMuAndnrp8142SuHquG0= X-Received: by 2002:a05:6e02:14ce:: with SMTP id o14mr5432405ilk.9.1611678098237; Tue, 26 Jan 2021 08:21:38 -0800 (PST) MIME-Version: 1.0 References: <20200217131455.31107-1-amir73il@gmail.com> <20200217131455.31107-9-amir73il@gmail.com> <20200226091804.GD10728@quack2.suse.cz> <20200226143843.GT10728@quack2.suse.cz> <20210125130149.GC1175@quack2.suse.cz> In-Reply-To: <20210125130149.GC1175@quack2.suse.cz> From: Amir Goldstein Date: Tue, 26 Jan 2021 18:21:26 +0200 Message-ID: Subject: Re: fanotify_merge improvements To: Jan Kara Cc: linux-fsdevel Content-Type: text/plain; charset="UTF-8" Precedence: bulk List-ID: X-Mailing-List: linux-fsdevel@vger.kernel.org On Mon, Jan 25, 2021 at 3:01 PM Jan Kara wrote: > > On Sat 23-01-21 15:30:59, Amir Goldstein wrote: > > On Fri, Jan 22, 2021 at 3:59 PM Amir Goldstein wrote: > > > > > > > > > Hum, now thinking about this, maybe we could clean this up even a bit more. > > > > > > event->inode is currently used only by inotify and fanotify for merging > > > > > > purposes. Now inotify could use its 'wd' instead of inode with exactly the > > > > > > same results, fanotify path or fid check is at least as strong as the inode > > > > > > check. So only for the case of pure "inode" events, we need to store inode > > > > > > identifier in struct fanotify_event - and we can do that in the union with > > > > > > struct path and completely remove the 'inode' member from fsnotify_event. > > > > > > Am I missing something? > > > > > > > > > > That generally sounds good and I did notice it is strange that wd is not > > > > > being compared. However, I think I was worried that comparing fid+name > > > > > (in following patches) would be more expensive than comparing dentry (or > > > > > object inode) as a "rule out first" in merge, so I preferred to keep the > > > > > tag/dentry/id comparison for fanotify_fid case. > > > > > > > > Yes, that could be a concern. > > > > > > > > > Given this analysis (and assuming it is correct), would you like me to > > > > > just go a head with the change suggested above? or anything beyond that? > > > > > > > > Let's go just with the change suggested above for now. We can work on this > > > > later (probably with optimizing of the fanotify merging code). > > > > > > > > > > Hi Jan, > > > > > > Recap: > > > - fanotify_merge is very inefficient and uses extensive CPU if queue contains > > > many events, so it is rather easy for a poorly written listener to > > > cripple the system > > > - You had an idea to store in event->objectid a hash of all the compared > > > fields (e.g. fid+name) > > > - I think you had an idea to keep a hash table of events in the queue > > > to find the > > > merge candidates faster > > > - For internal uses, I carry a patch that limits the linear search for > > > last 128 events > > > which is enough to relieve the CPU overuse in case of unattended long queues > > > > > > I tried looking into implementing the hash table idea, assuming I understood you > > > correctly and I struggled to choose appropriate table sizes. It seemed to make > > > sense to use a global hash table, such as inode/dentry cache for all the groups > > > but that would add complexity to locking rules of queue/dequeue and > > > group cleanup. > > > > > > A simpler solution I considered, similar to my 128 events limit patch, > > > is to limit > > > the linear search to events queued in the last X seconds. > > > The rationale is that event merging is not supposed to be long term at all. > > > If a listener fails to perform read from the queue, it is not fsnotify's job to > > > try and keep the queue compact. I think merging events mechanism was > > > mainly meant to merge short bursts of events on objects, which are quite > > > common and surely can happen concurrently on several objects. > > > > > > My intuition is that making event->objectid into event->hash in addition > > > to limiting the age of events to merge would address the real life workloads. > > > One question if we do choose this approach is what should the age limit be? > > > Should it be configurable? Default to infinity and let distro cap the age or > > > provide a sane default by kernel while slightly changing behavior (yes please). > > > > > > What are your thoughts about this? > > > > Aha! found it: > > https://lore.kernel.org/linux-fsdevel/20200227112755.GZ10728@quack2.suse.cz/ > > You suggested a small hash table per group (128 slots). > > > > My intuition is that this will not be good enough for the worst case, which is > > not that hard to hit is real life: > > 1. Listener sets FAN_UNLIMITED_QUEUE > > 2. Listener adds a FAN_MARK_FILESYSTEM watch > > 3. Many thousands of events are queued > > 4. Listener lingers (due to bad implementation?) in reading events > > 5. Every single event now incurs a huge fanotify_merge() cost > > > > Reducing the cost of merge from O(N) to O(N/128) doesn't really fix the > > problem. > > So my thought was that indeed reducing the overhead of merging by a factor > of 128 should be enough for any practical case as much as I agree that in > principle the computational complexity remains the same. And I've picked > per-group hash table to avoid interferences among notification groups and > to keep locking simple. That being said I'm not opposed to combining this > with a limit on the number of elements traversed in a hash chain (e.g. > those 128 you use yourself) - it will be naturally ordered by queue order > if we are a bit careful. This will provide efficient and effective merging > for ~8k queued events which seems enough to me. I find time based limits > not really worth it. Yes, they provide more predictable behavior but less > predictable runtime and overall I don't find the complexity worth the > benefit. > Sounds reasonable. If you have time, please take a look at this WIP branch: https://github.com/amir73il/linux/commits/fanotify_merge and let me know if you like the direction it is taking. This branch is only compile tested, but I am asking w.r.t to the chosen data structures. So far it is just an array of queues selected by (yet unmodified) objectid. Reading is just from any available queue. My goal was to avoid having to hang the event on multiple list/hlist and the idea is to implement read by order of events as follows: - With multi queue, high bit of obejctid will be masked for merge compare. - Instead, they will be used to store the next_qid to read from For example: - event #1 is added to queue 6 - set group->last_qid = 6 - set group->next_qid = 6 (because group->num_events == 1) - event #2 is added to queue 13 - the next_qid bits of the last event in last_qid (6) queue are set to 13 - set group->last_qid = 13 - read() checks value of group->next_qid and reads the first event from queue 6 (event #1) - event #1 has 13 stored in next_qid bits so set group->next_qid = 13 - read() reads first event from queue 13 (event #2) Permission events require special care, but that is the idea of a simple singly linked list using qid's for reading events by insert order and merging by hashed queue. The advantage of this method is that most of the generic code remains unaware of the multi queue changes (see WIP) and I think it gets the job done without complicating the code too much. Thoughts? Thanks, Amir.