Lines Matching refs:rq
32 struct request *rq;
43 rq = blk_mq_alloc_request(q, hdr->dout_xfer_len ?
45 if (IS_ERR(rq))
46 return PTR_ERR(rq);
47 rq->timeout = timeout;
49 job = blk_mq_rq_to_pdu(rq);
64 job->bidi_rq = blk_mq_alloc_request(rq->q, REQ_OP_DRV_IN, 0);
70 ret = blk_rq_map_user(rq->q, job->bidi_rq, NULL,
84 ret = blk_rq_map_user(rq->q, rq, NULL, uptr64(hdr->dout_xferp),
87 ret = blk_rq_map_user(rq->q, rq, NULL, uptr64(hdr->din_xferp),
94 bio = rq->bio;
95 blk_execute_rq(rq, !(hdr->flags & BSG_FLAG_Q_AT_TAIL));
148 blk_mq_free_request(rq);
159 struct request *rq = blk_mq_rq_from_pdu(job);
166 blk_mq_end_request(rq, BLK_STS_OK);
192 struct request *rq = blk_mq_rq_from_pdu(job);
196 if (likely(!blk_should_fake_timeout(rq->q)))
197 blk_mq_complete_request(rq);
203 * @rq: BSG request that holds the job to be destroyed
205 static void bsg_complete(struct request *rq)
207 struct bsg_job *job = blk_mq_rq_to_pdu(rq);
277 struct request *req = bd->rq;
335 static enum blk_eh_timer_return bsg_timeout(struct request *rq)
338 container_of(rq->q->tag_set, struct bsg_set, tag_set);
342 return bset->timeout_fn(rq);