From patchwork Tue Sep 19 19:53:03 2017 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Jens Axboe X-Patchwork-Id: 9960077 Return-Path: Received: from mail.wl.linuxfoundation.org (pdx-wl-mail.web.codeaurora.org [172.30.200.125]) by pdx-korg-patchwork.web.codeaurora.org (Postfix) with ESMTP id 52BB5601E9 for ; Tue, 19 Sep 2017 19:54:53 +0000 (UTC) Received: from mail.wl.linuxfoundation.org (localhost [127.0.0.1]) by mail.wl.linuxfoundation.org (Postfix) with ESMTP id 44F8828EB2 for ; Tue, 19 Sep 2017 19:54:53 +0000 (UTC) Received: by mail.wl.linuxfoundation.org (Postfix, from userid 486) id 39CD428EE2; Tue, 19 Sep 2017 19:54:53 +0000 (UTC) X-Spam-Checker-Version: SpamAssassin 3.3.1 (2010-03-16) on pdx-wl-mail.web.codeaurora.org X-Spam-Level: X-Spam-Status: No, score=-6.9 required=2.0 tests=BAYES_00,DKIM_SIGNED, DKIM_VALID,RCVD_IN_DNSWL_HI autolearn=unavailable version=3.3.1 Received: from vger.kernel.org (vger.kernel.org [209.132.180.67]) by mail.wl.linuxfoundation.org (Postfix) with ESMTP id 3E10E28EB2 for ; Tue, 19 Sep 2017 19:54:52 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1751790AbdISTyh (ORCPT ); Tue, 19 Sep 2017 15:54:37 -0400 Received: from mail-pf0-f173.google.com ([209.85.192.173]:54944 "EHLO mail-pf0-f173.google.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1751533AbdISTxS (ORCPT ); Tue, 19 Sep 2017 15:53:18 -0400 Received: by mail-pf0-f173.google.com with SMTP id d187so341819pfg.11 for ; Tue, 19 Sep 2017 12:53:17 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=kernel-dk.20150623.gappssmtp.com; s=20150623; h=from:to:cc:subject:date:message-id:in-reply-to:references; bh=nYNjh/22rSjBo5ruaVsr+aRSQ+prD2Tl66dbgrVRFk8=; b=fXcjUo7BPcezmahAorEiKhIrfYCUoWwuxwP5OYhImBPp0j488fdco2UmOK9WGcVQnn ytKGR6mzmAeDofnFqru3tSeZFqtyIiR3zqWZnsuW47iokExH8arVukzpmt3ULp3glvbD eriCKEcR20+SR4gOoLW5DnITpmxaWfMDiwWDG8iNwGB906gqv74hEMrLV14Bxv5Lj/Rb K+SjHgggV2DNPhk81V7Xr7obcSRIoa5zWgUdbpQZCQlqZnN6ZnH6mSjC4oT7DgJGvxPq MOCVG341VkU6EuAojswj8iulvCg23cAZHpvmoKzzoqzR3ueTU7JjjNCyMLLFgYW+O+gR hfBQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:to:cc:subject:date:message-id:in-reply-to :references; bh=nYNjh/22rSjBo5ruaVsr+aRSQ+prD2Tl66dbgrVRFk8=; b=GRGKlr53k+1/W7N+V0Z8sYsiEYpGOnEtYrMlkh0E+DIW1NpkyymHwSQBTrxLl13yG3 ZTxFQJgDD9pRPZ3I/gkluSY8mn3ITwn3zeGk0TT1x8Bx7SL8ZQzgts9U95BwTlE8W7pe 5P98jlac7IBwG2bEtYdPONDNvmJdyVL8uQz5+3u1s5yLWaTiNscaOPFR/q2Oa/m9bTsD eL/6Ilm0XQJAFMk76+7LiVJgkTDqwIfO/5cxq847R58fZLEkOGXgxEwhMQfu3cDRVfrv XjfGCE+NpRCLtVcBiJspfGV5XELGaN+i3uzmRYjO5mIcPYa80Dn1n+6NSbtWS5fLBkbI njHw== X-Gm-Message-State: AHPjjUiMMd0NRFW9ulJizdFWkHR/ALx8ZTxWQjvZow75w4r828OajI5r pAotNSsflvd4I8SfzIn3ljbdBbPkOi4= X-Google-Smtp-Source: AOwi7QD1yG29r/LIpE+L0QFLyPmaihy52HC5f1to7CHUfkRhYnp0Ero9ZLULXqQmcCe9MifcZHsGOA== X-Received: by 10.99.163.65 with SMTP id v1mr2386450pgn.310.1505850796954; Tue, 19 Sep 2017 12:53:16 -0700 (PDT) Received: from x1.thefacebook.com ([2620:10d:c090:180::1:3f91]) by smtp.gmail.com with ESMTPSA id r90sm5271856pfb.183.2017.09.19.12.53.15 (version=TLS1_2 cipher=ECDHE-RSA-AES128-SHA bits=128/128); Tue, 19 Sep 2017 12:53:16 -0700 (PDT) From: Jens Axboe To: linux-kernel@vger.kernel.org, linux-fsdevel@vger.kernel.org, linux-mm@kvack.org Cc: hannes@cmpxchg.org, clm@fb.com, jack@suse.cz, Jens Axboe Subject: [PATCH 2/6] fs-writeback: provide a wakeup_flusher_threads_bdi() Date: Tue, 19 Sep 2017 13:53:03 -0600 Message-Id: <1505850787-18311-3-git-send-email-axboe@kernel.dk> X-Mailer: git-send-email 2.7.4 In-Reply-To: <1505850787-18311-1-git-send-email-axboe@kernel.dk> References: <1505850787-18311-1-git-send-email-axboe@kernel.dk> Sender: linux-fsdevel-owner@vger.kernel.org Precedence: bulk List-ID: X-Mailing-List: linux-fsdevel@vger.kernel.org X-Virus-Scanned: ClamAV using ClamSMTP Similar to wakeup_flusher_threads(), except that we only wake up the flusher threads on the specified backing device. No functional changes in this patch. Signed-off-by: Jens Axboe Acked-by: Johannes Weiner Reviewed-by: Jan Kara --- fs/fs-writeback.c | 40 ++++++++++++++++++++++++++++++---------- include/linux/writeback.h | 2 ++ 2 files changed, 32 insertions(+), 10 deletions(-) diff --git a/fs/fs-writeback.c b/fs/fs-writeback.c index 245c430a2e41..03fda0830bf8 100644 --- a/fs/fs-writeback.c +++ b/fs/fs-writeback.c @@ -1947,6 +1947,34 @@ void wb_workfn(struct work_struct *work) } /* + * Start writeback of `nr_pages' pages on this bdi. If `nr_pages' is zero, + * write back the whole world. + */ +static void __wakeup_flusher_threads_bdi(struct backing_dev_info *bdi, + long nr_pages, enum wb_reason reason) +{ + struct bdi_writeback *wb; + + if (!bdi_has_dirty_io(bdi)) + return; + + list_for_each_entry_rcu(wb, &bdi->wb_list, bdi_node) + wb_start_writeback(wb, wb_split_bdi_pages(wb, nr_pages), + false, reason); +} + +void wakeup_flusher_threads_bdi(struct backing_dev_info *bdi, long nr_pages, + enum wb_reason reason) +{ + if (!nr_pages) + nr_pages = get_nr_dirty_pages(); + + rcu_read_lock(); + __wakeup_flusher_threads_bdi(bdi, nr_pages, reason); + rcu_read_unlock(); +} + +/* * Start writeback of `nr_pages' pages. If `nr_pages' is zero, write back * the whole world. */ @@ -1964,16 +1992,8 @@ void wakeup_flusher_threads(long nr_pages, enum wb_reason reason) nr_pages = get_nr_dirty_pages(); rcu_read_lock(); - list_for_each_entry_rcu(bdi, &bdi_list, bdi_list) { - struct bdi_writeback *wb; - - if (!bdi_has_dirty_io(bdi)) - continue; - - list_for_each_entry_rcu(wb, &bdi->wb_list, bdi_node) - wb_start_writeback(wb, wb_split_bdi_pages(wb, nr_pages), - false, reason); - } + list_for_each_entry_rcu(bdi, &bdi_list, bdi_list) + __wakeup_flusher_threads_bdi(bdi, nr_pages, reason); rcu_read_unlock(); } diff --git a/include/linux/writeback.h b/include/linux/writeback.h index d5815794416c..5a7ed74d1f6f 100644 --- a/include/linux/writeback.h +++ b/include/linux/writeback.h @@ -190,6 +190,8 @@ bool try_to_writeback_inodes_sb_nr(struct super_block *, unsigned long nr, enum wb_reason reason); void sync_inodes_sb(struct super_block *); void wakeup_flusher_threads(long nr_pages, enum wb_reason reason); +void wakeup_flusher_threads_bdi(struct backing_dev_info *bdi, long nr_pages, + enum wb_reason reason); void inode_wait_for_writeback(struct inode *inode); /* writeback.h requires fs.h; it, too, is not included from here. */