Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 76a33d0d authored by Jaegeuk Kim's avatar Jaegeuk Kim
Browse files

f2fs: sync filesystem after roll-forward recovery



Some works after roll-forward recovery can get an error which will release
all the data structures. Let's flush them in order to make it clean.

One possible corruption came from:

[   90.400500] list_del corruption. prev->next should be ffffffed1f566208, but was (null)
[   90.675349] Call trace:
[   90.677869]  __list_del_entry_valid+0x94/0xb4
[   90.682351]  remove_dirty_inode+0xac/0x114
[   90.686563]  __f2fs_write_data_pages+0x6a8/0x6c8
[   90.691302]  f2fs_write_data_pages+0x40/0x4c
[   90.695695]  do_writepages+0x80/0xf0
[   90.699372]  __writeback_single_inode+0xdc/0x4ac
[   90.704113]  writeback_sb_inodes+0x280/0x440
[   90.708501]  wb_writeback+0x1b8/0x3d0
[   90.712267]  wb_workfn+0x1a8/0x4d4
[   90.715765]  process_one_work+0x1c0/0x3d4
[   90.719883]  worker_thread+0x224/0x344
[   90.723739]  kthread+0x120/0x130
[   90.727055]  ret_from_fork+0x10/0x18

Reported-by: default avatarSahitya Tummala <stummala@codeaurora.org>
Reviewed-by: default avatarChao Yu <yuchao0@huawei.com>
Signed-off-by: default avatarJaegeuk Kim <jaegeuk@kernel.org>
parent aaed26f6
Loading
Loading
Loading
Loading
+3 −2
Original line number Original line Diff line number Diff line
@@ -306,8 +306,9 @@ static int f2fs_write_meta_pages(struct address_space *mapping,
		goto skip_write;
		goto skip_write;


	/* collect a number of dirty meta pages and write together */
	/* collect a number of dirty meta pages and write together */
	if (wbc->for_kupdate ||
	if (wbc->sync_mode != WB_SYNC_ALL &&
		get_pages(sbi, F2FS_DIRTY_META) < nr_pages_to_skip(sbi, META))
			get_pages(sbi, F2FS_DIRTY_META) <
					nr_pages_to_skip(sbi, META))
		goto skip_write;
		goto skip_write;


	/* if locked failed, cp will flush dirty pages instead */
	/* if locked failed, cp will flush dirty pages instead */
+3 −1
Original line number Original line Diff line number Diff line
@@ -1922,7 +1922,9 @@ static int f2fs_write_node_pages(struct address_space *mapping,
	f2fs_balance_fs_bg(sbi);
	f2fs_balance_fs_bg(sbi);


	/* collect a number of dirty node pages and write together */
	/* collect a number of dirty node pages and write together */
	if (get_pages(sbi, F2FS_DIRTY_NODES) < nr_pages_to_skip(sbi, NODE))
	if (wbc->sync_mode != WB_SYNC_ALL &&
			get_pages(sbi, F2FS_DIRTY_NODES) <
					nr_pages_to_skip(sbi, NODE))
		goto skip_write;
		goto skip_write;


	if (wbc->sync_mode == WB_SYNC_ALL)
	if (wbc->sync_mode == WB_SYNC_ALL)
+33 −11
Original line number Original line Diff line number Diff line
@@ -1458,9 +1458,16 @@ static int f2fs_enable_quotas(struct super_block *sb);


static int f2fs_disable_checkpoint(struct f2fs_sb_info *sbi)
static int f2fs_disable_checkpoint(struct f2fs_sb_info *sbi)
{
{
	unsigned int s_flags = sbi->sb->s_flags;
	struct cp_control cpc;
	struct cp_control cpc;
	int err;
	int err = 0;
	int ret;


	if (s_flags & SB_RDONLY) {
		f2fs_msg(sbi->sb, KERN_ERR,
				"checkpoint=disable on readonly fs");
		return -EINVAL;
	}
	sbi->sb->s_flags |= SB_ACTIVE;
	sbi->sb->s_flags |= SB_ACTIVE;


	f2fs_update_time(sbi, DISABLE_TIME);
	f2fs_update_time(sbi, DISABLE_TIME);
@@ -1468,18 +1475,24 @@ static int f2fs_disable_checkpoint(struct f2fs_sb_info *sbi)
	while (!f2fs_time_over(sbi, DISABLE_TIME)) {
	while (!f2fs_time_over(sbi, DISABLE_TIME)) {
		mutex_lock(&sbi->gc_mutex);
		mutex_lock(&sbi->gc_mutex);
		err = f2fs_gc(sbi, true, false, NULL_SEGNO);
		err = f2fs_gc(sbi, true, false, NULL_SEGNO);
		if (err == -ENODATA)
		if (err == -ENODATA) {
			err = 0;
			break;
			break;
		}
		if (err && err != -EAGAIN)
		if (err && err != -EAGAIN)
			return err;
			break;
	}
	}


	err = sync_filesystem(sbi->sb);
	ret = sync_filesystem(sbi->sb);
	if (err)
	if (ret || err) {
		return err;
		err = ret ? ret: err;
		goto restore_flag;
	}


	if (f2fs_disable_cp_again(sbi))
	if (f2fs_disable_cp_again(sbi)) {
		return -EAGAIN;
		err = -EAGAIN;
		goto restore_flag;
	}


	mutex_lock(&sbi->gc_mutex);
	mutex_lock(&sbi->gc_mutex);
	cpc.reason = CP_PAUSE;
	cpc.reason = CP_PAUSE;
@@ -1488,7 +1501,9 @@ static int f2fs_disable_checkpoint(struct f2fs_sb_info *sbi)


	sbi->unusable_block_count = 0;
	sbi->unusable_block_count = 0;
	mutex_unlock(&sbi->gc_mutex);
	mutex_unlock(&sbi->gc_mutex);
	return 0;
restore_flag:
	sbi->sb->s_flags = s_flags;	/* Restore MS_RDONLY status */
	return err;
}
}


static void f2fs_enable_checkpoint(struct f2fs_sb_info *sbi)
static void f2fs_enable_checkpoint(struct f2fs_sb_info *sbi)
@@ -3369,7 +3384,7 @@ static int f2fs_fill_super(struct super_block *sb, void *data, int silent)
	if (test_opt(sbi, DISABLE_CHECKPOINT)) {
	if (test_opt(sbi, DISABLE_CHECKPOINT)) {
		err = f2fs_disable_checkpoint(sbi);
		err = f2fs_disable_checkpoint(sbi);
		if (err)
		if (err)
			goto free_meta;
			goto sync_free_meta;
	} else if (is_set_ckpt_flags(sbi, CP_DISABLED_FLAG)) {
	} else if (is_set_ckpt_flags(sbi, CP_DISABLED_FLAG)) {
		f2fs_enable_checkpoint(sbi);
		f2fs_enable_checkpoint(sbi);
	}
	}
@@ -3382,7 +3397,7 @@ static int f2fs_fill_super(struct super_block *sb, void *data, int silent)
		/* After POR, we can run background GC thread.*/
		/* After POR, we can run background GC thread.*/
		err = f2fs_start_gc_thread(sbi);
		err = f2fs_start_gc_thread(sbi);
		if (err)
		if (err)
			goto free_meta;
			goto sync_free_meta;
	}
	}
	kvfree(options);
	kvfree(options);


@@ -3405,6 +3420,11 @@ static int f2fs_fill_super(struct super_block *sb, void *data, int silent)
	clear_sbi_flag(sbi, SBI_CP_DISABLED_QUICK);
	clear_sbi_flag(sbi, SBI_CP_DISABLED_QUICK);
	return 0;
	return 0;


sync_free_meta:
	/* safe to flush all the data */
	sync_filesystem(sbi->sb);
	retry = false;

free_meta:
free_meta:
#ifdef CONFIG_QUOTA
#ifdef CONFIG_QUOTA
	f2fs_truncate_quota_inode_pages(sb);
	f2fs_truncate_quota_inode_pages(sb);
@@ -3418,6 +3438,8 @@ static int f2fs_fill_super(struct super_block *sb, void *data, int silent)
	 * falls into an infinite loop in f2fs_sync_meta_pages().
	 * falls into an infinite loop in f2fs_sync_meta_pages().
	 */
	 */
	truncate_inode_pages_final(META_MAPPING(sbi));
	truncate_inode_pages_final(META_MAPPING(sbi));
	/* evict some inodes being cached by GC */
	evict_inodes(sb);
	f2fs_unregister_sysfs(sbi);
	f2fs_unregister_sysfs(sbi);
free_root_inode:
free_root_inode:
	dput(sb->s_root);
	dput(sb->s_root);