ClabureDB: Classified Bug-Reports Database

 
         blk_add_trace_generic(q, bio, rw, BLK_TA_GETRQ);
 out:
         return rq;
 }
 
 /*
  * No available requests for this queue, unplug the device and wait for some
  * requests to become available.
  *
  * Called with q->queue_lock held, and returns with it unlocked.
  */
 static struct request *get_request_wait(struct request_queue *q, int rw_flags,
                                         struct bio *bio)
 {
         const int rw = rw_flags & 0x01;
         struct request *rq;
 
         rq = get_request(q, rw_flags, bio, GFP_NOIO);
         while (!rq) {
                 DEFINE_WAIT(wait);
                 struct io_context *ioc;
                 struct request_list *rl = &q->rq;
 
                 prepare_to_wait_exclusive(&rl->wait[rw], &wait,
                                 TASK_UNINTERRUPTIBLE);
 
                 blk_add_trace_generic(q, bio, rw, BLK_TA_SLEEPRQ);
 
                 __generic_unplug_device(q);
                 spin_unlock_irq(q->queue_lock);
                 io_schedule();
 
                 /*
                  * After sleeping, we become a "batching" process and
                  * will be able to allocate at least one request, and
                  * up to a big batch of them for a small period time.
                  * See ioc_batching, ioc_set_batching
                  */
                 ioc = current_io_context(GFP_NOIO, q->node);
                 ioc_set_batching(q, ioc);