linux/block/bsg-lib.c

31 	struct bsg_job *job;
49 	job = blk_mq_rq_to_pdu(rq);
50 	reply = job->reply;
51 	memset(job, 0, sizeof(*job));
52 	job->reply = reply;
53 	job->reply_len = SCSI_SENSE_BUFFERSIZE;
54 	job->dd_data = job + 1;
56 	job->request_len = hdr->request_len;
57 	job->request = memdup_user(uptr64(hdr->request), hdr->request_len);
58 	if (IS_ERR(job->request)) {
59 		ret = PTR_ERR(job->request);
64 		job->bidi_rq = blk_mq_alloc_request(rq->q, REQ_OP_DRV_IN, 0);
65 		if (IS_ERR(job->bidi_rq)) {
66 			ret = PTR_ERR(job->bidi_rq);
70 		ret = blk_rq_map_user(rq->q, job->bidi_rq, NULL,
76 		job->bidi_bio = job->bidi_rq->bio;
78 		job->bidi_rq = NULL;
79 		job->bidi_bio = NULL;
101 	hdr->device_status = job->result & 0xff;
102 	hdr->transport_status = host_byte(job->result);
109 	if (job->result < 0) {
111 		job->reply_len = sizeof(u32);
112 		ret = job->result;
115 	if (job->reply_len && hdr->response) {
116 		int len = min(hdr->max_response_len, job->reply_len);
118 		if (copy_to_user(uptr64(hdr->response), job->reply, len))
127 	if (job->bidi_rq) {
128 		unsigned int rsp_len = job->reply_payload.payload_len;
130 		if (WARN_ON(job->reply_payload_rcv_len > rsp_len))
133 			hdr->din_resid = rsp_len - job->reply_payload_rcv_len;
140 	if (job->bidi_rq)
141 		blk_rq_unmap_user(job->bidi_bio);
143 	if (job->bidi_rq)
144 		blk_mq_free_request(job->bidi_rq);
146 	kfree(job->request);
153  * bsg_teardown_job - routine to teardown a bsg job
158 	struct bsg_job *job = container_of(kref, struct bsg_job, kref);
159 	struct request *rq = blk_mq_rq_from_pdu(job);
161 	put_device(job->dev);	/* release reference for the request */
163 	kfree(job->request_payload.sg_list);
164 	kfree(job->reply_payload.sg_list);
169 void bsg_job_put(struct bsg_job *job)
171 	kref_put(&job->kref, bsg_teardown_job);
175 int bsg_job_get(struct bsg_job *job)
177 	return kref_get_unless_zero(&job->kref);
183  * @job: bsg_job that is complete
184  * @result: job reply result
187  * The LLD should call this when the bsg job has completed.
189 void bsg_job_done(struct bsg_job *job, int result,
192 	struct request *rq = blk_mq_rq_from_pdu(job);
194 	job->result = result;
195 	job->reply_payload_rcv_len = reply_payload_rcv_len;
203  * @rq: BSG request that holds the job to be destroyed
207 	struct bsg_job *job = blk_mq_rq_to_pdu(rq);
209 	bsg_job_put(job);
230  * @req: BSG request that needs a job structure
234 	struct bsg_job *job = blk_mq_rq_to_pdu(req);
237 	job->timeout = req->timeout;
240 		ret = bsg_map_buffer(&job->request_payload, req);
244 	if (job->bidi_rq) {
245 		ret = bsg_map_buffer(&job->reply_payload, job->bidi_rq);
249 	job->dev = dev;
251 	get_device(job->dev);
252 	kref_init(&job->kref);
256 	kfree(job->request_payload.sg_list);
258 	job->result = -ENOMEM;
304 	struct bsg_job *job = blk_mq_rq_to_pdu(req);
306 	job->reply = kzalloc(SCSI_SENSE_BUFFERSIZE, GFP_KERNEL);
307 	if (!job->reply)
315 	struct bsg_job *job = blk_mq_rq_to_pdu(req);
317 	kfree(job->reply);
358  * @job_fn: bsg job handler
360  * @dd_job_size: size of LLD data needed for each job