Return-Path: Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1757613Ab2J2Ecx (ORCPT ); Mon, 29 Oct 2012 00:32:53 -0400 Received: from e1.ny.us.ibm.com ([32.97.182.141]:40836 "EHLO e1.ny.us.ibm.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1757390Ab2J2Ect (ORCPT ); Mon, 29 Oct 2012 00:32:49 -0400 From: zwu.kernel@gmail.com To: linux-fsdevel@vger.kernel.org Cc: linux-ext4@vger.kernel.org, linux-btrfs@vger.kernel.org, linux-kernel@vger.kernel.org, linuxram@linux.vnet.ibm.com, viro@zeniv.linux.org.uk, david@fromorbit.com, tytso@mit.edu, cmm@us.ibm.com, wuzhy@linux.vnet.ibm.com, wenqing.lz@taobao.com Subject: [RFC v4+ hot_track 11/19] vfs: register one shrinker Date: Mon, 29 Oct 2012 12:30:53 +0800 Message-Id: <1351485061-12297-12-git-send-email-zwu.kernel@gmail.com> X-Mailer: git-send-email 1.7.6.5 In-Reply-To: <1351485061-12297-1-git-send-email-zwu.kernel@gmail.com> References: <1351485061-12297-1-git-send-email-zwu.kernel@gmail.com> X-Content-Scanned: Fidelis XPS MAILER x-cbid: 12102904-6078-0000-0000-00001139DEDA Sender: linux-kernel-owner@vger.kernel.org List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Length: 3529 Lines: 121 From: Zhi Yong Wu Register a shrinker to control the amount of memory that is used in tracking hot regions - if we are throwing inodes out of memory due to memory pressure, we most definitely are going to need to reduce the amount of memory the tracking code is using, even if it means losing useful information (i.e. the shrinker accelerates the aging process). Signed-off-by: Zhi Yong Wu --- fs/hot_tracking.c | 61 ++++++++++++++++++++++++++++++++++++++++++ include/linux/hot_tracking.h | 1 + 2 files changed, 62 insertions(+), 0 deletions(-) diff --git a/fs/hot_tracking.c b/fs/hot_tracking.c index c6c6138..54a8208 100644 --- a/fs/hot_tracking.c +++ b/fs/hot_tracking.c @@ -653,6 +653,61 @@ err: } EXPORT_SYMBOL_GPL(hot_cache_init); +static int hot_track_prune_map(struct hot_map_head *map_head, + bool type, int nr) +{ + struct hot_comm_item *node; + int i; + + for (i = 0; i < HEAT_MAP_SIZE; i++) { + while (!list_empty(&(map_head + i)->node_list)) { + if (nr-- <= 0) + break; + + node = list_first_entry(&(map_head + i)->node_list, + struct hot_comm_item, n_list); + if (type) { + struct hot_inode_item *hot_inode = + container_of(node, + struct hot_inode_item, hot_inode); + hot_inode_item_put(hot_inode); + } else { + struct hot_range_item *hot_range = + container_of(node, + struct hot_range_item, hot_range); + hot_range_item_put(hot_range); + } + } + } + + return nr; +} + +/* The shrinker callback function */ +static int hot_track_prune(struct shrinker *shrink, + struct shrink_control *sc) +{ + struct hot_info *root = + container_of(shrink, struct hot_info, hot_shrink); + int ret; + + if (sc->nr_to_scan == 0) + return root->hot_map_nr; + + if (!(sc->gfp_mask & __GFP_FS)) + return -1; + + ret = hot_track_prune_map(root->heat_range_map, + false, sc->nr_to_scan); + if (ret > 0) + ret = hot_track_prune_map(root->heat_inode_map, + true, ret); + if (ret > 0) + root->hot_map_nr -= (sc->nr_to_scan - ret); + + return root->hot_map_nr; +} + /* * Main function to update access frequency from read/writepage(s) hooks */ @@ -791,6 +846,11 @@ int hot_track_init(struct super_block *sb) queue_delayed_work(root->update_wq, &root->update_work, msecs_to_jiffies(HEAT_UPDATE_DELAY * MSEC_PER_SEC)); + /* Register a shrinker callback */ + root->hot_shrink.shrink = hot_track_prune; + root->hot_shrink.seeks = DEFAULT_SEEKS; + register_shrinker(&root->hot_shrink); + printk(KERN_INFO "VFS: Turning on hot data tracking\n"); return 0; @@ -807,6 +867,7 @@ void hot_track_exit(struct super_block *sb) { struct hot_info *root = sb->s_hot_root; + unregister_shrinker(&root->hot_shrink); cancel_delayed_work_sync(&root->update_work); destroy_workqueue(root->update_wq); hot_map_array_exit(root); diff --git a/include/linux/hot_tracking.h b/include/linux/hot_tracking.h index 3941052..f82db2d 100644 --- a/include/linux/hot_tracking.h +++ b/include/linux/hot_tracking.h @@ -107,6 +107,7 @@ struct hot_info { struct workqueue_struct *update_wq; struct delayed_work update_work; struct hot_func_type *hot_func_type; + struct shrinker hot_shrink; }; extern void __init hot_cache_init(void); -- 1.7.6.5 -- To unsubscribe from this list: send the line "unsubscribe linux-kernel" in the body of a message to majordomo@vger.kernel.org More majordomo info at http://vger.kernel.org/majordomo-info.html Please read the FAQ at http://www.tux.org/lkml/