| xj | b04a402 | 2021-11-25 15:01:52 +0800 | [diff] [blame] | 1 | // SPDX-License-Identifier: GPL-2.0 | 
 | 2 | /* | 
 | 3 |  * fs/f2fs/recovery.c | 
 | 4 |  * | 
 | 5 |  * Copyright (c) 2012 Samsung Electronics Co., Ltd. | 
 | 6 |  *             http://www.samsung.com/ | 
 | 7 |  */ | 
 | 8 | #include <linux/fs.h> | 
 | 9 | #include <linux/f2fs_fs.h> | 
 | 10 | #include "f2fs.h" | 
 | 11 | #include "node.h" | 
 | 12 | #include "segment.h" | 
 | 13 |  | 
 | 14 | /* | 
 | 15 |  * Roll forward recovery scenarios. | 
 | 16 |  * | 
 | 17 |  * [Term] F: fsync_mark, D: dentry_mark | 
 | 18 |  * | 
 | 19 |  * 1. inode(x) | CP | inode(x) | dnode(F) | 
 | 20 |  * -> Update the latest inode(x). | 
 | 21 |  * | 
 | 22 |  * 2. inode(x) | CP | inode(F) | dnode(F) | 
 | 23 |  * -> No problem. | 
 | 24 |  * | 
 | 25 |  * 3. inode(x) | CP | dnode(F) | inode(x) | 
 | 26 |  * -> Recover to the latest dnode(F), and drop the last inode(x) | 
 | 27 |  * | 
 | 28 |  * 4. inode(x) | CP | dnode(F) | inode(F) | 
 | 29 |  * -> No problem. | 
 | 30 |  * | 
 | 31 |  * 5. CP | inode(x) | dnode(F) | 
 | 32 |  * -> The inode(DF) was missing. Should drop this dnode(F). | 
 | 33 |  * | 
 | 34 |  * 6. CP | inode(DF) | dnode(F) | 
 | 35 |  * -> No problem. | 
 | 36 |  * | 
 | 37 |  * 7. CP | dnode(F) | inode(DF) | 
 | 38 |  * -> If f2fs_iget fails, then goto next to find inode(DF). | 
 | 39 |  * | 
 | 40 |  * 8. CP | dnode(F) | inode(x) | 
 | 41 |  * -> If f2fs_iget fails, then goto next to find inode(DF). | 
 | 42 |  *    But it will fail due to no inode(DF). | 
 | 43 |  */ | 
 | 44 |  | 
 | 45 | static struct kmem_cache *fsync_entry_slab; | 
 | 46 |  | 
 | 47 | bool f2fs_space_for_roll_forward(struct f2fs_sb_info *sbi) | 
 | 48 | { | 
 | 49 | 	s64 nalloc = percpu_counter_sum_positive(&sbi->alloc_valid_block_count); | 
 | 50 |  | 
 | 51 | 	if (sbi->last_valid_block_count + nalloc > sbi->user_block_count) | 
 | 52 | 		return false; | 
 | 53 | 	return true; | 
 | 54 | } | 
 | 55 |  | 
 | 56 | static struct fsync_inode_entry *get_fsync_inode(struct list_head *head, | 
 | 57 | 								nid_t ino) | 
 | 58 | { | 
 | 59 | 	struct fsync_inode_entry *entry; | 
 | 60 |  | 
 | 61 | 	list_for_each_entry(entry, head, list) | 
 | 62 | 		if (entry->inode->i_ino == ino) | 
 | 63 | 			return entry; | 
 | 64 |  | 
 | 65 | 	return NULL; | 
 | 66 | } | 
 | 67 |  | 
 | 68 | static struct fsync_inode_entry *add_fsync_inode(struct f2fs_sb_info *sbi, | 
 | 69 | 			struct list_head *head, nid_t ino, bool quota_inode) | 
 | 70 | { | 
 | 71 | 	struct inode *inode; | 
 | 72 | 	struct fsync_inode_entry *entry; | 
 | 73 | 	int err; | 
 | 74 |  | 
 | 75 | 	inode = f2fs_iget_retry(sbi->sb, ino); | 
 | 76 | 	if (IS_ERR(inode)) | 
 | 77 | 		return ERR_CAST(inode); | 
 | 78 |  | 
 | 79 | 	err = dquot_initialize(inode); | 
 | 80 | 	if (err) | 
 | 81 | 		goto err_out; | 
 | 82 |  | 
 | 83 | 	if (quota_inode) { | 
 | 84 | 		err = dquot_alloc_inode(inode); | 
 | 85 | 		if (err) | 
 | 86 | 			goto err_out; | 
 | 87 | 	} | 
 | 88 |  | 
 | 89 | 	entry = f2fs_kmem_cache_alloc(fsync_entry_slab, GFP_F2FS_ZERO); | 
 | 90 | 	entry->inode = inode; | 
 | 91 | 	list_add_tail(&entry->list, head); | 
 | 92 |  | 
 | 93 | 	return entry; | 
 | 94 | err_out: | 
 | 95 | 	iput(inode); | 
 | 96 | 	return ERR_PTR(err); | 
 | 97 | } | 
 | 98 |  | 
 | 99 | static void del_fsync_inode(struct fsync_inode_entry *entry, int drop) | 
 | 100 | { | 
 | 101 | 	if (drop) { | 
 | 102 | 		/* inode should not be recovered, drop it */ | 
 | 103 | 		f2fs_inode_synced(entry->inode); | 
 | 104 | 	} | 
 | 105 | 	iput(entry->inode); | 
 | 106 | 	list_del(&entry->list); | 
 | 107 | 	kmem_cache_free(fsync_entry_slab, entry); | 
 | 108 | } | 
 | 109 |  | 
 | 110 | static int recover_dentry(struct inode *inode, struct page *ipage, | 
 | 111 | 						struct list_head *dir_list) | 
 | 112 | { | 
 | 113 | 	struct f2fs_inode *raw_inode = F2FS_INODE(ipage); | 
 | 114 | 	nid_t pino = le32_to_cpu(raw_inode->i_pino); | 
 | 115 | 	struct f2fs_dir_entry *de; | 
 | 116 | 	struct fscrypt_name fname; | 
 | 117 | 	struct page *page; | 
 | 118 | 	struct inode *dir, *einode; | 
 | 119 | 	struct fsync_inode_entry *entry; | 
 | 120 | 	int err = 0; | 
 | 121 | 	char *name; | 
 | 122 |  | 
 | 123 | 	entry = get_fsync_inode(dir_list, pino); | 
 | 124 | 	if (!entry) { | 
 | 125 | 		entry = add_fsync_inode(F2FS_I_SB(inode), dir_list, | 
 | 126 | 							pino, false); | 
 | 127 | 		if (IS_ERR(entry)) { | 
 | 128 | 			dir = ERR_CAST(entry); | 
 | 129 | 			err = PTR_ERR(entry); | 
 | 130 | 			goto out; | 
 | 131 | 		} | 
 | 132 | 	} | 
 | 133 |  | 
 | 134 | 	dir = entry->inode; | 
 | 135 |  | 
 | 136 | 	memset(&fname, 0, sizeof(struct fscrypt_name)); | 
 | 137 | 	fname.disk_name.len = le32_to_cpu(raw_inode->i_namelen); | 
 | 138 | 	fname.disk_name.name = raw_inode->i_name; | 
 | 139 |  | 
 | 140 | 	if (unlikely(fname.disk_name.len > F2FS_NAME_LEN)) { | 
 | 141 | 		WARN_ON(1); | 
 | 142 | 		err = -ENAMETOOLONG; | 
 | 143 | 		goto out; | 
 | 144 | 	} | 
 | 145 | retry: | 
 | 146 | 	de = __f2fs_find_entry(dir, &fname, &page); | 
 | 147 | 	if (de && inode->i_ino == le32_to_cpu(de->ino)) | 
 | 148 | 		goto out_put; | 
 | 149 |  | 
 | 150 | 	if (de) { | 
 | 151 | 		einode = f2fs_iget_retry(inode->i_sb, le32_to_cpu(de->ino)); | 
 | 152 | 		if (IS_ERR(einode)) { | 
 | 153 | 			WARN_ON(1); | 
 | 154 | 			err = PTR_ERR(einode); | 
 | 155 | 			if (err == -ENOENT) | 
 | 156 | 				err = -EEXIST; | 
 | 157 | 			goto out_put; | 
 | 158 | 		} | 
 | 159 |  | 
 | 160 | 		err = dquot_initialize(einode); | 
 | 161 | 		if (err) { | 
 | 162 | 			iput(einode); | 
 | 163 | 			goto out_put; | 
 | 164 | 		} | 
 | 165 |  | 
 | 166 | 		err = f2fs_acquire_orphan_inode(F2FS_I_SB(inode)); | 
 | 167 | 		if (err) { | 
 | 168 | 			iput(einode); | 
 | 169 | 			goto out_put; | 
 | 170 | 		} | 
 | 171 | 		f2fs_delete_entry(de, page, dir, einode); | 
 | 172 | 		iput(einode); | 
 | 173 | 		goto retry; | 
 | 174 | 	} else if (IS_ERR(page)) { | 
 | 175 | 		err = PTR_ERR(page); | 
 | 176 | 	} else { | 
 | 177 | 		err = f2fs_add_dentry(dir, &fname, inode, | 
 | 178 | 					inode->i_ino, inode->i_mode); | 
 | 179 | 	} | 
 | 180 | 	if (err == -ENOMEM) | 
 | 181 | 		goto retry; | 
 | 182 | 	goto out; | 
 | 183 |  | 
 | 184 | out_put: | 
 | 185 | 	f2fs_put_page(page, 0); | 
 | 186 | out: | 
 | 187 | 	if (file_enc_name(inode)) | 
 | 188 | 		name = "<encrypted>"; | 
 | 189 | 	else | 
 | 190 | 		name = raw_inode->i_name; | 
 | 191 | 	f2fs_notice(F2FS_I_SB(inode), "%s: ino = %x, name = %s, dir = %lx, err = %d", | 
 | 192 | 		    __func__, ino_of_node(ipage), name, | 
 | 193 | 		    IS_ERR(dir) ? 0 : dir->i_ino, err); | 
 | 194 | 	return err; | 
 | 195 | } | 
 | 196 |  | 
 | 197 | static int recover_quota_data(struct inode *inode, struct page *page) | 
 | 198 | { | 
 | 199 | 	struct f2fs_inode *raw = F2FS_INODE(page); | 
 | 200 | 	struct iattr attr; | 
 | 201 | 	uid_t i_uid = le32_to_cpu(raw->i_uid); | 
 | 202 | 	gid_t i_gid = le32_to_cpu(raw->i_gid); | 
 | 203 | 	int err; | 
 | 204 |  | 
 | 205 | 	memset(&attr, 0, sizeof(attr)); | 
 | 206 |  | 
 | 207 | 	attr.ia_uid = make_kuid(inode->i_sb->s_user_ns, i_uid); | 
 | 208 | 	attr.ia_gid = make_kgid(inode->i_sb->s_user_ns, i_gid); | 
 | 209 |  | 
 | 210 | 	if (!uid_eq(attr.ia_uid, inode->i_uid)) | 
 | 211 | 		attr.ia_valid |= ATTR_UID; | 
 | 212 | 	if (!gid_eq(attr.ia_gid, inode->i_gid)) | 
 | 213 | 		attr.ia_valid |= ATTR_GID; | 
 | 214 |  | 
 | 215 | 	if (!attr.ia_valid) | 
 | 216 | 		return 0; | 
 | 217 |  | 
 | 218 | 	err = dquot_transfer(inode, &attr); | 
 | 219 | 	if (err) | 
 | 220 | 		set_sbi_flag(F2FS_I_SB(inode), SBI_QUOTA_NEED_REPAIR); | 
 | 221 | 	return err; | 
 | 222 | } | 
 | 223 |  | 
 | 224 | static void recover_inline_flags(struct inode *inode, struct f2fs_inode *ri) | 
 | 225 | { | 
 | 226 | 	if (ri->i_inline & F2FS_PIN_FILE) | 
 | 227 | 		set_inode_flag(inode, FI_PIN_FILE); | 
 | 228 | 	else | 
 | 229 | 		clear_inode_flag(inode, FI_PIN_FILE); | 
 | 230 | 	if (ri->i_inline & F2FS_DATA_EXIST) | 
 | 231 | 		set_inode_flag(inode, FI_DATA_EXIST); | 
 | 232 | 	else | 
 | 233 | 		clear_inode_flag(inode, FI_DATA_EXIST); | 
 | 234 | } | 
 | 235 |  | 
 | 236 | static int recover_inode(struct inode *inode, struct page *page) | 
 | 237 | { | 
 | 238 | 	struct f2fs_inode *raw = F2FS_INODE(page); | 
 | 239 | 	char *name; | 
 | 240 | 	int err; | 
 | 241 |  | 
 | 242 | 	inode->i_mode = le16_to_cpu(raw->i_mode); | 
 | 243 |  | 
 | 244 | 	err = recover_quota_data(inode, page); | 
 | 245 | 	if (err) | 
 | 246 | 		return err; | 
 | 247 |  | 
 | 248 | 	i_uid_write(inode, le32_to_cpu(raw->i_uid)); | 
 | 249 | 	i_gid_write(inode, le32_to_cpu(raw->i_gid)); | 
 | 250 |  | 
 | 251 | 	if (raw->i_inline & F2FS_EXTRA_ATTR) { | 
 | 252 | 		if (f2fs_sb_has_project_quota(F2FS_I_SB(inode)) && | 
 | 253 | 			F2FS_FITS_IN_INODE(raw, le16_to_cpu(raw->i_extra_isize), | 
 | 254 | 								i_projid)) { | 
 | 255 | 			projid_t i_projid; | 
 | 256 | 			kprojid_t kprojid; | 
 | 257 |  | 
 | 258 | 			i_projid = (projid_t)le32_to_cpu(raw->i_projid); | 
 | 259 | 			kprojid = make_kprojid(&init_user_ns, i_projid); | 
 | 260 |  | 
 | 261 | 			if (!projid_eq(kprojid, F2FS_I(inode)->i_projid)) { | 
 | 262 | 				err = f2fs_transfer_project_quota(inode, | 
 | 263 | 								kprojid); | 
 | 264 | 				if (err) | 
 | 265 | 					return err; | 
 | 266 | 				F2FS_I(inode)->i_projid = kprojid; | 
 | 267 | 			} | 
 | 268 | 		} | 
 | 269 | 	} | 
 | 270 |  | 
 | 271 | 	f2fs_i_size_write(inode, le64_to_cpu(raw->i_size)); | 
 | 272 | 	inode->i_atime.tv_sec = le64_to_cpu(raw->i_atime); | 
 | 273 | 	inode->i_ctime.tv_sec = le64_to_cpu(raw->i_ctime); | 
 | 274 | 	inode->i_mtime.tv_sec = le64_to_cpu(raw->i_mtime); | 
 | 275 | 	inode->i_atime.tv_nsec = le32_to_cpu(raw->i_atime_nsec); | 
 | 276 | 	inode->i_ctime.tv_nsec = le32_to_cpu(raw->i_ctime_nsec); | 
 | 277 | 	inode->i_mtime.tv_nsec = le32_to_cpu(raw->i_mtime_nsec); | 
 | 278 |  | 
 | 279 | 	F2FS_I(inode)->i_advise = raw->i_advise; | 
 | 280 | 	F2FS_I(inode)->i_flags = le32_to_cpu(raw->i_flags); | 
 | 281 | 	f2fs_set_inode_flags(inode); | 
 | 282 | 	F2FS_I(inode)->i_gc_failures[GC_FAILURE_PIN] = | 
 | 283 | 				le16_to_cpu(raw->i_gc_failures); | 
 | 284 |  | 
 | 285 | 	recover_inline_flags(inode, raw); | 
 | 286 |  | 
 | 287 | 	f2fs_mark_inode_dirty_sync(inode, true); | 
 | 288 |  | 
 | 289 | 	if (file_enc_name(inode)) | 
 | 290 | 		name = "<encrypted>"; | 
 | 291 | 	else | 
 | 292 | 		name = F2FS_INODE(page)->i_name; | 
 | 293 |  | 
 | 294 | 	f2fs_notice(F2FS_I_SB(inode), "recover_inode: ino = %x, name = %s, inline = %x", | 
 | 295 | 		    ino_of_node(page), name, raw->i_inline); | 
 | 296 | 	return 0; | 
 | 297 | } | 
 | 298 |  | 
 | 299 | static int find_fsync_dnodes(struct f2fs_sb_info *sbi, struct list_head *head, | 
 | 300 | 				bool check_only) | 
 | 301 | { | 
 | 302 | 	struct curseg_info *curseg; | 
 | 303 | 	struct page *page = NULL; | 
 | 304 | 	block_t blkaddr; | 
 | 305 | 	unsigned int loop_cnt = 0; | 
 | 306 | 	unsigned int free_blocks = MAIN_SEGS(sbi) * sbi->blocks_per_seg - | 
 | 307 | 						valid_user_blocks(sbi); | 
 | 308 | 	int err = 0; | 
 | 309 |  | 
 | 310 | 	/* get node pages in the current segment */ | 
 | 311 | 	curseg = CURSEG_I(sbi, CURSEG_WARM_NODE); | 
 | 312 | 	blkaddr = NEXT_FREE_BLKADDR(sbi, curseg); | 
 | 313 |  | 
 | 314 | 	while (1) { | 
 | 315 | 		struct fsync_inode_entry *entry; | 
 | 316 |  | 
 | 317 | 		if (!f2fs_is_valid_blkaddr(sbi, blkaddr, META_POR)) | 
 | 318 | 			return 0; | 
 | 319 |  | 
 | 320 | 		page = f2fs_get_tmp_page(sbi, blkaddr); | 
 | 321 | 		if (IS_ERR(page)) { | 
 | 322 | 			err = PTR_ERR(page); | 
 | 323 | 			break; | 
 | 324 | 		} | 
 | 325 |  | 
 | 326 | 		if (!is_recoverable_dnode(page)) { | 
 | 327 | 			f2fs_put_page(page, 1); | 
 | 328 | 			break; | 
 | 329 | 		} | 
 | 330 |  | 
 | 331 | 		if (!is_fsync_dnode(page)) | 
 | 332 | 			goto next; | 
 | 333 |  | 
 | 334 | 		entry = get_fsync_inode(head, ino_of_node(page)); | 
 | 335 | 		if (!entry) { | 
 | 336 | 			bool quota_inode = false; | 
 | 337 |  | 
 | 338 | 			if (!check_only && | 
 | 339 | 					IS_INODE(page) && is_dent_dnode(page)) { | 
 | 340 | 				err = f2fs_recover_inode_page(sbi, page); | 
 | 341 | 				if (err) { | 
 | 342 | 					f2fs_put_page(page, 1); | 
 | 343 | 					break; | 
 | 344 | 				} | 
 | 345 | 				quota_inode = true; | 
 | 346 | 			} | 
 | 347 |  | 
 | 348 | 			/* | 
 | 349 | 			 * CP | dnode(F) | inode(DF) | 
 | 350 | 			 * For this case, we should not give up now. | 
 | 351 | 			 */ | 
 | 352 | 			entry = add_fsync_inode(sbi, head, ino_of_node(page), | 
 | 353 | 								quota_inode); | 
 | 354 | 			if (IS_ERR(entry)) { | 
 | 355 | 				err = PTR_ERR(entry); | 
 | 356 | 				if (err == -ENOENT) { | 
 | 357 | 					err = 0; | 
 | 358 | 					goto next; | 
 | 359 | 				} | 
 | 360 | 				f2fs_put_page(page, 1); | 
 | 361 | 				break; | 
 | 362 | 			} | 
 | 363 | 		} | 
 | 364 | 		entry->blkaddr = blkaddr; | 
 | 365 |  | 
 | 366 | 		if (IS_INODE(page) && is_dent_dnode(page)) | 
 | 367 | 			entry->last_dentry = blkaddr; | 
 | 368 | next: | 
 | 369 | 		/* sanity check in order to detect looped node chain */ | 
 | 370 | 		if (++loop_cnt >= free_blocks || | 
 | 371 | 			blkaddr == next_blkaddr_of_node(page)) { | 
 | 372 | 			f2fs_notice(sbi, "%s: detect looped node chain, blkaddr:%u, next:%u", | 
 | 373 | 				    __func__, blkaddr, | 
 | 374 | 				    next_blkaddr_of_node(page)); | 
 | 375 | 			f2fs_put_page(page, 1); | 
 | 376 | 			err = -EINVAL; | 
 | 377 | 			break; | 
 | 378 | 		} | 
 | 379 |  | 
 | 380 | 		/* check next segment */ | 
 | 381 | 		blkaddr = next_blkaddr_of_node(page); | 
 | 382 | 		f2fs_put_page(page, 1); | 
 | 383 |  | 
 | 384 | 		f2fs_ra_meta_pages_cond(sbi, blkaddr); | 
 | 385 | 	} | 
 | 386 | 	return err; | 
 | 387 | } | 
 | 388 |  | 
 | 389 | static void destroy_fsync_dnodes(struct list_head *head, int drop) | 
 | 390 | { | 
 | 391 | 	struct fsync_inode_entry *entry, *tmp; | 
 | 392 |  | 
 | 393 | 	list_for_each_entry_safe(entry, tmp, head, list) | 
 | 394 | 		del_fsync_inode(entry, drop); | 
 | 395 | } | 
 | 396 |  | 
 | 397 | static int check_index_in_prev_nodes(struct f2fs_sb_info *sbi, | 
 | 398 | 			block_t blkaddr, struct dnode_of_data *dn) | 
 | 399 | { | 
 | 400 | 	struct seg_entry *sentry; | 
 | 401 | 	unsigned int segno = GET_SEGNO(sbi, blkaddr); | 
 | 402 | 	unsigned short blkoff = GET_BLKOFF_FROM_SEG0(sbi, blkaddr); | 
 | 403 | 	struct f2fs_summary_block *sum_node; | 
 | 404 | 	struct f2fs_summary sum; | 
 | 405 | 	struct page *sum_page, *node_page; | 
 | 406 | 	struct dnode_of_data tdn = *dn; | 
 | 407 | 	nid_t ino, nid; | 
 | 408 | 	struct inode *inode; | 
 | 409 | 	unsigned int offset; | 
 | 410 | 	block_t bidx; | 
 | 411 | 	int i; | 
 | 412 |  | 
 | 413 | 	sentry = get_seg_entry(sbi, segno); | 
 | 414 | 	if (!f2fs_test_bit(blkoff, sentry->cur_valid_map)) | 
 | 415 | 		return 0; | 
 | 416 |  | 
 | 417 | 	/* Get the previous summary */ | 
 | 418 | 	for (i = CURSEG_HOT_DATA; i <= CURSEG_COLD_DATA; i++) { | 
 | 419 | 		struct curseg_info *curseg = CURSEG_I(sbi, i); | 
 | 420 | 		if (curseg->segno == segno) { | 
 | 421 | 			sum = curseg->sum_blk->entries[blkoff]; | 
 | 422 | 			goto got_it; | 
 | 423 | 		} | 
 | 424 | 	} | 
 | 425 |  | 
 | 426 | 	sum_page = f2fs_get_sum_page(sbi, segno); | 
 | 427 | 	if (IS_ERR(sum_page)) | 
 | 428 | 		return PTR_ERR(sum_page); | 
 | 429 | 	sum_node = (struct f2fs_summary_block *)page_address(sum_page); | 
 | 430 | 	sum = sum_node->entries[blkoff]; | 
 | 431 | 	f2fs_put_page(sum_page, 1); | 
 | 432 | got_it: | 
 | 433 | 	/* Use the locked dnode page and inode */ | 
 | 434 | 	nid = le32_to_cpu(sum.nid); | 
 | 435 | 	if (dn->inode->i_ino == nid) { | 
 | 436 | 		tdn.nid = nid; | 
 | 437 | 		if (!dn->inode_page_locked) | 
 | 438 | 			lock_page(dn->inode_page); | 
 | 439 | 		tdn.node_page = dn->inode_page; | 
 | 440 | 		tdn.ofs_in_node = le16_to_cpu(sum.ofs_in_node); | 
 | 441 | 		goto truncate_out; | 
 | 442 | 	} else if (dn->nid == nid) { | 
 | 443 | 		tdn.ofs_in_node = le16_to_cpu(sum.ofs_in_node); | 
 | 444 | 		goto truncate_out; | 
 | 445 | 	} | 
 | 446 |  | 
 | 447 | 	/* Get the node page */ | 
 | 448 | 	node_page = f2fs_get_node_page(sbi, nid); | 
 | 449 | 	if (IS_ERR(node_page)) | 
 | 450 | 		return PTR_ERR(node_page); | 
 | 451 |  | 
 | 452 | 	offset = ofs_of_node(node_page); | 
 | 453 | 	ino = ino_of_node(node_page); | 
 | 454 | 	f2fs_put_page(node_page, 1); | 
 | 455 |  | 
 | 456 | 	if (ino != dn->inode->i_ino) { | 
 | 457 | 		int ret; | 
 | 458 |  | 
 | 459 | 		/* Deallocate previous index in the node page */ | 
 | 460 | 		inode = f2fs_iget_retry(sbi->sb, ino); | 
 | 461 | 		if (IS_ERR(inode)) | 
 | 462 | 			return PTR_ERR(inode); | 
 | 463 |  | 
 | 464 | 		ret = dquot_initialize(inode); | 
 | 465 | 		if (ret) { | 
 | 466 | 			iput(inode); | 
 | 467 | 			return ret; | 
 | 468 | 		} | 
 | 469 | 	} else { | 
 | 470 | 		inode = dn->inode; | 
 | 471 | 	} | 
 | 472 |  | 
 | 473 | 	bidx = f2fs_start_bidx_of_node(offset, inode) + | 
 | 474 | 				le16_to_cpu(sum.ofs_in_node); | 
 | 475 |  | 
 | 476 | 	/* | 
 | 477 | 	 * if inode page is locked, unlock temporarily, but its reference | 
 | 478 | 	 * count keeps alive. | 
 | 479 | 	 */ | 
 | 480 | 	if (ino == dn->inode->i_ino && dn->inode_page_locked) | 
 | 481 | 		unlock_page(dn->inode_page); | 
 | 482 |  | 
 | 483 | 	set_new_dnode(&tdn, inode, NULL, NULL, 0); | 
 | 484 | 	if (f2fs_get_dnode_of_data(&tdn, bidx, LOOKUP_NODE)) | 
 | 485 | 		goto out; | 
 | 486 |  | 
 | 487 | 	if (tdn.data_blkaddr == blkaddr) | 
 | 488 | 		f2fs_truncate_data_blocks_range(&tdn, 1); | 
 | 489 |  | 
 | 490 | 	f2fs_put_dnode(&tdn); | 
 | 491 | out: | 
 | 492 | 	if (ino != dn->inode->i_ino) | 
 | 493 | 		iput(inode); | 
 | 494 | 	else if (dn->inode_page_locked) | 
 | 495 | 		lock_page(dn->inode_page); | 
 | 496 | 	return 0; | 
 | 497 |  | 
 | 498 | truncate_out: | 
 | 499 | 	if (datablock_addr(tdn.inode, tdn.node_page, | 
 | 500 | 					tdn.ofs_in_node) == blkaddr) | 
 | 501 | 		f2fs_truncate_data_blocks_range(&tdn, 1); | 
 | 502 | 	if (dn->inode->i_ino == nid && !dn->inode_page_locked) | 
 | 503 | 		unlock_page(dn->inode_page); | 
 | 504 | 	return 0; | 
 | 505 | } | 
 | 506 |  | 
 | 507 | static int do_recover_data(struct f2fs_sb_info *sbi, struct inode *inode, | 
 | 508 | 					struct page *page) | 
 | 509 | { | 
 | 510 | 	struct dnode_of_data dn; | 
 | 511 | 	struct node_info ni; | 
 | 512 | 	unsigned int start, end; | 
 | 513 | 	int err = 0, recovered = 0; | 
 | 514 |  | 
 | 515 | 	/* step 1: recover xattr */ | 
 | 516 | 	if (IS_INODE(page)) { | 
 | 517 | 		f2fs_recover_inline_xattr(inode, page); | 
 | 518 | 	} else if (f2fs_has_xattr_block(ofs_of_node(page))) { | 
 | 519 | 		err = f2fs_recover_xattr_data(inode, page); | 
 | 520 | 		if (!err) | 
 | 521 | 			recovered++; | 
 | 522 | 		goto out; | 
 | 523 | 	} | 
 | 524 |  | 
 | 525 | 	/* step 2: recover inline data */ | 
 | 526 | 	if (f2fs_recover_inline_data(inode, page)) | 
 | 527 | 		goto out; | 
 | 528 |  | 
 | 529 | 	/* step 3: recover data indices */ | 
 | 530 | 	start = f2fs_start_bidx_of_node(ofs_of_node(page), inode); | 
 | 531 | 	end = start + ADDRS_PER_PAGE(page, inode); | 
 | 532 |  | 
 | 533 | 	set_new_dnode(&dn, inode, NULL, NULL, 0); | 
 | 534 | retry_dn: | 
 | 535 | 	err = f2fs_get_dnode_of_data(&dn, start, ALLOC_NODE); | 
 | 536 | 	if (err) { | 
 | 537 | 		if (err == -ENOMEM) { | 
 | 538 | 			congestion_wait(BLK_RW_ASYNC, HZ/50); | 
 | 539 | 			goto retry_dn; | 
 | 540 | 		} | 
 | 541 | 		goto out; | 
 | 542 | 	} | 
 | 543 |  | 
 | 544 | 	f2fs_wait_on_page_writeback(dn.node_page, NODE, true, true); | 
 | 545 |  | 
 | 546 | 	err = f2fs_get_node_info(sbi, dn.nid, &ni); | 
 | 547 | 	if (err) | 
 | 548 | 		goto err; | 
 | 549 |  | 
 | 550 | 	f2fs_bug_on(sbi, ni.ino != ino_of_node(page)); | 
 | 551 |  | 
 | 552 | 	if (ofs_of_node(dn.node_page) != ofs_of_node(page)) { | 
 | 553 | 		f2fs_warn(sbi, "Inconsistent ofs_of_node, ino:%lu, ofs:%u, %u", | 
 | 554 | 			  inode->i_ino, ofs_of_node(dn.node_page), | 
 | 555 | 			  ofs_of_node(page)); | 
 | 556 | 		err = -EFSCORRUPTED; | 
 | 557 | 		goto err; | 
 | 558 | 	} | 
 | 559 |  | 
 | 560 | 	for (; start < end; start++, dn.ofs_in_node++) { | 
 | 561 | 		block_t src, dest; | 
 | 562 |  | 
 | 563 | 		src = datablock_addr(dn.inode, dn.node_page, dn.ofs_in_node); | 
 | 564 | 		dest = datablock_addr(dn.inode, page, dn.ofs_in_node); | 
 | 565 |  | 
 | 566 | 		if (__is_valid_data_blkaddr(src) && | 
 | 567 | 			!f2fs_is_valid_blkaddr(sbi, src, META_POR)) { | 
 | 568 | 			err = -EFSCORRUPTED; | 
 | 569 | 			goto err; | 
 | 570 | 		} | 
 | 571 |  | 
 | 572 | 		if (__is_valid_data_blkaddr(dest) && | 
 | 573 | 			!f2fs_is_valid_blkaddr(sbi, dest, META_POR)) { | 
 | 574 | 			err = -EFSCORRUPTED; | 
 | 575 | 			goto err; | 
 | 576 | 		} | 
 | 577 |  | 
 | 578 | 		/* skip recovering if dest is the same as src */ | 
 | 579 | 		if (src == dest) | 
 | 580 | 			continue; | 
 | 581 |  | 
 | 582 | 		/* dest is invalid, just invalidate src block */ | 
 | 583 | 		if (dest == NULL_ADDR) { | 
 | 584 | 			f2fs_truncate_data_blocks_range(&dn, 1); | 
 | 585 | 			continue; | 
 | 586 | 		} | 
 | 587 |  | 
 | 588 | 		if (!file_keep_isize(inode) && | 
 | 589 | 			(i_size_read(inode) <= ((loff_t)start << PAGE_SHIFT))) | 
 | 590 | 			f2fs_i_size_write(inode, | 
 | 591 | 				(loff_t)(start + 1) << PAGE_SHIFT); | 
 | 592 |  | 
 | 593 | 		/* | 
 | 594 | 		 * dest is reserved block, invalidate src block | 
 | 595 | 		 * and then reserve one new block in dnode page. | 
 | 596 | 		 */ | 
 | 597 | 		if (dest == NEW_ADDR) { | 
 | 598 | 			f2fs_truncate_data_blocks_range(&dn, 1); | 
 | 599 | 			f2fs_reserve_new_block(&dn); | 
 | 600 | 			continue; | 
 | 601 | 		} | 
 | 602 |  | 
 | 603 | 		/* dest is valid block, try to recover from src to dest */ | 
 | 604 | 		if (f2fs_is_valid_blkaddr(sbi, dest, META_POR)) { | 
 | 605 |  | 
 | 606 | 			if (src == NULL_ADDR) { | 
 | 607 | 				err = f2fs_reserve_new_block(&dn); | 
 | 608 | 				while (err && | 
 | 609 | 				       IS_ENABLED(CONFIG_F2FS_FAULT_INJECTION)) | 
 | 610 | 					err = f2fs_reserve_new_block(&dn); | 
 | 611 | 				/* We should not get -ENOSPC */ | 
 | 612 | 				f2fs_bug_on(sbi, err); | 
 | 613 | 				if (err) | 
 | 614 | 					goto err; | 
 | 615 | 			} | 
 | 616 | retry_prev: | 
 | 617 | 			/* Check the previous node page having this index */ | 
 | 618 | 			err = check_index_in_prev_nodes(sbi, dest, &dn); | 
 | 619 | 			if (err) { | 
 | 620 | 				if (err == -ENOMEM) { | 
 | 621 | 					congestion_wait(BLK_RW_ASYNC, HZ/50); | 
 | 622 | 					goto retry_prev; | 
 | 623 | 				} | 
 | 624 | 				goto err; | 
 | 625 | 			} | 
 | 626 |  | 
 | 627 | 			/* write dummy data page */ | 
 | 628 | 			f2fs_replace_block(sbi, &dn, src, dest, | 
 | 629 | 						ni.version, false, false); | 
 | 630 | 			recovered++; | 
 | 631 | 		} | 
 | 632 | 	} | 
 | 633 |  | 
 | 634 | 	copy_node_footer(dn.node_page, page); | 
 | 635 | 	fill_node_footer(dn.node_page, dn.nid, ni.ino, | 
 | 636 | 					ofs_of_node(page), false); | 
 | 637 | 	set_page_dirty(dn.node_page); | 
 | 638 | err: | 
 | 639 | 	f2fs_put_dnode(&dn); | 
 | 640 | out: | 
 | 641 | 	f2fs_notice(sbi, "recover_data: ino = %lx (i_size: %s) recovered = %d, err = %d", | 
 | 642 | 		    inode->i_ino, file_keep_isize(inode) ? "keep" : "recover", | 
 | 643 | 		    recovered, err); | 
 | 644 | 	return err; | 
 | 645 | } | 
 | 646 |  | 
 | 647 | static int recover_data(struct f2fs_sb_info *sbi, struct list_head *inode_list, | 
 | 648 | 		struct list_head *tmp_inode_list, struct list_head *dir_list) | 
 | 649 | { | 
 | 650 | 	struct curseg_info *curseg; | 
 | 651 | 	struct page *page = NULL; | 
 | 652 | 	int err = 0; | 
 | 653 | 	block_t blkaddr; | 
 | 654 |  | 
 | 655 | 	/* get node pages in the current segment */ | 
 | 656 | 	curseg = CURSEG_I(sbi, CURSEG_WARM_NODE); | 
 | 657 | 	blkaddr = NEXT_FREE_BLKADDR(sbi, curseg); | 
 | 658 |  | 
 | 659 | 	while (1) { | 
 | 660 | 		struct fsync_inode_entry *entry; | 
 | 661 |  | 
 | 662 | 		if (!f2fs_is_valid_blkaddr(sbi, blkaddr, META_POR)) | 
 | 663 | 			break; | 
 | 664 |  | 
 | 665 | 		f2fs_ra_meta_pages_cond(sbi, blkaddr); | 
 | 666 |  | 
 | 667 | 		page = f2fs_get_tmp_page(sbi, blkaddr); | 
 | 668 | 		if (IS_ERR(page)) { | 
 | 669 | 			err = PTR_ERR(page); | 
 | 670 | 			break; | 
 | 671 | 		} | 
 | 672 |  | 
 | 673 | 		if (!is_recoverable_dnode(page)) { | 
 | 674 | 			f2fs_put_page(page, 1); | 
 | 675 | 			break; | 
 | 676 | 		} | 
 | 677 |  | 
 | 678 | 		entry = get_fsync_inode(inode_list, ino_of_node(page)); | 
 | 679 | 		if (!entry) | 
 | 680 | 			goto next; | 
 | 681 | 		/* | 
 | 682 | 		 * inode(x) | CP | inode(x) | dnode(F) | 
 | 683 | 		 * In this case, we can lose the latest inode(x). | 
 | 684 | 		 * So, call recover_inode for the inode update. | 
 | 685 | 		 */ | 
 | 686 | 		if (IS_INODE(page)) { | 
 | 687 | 			err = recover_inode(entry->inode, page); | 
 | 688 | 			if (err) { | 
 | 689 | 				f2fs_put_page(page, 1); | 
 | 690 | 				break; | 
 | 691 | 			} | 
 | 692 | 		} | 
 | 693 | 		if (entry->last_dentry == blkaddr) { | 
 | 694 | 			err = recover_dentry(entry->inode, page, dir_list); | 
 | 695 | 			if (err) { | 
 | 696 | 				f2fs_put_page(page, 1); | 
 | 697 | 				break; | 
 | 698 | 			} | 
 | 699 | 		} | 
 | 700 | 		err = do_recover_data(sbi, entry->inode, page); | 
 | 701 | 		if (err) { | 
 | 702 | 			f2fs_put_page(page, 1); | 
 | 703 | 			break; | 
 | 704 | 		} | 
 | 705 |  | 
 | 706 | 		if (entry->blkaddr == blkaddr) | 
 | 707 | 			list_move_tail(&entry->list, tmp_inode_list); | 
 | 708 | next: | 
 | 709 | 		/* check next segment */ | 
 | 710 | 		blkaddr = next_blkaddr_of_node(page); | 
 | 711 | 		f2fs_put_page(page, 1); | 
 | 712 | 	} | 
 | 713 | 	if (!err) | 
 | 714 | 		f2fs_allocate_new_segments(sbi, NO_CHECK_TYPE); | 
 | 715 | 	return err; | 
 | 716 | } | 
 | 717 |  | 
 | 718 | int f2fs_recover_fsync_data(struct f2fs_sb_info *sbi, bool check_only) | 
 | 719 | { | 
 | 720 | 	struct list_head inode_list, tmp_inode_list; | 
 | 721 | 	struct list_head dir_list; | 
 | 722 | 	int err; | 
 | 723 | 	int ret = 0; | 
 | 724 | 	unsigned long s_flags = sbi->sb->s_flags; | 
 | 725 | 	bool need_writecp = false; | 
 | 726 | #ifdef CONFIG_QUOTA | 
 | 727 | 	int quota_enabled; | 
 | 728 | #endif | 
 | 729 |  | 
 | 730 | 	if (s_flags & SB_RDONLY) { | 
 | 731 | 		f2fs_info(sbi, "recover fsync data on readonly fs"); | 
 | 732 | 		sbi->sb->s_flags &= ~SB_RDONLY; | 
 | 733 | 	} | 
 | 734 |  | 
 | 735 | #ifdef CONFIG_QUOTA | 
 | 736 | 	/* Needed for iput() to work correctly and not trash data */ | 
 | 737 | 	sbi->sb->s_flags |= SB_ACTIVE; | 
 | 738 | 	/* Turn on quotas so that they are updated correctly */ | 
 | 739 | 	quota_enabled = f2fs_enable_quota_files(sbi, s_flags & SB_RDONLY); | 
 | 740 | #endif | 
 | 741 |  | 
 | 742 | 	fsync_entry_slab = f2fs_kmem_cache_create("f2fs_fsync_inode_entry", | 
 | 743 | 			sizeof(struct fsync_inode_entry)); | 
 | 744 | 	if (!fsync_entry_slab) { | 
 | 745 | 		err = -ENOMEM; | 
 | 746 | 		goto out; | 
 | 747 | 	} | 
 | 748 |  | 
 | 749 | 	INIT_LIST_HEAD(&inode_list); | 
 | 750 | 	INIT_LIST_HEAD(&tmp_inode_list); | 
 | 751 | 	INIT_LIST_HEAD(&dir_list); | 
 | 752 |  | 
 | 753 | 	/* prevent checkpoint */ | 
 | 754 | 	mutex_lock(&sbi->cp_mutex); | 
 | 755 |  | 
 | 756 | 	/* step #1: find fsynced inode numbers */ | 
 | 757 | 	err = find_fsync_dnodes(sbi, &inode_list, check_only); | 
 | 758 | 	if (err || list_empty(&inode_list)) | 
 | 759 | 		goto skip; | 
 | 760 |  | 
 | 761 | 	if (check_only) { | 
 | 762 | 		ret = 1; | 
 | 763 | 		goto skip; | 
 | 764 | 	} | 
 | 765 |  | 
 | 766 | 	need_writecp = true; | 
 | 767 |  | 
 | 768 | 	/* step #2: recover data */ | 
 | 769 | 	err = recover_data(sbi, &inode_list, &tmp_inode_list, &dir_list); | 
 | 770 | 	if (!err) | 
 | 771 | 		f2fs_bug_on(sbi, !list_empty(&inode_list)); | 
 | 772 | 	else { | 
 | 773 | 		/* restore s_flags to let iput() trash data */ | 
 | 774 | 		sbi->sb->s_flags = s_flags; | 
 | 775 | 	} | 
 | 776 | skip: | 
 | 777 | 	destroy_fsync_dnodes(&inode_list, err); | 
 | 778 | 	destroy_fsync_dnodes(&tmp_inode_list, err); | 
 | 779 |  | 
 | 780 | 	/* truncate meta pages to be used by the recovery */ | 
 | 781 | 	truncate_inode_pages_range(META_MAPPING(sbi), | 
 | 782 | 			(loff_t)MAIN_BLKADDR(sbi) << PAGE_SHIFT, -1); | 
 | 783 |  | 
 | 784 | 	if (err) { | 
 | 785 | 		truncate_inode_pages_final(NODE_MAPPING(sbi)); | 
 | 786 | 		truncate_inode_pages_final(META_MAPPING(sbi)); | 
 | 787 | 	} else { | 
 | 788 | 		clear_sbi_flag(sbi, SBI_POR_DOING); | 
 | 789 | 	} | 
 | 790 | 	mutex_unlock(&sbi->cp_mutex); | 
 | 791 |  | 
 | 792 | 	/* let's drop all the directory inodes for clean checkpoint */ | 
 | 793 | 	destroy_fsync_dnodes(&dir_list, err); | 
 | 794 |  | 
 | 795 | 	if (need_writecp) { | 
 | 796 | 		set_sbi_flag(sbi, SBI_IS_RECOVERED); | 
 | 797 |  | 
 | 798 | 		if (!err) { | 
 | 799 | 			struct cp_control cpc = { | 
 | 800 | 				.reason = CP_RECOVERY, | 
 | 801 | 			}; | 
 | 802 | 			err = f2fs_write_checkpoint(sbi, &cpc); | 
 | 803 | 		} | 
 | 804 | 	} | 
 | 805 |  | 
 | 806 | 	kmem_cache_destroy(fsync_entry_slab); | 
 | 807 | out: | 
 | 808 | #ifdef CONFIG_QUOTA | 
 | 809 | 	/* Turn quotas off */ | 
 | 810 | 	if (quota_enabled) | 
 | 811 | 		f2fs_quota_off_umount(sbi->sb); | 
 | 812 | #endif | 
 | 813 | 	sbi->sb->s_flags = s_flags; /* Restore SB_RDONLY status */ | 
 | 814 |  | 
 | 815 | 	return ret ? ret: err; | 
 | 816 | } |