|
@@ -798,3 +798,28 @@ static inline long nr_pages_to_write(struct f2fs_sb_info *sbi, int type,
|
|
|
wbc->nr_to_write = desired;
|
|
|
return desired - nr_to_write;
|
|
|
}
|
|
|
+
|
|
|
+static inline void wake_up_discard_thread(struct f2fs_sb_info *sbi, bool force)
|
|
|
+{
|
|
|
+ struct discard_cmd_control *dcc = SM_I(sbi)->dcc_info;
|
|
|
+ bool wakeup = false;
|
|
|
+ int i;
|
|
|
+
|
|
|
+ if (force)
|
|
|
+ goto wake_up;
|
|
|
+
|
|
|
+ mutex_lock(&dcc->cmd_lock);
|
|
|
+ for (i = MAX_PLIST_NUM - 1;
|
|
|
+ i >= 0 && plist_issue(dcc->pend_list_tag[i]); i--) {
|
|
|
+ if (!list_empty(&dcc->pend_list[i])) {
|
|
|
+ wakeup = true;
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ mutex_unlock(&dcc->cmd_lock);
|
|
|
+ if (!wakeup)
|
|
|
+ return;
|
|
|
+wake_up:
|
|
|
+ dcc->discard_wake = 1;
|
|
|
+ wake_up_interruptible_all(&dcc->discard_wait_queue);
|
|
|
+}
|