1 // SPDX-License-Identifier: GPL-2.0
3 * f2fs extent cache support
5 * Copyright (c) 2015 Motorola Mobility
6 * Copyright (c) 2015 Samsung Electronics
7 * Authors: Jaegeuk Kim <jaegeuk@kernel.org>
8 * Chao Yu <chao2.yu@samsung.com>
10 * block_age-based extent cache added by:
11 * Copyright (c) 2022 xiaomi Co., Ltd.
12 * http://www.xiaomi.com/
16 #include <linux/f2fs_fs.h>
20 #include <trace/events/f2fs.h>
22 static void __set_extent_info(struct extent_info *ei,
23 unsigned int fofs, unsigned int len,
24 block_t blk, bool keep_clen,
25 unsigned long age, unsigned long last_blocks,
26 enum extent_type type)
31 if (type == EX_READ) {
35 #ifdef CONFIG_F2FS_FS_COMPRESSION
38 } else if (type == EX_BLOCK_AGE) {
40 ei->last_blocks = last_blocks;
44 static bool __may_read_extent_tree(struct inode *inode)
46 struct f2fs_sb_info *sbi = F2FS_I_SB(inode);
48 if (!test_opt(sbi, READ_EXTENT_CACHE))
50 if (is_inode_flag_set(inode, FI_NO_EXTENT))
52 if (is_inode_flag_set(inode, FI_COMPRESSED_FILE) &&
53 !f2fs_sb_has_readonly(sbi))
55 return S_ISREG(inode->i_mode);
58 static bool __may_age_extent_tree(struct inode *inode)
60 struct f2fs_sb_info *sbi = F2FS_I_SB(inode);
62 if (!test_opt(sbi, AGE_EXTENT_CACHE))
64 /* don't cache block age info for cold file */
65 if (is_inode_flag_set(inode, FI_COMPRESSED_FILE))
67 if (file_is_cold(inode))
70 return S_ISREG(inode->i_mode) || S_ISDIR(inode->i_mode);
73 static bool __init_may_extent_tree(struct inode *inode, enum extent_type type)
76 return __may_read_extent_tree(inode);
77 else if (type == EX_BLOCK_AGE)
78 return __may_age_extent_tree(inode);
82 static bool __may_extent_tree(struct inode *inode, enum extent_type type)
85 * for recovered files during mount do not create extents
86 * if shrinker is not registered.
88 if (list_empty(&F2FS_I_SB(inode)->s_list))
91 return __init_may_extent_tree(inode, type);
94 static void __try_update_largest_extent(struct extent_tree *et,
95 struct extent_node *en)
97 if (et->type != EX_READ)
99 if (en->ei.len <= et->largest.len)
102 et->largest = en->ei;
103 et->largest_updated = true;
106 static bool __is_extent_mergeable(struct extent_info *back,
107 struct extent_info *front, enum extent_type type)
109 if (type == EX_READ) {
110 #ifdef CONFIG_F2FS_FS_COMPRESSION
111 if (back->c_len && back->len != back->c_len)
113 if (front->c_len && front->len != front->c_len)
116 return (back->fofs + back->len == front->fofs &&
117 back->blk + back->len == front->blk);
118 } else if (type == EX_BLOCK_AGE) {
119 return (back->fofs + back->len == front->fofs &&
120 abs(back->age - front->age) <= SAME_AGE_REGION &&
121 abs(back->last_blocks - front->last_blocks) <=
127 static bool __is_back_mergeable(struct extent_info *cur,
128 struct extent_info *back, enum extent_type type)
130 return __is_extent_mergeable(back, cur, type);
133 static bool __is_front_mergeable(struct extent_info *cur,
134 struct extent_info *front, enum extent_type type)
136 return __is_extent_mergeable(cur, front, type);
139 static struct rb_entry *__lookup_rb_tree_fast(struct rb_entry *cached_re,
143 if (cached_re->ofs <= ofs &&
144 cached_re->ofs + cached_re->len > ofs) {
151 static struct rb_entry *__lookup_rb_tree_slow(struct rb_root_cached *root,
154 struct rb_node *node = root->rb_root.rb_node;
158 re = rb_entry(node, struct rb_entry, rb_node);
161 node = node->rb_left;
162 else if (ofs >= re->ofs + re->len)
163 node = node->rb_right;
170 struct rb_entry *f2fs_lookup_rb_tree(struct rb_root_cached *root,
171 struct rb_entry *cached_re, unsigned int ofs)
175 re = __lookup_rb_tree_fast(cached_re, ofs);
177 return __lookup_rb_tree_slow(root, ofs);
182 struct rb_node **f2fs_lookup_rb_tree_ext(struct f2fs_sb_info *sbi,
183 struct rb_root_cached *root,
184 struct rb_node **parent,
185 unsigned long long key, bool *leftmost)
187 struct rb_node **p = &root->rb_root.rb_node;
192 re = rb_entry(*parent, struct rb_entry, rb_node);
205 struct rb_node **f2fs_lookup_rb_tree_for_insert(struct f2fs_sb_info *sbi,
206 struct rb_root_cached *root,
207 struct rb_node **parent,
208 unsigned int ofs, bool *leftmost)
210 struct rb_node **p = &root->rb_root.rb_node;
215 re = rb_entry(*parent, struct rb_entry, rb_node);
219 } else if (ofs >= re->ofs + re->len) {
231 * lookup rb entry in position of @ofs in rb-tree,
232 * if hit, return the entry, otherwise, return NULL
233 * @prev_ex: extent before ofs
234 * @next_ex: extent after ofs
235 * @insert_p: insert point for new extent at ofs
236 * in order to simpfy the insertion after.
237 * tree must stay unchanged between lookup and insertion.
239 struct rb_entry *f2fs_lookup_rb_tree_ret(struct rb_root_cached *root,
240 struct rb_entry *cached_re,
242 struct rb_entry **prev_entry,
243 struct rb_entry **next_entry,
244 struct rb_node ***insert_p,
245 struct rb_node **insert_parent,
246 bool force, bool *leftmost)
248 struct rb_node **pnode = &root->rb_root.rb_node;
249 struct rb_node *parent = NULL, *tmp_node;
250 struct rb_entry *re = cached_re;
253 *insert_parent = NULL;
257 if (RB_EMPTY_ROOT(&root->rb_root))
261 if (re->ofs <= ofs && re->ofs + re->len > ofs)
262 goto lookup_neighbors;
270 re = rb_entry(*pnode, struct rb_entry, rb_node);
273 pnode = &(*pnode)->rb_left;
274 } else if (ofs >= re->ofs + re->len) {
275 pnode = &(*pnode)->rb_right;
279 goto lookup_neighbors;
284 *insert_parent = parent;
286 re = rb_entry(parent, struct rb_entry, rb_node);
288 if (parent && ofs > re->ofs)
289 tmp_node = rb_next(parent);
290 *next_entry = rb_entry_safe(tmp_node, struct rb_entry, rb_node);
293 if (parent && ofs < re->ofs)
294 tmp_node = rb_prev(parent);
295 *prev_entry = rb_entry_safe(tmp_node, struct rb_entry, rb_node);
299 if (ofs == re->ofs || force) {
300 /* lookup prev node for merging backward later */
301 tmp_node = rb_prev(&re->rb_node);
302 *prev_entry = rb_entry_safe(tmp_node, struct rb_entry, rb_node);
304 if (ofs == re->ofs + re->len - 1 || force) {
305 /* lookup next node for merging frontward later */
306 tmp_node = rb_next(&re->rb_node);
307 *next_entry = rb_entry_safe(tmp_node, struct rb_entry, rb_node);
312 bool f2fs_check_rb_tree_consistence(struct f2fs_sb_info *sbi,
313 struct rb_root_cached *root, bool check_key)
315 #ifdef CONFIG_F2FS_CHECK_FS
316 struct rb_node *cur = rb_first_cached(root), *next;
317 struct rb_entry *cur_re, *next_re;
327 cur_re = rb_entry(cur, struct rb_entry, rb_node);
328 next_re = rb_entry(next, struct rb_entry, rb_node);
331 if (cur_re->key > next_re->key) {
332 f2fs_info(sbi, "inconsistent rbtree, "
333 "cur(%llu) next(%llu)",
334 cur_re->key, next_re->key);
340 if (cur_re->ofs + cur_re->len > next_re->ofs) {
341 f2fs_info(sbi, "inconsistent rbtree, cur(%u, %u) next(%u, %u)",
342 cur_re->ofs, cur_re->len,
343 next_re->ofs, next_re->len);
353 static struct kmem_cache *extent_tree_slab;
354 static struct kmem_cache *extent_node_slab;
356 static struct extent_node *__attach_extent_node(struct f2fs_sb_info *sbi,
357 struct extent_tree *et, struct extent_info *ei,
358 struct rb_node *parent, struct rb_node **p,
361 struct extent_tree_info *eti = &sbi->extent_tree[et->type];
362 struct extent_node *en;
364 en = f2fs_kmem_cache_alloc(extent_node_slab, GFP_ATOMIC, false, sbi);
369 INIT_LIST_HEAD(&en->list);
372 rb_link_node(&en->rb_node, parent, p);
373 rb_insert_color_cached(&en->rb_node, &et->root, leftmost);
374 atomic_inc(&et->node_cnt);
375 atomic_inc(&eti->total_ext_node);
379 static void __detach_extent_node(struct f2fs_sb_info *sbi,
380 struct extent_tree *et, struct extent_node *en)
382 struct extent_tree_info *eti = &sbi->extent_tree[et->type];
384 rb_erase_cached(&en->rb_node, &et->root);
385 atomic_dec(&et->node_cnt);
386 atomic_dec(&eti->total_ext_node);
388 if (et->cached_en == en)
389 et->cached_en = NULL;
390 kmem_cache_free(extent_node_slab, en);
394 * Flow to release an extent_node:
396 * 2. __detach_extent_node
397 * 3. kmem_cache_free.
399 static void __release_extent_node(struct f2fs_sb_info *sbi,
400 struct extent_tree *et, struct extent_node *en)
402 struct extent_tree_info *eti = &sbi->extent_tree[et->type];
404 spin_lock(&eti->extent_lock);
405 f2fs_bug_on(sbi, list_empty(&en->list));
406 list_del_init(&en->list);
407 spin_unlock(&eti->extent_lock);
409 __detach_extent_node(sbi, et, en);
412 static struct extent_tree *__grab_extent_tree(struct inode *inode,
413 enum extent_type type)
415 struct f2fs_sb_info *sbi = F2FS_I_SB(inode);
416 struct extent_tree_info *eti = &sbi->extent_tree[type];
417 struct extent_tree *et;
418 nid_t ino = inode->i_ino;
420 mutex_lock(&eti->extent_tree_lock);
421 et = radix_tree_lookup(&eti->extent_tree_root, ino);
423 et = f2fs_kmem_cache_alloc(extent_tree_slab,
424 GFP_NOFS, true, NULL);
425 f2fs_radix_tree_insert(&eti->extent_tree_root, ino, et);
426 memset(et, 0, sizeof(struct extent_tree));
429 et->root = RB_ROOT_CACHED;
430 et->cached_en = NULL;
431 rwlock_init(&et->lock);
432 INIT_LIST_HEAD(&et->list);
433 atomic_set(&et->node_cnt, 0);
434 atomic_inc(&eti->total_ext_tree);
436 atomic_dec(&eti->total_zombie_tree);
437 list_del_init(&et->list);
439 mutex_unlock(&eti->extent_tree_lock);
441 /* never died until evict_inode */
442 F2FS_I(inode)->extent_tree[type] = et;
447 static unsigned int __free_extent_tree(struct f2fs_sb_info *sbi,
448 struct extent_tree *et)
450 struct rb_node *node, *next;
451 struct extent_node *en;
452 unsigned int count = atomic_read(&et->node_cnt);
454 node = rb_first_cached(&et->root);
456 next = rb_next(node);
457 en = rb_entry(node, struct extent_node, rb_node);
458 __release_extent_node(sbi, et, en);
462 return count - atomic_read(&et->node_cnt);
465 static void __drop_largest_extent(struct extent_tree *et,
466 pgoff_t fofs, unsigned int len)
468 if (fofs < et->largest.fofs + et->largest.len &&
469 fofs + len > et->largest.fofs) {
471 et->largest_updated = true;
475 void f2fs_init_read_extent_tree(struct inode *inode, struct page *ipage)
477 struct f2fs_sb_info *sbi = F2FS_I_SB(inode);
478 struct extent_tree_info *eti = &sbi->extent_tree[EX_READ];
479 struct f2fs_extent *i_ext = &F2FS_INODE(ipage)->i_ext;
480 struct extent_tree *et;
481 struct extent_node *en;
482 struct extent_info ei;
484 if (!__may_extent_tree(inode, EX_READ)) {
485 /* drop largest read extent */
486 if (i_ext && i_ext->len) {
487 f2fs_wait_on_page_writeback(ipage, NODE, true, true);
489 set_page_dirty(ipage);
494 et = __grab_extent_tree(inode, EX_READ);
496 if (!i_ext || !i_ext->len)
499 get_read_extent_info(&ei, i_ext);
501 write_lock(&et->lock);
502 if (atomic_read(&et->node_cnt))
505 en = __attach_extent_node(sbi, et, &ei, NULL,
506 &et->root.rb_root.rb_node, true);
508 et->largest = en->ei;
511 spin_lock(&eti->extent_lock);
512 list_add_tail(&en->list, &eti->extent_list);
513 spin_unlock(&eti->extent_lock);
516 write_unlock(&et->lock);
518 if (!F2FS_I(inode)->extent_tree[EX_READ])
519 set_inode_flag(inode, FI_NO_EXTENT);
522 void f2fs_init_age_extent_tree(struct inode *inode)
524 if (!__init_may_extent_tree(inode, EX_BLOCK_AGE))
526 __grab_extent_tree(inode, EX_BLOCK_AGE);
529 void f2fs_init_extent_tree(struct inode *inode)
531 /* initialize read cache */
532 if (__init_may_extent_tree(inode, EX_READ))
533 __grab_extent_tree(inode, EX_READ);
535 /* initialize block age cache */
536 if (__init_may_extent_tree(inode, EX_BLOCK_AGE))
537 __grab_extent_tree(inode, EX_BLOCK_AGE);
540 static bool __lookup_extent_tree(struct inode *inode, pgoff_t pgofs,
541 struct extent_info *ei, enum extent_type type)
543 struct f2fs_sb_info *sbi = F2FS_I_SB(inode);
544 struct extent_tree_info *eti = &sbi->extent_tree[type];
545 struct extent_tree *et = F2FS_I(inode)->extent_tree[type];
546 struct extent_node *en;
552 trace_f2fs_lookup_extent_tree_start(inode, pgofs, type);
554 read_lock(&et->lock);
556 if (type == EX_READ &&
557 et->largest.fofs <= pgofs &&
558 et->largest.fofs + et->largest.len > pgofs) {
561 stat_inc_largest_node_hit(sbi);
565 en = (struct extent_node *)f2fs_lookup_rb_tree(&et->root,
566 (struct rb_entry *)et->cached_en, pgofs);
570 if (en == et->cached_en)
571 stat_inc_cached_node_hit(sbi, type);
573 stat_inc_rbtree_node_hit(sbi, type);
576 spin_lock(&eti->extent_lock);
577 if (!list_empty(&en->list)) {
578 list_move_tail(&en->list, &eti->extent_list);
581 spin_unlock(&eti->extent_lock);
584 stat_inc_total_hit(sbi, type);
585 read_unlock(&et->lock);
588 trace_f2fs_lookup_read_extent_tree_end(inode, pgofs, ei);
589 else if (type == EX_BLOCK_AGE)
590 trace_f2fs_lookup_age_extent_tree_end(inode, pgofs, ei);
594 static struct extent_node *__try_merge_extent_node(struct f2fs_sb_info *sbi,
595 struct extent_tree *et, struct extent_info *ei,
596 struct extent_node *prev_ex,
597 struct extent_node *next_ex)
599 struct extent_tree_info *eti = &sbi->extent_tree[et->type];
600 struct extent_node *en = NULL;
602 if (prev_ex && __is_back_mergeable(ei, &prev_ex->ei, et->type)) {
603 prev_ex->ei.len += ei->len;
608 if (next_ex && __is_front_mergeable(ei, &next_ex->ei, et->type)) {
609 next_ex->ei.fofs = ei->fofs;
610 next_ex->ei.len += ei->len;
611 if (et->type == EX_READ)
612 next_ex->ei.blk = ei->blk;
614 __release_extent_node(sbi, et, prev_ex);
622 __try_update_largest_extent(et, en);
624 spin_lock(&eti->extent_lock);
625 if (!list_empty(&en->list)) {
626 list_move_tail(&en->list, &eti->extent_list);
629 spin_unlock(&eti->extent_lock);
633 static struct extent_node *__insert_extent_tree(struct f2fs_sb_info *sbi,
634 struct extent_tree *et, struct extent_info *ei,
635 struct rb_node **insert_p,
636 struct rb_node *insert_parent,
639 struct extent_tree_info *eti = &sbi->extent_tree[et->type];
641 struct rb_node *parent = NULL;
642 struct extent_node *en = NULL;
644 if (insert_p && insert_parent) {
645 parent = insert_parent;
652 p = f2fs_lookup_rb_tree_for_insert(sbi, &et->root, &parent,
653 ei->fofs, &leftmost);
655 en = __attach_extent_node(sbi, et, ei, parent, p, leftmost);
659 __try_update_largest_extent(et, en);
661 /* update in global extent list */
662 spin_lock(&eti->extent_lock);
663 list_add_tail(&en->list, &eti->extent_list);
665 spin_unlock(&eti->extent_lock);
669 static void __update_extent_tree_range(struct inode *inode,
670 struct extent_info *tei, enum extent_type type)
672 struct f2fs_sb_info *sbi = F2FS_I_SB(inode);
673 struct extent_tree *et = F2FS_I(inode)->extent_tree[type];
674 struct extent_node *en = NULL, *en1 = NULL;
675 struct extent_node *prev_en = NULL, *next_en = NULL;
676 struct extent_info ei, dei, prev;
677 struct rb_node **insert_p = NULL, *insert_parent = NULL;
678 unsigned int fofs = tei->fofs, len = tei->len;
679 unsigned int end = fofs + len;
680 bool updated = false;
681 bool leftmost = false;
687 trace_f2fs_update_read_extent_tree_range(inode, fofs, len,
689 else if (type == EX_BLOCK_AGE)
690 trace_f2fs_update_age_extent_tree_range(inode, fofs, len,
691 tei->age, tei->last_blocks);
693 write_lock(&et->lock);
695 if (type == EX_READ) {
696 if (is_inode_flag_set(inode, FI_NO_EXTENT)) {
697 write_unlock(&et->lock);
705 * drop largest extent before lookup, in case it's already
706 * been shrunk from extent tree
708 __drop_largest_extent(et, fofs, len);
711 /* 1. lookup first extent node in range [fofs, fofs + len - 1] */
712 en = (struct extent_node *)f2fs_lookup_rb_tree_ret(&et->root,
713 (struct rb_entry *)et->cached_en, fofs,
714 (struct rb_entry **)&prev_en,
715 (struct rb_entry **)&next_en,
716 &insert_p, &insert_parent, false,
721 /* 2. invlidate all extent nodes in range [fofs, fofs + len - 1] */
722 while (en && en->ei.fofs < end) {
723 unsigned int org_end;
724 int parts = 0; /* # of parts current extent split into */
726 next_en = en1 = NULL;
729 org_end = dei.fofs + dei.len;
730 f2fs_bug_on(sbi, fofs >= org_end);
732 if (fofs > dei.fofs && (type != EX_READ ||
733 fofs - dei.fofs >= F2FS_MIN_EXTENT_LEN)) {
734 en->ei.len = fofs - en->ei.fofs;
739 if (end < org_end && (type != EX_READ ||
740 org_end - end >= F2FS_MIN_EXTENT_LEN)) {
742 __set_extent_info(&ei,
744 end - dei.fofs + dei.blk, false,
745 dei.age, dei.last_blocks,
747 en1 = __insert_extent_tree(sbi, et, &ei,
751 __set_extent_info(&en->ei,
752 end, en->ei.len - (end - dei.fofs),
753 en->ei.blk + (end - dei.fofs), true,
754 dei.age, dei.last_blocks,
762 struct rb_node *node = rb_next(&en->rb_node);
764 next_en = rb_entry_safe(node, struct extent_node,
769 __try_update_largest_extent(et, en);
771 __release_extent_node(sbi, et, en);
774 * if original extent is split into zero or two parts, extent
775 * tree has been altered by deletion or insertion, therefore
776 * invalidate pointers regard to tree.
780 insert_parent = NULL;
785 if (type == EX_BLOCK_AGE)
786 goto update_age_extent_cache;
788 /* 3. update extent in read extent cache */
789 BUG_ON(type != EX_READ);
792 __set_extent_info(&ei, fofs, len, tei->blk, false,
794 if (!__try_merge_extent_node(sbi, et, &ei, prev_en, next_en))
795 __insert_extent_tree(sbi, et, &ei,
796 insert_p, insert_parent, leftmost);
798 /* give up extent_cache, if split and small updates happen */
800 prev.len < F2FS_MIN_EXTENT_LEN &&
801 et->largest.len < F2FS_MIN_EXTENT_LEN) {
803 et->largest_updated = true;
804 set_inode_flag(inode, FI_NO_EXTENT);
808 if (is_inode_flag_set(inode, FI_NO_EXTENT))
809 __free_extent_tree(sbi, et);
811 if (et->largest_updated) {
812 et->largest_updated = false;
815 goto out_read_extent_cache;
816 update_age_extent_cache:
817 if (!tei->last_blocks)
818 goto out_read_extent_cache;
820 __set_extent_info(&ei, fofs, len, 0, false,
821 tei->age, tei->last_blocks, EX_BLOCK_AGE);
822 if (!__try_merge_extent_node(sbi, et, &ei, prev_en, next_en))
823 __insert_extent_tree(sbi, et, &ei,
824 insert_p, insert_parent, leftmost);
825 out_read_extent_cache:
826 write_unlock(&et->lock);
829 f2fs_mark_inode_dirty_sync(inode, true);
832 #ifdef CONFIG_F2FS_FS_COMPRESSION
833 void f2fs_update_read_extent_tree_range_compressed(struct inode *inode,
834 pgoff_t fofs, block_t blkaddr, unsigned int llen,
837 struct f2fs_sb_info *sbi = F2FS_I_SB(inode);
838 struct extent_tree *et = F2FS_I(inode)->extent_tree[EX_READ];
839 struct extent_node *en = NULL;
840 struct extent_node *prev_en = NULL, *next_en = NULL;
841 struct extent_info ei;
842 struct rb_node **insert_p = NULL, *insert_parent = NULL;
843 bool leftmost = false;
845 trace_f2fs_update_read_extent_tree_range(inode, fofs, llen,
848 /* it is safe here to check FI_NO_EXTENT w/o et->lock in ro image */
849 if (is_inode_flag_set(inode, FI_NO_EXTENT))
852 write_lock(&et->lock);
854 en = (struct extent_node *)f2fs_lookup_rb_tree_ret(&et->root,
855 (struct rb_entry *)et->cached_en, fofs,
856 (struct rb_entry **)&prev_en,
857 (struct rb_entry **)&next_en,
858 &insert_p, &insert_parent, false,
863 __set_extent_info(&ei, fofs, llen, blkaddr, true, 0, 0, EX_READ);
866 if (!__try_merge_extent_node(sbi, et, &ei, prev_en, next_en))
867 __insert_extent_tree(sbi, et, &ei,
868 insert_p, insert_parent, leftmost);
870 write_unlock(&et->lock);
874 static unsigned long long __calculate_block_age(unsigned long long new,
875 unsigned long long old)
877 unsigned long long diff;
879 diff = (new >= old) ? new - (new - old) : new + (old - new);
881 return div_u64(diff * LAST_AGE_WEIGHT, 100);
884 /* This returns a new age and allocated blocks in ei */
885 static int __get_new_block_age(struct inode *inode, struct extent_info *ei,
888 struct f2fs_sb_info *sbi = F2FS_I_SB(inode);
889 loff_t f_size = i_size_read(inode);
890 unsigned long long cur_blocks =
891 atomic64_read(&sbi->allocated_data_blocks);
892 struct extent_info tei = *ei; /* only fofs and len are valid */
895 * When I/O is not aligned to a PAGE_SIZE, update will happen to the last
896 * file block even in seq write. So don't record age for newly last file
899 if ((f_size >> PAGE_SHIFT) == ei->fofs && f_size & (PAGE_SIZE - 1) &&
903 if (__lookup_extent_tree(inode, ei->fofs, &tei, EX_BLOCK_AGE)) {
904 unsigned long long cur_age;
906 if (cur_blocks >= tei.last_blocks)
907 cur_age = cur_blocks - tei.last_blocks;
909 /* allocated_data_blocks overflow */
910 cur_age = ULLONG_MAX - tei.last_blocks + cur_blocks;
913 ei->age = __calculate_block_age(cur_age, tei.age);
916 ei->last_blocks = cur_blocks;
917 WARN_ON(ei->age > cur_blocks);
921 f2fs_bug_on(sbi, blkaddr == NULL_ADDR);
923 /* the data block was allocated for the first time */
924 if (blkaddr == NEW_ADDR)
927 if (__is_valid_data_blkaddr(blkaddr) &&
928 !f2fs_is_valid_blkaddr(sbi, blkaddr, DATA_GENERIC_ENHANCE)) {
934 * init block age with zero, this can happen when the block age extent
935 * was reclaimed due to memory constraint or system reboot
938 ei->last_blocks = cur_blocks;
942 static void __update_extent_cache(struct dnode_of_data *dn, enum extent_type type)
944 struct extent_info ei = {};
946 if (!__may_extent_tree(dn->inode, type))
949 ei.fofs = f2fs_start_bidx_of_node(ofs_of_node(dn->node_page), dn->inode) +
953 if (type == EX_READ) {
954 if (dn->data_blkaddr == NEW_ADDR)
957 ei.blk = dn->data_blkaddr;
958 } else if (type == EX_BLOCK_AGE) {
959 if (__get_new_block_age(dn->inode, &ei, dn->data_blkaddr))
962 __update_extent_tree_range(dn->inode, &ei, type);
965 static unsigned int __shrink_extent_tree(struct f2fs_sb_info *sbi, int nr_shrink,
966 enum extent_type type)
968 struct extent_tree_info *eti = &sbi->extent_tree[type];
969 struct extent_tree *et, *next;
970 struct extent_node *en;
971 unsigned int node_cnt = 0, tree_cnt = 0;
974 if (!atomic_read(&eti->total_zombie_tree))
977 if (!mutex_trylock(&eti->extent_tree_lock))
980 /* 1. remove unreferenced extent tree */
981 list_for_each_entry_safe(et, next, &eti->zombie_list, list) {
982 if (atomic_read(&et->node_cnt)) {
983 write_lock(&et->lock);
984 node_cnt += __free_extent_tree(sbi, et);
985 write_unlock(&et->lock);
987 f2fs_bug_on(sbi, atomic_read(&et->node_cnt));
988 list_del_init(&et->list);
989 radix_tree_delete(&eti->extent_tree_root, et->ino);
990 kmem_cache_free(extent_tree_slab, et);
991 atomic_dec(&eti->total_ext_tree);
992 atomic_dec(&eti->total_zombie_tree);
995 if (node_cnt + tree_cnt >= nr_shrink)
999 mutex_unlock(&eti->extent_tree_lock);
1002 /* 2. remove LRU extent entries */
1003 if (!mutex_trylock(&eti->extent_tree_lock))
1006 remained = nr_shrink - (node_cnt + tree_cnt);
1008 spin_lock(&eti->extent_lock);
1009 for (; remained > 0; remained--) {
1010 if (list_empty(&eti->extent_list))
1012 en = list_first_entry(&eti->extent_list,
1013 struct extent_node, list);
1015 if (!write_trylock(&et->lock)) {
1016 /* refresh this extent node's position in extent list */
1017 list_move_tail(&en->list, &eti->extent_list);
1021 list_del_init(&en->list);
1022 spin_unlock(&eti->extent_lock);
1024 __detach_extent_node(sbi, et, en);
1026 write_unlock(&et->lock);
1028 spin_lock(&eti->extent_lock);
1030 spin_unlock(&eti->extent_lock);
1033 mutex_unlock(&eti->extent_tree_lock);
1035 trace_f2fs_shrink_extent_tree(sbi, node_cnt, tree_cnt, type);
1037 return node_cnt + tree_cnt;
1040 /* read extent cache operations */
1041 bool f2fs_lookup_read_extent_cache(struct inode *inode, pgoff_t pgofs,
1042 struct extent_info *ei)
1044 if (!__may_extent_tree(inode, EX_READ))
1047 return __lookup_extent_tree(inode, pgofs, ei, EX_READ);
1050 void f2fs_update_read_extent_cache(struct dnode_of_data *dn)
1052 return __update_extent_cache(dn, EX_READ);
1055 void f2fs_update_read_extent_cache_range(struct dnode_of_data *dn,
1056 pgoff_t fofs, block_t blkaddr, unsigned int len)
1058 struct extent_info ei = {
1064 if (!__may_extent_tree(dn->inode, EX_READ))
1067 __update_extent_tree_range(dn->inode, &ei, EX_READ);
1070 unsigned int f2fs_shrink_read_extent_tree(struct f2fs_sb_info *sbi, int nr_shrink)
1072 if (!test_opt(sbi, READ_EXTENT_CACHE))
1075 return __shrink_extent_tree(sbi, nr_shrink, EX_READ);
1078 /* block age extent cache operations */
1079 bool f2fs_lookup_age_extent_cache(struct inode *inode, pgoff_t pgofs,
1080 struct extent_info *ei)
1082 if (!__may_extent_tree(inode, EX_BLOCK_AGE))
1085 return __lookup_extent_tree(inode, pgofs, ei, EX_BLOCK_AGE);
1088 void f2fs_update_age_extent_cache(struct dnode_of_data *dn)
1090 return __update_extent_cache(dn, EX_BLOCK_AGE);
1093 void f2fs_update_age_extent_cache_range(struct dnode_of_data *dn,
1094 pgoff_t fofs, unsigned int len)
1096 struct extent_info ei = {
1101 if (!__may_extent_tree(dn->inode, EX_BLOCK_AGE))
1104 __update_extent_tree_range(dn->inode, &ei, EX_BLOCK_AGE);
1107 unsigned int f2fs_shrink_age_extent_tree(struct f2fs_sb_info *sbi, int nr_shrink)
1109 if (!test_opt(sbi, AGE_EXTENT_CACHE))
1112 return __shrink_extent_tree(sbi, nr_shrink, EX_BLOCK_AGE);
1115 static unsigned int __destroy_extent_node(struct inode *inode,
1116 enum extent_type type)
1118 struct f2fs_sb_info *sbi = F2FS_I_SB(inode);
1119 struct extent_tree *et = F2FS_I(inode)->extent_tree[type];
1120 unsigned int node_cnt = 0;
1122 if (!et || !atomic_read(&et->node_cnt))
1125 write_lock(&et->lock);
1126 node_cnt = __free_extent_tree(sbi, et);
1127 write_unlock(&et->lock);
1132 void f2fs_destroy_extent_node(struct inode *inode)
1134 __destroy_extent_node(inode, EX_READ);
1135 __destroy_extent_node(inode, EX_BLOCK_AGE);
1138 static void __drop_extent_tree(struct inode *inode, enum extent_type type)
1140 struct f2fs_sb_info *sbi = F2FS_I_SB(inode);
1141 struct extent_tree *et = F2FS_I(inode)->extent_tree[type];
1142 bool updated = false;
1144 if (!__may_extent_tree(inode, type))
1147 write_lock(&et->lock);
1148 __free_extent_tree(sbi, et);
1149 if (type == EX_READ) {
1150 set_inode_flag(inode, FI_NO_EXTENT);
1151 if (et->largest.len) {
1152 et->largest.len = 0;
1156 write_unlock(&et->lock);
1158 f2fs_mark_inode_dirty_sync(inode, true);
1161 void f2fs_drop_extent_tree(struct inode *inode)
1163 __drop_extent_tree(inode, EX_READ);
1164 __drop_extent_tree(inode, EX_BLOCK_AGE);
1167 static void __destroy_extent_tree(struct inode *inode, enum extent_type type)
1169 struct f2fs_sb_info *sbi = F2FS_I_SB(inode);
1170 struct extent_tree_info *eti = &sbi->extent_tree[type];
1171 struct extent_tree *et = F2FS_I(inode)->extent_tree[type];
1172 unsigned int node_cnt = 0;
1177 if (inode->i_nlink && !is_bad_inode(inode) &&
1178 atomic_read(&et->node_cnt)) {
1179 mutex_lock(&eti->extent_tree_lock);
1180 list_add_tail(&et->list, &eti->zombie_list);
1181 atomic_inc(&eti->total_zombie_tree);
1182 mutex_unlock(&eti->extent_tree_lock);
1186 /* free all extent info belong to this extent tree */
1187 node_cnt = __destroy_extent_node(inode, type);
1189 /* delete extent tree entry in radix tree */
1190 mutex_lock(&eti->extent_tree_lock);
1191 f2fs_bug_on(sbi, atomic_read(&et->node_cnt));
1192 radix_tree_delete(&eti->extent_tree_root, inode->i_ino);
1193 kmem_cache_free(extent_tree_slab, et);
1194 atomic_dec(&eti->total_ext_tree);
1195 mutex_unlock(&eti->extent_tree_lock);
1197 F2FS_I(inode)->extent_tree[type] = NULL;
1199 trace_f2fs_destroy_extent_tree(inode, node_cnt, type);
1202 void f2fs_destroy_extent_tree(struct inode *inode)
1204 __destroy_extent_tree(inode, EX_READ);
1205 __destroy_extent_tree(inode, EX_BLOCK_AGE);
1208 static void __init_extent_tree_info(struct extent_tree_info *eti)
1210 INIT_RADIX_TREE(&eti->extent_tree_root, GFP_NOIO);
1211 mutex_init(&eti->extent_tree_lock);
1212 INIT_LIST_HEAD(&eti->extent_list);
1213 spin_lock_init(&eti->extent_lock);
1214 atomic_set(&eti->total_ext_tree, 0);
1215 INIT_LIST_HEAD(&eti->zombie_list);
1216 atomic_set(&eti->total_zombie_tree, 0);
1217 atomic_set(&eti->total_ext_node, 0);
1220 void f2fs_init_extent_cache_info(struct f2fs_sb_info *sbi)
1222 __init_extent_tree_info(&sbi->extent_tree[EX_READ]);
1223 __init_extent_tree_info(&sbi->extent_tree[EX_BLOCK_AGE]);
1225 /* initialize for block age extents */
1226 atomic64_set(&sbi->allocated_data_blocks, 0);
1227 sbi->hot_data_age_threshold = DEF_HOT_DATA_AGE_THRESHOLD;
1228 sbi->warm_data_age_threshold = DEF_WARM_DATA_AGE_THRESHOLD;
1231 int __init f2fs_create_extent_cache(void)
1233 extent_tree_slab = f2fs_kmem_cache_create("f2fs_extent_tree",
1234 sizeof(struct extent_tree));
1235 if (!extent_tree_slab)
1237 extent_node_slab = f2fs_kmem_cache_create("f2fs_extent_node",
1238 sizeof(struct extent_node));
1239 if (!extent_node_slab) {
1240 kmem_cache_destroy(extent_tree_slab);
1246 void f2fs_destroy_extent_cache(void)
1248 kmem_cache_destroy(extent_node_slab);
1249 kmem_cache_destroy(extent_tree_slab);