192 static int sg_start_req(Sg_request *srp, unsigned char *cmd);
193 static int sg_finish_rem_req(Sg_request * srp);
196 			   Sg_request * srp);
200 static int sg_common_write(Sg_fd * sfp, Sg_request * srp,
202 static int sg_read_oxfer(Sg_request * srp, char __user *outp, int num_read_xfer);
205 static void sg_link_reserve(Sg_fd * sfp, Sg_request * srp, int size);
206 static void sg_unlink_reserve(Sg_fd * sfp, Sg_request * srp);
211 static int sg_remove_request(Sg_fd * sfp, Sg_request * srp);
403 	Sg_request *srp;  in sg_read()  local
444 	srp = sg_get_rq_mark(sfp, req_pack_id);  in sg_read()
445 	if (!srp) {		/* now wait on packet to arrive */  in sg_read()
456 			(srp = sg_get_rq_mark(sfp, req_pack_id))));  in sg_read()
466 	if (srp->header.interface_id != '\0') {  in sg_read()
467 		retval = sg_new_read(sfp, buf, count, srp);  in sg_read()
471 	hp = &srp->header;  in sg_read()
484 	    ((srp->data.cmd_opcode >= 0xc0) && (12 == hp->cmd_len)) ? 1 : 0;  in sg_read()
490 		memcpy(old_hdr->sense_buffer, srp->sense_b,  in sg_read()
513 		old_hdr->result = (srp->sense_b[0] == 0 &&   in sg_read()
531 			if (sg_read_oxfer(srp, buf, count - SZ_SG_HEADER)) {  in sg_read()
538 	sg_finish_rem_req(srp);  in sg_read()
546 sg_new_read(Sg_fd * sfp, char __user *buf, size_t count, Sg_request * srp)  in sg_new_read()  argument
548 	sg_io_hdr_t *hp = &srp->header;  in sg_new_read()
562 			len = 8 + (int) srp->sense_b[7];	/* Additional sense length field */  in sg_new_read()
564 			if (copy_to_user(hp->sbp, srp->sense_b, len)) {  in sg_new_read()
578 	err2 = sg_finish_rem_req(srp);  in sg_new_read()
590 	Sg_request *srp;  in sg_write()  local
618 	if (!(srp = sg_add_request(sfp))) {  in sg_write()
641 		sg_remove_request(sfp, srp);  in sg_write()
644 	hp = &srp->header;  in sg_write()
686 	k = sg_common_write(sfp, srp, cmnd, sfp->timeout, blocking);  in sg_write()
696 	Sg_request *srp;  in sg_new_write()  local
708 	if (!(srp = sg_add_request(sfp))) {  in sg_new_write()
713 	srp->sg_io_owned = sg_io_owned;  in sg_new_write()
714 	hp = &srp->header;  in sg_new_write()
716 		sg_remove_request(sfp, srp);  in sg_new_write()
720 		sg_remove_request(sfp, srp);  in sg_new_write()
725 			sg_remove_request(sfp, srp);  in sg_new_write()
729 			sg_remove_request(sfp, srp);  in sg_new_write()
733 			sg_remove_request(sfp, srp);  in sg_new_write()
737 	ul_timeout = msecs_to_jiffies(srp->header.timeout);  in sg_new_write()
740 		sg_remove_request(sfp, srp);  in sg_new_write()
744 		sg_remove_request(sfp, srp);  in sg_new_write()
748 		sg_remove_request(sfp, srp);  in sg_new_write()
752 		sg_remove_request(sfp, srp);  in sg_new_write()
755 	k = sg_common_write(sfp, srp, cmnd, timeout, blocking);  in sg_new_write()
759 		*o_srp = srp;  in sg_new_write()
764 sg_common_write(Sg_fd * sfp, Sg_request * srp,  in sg_common_write()  argument
769 	sg_io_hdr_t *hp = &srp->header;  in sg_common_write()
771 	srp->data.cmd_opcode = cmnd[0];	/* hold opcode of command */  in sg_common_write()
783 	k = sg_start_req(srp, cmnd);  in sg_common_write()
787 		sg_finish_rem_req(srp);  in sg_common_write()
791 		if (srp->bio)  in sg_common_write()
792 			blk_end_request_all(srp->rq, -EIO);  in sg_common_write()
793 		sg_finish_rem_req(srp);  in sg_common_write()
804 	srp->rq->timeout = timeout;  in sg_common_write()
807 			      srp->rq, at_head, sg_rq_end_io);  in sg_common_write()
811 static int srp_done(Sg_fd *sfp, Sg_request *srp)  in srp_done()  argument
817 	ret = srp->done;  in srp_done()
839 	Sg_request *srp;  in sg_ioctl()  local
858 				 1, read_only, 1, &srp);  in sg_ioctl()
862 			(srp_done(sfp, srp) || atomic_read(&sdp->detaching)));  in sg_ioctl()
866 		if (srp->done) {  in sg_ioctl()
867 			srp->done = 2;  in sg_ioctl()
869 			result = sg_new_read(sfp, p, SZ_SG_IO_HDR, srp);  in sg_ioctl()
872 		srp->orphan = 1;  in sg_ioctl()
942 		for (srp = sfp->headrp; srp; srp = srp->nextrp) {  in sg_ioctl()
943 			if ((1 == srp->done) && (!srp->sg_io_owned)) {  in sg_ioctl()
946 				__put_user(srp->header.pack_id, ip);  in sg_ioctl()
955 		for (val = 0, srp = sfp->headrp; srp; srp = srp->nextrp) {  in sg_ioctl()
956 			if ((1 == srp->done) && (!srp->sg_io_owned))  in sg_ioctl()
1022 			for (srp = sfp->headrp, val = 0; val < SG_MAX_QUEUE;  in sg_ioctl()
1023 			     ++val, srp = srp ? srp->nextrp : srp) {  in sg_ioctl()
1025 				if (srp) {  in sg_ioctl()
1026 					rinfo[val].req_state = srp->done + 1;  in sg_ioctl()
1028 					    srp->header.masked_status &   in sg_ioctl()
1029 					    srp->header.host_status &   in sg_ioctl()
1030 					    srp->header.driver_status;  in sg_ioctl()
1031 					if (srp->done)  in sg_ioctl()
1033 							srp->header.duration;  in sg_ioctl()
1037 						    (ms > srp->header.duration) ?  in sg_ioctl()
1038 						    (ms - srp->header.duration) : 0;  in sg_ioctl()
1040 					rinfo[val].orphan = srp->orphan;  in sg_ioctl()
1042 							srp->sg_io_owned;  in sg_ioctl()
1044 							srp->header.pack_id;  in sg_ioctl()
1046 							srp->header.usr_ptr;  in sg_ioctl()
1144 	Sg_request *srp;  in sg_poll()  local
1156 	for (srp = sfp->headrp; srp; srp = srp->nextrp) {  in sg_poll()
1158 		if ((0 == res) && (1 == srp->done) && (!srp->sg_io_owned))  in sg_poll()
1268 	struct sg_request *srp = container_of(work, struct sg_request, ew.work);  in sg_rq_end_io_usercontext()  local
1269 	struct sg_fd *sfp = srp->parentfp;  in sg_rq_end_io_usercontext()
1271 	sg_finish_rem_req(srp);  in sg_rq_end_io_usercontext()
1282 	struct sg_request *srp = rq->end_io_data;  in sg_rq_end_io()  local
1290 	if (WARN_ON(srp->done != 0))  in sg_rq_end_io()
1293 	sfp = srp->parentfp;  in sg_rq_end_io()
1307 				      srp->header.pack_id, result));  in sg_rq_end_io()
1308 	srp->header.resid = resid;  in sg_rq_end_io()
1310 	srp->header.duration = (ms > srp->header.duration) ?  in sg_rq_end_io()
1311 				(ms - srp->header.duration) : 0;  in sg_rq_end_io()
1315 		srp->header.status = 0xff & result;  in sg_rq_end_io()
1316 		srp->header.masked_status = status_byte(result);  in sg_rq_end_io()
1317 		srp->header.msg_status = msg_byte(result);  in sg_rq_end_io()
1318 		srp->header.host_status = host_byte(result);  in sg_rq_end_io()
1319 		srp->header.driver_status = driver_byte(result);  in sg_rq_end_io()
1321 		    ((CHECK_CONDITION == srp->header.masked_status) ||  in sg_rq_end_io()
1322 		     (COMMAND_TERMINATED == srp->header.masked_status)))  in sg_rq_end_io()
1345 	srp->rq = NULL;  in sg_rq_end_io()
1351 	if (unlikely(srp->orphan)) {  in sg_rq_end_io()
1353 			srp->sg_io_owned = 0;  in sg_rq_end_io()
1357 	srp->done = done;  in sg_rq_end_io()
1368 		INIT_WORK(&srp->ew.work, sg_rq_end_io_usercontext);  in sg_rq_end_io()
1369 		schedule_work(&srp->ew.work);  in sg_rq_end_io()
1658 sg_start_req(Sg_request *srp, unsigned char *cmd)  in sg_start_req()  argument
1662 	Sg_fd *sfp = srp->parentfp;  in sg_start_req()
1663 	sg_io_hdr_t *hp = &srp->header;  in sg_start_req()
1667 	Sg_scatter_hold *req_schp = &srp->data;  in sg_start_req()
1712 	srp->rq = rq;  in sg_start_req()
1713 	rq->end_io_data = srp;  in sg_start_req()
1714 	rq->sense = srp->sense_b;  in sg_start_req()
1730 			sg_link_reserve(sfp, srp, dxfer_len);  in sg_start_req()
1765 		srp->bio = rq->bio;  in sg_start_req()
1776 sg_finish_rem_req(Sg_request *srp)  in sg_finish_rem_req()  argument
1780 	Sg_fd *sfp = srp->parentfp;  in sg_finish_rem_req()
1781 	Sg_scatter_hold *req_schp = &srp->data;  in sg_finish_rem_req()
1785 				      (int) srp->res_used));  in sg_finish_rem_req()
1786 	if (srp->bio)  in sg_finish_rem_req()
1787 		ret = blk_rq_unmap_user(srp->bio);  in sg_finish_rem_req()
1789 	if (srp->rq) {  in sg_finish_rem_req()
1790 		if (srp->rq->cmd != srp->rq->__cmd)  in sg_finish_rem_req()
1791 			kfree(srp->rq->cmd);  in sg_finish_rem_req()
1792 		blk_put_request(srp->rq);  in sg_finish_rem_req()
1795 	if (srp->res_used)  in sg_finish_rem_req()
1796 		sg_unlink_reserve(sfp, srp);  in sg_finish_rem_req()
1800 	sg_remove_request(sfp, srp);  in sg_finish_rem_req()
1926 sg_read_oxfer(Sg_request * srp, char __user *outp, int num_read_xfer)  in sg_read_oxfer()  argument
1928 	Sg_scatter_hold *schp = &srp->data;  in sg_read_oxfer()
1931 	SCSI_LOG_TIMEOUT(4, sg_printk(KERN_INFO, srp->parentfp->parentdp,  in sg_read_oxfer()
1977 sg_link_reserve(Sg_fd * sfp, Sg_request * srp, int size)  in sg_link_reserve()  argument
1979 	Sg_scatter_hold *req_schp = &srp->data;  in sg_link_reserve()
1983 	srp->res_used = 1;  in sg_link_reserve()
2008 sg_unlink_reserve(Sg_fd * sfp, Sg_request * srp)  in sg_unlink_reserve()  argument
2010 	Sg_scatter_hold *req_schp = &srp->data;  in sg_unlink_reserve()
2012 	SCSI_LOG_TIMEOUT(4, sg_printk(KERN_INFO, srp->parentfp->parentdp,  in sg_unlink_reserve()
2021 	srp->res_used = 0;  in sg_unlink_reserve()
2088 sg_remove_request(Sg_fd * sfp, Sg_request * srp)  in sg_remove_request()  argument
2095 	if ((!sfp) || (!srp) || (!sfp->headrp))  in sg_remove_request()
2099 	if (srp == prev_rp) {  in sg_remove_request()
2105 			if (srp == rp) {  in sg_remove_request()
2211 	const Sg_request *srp;  in sg_res_in_use()  local
2215 	for (srp = sfp->headrp; srp; srp = srp->nextrp)  in sg_res_in_use()
2216 		if (srp->res_used)  in sg_res_in_use()
2219 	return srp ? 1 : 0;  in sg_res_in_use()
2592 	Sg_request *srp;  in sg_proc_debug_helper()  local
2611 		for (m = 0, srp = fp->headrp;  in sg_proc_debug_helper()
2612 				srp != NULL;  in sg_proc_debug_helper()
2613 				++m, srp = srp->nextrp) {  in sg_proc_debug_helper()
2614 			hp = &srp->header;  in sg_proc_debug_helper()
2616 			if (srp->res_used) {  in sg_proc_debug_helper()
2629 			blen = srp->data.bufflen;  in sg_proc_debug_helper()
2630 			usg = srp->data.k_use_sg;  in sg_proc_debug_helper()
2631 			seq_puts(s, srp->done ?  in sg_proc_debug_helper()
2632 				 ((1 == srp->done) ?  "rcv:" : "fin:")  in sg_proc_debug_helper()
2635 				   srp->header.pack_id, blen);  in sg_proc_debug_helper()
2636 			if (srp->done)  in sg_proc_debug_helper()
2646 				   (int) srp->data.cmd_opcode);  in sg_proc_debug_helper()