730 #define	DRHASH(dr)	XIDHASH((dr)->dr_xid)  argument
769 	struct dupreq *dr;  in svc_cots_kdup()  local
780 	dr = cotsdrhashtbl[XIDHASH(xid)];  in svc_cots_kdup()
781 	while (dr != NULL) {  in svc_cots_kdup()
782 		if (dr->dr_xid == xid &&  in svc_cots_kdup()
783 		    dr->dr_proc == req->rq_proc &&  in svc_cots_kdup()
784 		    dr->dr_prog == req->rq_prog &&  in svc_cots_kdup()
785 		    dr->dr_vers == req->rq_vers &&  in svc_cots_kdup()
786 		    dr->dr_addr.len == req->rq_xprt->xp_rtaddr.len &&  in svc_cots_kdup()
787 		    bcmp((caddr_t)dr->dr_addr.buf,  in svc_cots_kdup()
789 		    dr->dr_addr.len) == 0) {  in svc_cots_kdup()
790 			status = dr->dr_status;  in svc_cots_kdup()
792 				bcopy(dr->dr_resp.buf, res, size);  in svc_cots_kdup()
794 					*dupcachedp = (dr->dr_resfree != NULL);  in svc_cots_kdup()
798 				dr->dr_status = DUP_INPROGRESS;  in svc_cots_kdup()
799 				*drpp = dr;  in svc_cots_kdup()
808 		dr = dr->dr_chain;  in svc_cots_kdup()
816 		dr = kmem_alloc(sizeof (*dr), KM_NOSLEEP);  in svc_cots_kdup()
817 		if (dr == NULL) {  in svc_cots_kdup()
821 		dr->dr_resp.buf = NULL;  in svc_cots_kdup()
822 		dr->dr_resp.maxlen = 0;  in svc_cots_kdup()
823 		dr->dr_addr.buf = NULL;  in svc_cots_kdup()
824 		dr->dr_addr.maxlen = 0;  in svc_cots_kdup()
826 			dr->dr_next = cotsdrmru->dr_next;  in svc_cots_kdup()
827 			cotsdrmru->dr_next = dr;  in svc_cots_kdup()
829 			dr->dr_next = dr;  in svc_cots_kdup()
833 		dr = cotsdrmru->dr_next;  in svc_cots_kdup()
834 		while (dr->dr_status == DUP_INPROGRESS) {  in svc_cots_kdup()
835 			dr = dr->dr_next;  in svc_cots_kdup()
836 			if (dr == cotsdrmru->dr_next) {  in svc_cots_kdup()
842 		unhash(dr);  in svc_cots_kdup()
843 		if (dr->dr_resfree) {  in svc_cots_kdup()
844 			(*dr->dr_resfree)(dr->dr_resp.buf);  in svc_cots_kdup()
847 	dr->dr_resfree = NULL;  in svc_cots_kdup()
848 	cotsdrmru = dr;  in svc_cots_kdup()
850 	dr->dr_xid = REQTOXID(req);  in svc_cots_kdup()
851 	dr->dr_prog = req->rq_prog;  in svc_cots_kdup()
852 	dr->dr_vers = req->rq_vers;  in svc_cots_kdup()
853 	dr->dr_proc = req->rq_proc;  in svc_cots_kdup()
854 	if (dr->dr_addr.maxlen < req->rq_xprt->xp_rtaddr.len) {  in svc_cots_kdup()
855 		if (dr->dr_addr.buf != NULL)  in svc_cots_kdup()
856 			kmem_free(dr->dr_addr.buf, dr->dr_addr.maxlen);  in svc_cots_kdup()
857 		dr->dr_addr.maxlen = req->rq_xprt->xp_rtaddr.len;  in svc_cots_kdup()
858 		dr->dr_addr.buf = kmem_alloc(dr->dr_addr.maxlen, KM_NOSLEEP);  in svc_cots_kdup()
859 		if (dr->dr_addr.buf == NULL) {  in svc_cots_kdup()
860 			dr->dr_addr.maxlen = 0;  in svc_cots_kdup()
861 			dr->dr_status = DUP_DROP;  in svc_cots_kdup()
866 	dr->dr_addr.len = req->rq_xprt->xp_rtaddr.len;  in svc_cots_kdup()
867 	bcopy(req->rq_xprt->xp_rtaddr.buf, dr->dr_addr.buf, dr->dr_addr.len);  in svc_cots_kdup()
868 	if (dr->dr_resp.maxlen < size) {  in svc_cots_kdup()
869 		if (dr->dr_resp.buf != NULL)  in svc_cots_kdup()
870 			kmem_free(dr->dr_resp.buf, dr->dr_resp.maxlen);  in svc_cots_kdup()
871 		dr->dr_resp.maxlen = (unsigned int)size;  in svc_cots_kdup()
872 		dr->dr_resp.buf = kmem_alloc(size, KM_NOSLEEP);  in svc_cots_kdup()
873 		if (dr->dr_resp.buf == NULL) {  in svc_cots_kdup()
874 			dr->dr_resp.maxlen = 0;  in svc_cots_kdup()
875 			dr->dr_status = DUP_DROP;  in svc_cots_kdup()
880 	dr->dr_status = DUP_INPROGRESS;  in svc_cots_kdup()
882 	drhash = (uint32_t)DRHASH(dr);  in svc_cots_kdup()
883 	dr->dr_chain = cotsdrhashtbl[drhash];  in svc_cots_kdup()
884 	cotsdrhashtbl[drhash] = dr;  in svc_cots_kdup()
887 	*drpp = dr;  in svc_cots_kdup()
901 svc_cots_kdupdone(struct dupreq *dr, caddr_t res, void (*dis_resfree)(),  in svc_cots_kdupdone()  argument
904 	ASSERT(dr->dr_resfree == NULL);  in svc_cots_kdupdone()
906 		bcopy(res, dr->dr_resp.buf, size);  in svc_cots_kdupdone()
907 		dr->dr_resfree = dis_resfree;  in svc_cots_kdupdone()
909 	dr->dr_status = status;  in svc_cots_kdupdone()
916 unhash(struct dupreq *dr)  in unhash()  argument
924 	drhash = (uint32_t)DRHASH(dr);  in unhash()
927 		if (drt == dr) {  in unhash()