Commit 185a453b authored by Yuwei Guan's avatar Yuwei Guan Committed by Jaegeuk Kim

f2fs: deliver the accumulated 'issued' to __issue_discard_cmd_orderly()

Any of the following scenarios will send more than the number of
max_requests at a time, which will not meet the design of the
max_requests limit.

- Set max_ordered_discard larger than discard_granularity from userspace.
- It is a small size device, discard_granularity can be tuned to 1 in
  f2fs_tuning_parameters().

We need to deliver the accumulated @issued to __issue_discard_cmd_orderly()
to meet the max_requests limit.

BTW, convert the parameter type of @issued in __submit_discard_cmd().
Signed-off-by: default avatarYuwei Guan <Yuwei.Guan@zeekrlife.com>
Cc: Bagas Sanjaya <bagasdotme@gmail.com>
Reviewed-by: default avatarChao Yu <chao@kernel.org>
Signed-off-by: default avatarJaegeuk Kim <jaegeuk@kernel.org>
parent 8358014d
...@@ -1095,9 +1095,8 @@ static void __update_discard_tree_range(struct f2fs_sb_info *sbi, ...@@ -1095,9 +1095,8 @@ static void __update_discard_tree_range(struct f2fs_sb_info *sbi,
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 int __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, int *issued)
unsigned int *issued)
{ {
struct block_device *bdev = dc->bdev; struct block_device *bdev = dc->bdev;
unsigned int max_discard_blocks = unsigned int max_discard_blocks =
...@@ -1378,8 +1377,8 @@ static void __queue_discard_cmd(struct f2fs_sb_info *sbi, ...@@ -1378,8 +1377,8 @@ static void __queue_discard_cmd(struct f2fs_sb_info *sbi,
mutex_unlock(&SM_I(sbi)->dcc_info->cmd_lock); mutex_unlock(&SM_I(sbi)->dcc_info->cmd_lock);
} }
static unsigned int __issue_discard_cmd_orderly(struct f2fs_sb_info *sbi, static void __issue_discard_cmd_orderly(struct f2fs_sb_info *sbi,
struct discard_policy *dpolicy) struct discard_policy *dpolicy, int *issued)
{ {
struct discard_cmd_control *dcc = SM_I(sbi)->dcc_info; struct discard_cmd_control *dcc = SM_I(sbi)->dcc_info;
struct discard_cmd *prev_dc = NULL, *next_dc = NULL; struct discard_cmd *prev_dc = NULL, *next_dc = NULL;
...@@ -1387,7 +1386,6 @@ static unsigned int __issue_discard_cmd_orderly(struct f2fs_sb_info *sbi, ...@@ -1387,7 +1386,6 @@ static unsigned int __issue_discard_cmd_orderly(struct f2fs_sb_info *sbi,
struct discard_cmd *dc; struct discard_cmd *dc;
struct blk_plug plug; struct blk_plug plug;
unsigned int pos = dcc->next_pos; unsigned int pos = dcc->next_pos;
unsigned int issued = 0;
bool io_interrupted = false; bool io_interrupted = false;
mutex_lock(&dcc->cmd_lock); mutex_lock(&dcc->cmd_lock);
...@@ -1414,9 +1412,9 @@ static unsigned int __issue_discard_cmd_orderly(struct f2fs_sb_info *sbi, ...@@ -1414,9 +1412,9 @@ 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;
err = __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);
...@@ -1432,10 +1430,8 @@ static unsigned int __issue_discard_cmd_orderly(struct f2fs_sb_info *sbi, ...@@ -1432,10 +1430,8 @@ static unsigned int __issue_discard_cmd_orderly(struct f2fs_sb_info *sbi,
mutex_unlock(&dcc->cmd_lock); mutex_unlock(&dcc->cmd_lock);
if (!issued && io_interrupted) if (!(*issued) && io_interrupted)
issued = -1; *issued = -1;
return issued;
} }
static unsigned int __wait_all_discard_cmd(struct f2fs_sb_info *sbi, static unsigned int __wait_all_discard_cmd(struct f2fs_sb_info *sbi,
struct discard_policy *dpolicy); struct discard_policy *dpolicy);
...@@ -1463,8 +1459,10 @@ static int __issue_discard_cmd(struct f2fs_sb_info *sbi, ...@@ -1463,8 +1459,10 @@ static int __issue_discard_cmd(struct f2fs_sb_info *sbi,
if (i + 1 < dpolicy->granularity) if (i + 1 < dpolicy->granularity)
break; break;
if (i + 1 < dcc->max_ordered_discard && dpolicy->ordered) if (i + 1 < dcc->max_ordered_discard && dpolicy->ordered) {
return __issue_discard_cmd_orderly(sbi, dpolicy); __issue_discard_cmd_orderly(sbi, dpolicy, &issued);
return issued;
}
pend_list = &dcc->pend_list[i]; pend_list = &dcc->pend_list[i];
......
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