176 static int sg_start_req(Sg_request *srp, unsigned char *cmd);
177 static int sg_finish_rem_req(Sg_request * srp);
180 			   Sg_request * srp);
184 static int sg_common_write(Sg_fd * sfp, Sg_request * srp,
186 static int sg_read_oxfer(Sg_request * srp, char __user *outp, int num_read_xfer);
189 static void sg_link_reserve(Sg_fd * sfp, Sg_request * srp, int size);
190 static void sg_unlink_reserve(Sg_fd * sfp, Sg_request * srp);
195 static int sg_remove_request(Sg_fd * sfp, Sg_request * srp);
445 	Sg_request *srp;  in sg_read()  local
469 	srp = sg_get_rq_mark(sfp, req_pack_id);  in sg_read()
470 	if (!srp) {		/* now wait on packet to arrive */  in sg_read()
477 			(srp = sg_get_rq_mark(sfp, req_pack_id))));  in sg_read()
484 	if (srp->header.interface_id != '\0')  in sg_read()
485 		return sg_new_read(sfp, buf, count, srp);  in sg_read()
487 	hp = &srp->header;  in sg_read()
496 	    ((srp->data.cmd_opcode >= 0xc0) && (12 == hp->cmd_len)) ? 1 : 0;  in sg_read()
501 	    (srp->sense_b[0] & 0x70) == 0x70) {  in sg_read()
503 		memcpy(old_hdr->sense_buffer, srp->sense_b,  in sg_read()
527 		old_hdr->result = (srp->sense_b[0] == 0 &&   in sg_read()
545 			if (sg_read_oxfer(srp, buf, count - SZ_SG_HEADER)) {  in sg_read()
552 	sg_finish_rem_req(srp);  in sg_read()
553 	sg_remove_request(sfp, srp);  in sg_read()
561 sg_new_read(Sg_fd * sfp, char __user *buf, size_t count, Sg_request * srp)  in sg_new_read()  argument
563 	sg_io_hdr_t *hp = &srp->header;  in sg_new_read()
579 		    (srp->sense_b[0] & 0x70) == 0x70) {  in sg_new_read()
582 			len = 8 + (int) srp->sense_b[7];	/* Additional sense length field */  in sg_new_read()
584 			if (copy_to_user(hp->sbp, srp->sense_b, len)) {  in sg_new_read()
596 	err2 = sg_finish_rem_req(srp);  in sg_new_read()
597 	sg_remove_request(sfp, srp);  in sg_new_read()
609 	Sg_request *srp;  in sg_write()  local
644 	if (!(srp = sg_add_request(sfp))) {  in sg_write()
667 		sg_remove_request(sfp, srp);  in sg_write()
670 	hp = &srp->header;  in sg_write()
692 		sg_remove_request(sfp, srp);  in sg_write()
710 	k = sg_common_write(sfp, srp, cmnd, sfp->timeout, blocking);  in sg_write()
720 	Sg_request *srp;  in sg_new_write()  local
730 	if (!(srp = sg_add_request(sfp))) {  in sg_new_write()
735 	srp->sg_io_owned = sg_io_owned;  in sg_new_write()
736 	hp = &srp->header;  in sg_new_write()
738 		sg_remove_request(sfp, srp);  in sg_new_write()
742 		sg_remove_request(sfp, srp);  in sg_new_write()
747 			sg_remove_request(sfp, srp);  in sg_new_write()
751 			sg_remove_request(sfp, srp);  in sg_new_write()
755 			sg_remove_request(sfp, srp);  in sg_new_write()
759 	ul_timeout = msecs_to_jiffies(srp->header.timeout);  in sg_new_write()
762 		sg_remove_request(sfp, srp);  in sg_new_write()
766 		sg_remove_request(sfp, srp);  in sg_new_write()
770 		sg_remove_request(sfp, srp);  in sg_new_write()
773 	k = sg_common_write(sfp, srp, cmnd, timeout, blocking);  in sg_new_write()
777 		*o_srp = srp;  in sg_new_write()
782 sg_common_write(Sg_fd * sfp, Sg_request * srp,  in sg_common_write()  argument
787 	sg_io_hdr_t *hp = &srp->header;  in sg_common_write()
789 	srp->data.cmd_opcode = cmnd[0];	/* hold opcode of command */  in sg_common_write()
802 		sg_remove_request(sfp, srp);  in sg_common_write()
806 	k = sg_start_req(srp, cmnd);  in sg_common_write()
810 		sg_finish_rem_req(srp);  in sg_common_write()
811 		sg_remove_request(sfp, srp);  in sg_common_write()
815 		if (srp->bio) {  in sg_common_write()
816 			scsi_req_free_cmd(scsi_req(srp->rq));  in sg_common_write()
817 			blk_put_request(srp->rq);  in sg_common_write()
818 			srp->rq = NULL;  in sg_common_write()
821 		sg_finish_rem_req(srp);  in sg_common_write()
822 		sg_remove_request(sfp, srp);  in sg_common_write()
833 	srp->rq->timeout = timeout;  in sg_common_write()
835 	blk_execute_rq_nowait(NULL, srp->rq, at_head, sg_rq_end_io);  in sg_common_write()
839 static int srp_done(Sg_fd *sfp, Sg_request *srp)  in srp_done()  argument
845 	ret = srp->done;  in srp_done()
862 	Sg_request *srp;  in sg_fill_request_table()  local
867 	list_for_each_entry(srp, &sfp->rq_list, entry) {  in sg_fill_request_table()
870 		rinfo[val].req_state = srp->done + 1;  in sg_fill_request_table()
872 			srp->header.masked_status &  in sg_fill_request_table()
873 			srp->header.host_status &  in sg_fill_request_table()
874 			srp->header.driver_status;  in sg_fill_request_table()
875 		if (srp->done)  in sg_fill_request_table()
877 				srp->header.duration;  in sg_fill_request_table()
881 				(ms > srp->header.duration) ?  in sg_fill_request_table()
882 				(ms - srp->header.duration) : 0;  in sg_fill_request_table()
884 		rinfo[val].orphan = srp->orphan;  in sg_fill_request_table()
885 		rinfo[val].sg_io_owned = srp->sg_io_owned;  in sg_fill_request_table()
886 		rinfo[val].pack_id = srp->header.pack_id;  in sg_fill_request_table()
887 		rinfo[val].usr_ptr = srp->header.usr_ptr;  in sg_fill_request_table()
925 	Sg_request *srp;  in sg_ioctl_common()  local
939 				 1, read_only, 1, &srp);  in sg_ioctl_common()
943 			(srp_done(sfp, srp) || atomic_read(&sdp->detaching)));  in sg_ioctl_common()
947 		if (srp->done) {  in sg_ioctl_common()
948 			srp->done = 2;  in sg_ioctl_common()
950 			result = sg_new_read(sfp, p, SZ_SG_IO_HDR, srp);  in sg_ioctl_common()
953 		srp->orphan = 1;  in sg_ioctl_common()
1007 		list_for_each_entry(srp, &sfp->rq_list, entry) {  in sg_ioctl_common()
1008 			if ((1 == srp->done) && (!srp->sg_io_owned)) {  in sg_ioctl_common()
1011 				return put_user(srp->header.pack_id, ip);  in sg_ioctl_common()
1019 		list_for_each_entry(srp, &sfp->rq_list, entry) {  in sg_ioctl_common()
1020 			if ((1 == srp->done) && (!srp->sg_io_owned))  in sg_ioctl_common()
1176 	Sg_request *srp;  in sg_poll()  local
1188 	list_for_each_entry(srp, &sfp->rq_list, entry) {  in sg_poll()
1190 		if ((0 == res) && (1 == srp->done) && (!srp->sg_io_owned))  in sg_poll()
1307 	struct sg_request *srp = container_of(work, struct sg_request, ew.work);  in sg_rq_end_io_usercontext()  local
1308 	struct sg_fd *sfp = srp->parentfp;  in sg_rq_end_io_usercontext()
1310 	sg_finish_rem_req(srp);  in sg_rq_end_io_usercontext()
1311 	sg_remove_request(sfp, srp);  in sg_rq_end_io_usercontext()
1322 	struct sg_request *srp = rq->end_io_data;  in sg_rq_end_io()  local
1331 	if (WARN_ON(srp->done != 0))  in sg_rq_end_io()
1334 	sfp = srp->parentfp;  in sg_rq_end_io()
1348 				      srp->header.pack_id, result));  in sg_rq_end_io()
1349 	srp->header.resid = resid;  in sg_rq_end_io()
1351 	srp->header.duration = (ms > srp->header.duration) ?  in sg_rq_end_io()
1352 				(ms - srp->header.duration) : 0;  in sg_rq_end_io()
1356 		srp->header.status = 0xff & result;  in sg_rq_end_io()
1357 		srp->header.masked_status = status_byte(result);  in sg_rq_end_io()
1358 		srp->header.msg_status = COMMAND_COMPLETE;  in sg_rq_end_io()
1359 		srp->header.host_status = host_byte(result);  in sg_rq_end_io()
1360 		srp->header.driver_status = driver_byte(result);  in sg_rq_end_io()
1362 		    ((CHECK_CONDITION == srp->header.masked_status) ||  in sg_rq_end_io()
1363 		     (COMMAND_TERMINATED == srp->header.masked_status)))  in sg_rq_end_io()
1380 		memcpy(srp->sense_b, req->sense, SCSI_SENSE_BUFFERSIZE);  in sg_rq_end_io()
1390 	srp->rq = NULL;  in sg_rq_end_io()
1395 	if (unlikely(srp->orphan)) {  in sg_rq_end_io()
1397 			srp->sg_io_owned = 0;  in sg_rq_end_io()
1401 	srp->done = done;  in sg_rq_end_io()
1412 		INIT_WORK(&srp->ew.work, sg_rq_end_io_usercontext);  in sg_rq_end_io()
1413 		schedule_work(&srp->ew.work);  in sg_rq_end_io()
1688 sg_start_req(Sg_request *srp, unsigned char *cmd)  in sg_start_req()  argument
1693 	Sg_fd *sfp = srp->parentfp;  in sg_start_req()
1694 	sg_io_hdr_t *hp = &srp->header;  in sg_start_req()
1698 	Sg_scatter_hold *req_schp = &srp->data;  in sg_start_req()
1739 	srp->rq = rq;  in sg_start_req()
1740 	rq->end_io_data = srp;  in sg_start_req()
1758 			sg_link_reserve(sfp, srp, dxfer_len);  in sg_start_req()
1806 		srp->bio = rq->bio;  in sg_start_req()
1817 sg_finish_rem_req(Sg_request *srp)  in sg_finish_rem_req()  argument
1821 	Sg_fd *sfp = srp->parentfp;  in sg_finish_rem_req()
1822 	Sg_scatter_hold *req_schp = &srp->data;  in sg_finish_rem_req()
1826 				      (int) srp->res_used));  in sg_finish_rem_req()
1827 	if (srp->bio)  in sg_finish_rem_req()
1828 		ret = blk_rq_unmap_user(srp->bio);  in sg_finish_rem_req()
1830 	if (srp->rq) {  in sg_finish_rem_req()
1831 		scsi_req_free_cmd(scsi_req(srp->rq));  in sg_finish_rem_req()
1832 		blk_put_request(srp->rq);  in sg_finish_rem_req()
1835 	if (srp->res_used)  in sg_finish_rem_req()
1836 		sg_unlink_reserve(sfp, srp);  in sg_finish_rem_req()
1958 sg_read_oxfer(Sg_request * srp, char __user *outp, int num_read_xfer)  in sg_read_oxfer()  argument
1960 	Sg_scatter_hold *schp = &srp->data;  in sg_read_oxfer()
1963 	SCSI_LOG_TIMEOUT(4, sg_printk(KERN_INFO, srp->parentfp->parentdp,  in sg_read_oxfer()
2009 sg_link_reserve(Sg_fd * sfp, Sg_request * srp, int size)  in sg_link_reserve()  argument
2011 	Sg_scatter_hold *req_schp = &srp->data;  in sg_link_reserve()
2015 	srp->res_used = 1;  in sg_link_reserve()
2040 sg_unlink_reserve(Sg_fd * sfp, Sg_request * srp)  in sg_unlink_reserve()  argument
2042 	Sg_scatter_hold *req_schp = &srp->data;  in sg_unlink_reserve()
2044 	SCSI_LOG_TIMEOUT(4, sg_printk(KERN_INFO, srp->parentfp->parentdp,  in sg_unlink_reserve()
2052 	srp->res_used = 0;  in sg_unlink_reserve()
2110 sg_remove_request(Sg_fd * sfp, Sg_request * srp)  in sg_remove_request()  argument
2115 	if (!sfp || !srp || list_empty(&sfp->rq_list))  in sg_remove_request()
2118 	if (!list_empty(&srp->entry)) {  in sg_remove_request()
2119 		list_del(&srp->entry);  in sg_remove_request()
2120 		srp->parentfp = NULL;  in sg_remove_request()
2180 	Sg_request *srp;  in sg_remove_sfp_usercontext()  local
2186 		srp = list_first_entry(&sfp->rq_list, Sg_request, entry);  in sg_remove_sfp_usercontext()
2187 		sg_finish_rem_req(srp);  in sg_remove_sfp_usercontext()
2188 		list_del(&srp->entry);  in sg_remove_sfp_usercontext()
2189 		srp->parentfp = NULL;  in sg_remove_sfp_usercontext()
2499 	Sg_request *srp;  in sg_proc_debug_helper()  local
2517 		list_for_each_entry(srp, &fp->rq_list, entry) {  in sg_proc_debug_helper()
2518 			hp = &srp->header;  in sg_proc_debug_helper()
2520 			if (srp->res_used) {  in sg_proc_debug_helper()
2533 			blen = srp->data.bufflen;  in sg_proc_debug_helper()
2534 			usg = srp->data.k_use_sg;  in sg_proc_debug_helper()
2535 			seq_puts(s, srp->done ?  in sg_proc_debug_helper()
2536 				 ((1 == srp->done) ?  "rcv:" : "fin:")  in sg_proc_debug_helper()
2539 				   srp->header.pack_id, blen);  in sg_proc_debug_helper()
2540 			if (srp->done)  in sg_proc_debug_helper()
2550 				   (int) srp->data.cmd_opcode);  in sg_proc_debug_helper()