From mboxrd@z Thu Jan 1 00:00:00 1970 From: zwu.kernel@gmail.com Subject: [[RESEND]PATCH v4 07/10] VFS hot tracking: Add a /proc interfaces to control memory usage Date: Mon, 12 Aug 2013 10:20:21 +0800 Message-ID: <1376274024-28689-8-git-send-email-zwu.kernel@gmail.com> References: <1376274024-28689-1-git-send-email-zwu.kernel@gmail.com> Cc: torvalds@linux-foundation.org, linux-fsdevel@vger.kernel.org, Zhi Yong Wu , Chandra Seetharaman To: viro@zeniv.linux.org.uk Return-path: Received: from e38.co.us.ibm.com ([32.97.110.159]:50965 "EHLO e38.co.us.ibm.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1755497Ab3HLCXL (ORCPT ); Sun, 11 Aug 2013 22:23:11 -0400 Received: from /spool/local by e38.co.us.ibm.com with IBM ESMTP SMTP Gateway: Authorized Use Only! Violators will be prosecuted for from ; Sun, 11 Aug 2013 20:23:11 -0600 Received: from d03relay02.boulder.ibm.com (d03relay02.boulder.ibm.com [9.17.195.227]) by d03dlp01.boulder.ibm.com (Postfix) with ESMTP id B1C861FF001D for ; Sun, 11 Aug 2013 20:17:41 -0600 (MDT) Received: from d03av03.boulder.ibm.com (d03av03.boulder.ibm.com [9.17.195.169]) by d03relay02.boulder.ibm.com (8.13.8/8.13.8/NCO v10.0) with ESMTP id r7C2N7Sj187248 for ; Sun, 11 Aug 2013 20:23:07 -0600 Received: from d03av03.boulder.ibm.com (loopback [127.0.0.1]) by d03av03.boulder.ibm.com (8.14.4/8.13.1/NCO v10.0 AVout) with ESMTP id r7C2N6j4005748 for ; Sun, 11 Aug 2013 20:23:06 -0600 In-Reply-To: <1376274024-28689-1-git-send-email-zwu.kernel@gmail.com> Sender: linux-fsdevel-owner@vger.kernel.org List-ID: From: Zhi Yong Wu Introduce a proc interfaces hot-mem-high-thresh and to cap the memory which is consumed by hot_inode_item and hot_range_item, and they will be in the unit of 1M bytes. Signed-off-by: Chandra Seetharaman Signed-off-by: Zhi Yong Wu --- fs/hot_tracking.c | 27 +++++++++++++++++++++++++++ fs/hot_tracking.h | 23 +++++++++++++++++++++++ include/linux/hot_tracking.h | 3 +++ kernel/sysctl.c | 7 +++++++ 4 files changed, 60 insertions(+) diff --git a/fs/hot_tracking.c b/fs/hot_tracking.c index 89b7268..188f78c 100644 --- a/fs/hot_tracking.c +++ b/fs/hot_tracking.c @@ -15,6 +15,9 @@ #include #include "hot_tracking.h" +int sysctl_hot_mem_high_thresh __read_mostly = 0; +EXPORT_SYMBOL_GPL(sysctl_hot_mem_high_thresh); + int sysctl_hot_update_interval __read_mostly = 150; EXPORT_SYMBOL_GPL(sysctl_hot_update_interval); @@ -33,6 +36,7 @@ static void hot_range_item_init(struct hot_range_item *hr, hr->len = hot_bit_shift(1, RANGE_BITS, true); hr->hot_inode = he; atomic_long_inc(&he->hot_root->hot_cnt); + hot_mem_limit_add(he->hot_root, sizeof(struct hot_range_item)); } static void hot_range_item_free_cb(struct rcu_head *head) @@ -42,6 +46,7 @@ static void hot_range_item_free_cb(struct rcu_head *head) struct hot_info *root = hr->hot_inode->hot_root; atomic_long_dec(&root->hot_cnt); + hot_mem_limit_sub(root, sizeof(struct hot_range_item)); kmem_cache_free(hot_range_item_cachep, hr); } @@ -226,6 +231,7 @@ static void hot_inode_item_init(struct hot_inode_item *he, he->hot_root = root; spin_lock_init(&he->i_lock); atomic_long_inc(&root->hot_cnt); + hot_mem_limit_add(root, sizeof(struct hot_inode_item)); } static void hot_inode_item_free_cb(struct rcu_head *head) @@ -235,6 +241,7 @@ static void hot_inode_item_free_cb(struct rcu_head *head) struct hot_info *root = he->hot_root; atomic_long_dec(&root->hot_cnt); + hot_mem_limit_sub(root, sizeof(struct hot_inode_item)); kmem_cache_free(hot_inode_item_cachep, he); } @@ -546,6 +553,23 @@ static void hot_item_evict(struct hot_info *root, unsigned long work, } } +static void hot_mem_evict(struct hot_info *root) +{ + unsigned long sum, thresh; + + if (sysctl_hot_mem_high_thresh == 0) + return; + + sum = hot_mem_limit_sum(root); + /* Note: sysctl_** is in the unit of 1M bytes */ + thresh = sysctl_hot_mem_high_thresh; + thresh *= 1024 * 1024; + if (sum <= thresh) + return; + + hot_item_evict(root, sum - thresh, hot_mem_limit_sum); +} + /* * Every sync period we update temperatures for * each hot inode item and hot range item for aging @@ -559,6 +583,8 @@ static void hot_update_worker(struct work_struct *work) struct rb_node *node; int i; + hot_mem_evict(root); + rcu_read_lock(); node = rb_first(&root->hot_inode_tree); while (node) { @@ -775,6 +801,7 @@ int hot_track_init(struct super_block *sb) goto err; } + hot_mem_limit_init(root); sb->s_hot_root = root; printk(KERN_INFO "VFS: Turning on hot tracking\n"); diff --git a/fs/hot_tracking.h b/fs/hot_tracking.h index 23b1339..c9efa5b 100644 --- a/fs/hot_tracking.h +++ b/fs/hot_tracking.h @@ -40,4 +40,27 @@ #define AVW_DIVIDER_POWER 40 /* AVW - average delta between recent writes(ns) */ #define AVW_COEFF_POWER 0 +/* Memory Tracking Functions. */ +static inline unsigned long hot_mem_limit_sum(struct hot_info *root) +{ + return atomic_long_read(&root->mem); +} + +static inline void hot_mem_limit_sub(struct hot_info *root, + unsigned long count) +{ + atomic_long_sub(count, &root->mem); +} + +static inline void hot_mem_limit_add(struct hot_info *root, + unsigned long count) +{ + atomic_long_add(count, &root->mem); +} + +static inline void hot_mem_limit_init(struct hot_info *root) +{ + atomic_long_set(&root->mem, 0); +} + #endif /* __HOT_TRACKING__ */ diff --git a/include/linux/hot_tracking.h b/include/linux/hot_tracking.h index f9185a6..fd03fca 100644 --- a/include/linux/hot_tracking.h +++ b/include/linux/hot_tracking.h @@ -99,10 +99,13 @@ struct hot_info { struct workqueue_struct *update_wq; struct delayed_work update_work; struct shrinker hot_shrink; + atomic_long_t mem; }; /* set how often to update temperatures (seconds) */ extern int sysctl_hot_update_interval; +/* note: sysctl_** is in the unit of 1M bytes */ +extern int sysctl_hot_mem_high_thresh; /* * Hot data tracking ioctls: diff --git a/kernel/sysctl.c b/kernel/sysctl.c index 398cc05..0181e6a 100644 --- a/kernel/sysctl.c +++ b/kernel/sysctl.c @@ -1632,6 +1632,13 @@ static struct ctl_table fs_table[] = { .extra1 = &pipe_min_size, }, { + .procname = "hot-mem-high-thresh", + .data = &sysctl_hot_mem_high_thresh, + .maxlen = sizeof(int), + .mode = 0644, + .proc_handler = proc_dointvec, + }, + { .procname = "hot-update-interval", .data = &sysctl_hot_update_interval, .maxlen = sizeof(int), -- 1.7.11.7