Lines Matching refs:job
39 struct bsg_job *job = blk_mq_rq_to_pdu(rq);
42 job->request_len = hdr->request_len;
43 job->request = memdup_user(uptr64(hdr->request), hdr->request_len);
44 if (IS_ERR(job->request))
45 return PTR_ERR(job->request);
48 job->bidi_rq = blk_get_request(rq->q, REQ_OP_SCSI_IN, 0);
49 if (IS_ERR(job->bidi_rq)) {
50 ret = PTR_ERR(job->bidi_rq);
54 ret = blk_rq_map_user(rq->q, job->bidi_rq, NULL,
60 job->bidi_bio = job->bidi_rq->bio;
62 job->bidi_rq = NULL;
63 job->bidi_bio = NULL;
69 if (job->bidi_rq)
70 blk_put_request(job->bidi_rq);
72 kfree(job->request);
78 struct bsg_job *job = blk_mq_rq_to_pdu(rq);
85 hdr->device_status = job->result & 0xff;
86 hdr->transport_status = host_byte(job->result);
87 hdr->driver_status = driver_byte(job->result);
93 if (job->result < 0) {
95 job->reply_len = sizeof(u32);
96 ret = job->result;
99 if (job->reply_len && hdr->response) {
100 int len = min(hdr->max_response_len, job->reply_len);
102 if (copy_to_user(uptr64(hdr->response), job->reply, len))
111 if (job->bidi_rq) {
112 unsigned int rsp_len = job->reply_payload.payload_len;
114 if (WARN_ON(job->reply_payload_rcv_len > rsp_len))
117 hdr->din_resid = rsp_len - job->reply_payload_rcv_len;
127 struct bsg_job *job = blk_mq_rq_to_pdu(rq);
129 if (job->bidi_rq) {
130 blk_rq_unmap_user(job->bidi_bio);
131 blk_put_request(job->bidi_rq);
134 kfree(job->request);
145 * bsg_teardown_job - routine to teardown a bsg job
150 struct bsg_job *job = container_of(kref, struct bsg_job, kref);
151 struct request *rq = blk_mq_rq_from_pdu(job);
153 put_device(job->dev); /* release reference for the request */
155 kfree(job->request_payload.sg_list);
156 kfree(job->reply_payload.sg_list);
161 void bsg_job_put(struct bsg_job *job)
163 kref_put(&job->kref, bsg_teardown_job);
167 int bsg_job_get(struct bsg_job *job)
169 return kref_get_unless_zero(&job->kref);
175 * @job: bsg_job that is complete
176 * @result: job reply result
179 * The LLD should call this when the bsg job has completed.
181 void bsg_job_done(struct bsg_job *job, int result,
184 struct request *rq = blk_mq_rq_from_pdu(job);
186 job->result = result;
187 job->reply_payload_rcv_len = reply_payload_rcv_len;
195 * @rq: BSG request that holds the job to be destroyed
199 struct bsg_job *job = blk_mq_rq_to_pdu(rq);
201 bsg_job_put(job);
222 * @req: BSG request that needs a job structure
226 struct bsg_job *job = blk_mq_rq_to_pdu(req);
229 job->timeout = req->timeout;
232 ret = bsg_map_buffer(&job->request_payload, req);
236 if (job->bidi_rq) {
237 ret = bsg_map_buffer(&job->reply_payload, job->bidi_rq);
241 job->dev = dev;
243 get_device(job->dev);
244 kref_init(&job->kref);
248 kfree(job->request_payload.sg_list);
250 job->result = -ENOMEM;
296 struct bsg_job *job = blk_mq_rq_to_pdu(req);
298 job->reply = kzalloc(SCSI_SENSE_BUFFERSIZE, GFP_KERNEL);
299 if (!job->reply)
307 struct bsg_job *job = blk_mq_rq_to_pdu(req);
308 void *reply = job->reply;
310 memset(job, 0, sizeof(*job));
311 job->reply = reply;
312 job->reply_len = SCSI_SENSE_BUFFERSIZE;
313 job->dd_data = job + 1;
319 struct bsg_job *job = blk_mq_rq_to_pdu(req);
321 kfree(job->reply);
361 * @job_fn: bsg job handler
363 * @dd_job_size: size of LLD data needed for each job