Skip to contentSkip to conversation

ext4: auto batched discard support at kernel thread

RFC PATCH In review Kyungmin Park 4 participants 5 messages Dec 2, 2011 – Dec 5, 2011 ext4 file system

lore
Share & tools
lore

Kyungmin Park

author
#0 lore raw

RFC PATCH 1/1 ext4: auto batched discard support at kernel thread

Hi,

It's proof of concept to run kernel thread for batched discard.

Now it can run fitrim at user level. but it's not clear which deamon run this activity. In case of android platform, the launcher is candidate
but user can change the default launcher then it can't use the fitrim any more.

To address this issue. no dependency with platform. run the fitrim at kernel.
Basically don't bother the user it runs at 2 clock. Please note that if it's clean state, it doesn't take much time.

Please give opinions and comments.

Thank you,
Kyungmin Park
---

fs/ext4/ext4.h +5 -0
index 5b0e26a..2cad9b3 100644
@@ -942,6 +942,7 @@ struct ext4_inode_info {
 
 #define EXT4_MOUNT2_EXPLICIT_DELALLOC	0x00000001 /* User explicitly
 						      specified delalloc */
+#define EXT4_MOUNT2_AUTO_DISCARD	0x00000002 /* Auto batched discard */
 
 #define clear_opt(sb, opt)		EXT4_SB(sb)->s_mount_opt &= \
 						~EXT4_MOUNT_##opt

@@ -1249,6 +1250,10 @@ struct ext4_sb_info {
 
 	/* record the last minlen when FITRIM is called. */
 	atomic_t s_last_trim_minblks;
+
+	/* timer for periodic auto batched discard */
+	struct timer_list s_auto_discard;
+	struct task_struct *s_auto_discard_thread;
 };
 
 static inline struct ext4_sb_info *EXT4_SB(struct super_block *sb)
fs/ext4/super.c +112 -1

167 lines not on this page · raw message

#1 lore raw

2011/12/2 Kyungmin Park <[email protected]>:

Quoted 4 lines

Hi,

It's proof of concept to run kernel thread for batched discard.

Quoted 8 lines

Now it can run fitrim at user level. but it's not clear which deamon run this activity. In case of android platform, the launcher is candidate
but user can change the default launcher then it can't use the fitrim any more.

To address this issue. no dependency with platform. run the fitrim at kernel.
Basically don't bother the user it runs at 2 clock. Please note that if it's clean state, it doesn't take much time.

Please give opinions and comments.

I think that it is good approach. If we can adjust wake up time and cycle, it is more better.
And we can avoid performance degradation by copy merging in mmc/sdd internal. On the other hand lifetime of ssd/mmc is decreased by this patch ?

Quoted 207 lines

Thank you,
Kyungmin Park
---

fs/ext4/ext4.h +0 -0
index 5b0e26a..2cad9b3 100644
@@ -942,6 +942,7 @@ struct ext4_inode_info {
 
  #define EXT4_MOUNT2_EXPLICIT_DELALLOC  0x00000001 /* User explicitly

                                                     specified delalloc */ +#define EXT4_MOUNT2_AUTO_DISCARD       0x00000002 /* Auto batched discard */

 #define clear_opt(sb, opt)             EXT4_SB(sb)->s_mount_opt &= \
                                               ~EXT4_MOUNT_##opt

fs/ext4/ext4.h +4 -0
@@ -1249,6 +1250,10 @@ struct ext4_sb_info {
 
        /* record the last minlen when FITRIM is called. */
        atomic_t s_last_trim_minblks;
+
+       /* timer for periodic auto batched discard */
+       struct timer_list s_auto_discard;
+       struct task_struct *s_auto_discard_thread;
  };
 
  static inline struct ext4_sb_info *EXT4_SB(struct super_block *sb)
fs/ext4/super.c +9 -1
index 3858767..a2e9920 100644
@@ -818,6 +818,10 @@ static void ext4_put_super(struct super_block *sb)
                        ext4_abort(sb, "Couldn't clean up the journal");
        }
 
+       if (test_opt2(sb, AUTO_DISCARD)) {
+               kthread_stop(sbi->s_auto_discard_thread);
+               del_timer(&sbi->s_auto_discard);
+       }
        del_timer(&sbi->s_err_report);
        ext4_release_system_zone(sb);
        ext4_mb_release(sb);

@@ -1144,6 +1148,9 @@ static int ext4_show_options(struct seq_file *seq, struct vfsmount *vfs)
        if (test_opt(sb, DISCARD) && !(def_mount_opts & EXT4_DEFM_DISCARD))
                seq_puts(seq, ",discard");
 
+       if (test_opt2(sb, AUTO_DISCARD))
+               seq_puts(seq, ",auto_batched_discard");
+
        if (test_opt(sb, NOLOAD))
                seq_puts(seq, ",norecovery");
 

@@ -1333,7 +1340,7 @@ enum {
        Opt_nomblk_io_submit, Opt_block_validity, Opt_noblock_validity,
        Opt_inode_readahead_blks, Opt_journal_ioprio,
        Opt_dioread_nolock, Opt_dioread_lock,
-       Opt_discard, Opt_nodiscard,
+       Opt_discard, Opt_nodiscard, Opt_auto_discard,
        Opt_init_inode_table, Opt_noinit_inode_table,
  };
 

@@ -1407,6 +1414,7 @@ static const match_table_t tokens = {
        {Opt_dioread_lock, "dioread_lock"},
        {Opt_discard, "discard"},
        {Opt_nodiscard, "nodiscard"},
+       {Opt_auto_discard, "auto_batched_discard"},
        {Opt_init_inode_table, "init_itable=%u"},
        {Opt_init_inode_table, "init_itable"},
        {Opt_noinit_inode_table, "noinit_itable"},

@@ -1886,6 +1894,9 @@ set_qf_format:

               case Opt_nodiscard:
                       clear_opt(sb, DISCARD); break;
+               case Opt_auto_discard:
+                       set_opt2(sb, AUTO_DISCARD);
+                       break;
               case Opt_dioread_nolock:
                       set_opt(sb, DIOREAD_NOLOCK); break;

fs/ext4/super.c +0 -0
@@ -2763,6 +2774,71 @@ static void print_daily_error_info(unsigned long arg)

       mod_timer(&sbi->s_err_report, jiffies + 24*60*60*HZ);  /* Once a day */ }

fs/ext4/super.c +65 -0
+/*
+ * This function is called once a day to make a trim the device
+ */
+static int ext4_auto_batched_discard_thread(void *data)
+{
+       struct super_block *sb = data;
+       struct ext4_sb_info *sbi = EXT4_SB(sb);
+       struct fstrim_range range;
+       struct timeval now;
+       struct tm tm;
+       long next;
+       int ret;
+
+       set_freezable();
+
+       for (;;) {
+               if (kthread_should_stop())
+                       break;
+
+               if (try_to_freeze())
+                       continue;
+
+               range.start = 0;
+               range.len = ~(__u64)0;
+               range.minlen = SZ_1M;
+
+               ret = ext4_trim_fs(sb, &range);
+               if (ret < 0)
+                       ext4_msg(sb, KERN_NOTICE, "error count: %u", ret);
+               else
+                       ext4_msg(sb, KERN_NOTICE, "trimmed size %llu",
+                                       range.len);
+
+               do_gettimeofday(&now);
+               time_to_tm((time_t) now.tv_sec, 0, &tm);
+
+               /* Run the every day at 2 clock */
+               /* XXX need to consider the timezone? */
+               next = 2 - tm.tm_hour;
+               if (next <= 0)
+                       next += 24;
+               next *= 60*60*HZ;
+
+               /* Re-arm the timer for next trim */
+               mod_timer(&sbi->s_auto_discard, jiffies + next);
+
+               set_current_state(TASK_INTERRUPTIBLE);
+               schedule();
+       }
+
+       return 0;
+}
+
+static void ext4_auto_batched_discard(unsigned long arg)
+{
+       struct super_block *sb = (struct super_block *) arg;
+       struct ext4_sb_info *sbi = EXT4_SB(sb);
+
+       /*
+        * The ext4_trim_fs can't run at timer context
+        * So use the created kthread.
+        */
+       wake_up_process(sbi->s_auto_discard_thread);
+}
+

 /* Find next suitable group and run ext4_init_inode_table */ static int ext4_run_li_request(struct ext4_li_request *elr) {

fs/ext4/super.c +15 -0
@@ -3576,6 +3652,21 @@ static int ext4_fill_super(struct super_block *sb, void *data, int silent)
        sbi->s_err_report.function = print_daily_error_info;
        sbi->s_err_report.data = (unsigned long) sb;
 
+       if (test_opt2(sb, AUTO_DISCARD)) {
+               init_timer(&sbi->s_auto_discard);
+               sbi->s_auto_discard.function = ext4_auto_batched_discard;
+               sbi->s_auto_discard.data = (unsigned long) sb;
+               sbi->s_auto_discard_thread =
+                       kthread_create(ext4_auto_batched_discard_thread, sb,
+                               "ext4-batched-discard");
+               if (IS_ERR(sbi->s_auto_discard_thread)) {
+                       err = PTR_ERR(sbi->s_auto_discard_thread);
+                       goto failed_mount2;
+               }
+               /* One hour is enough to know the time */
+               mod_timer(&sbi->s_auto_discard, jiffies + 1*60*60*HZ);
+       }
+
        err = percpu_counter_init(&sbi->s_freeclusters_counter,
                        ext4_count_free_clusters(sb));
        if (!err) {

@@ -3848,6 +3939,10 @@ failed_mount_wq:
                sbi->s_journal = NULL;
        }

 failed_mount3:
+       if (test_opt2(sb, AUTO_DISCARD)) {
+               kthread_stop(sbi->s_auto_discard_thread);
+               del_timer(&sbi->s_auto_discard);
+       }
       del_timer(&sbi->s_err_report);
       if (sbi->s_flex_groups) ext4_kvfree(sbi->s_flex_groups);

fs/ext4/super.c +16 -1
@@ -4546,6 +4641,22 @@ static int ext4_remount(struct super_block *sb, int *flags, char *data)
        if (sbi->s_journal == NULL)
                ext4_commit_super(sb, 1);
 
+       if (test_opt2(sb, AUTO_DISCARD) && !sbi->s_auto_discard_thread) {
+               init_timer(&sbi->s_auto_discard);
+               sbi->s_auto_discard.function = ext4_auto_batched_discard;
+               sbi->s_auto_discard.data = (unsigned long) sb;
+               sbi->s_auto_discard_thread =
+                       kthread_create(ext4_auto_batched_discard_thread, sb,
+                               "ext4-batched-discard");
+               if (IS_ERR(sbi->s_auto_discard_thread)) {
+                       err = PTR_ERR(sbi->s_auto_discard_thread);
+                       goto restore_opts;
+               }
+
+               /* One hour is enough to know the time */
+               mod_timer(&sbi->s_auto_discard, jiffies + 1*60*60*HZ);
+       }
+
  #ifdef CONFIG_QUOTA
        /* Release old quota file names */
        for (i = 0; i < MAXQUOTAS; i++)
--
Quoted 4 lines

To unsubscribe from this list: send the line "unsubscribe linux-kernel" in the body of a message to [email protected]
More majordomo info at  http://vger.kernel.org/majordomo-info.html
Please read the FAQ at  http://www.tux.org/lkml/

--
To unsubscribe from this list: send the line "unsubscribe linux-ext4" in the body of a message to [email protected]
More majordomo info at http://vger.kernel.org/majordomo-info.html

#2 lore raw
In reply to Kyungmin Park
Quoted 5 lines · Kyungmin Park

Hi,

It's proof of concept to run kernel thread for batched discard.

Now it can run fitrim at user level. but it's not clear which deamon run this activity.

fstrim from a cron job.

Quoted 2 lines

In case of android platform, the launcher is candidate
but user can change the default launcher then it can't use the fitrim any more.

Android beeing broken as shit is no reason to push useless code into the kernel.

#3 lore raw
In reply to Kyungmin Park
Quoted 7 lines · Kyungmin Park

Hi,

It's proof of concept to run kernel thread for batched discard.

Now it can run fitrim at user level. but it's not clear which deamon run this activity. In case of android platform, the launcher is candidate
but user can change the default launcher then it can't use the fitrim any more.

I do not thing this logic belongs to the kernel. You would be perfectly fine just with cron lob (or launcher) running fitrim regularly and it is so much easier than pushing this functionality to the kernel side. Not talking about the fact that cron (and others) gives you *much* more flexibility in running fitrim on regular basis and I do not think you want to reimplement cron within the kernel.

Also it seems to me that the problem you're trying to solve should be rather solved on the Android (launcher) side.

I am against this functionality, sorry.

Thanks!
-Lukas

Quoted 213 lines

To address this issue. no dependency with platform. run the fitrim at kernel.
Basically don't bother the user it runs at 2 clock. Please note that if it's clean state, it doesn't take much time.

Please give opinions and comments.

Thank you,
Kyungmin Park
---

fs/ext4/ext4.h +5 -0
index 5b0e26a..2cad9b3 100644
@@ -942,6 +942,7 @@ struct ext4_inode_info {
 
 #define EXT4_MOUNT2_EXPLICIT_DELALLOC	0x00000001 /* User explicitly
 						      specified delalloc */
+#define EXT4_MOUNT2_AUTO_DISCARD	0x00000002 /* Auto batched discard */
 
 #define clear_opt(sb, opt)		EXT4_SB(sb)->s_mount_opt &= \
 						~EXT4_MOUNT_##opt

@@ -1249,6 +1250,10 @@ struct ext4_sb_info {
 
 	/* record the last minlen when FITRIM is called. */
 	atomic_t s_last_trim_minblks;
+
+	/* timer for periodic auto batched discard */
+	struct timer_list s_auto_discard;
+	struct task_struct *s_auto_discard_thread;
 };
 
 static inline struct ext4_sb_info *EXT4_SB(struct super_block *sb)
fs/ext4/super.c +112 -1
index 3858767..a2e9920 100644
@@ -818,6 +818,10 @@ static void ext4_put_super(struct super_block *sb)
 			ext4_abort(sb, "Couldn't clean up the journal");
 	}
 
+	if (test_opt2(sb, AUTO_DISCARD)) {
+		kthread_stop(sbi->s_auto_discard_thread);
+		del_timer(&sbi->s_auto_discard);
+	}
 	del_timer(&sbi->s_err_report);
 	ext4_release_system_zone(sb);
 	ext4_mb_release(sb);

@@ -1144,6 +1148,9 @@ static int ext4_show_options(struct seq_file *seq, struct vfsmount *vfs)
 	if (test_opt(sb, DISCARD) && !(def_mount_opts & EXT4_DEFM_DISCARD))
 		seq_puts(seq, ",discard");
 
+	if (test_opt2(sb, AUTO_DISCARD))
+		seq_puts(seq, ",auto_batched_discard");
+
 	if (test_opt(sb, NOLOAD))
 		seq_puts(seq, ",norecovery");
 

@@ -1333,7 +1340,7 @@ enum {
 	Opt_nomblk_io_submit, Opt_block_validity, Opt_noblock_validity,
 	Opt_inode_readahead_blks, Opt_journal_ioprio,
 	Opt_dioread_nolock, Opt_dioread_lock,
-	Opt_discard, Opt_nodiscard,
+	Opt_discard, Opt_nodiscard, Opt_auto_discard,
 	Opt_init_inode_table, Opt_noinit_inode_table,
 };
 

@@ -1407,6 +1414,7 @@ static const match_table_t tokens = {
 	{Opt_dioread_lock, "dioread_lock"},
 	{Opt_discard, "discard"},
 	{Opt_nodiscard, "nodiscard"},
+	{Opt_auto_discard, "auto_batched_discard"},
 	{Opt_init_inode_table, "init_itable=%u"},
 	{Opt_init_inode_table, "init_itable"},
 	{Opt_noinit_inode_table, "noinit_itable"},

@@ -1886,6 +1894,9 @@ set_qf_format:
 		case Opt_nodiscard:
 			clear_opt(sb, DISCARD);
 			break;
+		case Opt_auto_discard:
+			set_opt2(sb, AUTO_DISCARD);
+			break;
 		case Opt_dioread_nolock:
 			set_opt(sb, DIOREAD_NOLOCK);
 			break;

@@ -2763,6 +2774,71 @@ static void print_daily_error_info(unsigned long arg)
 	mod_timer(&sbi->s_err_report, jiffies + 24*60*60*HZ);  /* Once a day */
 }
 
+/*
+ * This function is called once a day to make a trim the device
+ */
+static int ext4_auto_batched_discard_thread(void *data)
+{
+	struct super_block *sb = data;
+	struct ext4_sb_info *sbi = EXT4_SB(sb);
+	struct fstrim_range range;
+	struct timeval now;
+	struct tm tm;
+	long next;
+	int ret;
+
+	set_freezable();
+
+	for (;;) {
+		if (kthread_should_stop())
+			break;
+
+		if (try_to_freeze())
+			continue;
+
+		range.start = 0;
+		range.len = ~(__u64)0;
+		range.minlen = SZ_1M;
+
+		ret = ext4_trim_fs(sb, &range);
+		if (ret < 0)
+			ext4_msg(sb, KERN_NOTICE, "error count: %u", ret);
+		else
+			ext4_msg(sb, KERN_NOTICE, "trimmed size %llu",
+					range.len);
+
+		do_gettimeofday(&now);
+		time_to_tm((time_t) now.tv_sec, 0, &tm);
+
+		/* Run the every day at 2 clock */
+		/* XXX need to consider the timezone? */
+		next = 2 - tm.tm_hour;
+		if (next <= 0)
+			next += 24;
+		next *= 60*60*HZ;
+
+		/* Re-arm the timer for next trim */
+		mod_timer(&sbi->s_auto_discard, jiffies + next);
+
+		set_current_state(TASK_INTERRUPTIBLE);
+		schedule();
+	}
+
+	return 0;
+}
+
+static void ext4_auto_batched_discard(unsigned long arg)
+{
+	struct super_block *sb = (struct super_block *) arg;
+	struct ext4_sb_info *sbi = EXT4_SB(sb);
+
+	/*
+	 * The ext4_trim_fs can't run at timer context
+	 * So use the created kthread.
+	 */
+	wake_up_process(sbi->s_auto_discard_thread);
+}
+
 /* Find next suitable group and run ext4_init_inode_table */
 static int ext4_run_li_request(struct ext4_li_request *elr)
 {

@@ -3576,6 +3652,21 @@ static int ext4_fill_super(struct super_block *sb, void *data, int silent)
 	sbi->s_err_report.function = print_daily_error_info;
 	sbi->s_err_report.data = (unsigned long) sb;
 
+	if (test_opt2(sb, AUTO_DISCARD)) {
+		init_timer(&sbi->s_auto_discard);
+		sbi->s_auto_discard.function = ext4_auto_batched_discard;
+		sbi->s_auto_discard.data = (unsigned long) sb;
+		sbi->s_auto_discard_thread =
+			kthread_create(ext4_auto_batched_discard_thread, sb,
+				"ext4-batched-discard");
+		if (IS_ERR(sbi->s_auto_discard_thread)) {
+			err = PTR_ERR(sbi->s_auto_discard_thread);
+			goto failed_mount2;
+		}
+		/* One hour is enough to know the time */
+		mod_timer(&sbi->s_auto_discard, jiffies + 1*60*60*HZ);
+	}
+
 	err = percpu_counter_init(&sbi->s_freeclusters_counter,
 			ext4_count_free_clusters(sb));
 	if (!err) {

@@ -3848,6 +3939,10 @@ failed_mount_wq:
 		sbi->s_journal = NULL;
 	}
 failed_mount3:
+	if (test_opt2(sb, AUTO_DISCARD)) {
+		kthread_stop(sbi->s_auto_discard_thread);
+		del_timer(&sbi->s_auto_discard);
+	}
 	del_timer(&sbi->s_err_report);
 	if (sbi->s_flex_groups)
 		ext4_kvfree(sbi->s_flex_groups);

@@ -4546,6 +4641,22 @@ static int ext4_remount(struct super_block *sb, int *flags, char *data)
 	if (sbi->s_journal == NULL)
 		ext4_commit_super(sb, 1);
 
+	if (test_opt2(sb, AUTO_DISCARD) && !sbi->s_auto_discard_thread) {
+		init_timer(&sbi->s_auto_discard);
+		sbi->s_auto_discard.function = ext4_auto_batched_discard;
+		sbi->s_auto_discard.data = (unsigned long) sb;
+		sbi->s_auto_discard_thread =
+			kthread_create(ext4_auto_batched_discard_thread, sb,
+				"ext4-batched-discard");
+		if (IS_ERR(sbi->s_auto_discard_thread)) {
+			err = PTR_ERR(sbi->s_auto_discard_thread);
+			goto restore_opts;
+		}
+
+		/* One hour is enough to know the time */
+		mod_timer(&sbi->s_auto_discard, jiffies + 1*60*60*HZ);
+	}
+
 #ifdef CONFIG_QUOTA
 	/* Release old quota file names */
 	for (i = 0; i < MAXQUOTAS; i++)
author
#4 lore raw
Quoted 19 lines · Lukas Czerner
Quoted 9 lines · Kyungmin Park

Hi,

It's proof of concept to run kernel thread for batched discard.

Now it can run fitrim at user level. but it's not clear which deamon run this activity.
In case of android platform, the launcher is candidate
but user can change the default launcher then it can't use the fitrim any more.

I do not thing this logic belongs to the kernel. You would be perfectly fine just with cron lob (or launcher) running fitrim regularly and it is so much easier than pushing this functionality to the kernel side. Not talking about the fact that cron (and others) gives you *much* more flexibility in running fitrim on regular basis and I do not think you want to reimplement cron within the kernel.

Quoted 4 lines

Also it seems to me that the problem you're trying to solve should be rather solved on the Android (launcher) side.

I am against this functionality, sorry.

No problem, It will be support at user space as original design. e.g., system settings

Thank you for all comments.

BR,
Kyungmin Park

Quoted 226 lines

Thanks!
-Lukas

Quoted 217 lines

To address this issue. no dependency with platform. run the fitrim at kernel.
Basically don't bother the user it runs at 2 clock. Please note that if it's clean state, it doesn't take much time.

Please give opinions and comments.

Thank you,
Kyungmin Park
---

fs/ext4/ext4.h +5 -0
index 5b0e26a..2cad9b3 100644
@@ -942,6 +942,7 @@ struct ext4_inode_info {
 
 #define EXT4_MOUNT2_EXPLICIT_DELALLOC	0x00000001 /* User explicitly
 						      specified delalloc */
+#define EXT4_MOUNT2_AUTO_DISCARD	0x00000002 /* Auto batched discard */
 
 #define clear_opt(sb, opt)		EXT4_SB(sb)->s_mount_opt &= \
 						~EXT4_MOUNT_##opt

@@ -1249,6 +1250,10 @@ struct ext4_sb_info {
 
 	/* record the last minlen when FITRIM is called. */
 	atomic_t s_last_trim_minblks;
+
+	/* timer for periodic auto batched discard */
+	struct timer_list s_auto_discard;
+	struct task_struct *s_auto_discard_thread;
 };
 
 static inline struct ext4_sb_info *EXT4_SB(struct super_block *sb)
fs/ext4/super.c +77 -1
index 3858767..a2e9920 100644
@@ -818,6 +818,10 @@ static void ext4_put_super(struct super_block *sb)
 			ext4_abort(sb, "Couldn't clean up the journal");
 	}
 
+	if (test_opt2(sb, AUTO_DISCARD)) {
+		kthread_stop(sbi->s_auto_discard_thread);
+		del_timer(&sbi->s_auto_discard);
+	}
 	del_timer(&sbi->s_err_report);
 	ext4_release_system_zone(sb);
 	ext4_mb_release(sb);

@@ -1144,6 +1148,9 @@ static int ext4_show_options(struct seq_file *seq,
 struct vfsmount *vfs)
 	if (test_opt(sb, DISCARD) && !(def_mount_opts & EXT4_DEFM_DISCARD))
 		seq_puts(seq, ",discard");
 
+	if (test_opt2(sb, AUTO_DISCARD))
+		seq_puts(seq, ",auto_batched_discard");
+
 	if (test_opt(sb, NOLOAD))
 		seq_puts(seq, ",norecovery");

@@ -1333,7 +1340,7 @@ enum {
 	Opt_nomblk_io_submit, Opt_block_validity, Opt_noblock_validity,
 	Opt_inode_readahead_blks, Opt_journal_ioprio,
 	Opt_dioread_nolock, Opt_dioread_lock,
-	Opt_discard, Opt_nodiscard,
+	Opt_discard, Opt_nodiscard, Opt_auto_discard,
 	Opt_init_inode_table, Opt_noinit_inode_table,
 };
 

@@ -1407,6 +1414,7 @@ static const match_table_t tokens = {
 	{Opt_dioread_lock, "dioread_lock"},
 	{Opt_discard, "discard"},
 	{Opt_nodiscard, "nodiscard"},
+	{Opt_auto_discard, "auto_batched_discard"},
 	{Opt_init_inode_table, "init_itable=%u"},
 	{Opt_init_inode_table, "init_itable"},
 	{Opt_noinit_inode_table, "noinit_itable"},

@@ -1886,6 +1894,9 @@ set_qf_format:
 		case Opt_nodiscard:
 			clear_opt(sb, DISCARD);
 			break;
+		case Opt_auto_discard:
+			set_opt2(sb, AUTO_DISCARD);
+			break;
 		case Opt_dioread_nolock:
 			set_opt(sb, DIOREAD_NOLOCK);
 			break;

@@ -2763,6 +2774,71 @@ static void print_daily_error_info(unsigned long
 arg)
 	mod_timer(&sbi->s_err_report, jiffies + 24*60*60*HZ);  /* Once a day */
 }
 
+/*
+ * This function is called once a day to make a trim the device
+ */
+static int ext4_auto_batched_discard_thread(void *data)
+{
+	struct super_block *sb = data;
+	struct ext4_sb_info *sbi = EXT4_SB(sb);
+	struct fstrim_range range;
+	struct timeval now;
+	struct tm tm;
+	long next;
+	int ret;
+
+	set_freezable();
+
+	for (;;) {
+		if (kthread_should_stop())
+			break;
+
+		if (try_to_freeze())
+			continue;
+
+		range.start = 0;
+		range.len = ~(__u64)0;
+		range.minlen = SZ_1M;
+
+		ret = ext4_trim_fs(sb, &range);
+		if (ret < 0)
+			ext4_msg(sb, KERN_NOTICE, "error count: %u", ret);
+		else
+			ext4_msg(sb, KERN_NOTICE, "trimmed size %llu",
+					range.len);
+
+		do_gettimeofday(&now);
+		time_to_tm((time_t) now.tv_sec, 0, &tm);
+
+		/* Run the every day at 2 clock */
+		/* XXX need to consider the timezone? */
+		next = 2 - tm.tm_hour;
+		if (next <= 0)
+			next += 24;
+		next *= 60*60*HZ;
+
+		/* Re-arm the timer for next trim */
+		mod_timer(&sbi->s_auto_discard, jiffies + next);
+
+		set_current_state(TASK_INTERRUPTIBLE);
+		schedule();
+	}
+
+	return 0;
+}
+
+static void ext4_auto_batched_discard(unsigned long arg)
+{
+	struct super_block *sb = (struct super_block *) arg;
+	struct ext4_sb_info *sbi = EXT4_SB(sb);
+
+	/*
+	 * The ext4_trim_fs can't run at timer context
+	 * So use the created kthread.
+	 */
+	wake_up_process(sbi->s_auto_discard_thread);
+}
+
 /* Find next suitable group and run ext4_init_inode_table */
 static int ext4_run_li_request(struct ext4_li_request *elr)

{

fs/ext4/super.c +15 -0
@@ -3576,6 +3652,21 @@ static int ext4_fill_super(struct super_block *sb,
 void *data, int silent)
 	sbi->s_err_report.function = print_daily_error_info;
 	sbi->s_err_report.data = (unsigned long) sb;
 
+	if (test_opt2(sb, AUTO_DISCARD)) {
+		init_timer(&sbi->s_auto_discard);
+		sbi->s_auto_discard.function = ext4_auto_batched_discard;
+		sbi->s_auto_discard.data = (unsigned long) sb;
+		sbi->s_auto_discard_thread =
+			kthread_create(ext4_auto_batched_discard_thread, sb,
+				"ext4-batched-discard");
+		if (IS_ERR(sbi->s_auto_discard_thread)) {
+			err = PTR_ERR(sbi->s_auto_discard_thread);
+			goto failed_mount2;
+		}
+		/* One hour is enough to know the time */
+		mod_timer(&sbi->s_auto_discard, jiffies + 1*60*60*HZ);
+	}
+
 	err = percpu_counter_init(&sbi->s_freeclusters_counter,
 			ext4_count_free_clusters(sb));
fs/ext4/super.c +20 -0
 	if (!err) {

@@ -3848,6 +3939,10 @@ failed_mount_wq:
 		sbi->s_journal = NULL;
 	}
 failed_mount3:
+	if (test_opt2(sb, AUTO_DISCARD)) {
+		kthread_stop(sbi->s_auto_discard_thread);
+		del_timer(&sbi->s_auto_discard);
+	}
 	del_timer(&sbi->s_err_report);
 	if (sbi->s_flex_groups)
 		ext4_kvfree(sbi->s_flex_groups);

@@ -4546,6 +4641,22 @@ static int ext4_remount(struct super_block *sb, int
 *flags, char *data)
 	if (sbi->s_journal == NULL)
 		ext4_commit_super(sb, 1);
 
+	if (test_opt2(sb, AUTO_DISCARD) && !sbi->s_auto_discard_thread) {
+		init_timer(&sbi->s_auto_discard);
+		sbi->s_auto_discard.function = ext4_auto_batched_discard;
+		sbi->s_auto_discard.data = (unsigned long) sb;
+		sbi->s_auto_discard_thread =
+			kthread_create(ext4_auto_batched_discard_thread, sb,
+				"ext4-batched-discard");
+		if (IS_ERR(sbi->s_auto_discard_thread)) {
+			err = PTR_ERR(sbi->s_auto_discard_thread);
+			goto restore_opts;
+		}
+
+		/* One hour is enough to know the time */
+		mod_timer(&sbi->s_auto_discard, jiffies + 1*60*60*HZ);
+	}
+
 #ifdef CONFIG_QUOTA
 	/* Release old quota file names */
Quoted 2 lines

for (i = 0; i < MAXQUOTAS; i++)

--