Many works will go to submit_bio(), and in many cases the io priority
of kworker cannot meet the real-time requirements of this work.
So create a new struct io_work, which contains the io priority that
the kworker thread can adjust its own io priority according to.
And,
new function set_io_work_ioprio() to set the io priority of io work,
new function may_adjust_io_work_task_ioprio() to adjust kworker's io
priority,
new function restore_io_work_task_ioprio() to restore kworker's io
priority.
Signed-off-by: Yi Sun <yi....@unisoc.com>
---
include/linux/workqueue.h | 47 ++++++++++++++++++++++++++++++++++++
kernel/workqueue.c | 50 +++++++++++++++++++++++++++++++++++++++
2 files changed, 97 insertions(+)
diff --git a/include/linux/workqueue.h b/include/linux/workqueue.h
index d9968bfc8eac..4b2cb54a68b2 100644
--- a/include/linux/workqueue.h
+++ b/include/linux/workqueue.h
@@ -127,6 +127,21 @@ struct rcu_work {
struct workqueue_struct *wq;
};
+/*
+ * If a work may do disk IO, it is recommended to use struct io_work
+ * instead of struct work_struct.
+ */
+struct io_work {
+ struct work_struct work;
+
+ /* If the work does submit_bio, io priority may be needed. */
+ unsigned short ioprio;
+ /* Record kworker's original io priority. */
+ unsigned short ori_ioprio;
+ /* Whether the work has set io priority? */
+ long ioprio_flag;
+};
+
enum wq_affn_scope {
WQ_AFFN_DFL, /* use system default */
WQ_AFFN_CPU, /* one pod per CPU */
@@ -218,6 +233,11 @@ static inline struct rcu_work *to_rcu_work(struct
work_struct *work)
return container_of(work, struct rcu_work, work);
}
+static inline struct io_work *to_io_work(struct work_struct *work)
+{
+ return container_of(work, struct io_work, work);
+}
+
struct execute_work {
struct work_struct work;
};
@@ -347,6 +367,18 @@ static inline unsigned int work_static(struct work_struct
*work) { return 0; }
#define INIT_RCU_WORK_ONSTACK(_work, _func) \
INIT_WORK_ONSTACK(&(_work)->work, (_func))
+#define INIT_IO_WORK(_work, _func) \
+ do { \
+ INIT_WORK(&(_work)->work, (_func)); \
+ (_work)->ioprio_flag = 0; \
+ } while (0)
+
+#define INIT_IO_WORK_ONSTACK(_work, _func) \
+ do { \
+ INIT_WORK_ONSTACK(&(_work)->work, (_func)); \
+ (_work)->ioprio_flag = 0; \
+ } while (0)
+
/**
* work_pending - Find out whether a work item is currently pending
* @work: The work item in question
@@ -552,6 +584,10 @@ extern bool mod_delayed_work_on(int cpu, struct
workqueue_struct *wq,
struct delayed_work *dwork, unsigned long delay);
extern bool queue_rcu_work(struct workqueue_struct *wq, struct rcu_work
*rwork);
+extern void set_io_work_ioprio(struct io_work *work, unsigned short ioprio);
+extern void may_adjust_io_work_task_ioprio(struct io_work *work);
+extern void restore_io_work_task_ioprio(struct io_work *work);
+
extern void __flush_workqueue(struct workqueue_struct *wq);
extern void drain_workqueue(struct workqueue_struct *wq);
@@ -636,6 +672,17 @@ static inline bool queue_delayed_work(struct
workqueue_struct *wq,
return queue_delayed_work_on(WORK_CPU_UNBOUND, wq, dwork, delay);
}
+/**
+ * queue_io_work - queue io work on a workqueue
+ * @wq: workqueue to use
+ * @iowork: io work to queue
+ */
+static inline bool queue_io_work(struct workqueue_struct *wq,
+ struct io_work *iowork)
+{
+ return queue_work(wq, &(iowork->work));
+}
+
/**
* mod_delayed_work - modify delay of or queue a delayed work
* @wq: workqueue to use
diff --git a/kernel/workqueue.c b/kernel/workqueue.c
index 3fbaecfc88c2..a55b74d5f560 100644
--- a/kernel/workqueue.c
+++ b/kernel/workqueue.c
@@ -2652,6 +2652,56 @@ bool queue_rcu_work(struct workqueue_struct *wq, struct
rcu_work *rwork)
}
EXPORT_SYMBOL(queue_rcu_work);
+/**
+ * set_io_work_ioprio - set io priority for the current io work
+ * @iowork: the io work to be set
+ * @ioprio: desired io priority
+ *
+ * This function can be called after INIT_IO_WORK if the io priority
+ * of the io work needs to adjust. And it is recommended to use this
+ * function together with may_adjust_io_work_task_ioprio() and
+ * restore_io_work_task_ioprio().
+ */
+void set_io_work_ioprio(struct io_work *iowork, unsigned short ioprio)
+{
+ iowork->ioprio = ioprio;
+ iowork->ioprio_flag = 1;
+}
+EXPORT_SYMBOL(set_io_work_ioprio);
+
+/**
+ * may_adjust_io_work_task_ioprio - maybe adjust the io priority of kworker
+ * @iowork: the io work that kworker will do
+ *
+ * It is recommended to use this function together with set_io_work_ioprio()
+ * and restore_io_work_task_ioprio().
+ */
+void may_adjust_io_work_task_ioprio(struct io_work *iowork)
+{
+ if (iowork->ioprio_flag) {
+ iowork->ori_ioprio = get_current_ioprio();
+ set_task_ioprio(current, iowork->ioprio);
+ }
+}
+EXPORT_SYMBOL(may_adjust_io_work_task_ioprio);
+
+/**
+ * restore_io_work_task_ioprio - restore the io priority of kworker
+ * @iowork: the io work that kworker just did
+ *
+ * When kworker finishes the io work, the original io priority of
+ * kworker should be restored. It is recommended to use this function
+ * together with set_io_work_ioprio() and may_adjust_io_work_task_ioprio().
+ */
+void restore_io_work_task_ioprio(struct io_work *iowork)
+{
+ if (iowork->ioprio_flag) {
+ set_task_ioprio(current, iowork->ori_ioprio);
+ iowork->ioprio_flag = 0;
+ }
+}
+EXPORT_SYMBOL(restore_io_work_task_ioprio);
+
static struct worker *alloc_worker(int node)
{
struct worker *worker;
--
2.25.1
_______________________________________________
Linux-f2fs-devel mailing list
Linux-f2fs-devel@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/linux-f2fs-devel
