CFQ_CFQQ_FLAG_prio_changed,     /* task priority has changed */
        CFQ_CFQQ_FLAG_slice_new,        /* no requests dispatched in slice */
        CFQ_CFQQ_FLAG_sync,             /* synchronous queue */
 -      CFQ_CFQQ_FLAG_coop,             /* has done a coop jump of the queue */
 +      CFQ_CFQQ_FLAG_coop,             /* cfqq is shared */
+       CFQ_CFQQ_FLAG_coop_preempt,     /* coop preempt */
  };
  
  #define CFQ_CFQQ_FNS(name)                                            \
  static struct cfq_queue *cfq_set_active_queue(struct cfq_data *cfqd,
                                              struct cfq_queue *cfqq)
  {
-       if (!cfqq)
+       if (!cfqq) {
                cfqq = cfq_get_next_queue(cfqd);
 +
+               if (cfqq && !cfq_cfqq_coop_preempt(cfqq))
+                       cfq_clear_cfqq_coop(cfqq);
+       }
+ 
+       if (cfqq)
+               cfq_clear_cfqq_coop_preempt(cfqq);
+ 
        __cfq_set_active_queue(cfqd, cfqq);
        return cfqq;
  }
         * if this request is as-good as one we would expect from the
         * current cfqq, let it preempt
         */
 -      if (cfq_rq_close(cfqd, rq) && (!cfq_cfqq_coop(new_cfqq) ||
 +      if (cfq_rq_close(cfqd, cfqq, rq))
++      if (cfq_rq_close(cfqd, cfqq, rq) && (!cfq_cfqq_coop(new_cfqq) ||
+           cfqd->busy_queues == 1)) {
+               /*
+                * Mark new queue coop_preempt, so its coop flag will not be
+                * cleared when new queue gets scheduled at the very first time
+                */
+               cfq_mark_cfqq_coop_preempt(new_cfqq);
+               cfq_mark_cfqq_coop(new_cfqq);
                return true;
+       }
  
        return false;
  }