Merge branch 'mpi-master' into wip-k-fmlpwip-k-fmlp

Conflicts:
	litmus/sched_cedf.c

1 files changed, 13 insertions, 24 deletions

diff --git a/drivers/mmc/card/queue.c b/drivers/mmc/card/queue.c
index e876678176be..6413afa318d2 100644
--- a/drivers/mmc/card/queue.c
+++ b/drivers/mmc/card/queue.c
@@ -55,8 +55,7 @@ static int mmc_queue_thread(void *d)
 
                 spin_lock_irq(q->queue_lock);
                 set_current_state(TASK_INTERRUPTIBLE);
-                if (!blk_queue_plugged(q))
-                        req = blk_fetch_request(q);
+                req = blk_fetch_request(q);
                 mq->req = req;
                 spin_unlock_irq(q->queue_lock);
 
@@ -107,10 +106,12 @@ static void mmc_request(struct request_queue *q)
  * @mq: mmc queue
  * @card: mmc card to attach this queue
  * @lock: queue lock
+ * @subname: partition subname
  *
  * Initialise a MMC card request queue.
  */
-int mmc_init_queue(struct mmc_queue *mq, struct mmc_card *card, spinlock_t *lock)
+int mmc_init_queue(struct mmc_queue *mq, struct mmc_card *card,
+                   spinlock_t *lock, const char *subname)
 {
         struct mmc_host *host = card->host;
         u64 limit = BLK_BOUNCE_HIGH;
@@ -128,26 +129,20 @@ int mmc_init_queue(struct mmc_queue *mq, struct mmc_card *card, spinlock_t *lock
         mq->req = NULL;
 
         blk_queue_prep_rq(mq->queue, mmc_prep_request);
-        blk_queue_ordered(mq->queue, QUEUE_ORDERED_DRAIN);
         queue_flag_set_unlocked(QUEUE_FLAG_NONROT, mq->queue);
         if (mmc_can_erase(card)) {
                 queue_flag_set_unlocked(QUEUE_FLAG_DISCARD, mq->queue);
                 mq->queue->limits.max_discard_sectors = UINT_MAX;
                 if (card->erased_byte == 0)
                         mq->queue->limits.discard_zeroes_data = 1;
-                if (!mmc_can_trim(card) && is_power_of_2(card->erase_size)) {
-                        mq->queue->limits.discard_granularity =
-                                                        card->erase_size << 9;
-                        mq->queue->limits.discard_alignment =
-                                                        card->erase_size << 9;
-                }
+                mq->queue->limits.discard_granularity = card->pref_erase << 9;
                 if (mmc_can_secure_erase_trim(card))
                         queue_flag_set_unlocked(QUEUE_FLAG_SECDISCARD,
                                                 mq->queue);
         }
 
 #ifdef CONFIG_MMC_BLOCK_BOUNCE
-        if (host->max_hw_segs == 1) {
+        if (host->max_segs == 1) {
                 unsigned int bouncesz;
 
                 bouncesz = MMC_QUEUE_BOUNCESZ;
@@ -197,21 +192,23 @@ int mmc_init_queue(struct mmc_queue *mq, struct mmc_card *card, spinlock_t *lock
                 blk_queue_bounce_limit(mq->queue, limit);
                 blk_queue_max_hw_sectors(mq->queue,
                         min(host->max_blk_count, host->max_req_size / 512));
-                blk_queue_max_segments(mq->queue, host->max_hw_segs);
+                blk_queue_max_segments(mq->queue, host->max_segs);
                 blk_queue_max_segment_size(mq->queue, host->max_seg_size);
 
                 mq->sg = kmalloc(sizeof(struct scatterlist) *
-                        host->max_phys_segs, GFP_KERNEL);
+                        host->max_segs, GFP_KERNEL);
                 if (!mq->sg) {
                         ret = -ENOMEM;
                         goto cleanup_queue;
                 }
-                sg_init_table(mq->sg, host->max_phys_segs);
+                sg_init_table(mq->sg, host->max_segs);
         }
 
-        init_MUTEX(&mq->thread_sem);
+        sema_init(&mq->thread_sem, 1);
+
+        mq->thread = kthread_run(mmc_queue_thread, mq, "mmcqd/%d%s",
+                host->index, subname ? subname : "");
 
-        mq->thread = kthread_run(mmc_queue_thread, mq, "mmcqd");
         if (IS_ERR(mq->thread)) {
                 ret = PTR_ERR(mq->thread);
                 goto free_bounce_sg;
@@ -343,18 +340,14 @@ unsigned int mmc_queue_map_sg(struct mmc_queue *mq)
  */
 void mmc_queue_bounce_pre(struct mmc_queue *mq)
 {
-        unsigned long flags;
-
         if (!mq->bounce_buf)
                 return;
 
         if (rq_data_dir(mq->req) != WRITE)
                 return;
 
-        local_irq_save(flags);
         sg_copy_to_buffer(mq->bounce_sg, mq->bounce_sg_len,
                 mq->bounce_buf, mq->sg[0].length);
-        local_irq_restore(flags);
 }
 
 /*
@@ -363,17 +356,13 @@ void mmc_queue_bounce_pre(struct mmc_queue *mq)
  */
 void mmc_queue_bounce_post(struct mmc_queue *mq)
 {
-        unsigned long flags;
-
         if (!mq->bounce_buf)
                 return;
 
         if (rq_data_dir(mq->req) != READ)
                 return;
 
-        local_irq_save(flags);
         sg_copy_from_buffer(mq->bounce_sg, mq->bounce_sg_len,
                 mq->bounce_buf, mq->sg[0].length);
-        local_irq_restore(flags);
 }