|
@@ -133,6 +133,10 @@ static int mtd_blktrans_thread(void *arg)
|
|
|
|
|
|
if (!req && !(req = blk_fetch_request(rq))) {
|
|
if (!req && !(req = blk_fetch_request(rq))) {
|
|
set_current_state(TASK_INTERRUPTIBLE);
|
|
set_current_state(TASK_INTERRUPTIBLE);
|
|
|
|
+
|
|
|
|
+ if (kthread_should_stop())
|
|
|
|
+ set_current_state(TASK_RUNNING);
|
|
|
|
+
|
|
spin_unlock_irq(rq->queue_lock);
|
|
spin_unlock_irq(rq->queue_lock);
|
|
schedule();
|
|
schedule();
|
|
spin_lock_irq(rq->queue_lock);
|
|
spin_lock_irq(rq->queue_lock);
|