Loading fs/io-wq.c +0 −10 Original line number Diff line number Diff line Loading @@ -32,7 +32,6 @@ enum { enum { IO_WQ_BIT_EXIT = 0, /* wq exiting */ IO_WQ_BIT_ERROR = 1, /* error on setup */ }; enum { Loading Loading @@ -733,7 +732,6 @@ static int io_wq_manager(void *data) { struct io_wq *wq = data; char buf[TASK_COMM_LEN]; int node; sprintf(buf, "iou-mgr-%d", wq->task_pid); set_task_comm(current, buf); Loading @@ -751,14 +749,6 @@ static int io_wq_manager(void *data) } while (!test_bit(IO_WQ_BIT_EXIT, &wq->state)); io_wq_check_workers(wq); /* if ERROR is set and we get here, we have workers to wake */ if (test_bit(IO_WQ_BIT_ERROR, &wq->state)) { rcu_read_lock(); for_each_node(node) io_wq_for_each_worker(wq->wqes[node], io_wq_worker_wake, NULL); rcu_read_unlock(); } wq->manager = NULL; io_wq_put(wq); do_exit(0); Loading Loading
fs/io-wq.c +0 −10 Original line number Diff line number Diff line Loading @@ -32,7 +32,6 @@ enum { enum { IO_WQ_BIT_EXIT = 0, /* wq exiting */ IO_WQ_BIT_ERROR = 1, /* error on setup */ }; enum { Loading Loading @@ -733,7 +732,6 @@ static int io_wq_manager(void *data) { struct io_wq *wq = data; char buf[TASK_COMM_LEN]; int node; sprintf(buf, "iou-mgr-%d", wq->task_pid); set_task_comm(current, buf); Loading @@ -751,14 +749,6 @@ static int io_wq_manager(void *data) } while (!test_bit(IO_WQ_BIT_EXIT, &wq->state)); io_wq_check_workers(wq); /* if ERROR is set and we get here, we have workers to wake */ if (test_bit(IO_WQ_BIT_ERROR, &wq->state)) { rcu_read_lock(); for_each_node(node) io_wq_for_each_worker(wq->wqes[node], io_wq_worker_wake, NULL); rcu_read_unlock(); } wq->manager = NULL; io_wq_put(wq); do_exit(0); Loading