|
@@ -86,8 +86,8 @@ static int mmc_queue_thread(void *d)
|
|
|
set_current_state(TASK_RUNNING);
|
|
|
mmc_blk_issue_rq(mq, req);
|
|
|
cond_resched();
|
|
|
- if (mq->flags & MMC_QUEUE_NEW_REQUEST) {
|
|
|
- mq->flags &= ~MMC_QUEUE_NEW_REQUEST;
|
|
|
+ if (mq->new_request) {
|
|
|
+ mq->new_request = false;
|
|
|
continue; /* fetch again */
|
|
|
}
|
|
|
|
|
@@ -401,8 +401,8 @@ void mmc_queue_suspend(struct mmc_queue *mq)
|
|
|
struct request_queue *q = mq->queue;
|
|
|
unsigned long flags;
|
|
|
|
|
|
- if (!(mq->flags & MMC_QUEUE_SUSPENDED)) {
|
|
|
- mq->flags |= MMC_QUEUE_SUSPENDED;
|
|
|
+ if (!mq->suspended) {
|
|
|
+ mq->suspended |= true;
|
|
|
|
|
|
spin_lock_irqsave(q->queue_lock, flags);
|
|
|
blk_stop_queue(q);
|
|
@@ -421,8 +421,8 @@ void mmc_queue_resume(struct mmc_queue *mq)
|
|
|
struct request_queue *q = mq->queue;
|
|
|
unsigned long flags;
|
|
|
|
|
|
- if (mq->flags & MMC_QUEUE_SUSPENDED) {
|
|
|
- mq->flags &= ~MMC_QUEUE_SUSPENDED;
|
|
|
+ if (mq->suspended) {
|
|
|
+ mq->suspended = false;
|
|
|
|
|
|
up(&mq->thread_sem);
|
|
|
|