Commit 6b9cb124 authored by Chao Yu's avatar Chao Yu Committed by Jaegeuk Kim

f2fs: fix use-after-free of dicard command entry

As Dan Carpenter reported:

The patch 20ee4382: "f2fs: issue small discard by LBA order" from
Jul 8, 2018, leads to the following Smatch warning:

	fs/f2fs/segment.c:1277 __issue_discard_cmd_orderly()
	warn: 'dc' was already freed.

See also:
fs/f2fs/segment.c:2550 __issue_discard_cmd_range() warn: 'dc' was already freed.

In order to fix this issue, let's get error from __submit_discard_cmd(),
and release current discard command after we referenced next one.
Reported-by: default avatarDan Carpenter <dan.carpenter@oracle.com>
Signed-off-by: default avatarChao Yu <yuchao0@huawei.com>
Signed-off-by: default avatarJaegeuk Kim <jaegeuk@kernel.org>
parent b83dcfe6
...@@ -994,7 +994,7 @@ static void __update_discard_tree_range(struct f2fs_sb_info *sbi, ...@@ -994,7 +994,7 @@ static void __update_discard_tree_range(struct f2fs_sb_info *sbi,
struct block_device *bdev, block_t lstart, struct block_device *bdev, block_t lstart,
block_t start, block_t len); block_t start, block_t len);
/* this function is copied from blkdev_issue_discard from block/blk-lib.c */ /* this function is copied from blkdev_issue_discard from block/blk-lib.c */
static void __submit_discard_cmd(struct f2fs_sb_info *sbi, static int __submit_discard_cmd(struct f2fs_sb_info *sbi,
struct discard_policy *dpolicy, struct discard_policy *dpolicy,
struct discard_cmd *dc, struct discard_cmd *dc,
unsigned int *issued) unsigned int *issued)
...@@ -1011,10 +1011,10 @@ static void __submit_discard_cmd(struct f2fs_sb_info *sbi, ...@@ -1011,10 +1011,10 @@ static void __submit_discard_cmd(struct f2fs_sb_info *sbi,
int err = 0; int err = 0;
if (dc->state != D_PREP) if (dc->state != D_PREP)
return; return 0;
if (is_sbi_flag_set(sbi, SBI_NEED_FSCK)) if (is_sbi_flag_set(sbi, SBI_NEED_FSCK))
return; return 0;
trace_f2fs_issue_discard(bdev, dc->start, dc->len); trace_f2fs_issue_discard(bdev, dc->start, dc->len);
...@@ -1053,43 +1053,44 @@ static void __submit_discard_cmd(struct f2fs_sb_info *sbi, ...@@ -1053,43 +1053,44 @@ static void __submit_discard_cmd(struct f2fs_sb_info *sbi,
SECTOR_FROM_BLOCK(len), SECTOR_FROM_BLOCK(len),
GFP_NOFS, 0, &bio); GFP_NOFS, 0, &bio);
submit: submit:
if (!err && bio) { if (err) {
/*
* should keep before submission to avoid D_DONE
* right away
*/
spin_lock_irqsave(&dc->lock, flags); spin_lock_irqsave(&dc->lock, flags);
if (last) if (dc->state == D_PARTIAL)
dc->state = D_SUBMIT; dc->state = D_SUBMIT;
else
dc->state = D_PARTIAL;
dc->bio_ref++;
spin_unlock_irqrestore(&dc->lock, flags); spin_unlock_irqrestore(&dc->lock, flags);
atomic_inc(&dcc->issing_discard); break;
dc->issuing++; }
list_move_tail(&dc->list, wait_list);
/* sanity check on discard range */ f2fs_bug_on(sbi, !bio);
__check_sit_bitmap(sbi, start, start + len);
bio->bi_private = dc; /*
bio->bi_end_io = f2fs_submit_discard_endio; * should keep before submission to avoid D_DONE
bio->bi_opf |= flag; * right away
submit_bio(bio); */
spin_lock_irqsave(&dc->lock, flags);
if (last)
dc->state = D_SUBMIT;
else
dc->state = D_PARTIAL;
dc->bio_ref++;
spin_unlock_irqrestore(&dc->lock, flags);
atomic_inc(&dcc->issued_discard); atomic_inc(&dcc->issing_discard);
dc->issuing++;
list_move_tail(&dc->list, wait_list);
f2fs_update_iostat(sbi, FS_DISCARD, 1); /* sanity check on discard range */
} else { __check_sit_bitmap(sbi, start, start + len);
spin_lock_irqsave(&dc->lock, flags);
if (dc->state == D_PARTIAL)
dc->state = D_SUBMIT;
spin_unlock_irqrestore(&dc->lock, flags);
__remove_discard_cmd(sbi, dc); bio->bi_private = dc;
err = -EIO; bio->bi_end_io = f2fs_submit_discard_endio;
} bio->bi_opf |= flag;
submit_bio(bio);
atomic_inc(&dcc->issued_discard);
f2fs_update_iostat(sbi, FS_DISCARD, 1);
lstart += len; lstart += len;
start += len; start += len;
...@@ -1097,8 +1098,9 @@ static void __submit_discard_cmd(struct f2fs_sb_info *sbi, ...@@ -1097,8 +1098,9 @@ static void __submit_discard_cmd(struct f2fs_sb_info *sbi,
len = total_len; len = total_len;
} }
if (len) if (!err && len)
__update_discard_tree_range(sbi, bdev, lstart, start, len); __update_discard_tree_range(sbi, bdev, lstart, start, len);
return err;
} }
static struct discard_cmd *__insert_discard_tree(struct f2fs_sb_info *sbi, static struct discard_cmd *__insert_discard_tree(struct f2fs_sb_info *sbi,
...@@ -1304,6 +1306,7 @@ static unsigned int __issue_discard_cmd_orderly(struct f2fs_sb_info *sbi, ...@@ -1304,6 +1306,7 @@ static unsigned int __issue_discard_cmd_orderly(struct f2fs_sb_info *sbi,
while (dc) { while (dc) {
struct rb_node *node; struct rb_node *node;
int err = 0;
if (dc->state != D_PREP) if (dc->state != D_PREP)
goto next; goto next;
...@@ -1314,12 +1317,14 @@ static unsigned int __issue_discard_cmd_orderly(struct f2fs_sb_info *sbi, ...@@ -1314,12 +1317,14 @@ static unsigned int __issue_discard_cmd_orderly(struct f2fs_sb_info *sbi,
} }
dcc->next_pos = dc->lstart + dc->len; dcc->next_pos = dc->lstart + dc->len;
__submit_discard_cmd(sbi, dpolicy, dc, &issued); err = __submit_discard_cmd(sbi, dpolicy, dc, &issued);
if (issued >= dpolicy->max_requests) if (issued >= dpolicy->max_requests)
break; break;
next: next:
node = rb_next(&dc->rb_node); node = rb_next(&dc->rb_node);
if (err)
__remove_discard_cmd(sbi, dc);
dc = rb_entry_safe(node, struct discard_cmd, rb_node); dc = rb_entry_safe(node, struct discard_cmd, rb_node);
} }
...@@ -2571,6 +2576,7 @@ static unsigned int __issue_discard_cmd_range(struct f2fs_sb_info *sbi, ...@@ -2571,6 +2576,7 @@ static unsigned int __issue_discard_cmd_range(struct f2fs_sb_info *sbi,
while (dc && dc->lstart <= end) { while (dc && dc->lstart <= end) {
struct rb_node *node; struct rb_node *node;
int err = 0;
if (dc->len < dpolicy->granularity) if (dc->len < dpolicy->granularity)
goto skip; goto skip;
...@@ -2580,11 +2586,14 @@ static unsigned int __issue_discard_cmd_range(struct f2fs_sb_info *sbi, ...@@ -2580,11 +2586,14 @@ static unsigned int __issue_discard_cmd_range(struct f2fs_sb_info *sbi,
goto skip; goto skip;
} }
__submit_discard_cmd(sbi, dpolicy, dc, &issued); err = __submit_discard_cmd(sbi, dpolicy, dc, &issued);
if (issued >= dpolicy->max_requests) { if (issued >= dpolicy->max_requests) {
start = dc->lstart + dc->len; start = dc->lstart + dc->len;
if (err)
__remove_discard_cmd(sbi, dc);
blk_finish_plug(&plug); blk_finish_plug(&plug);
mutex_unlock(&dcc->cmd_lock); mutex_unlock(&dcc->cmd_lock);
trimmed += __wait_all_discard_cmd(sbi, NULL); trimmed += __wait_all_discard_cmd(sbi, NULL);
...@@ -2593,6 +2602,8 @@ static unsigned int __issue_discard_cmd_range(struct f2fs_sb_info *sbi, ...@@ -2593,6 +2602,8 @@ static unsigned int __issue_discard_cmd_range(struct f2fs_sb_info *sbi,
} }
skip: skip:
node = rb_next(&dc->rb_node); node = rb_next(&dc->rb_node);
if (err)
__remove_discard_cmd(sbi, dc);
dc = rb_entry_safe(node, struct discard_cmd, rb_node); dc = rb_entry_safe(node, struct discard_cmd, rb_node);
if (fatal_signal_pending(current)) if (fatal_signal_pending(current))
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment