728 #define	DRHASH(dr)	XIDHASH((dr)->dr_xid)  argument
767 	struct dupreq *dr;  in svc_cots_kdup()  local
778 	dr = cotsdrhashtbl[XIDHASH(xid)];  in svc_cots_kdup()
779 	while (dr != NULL) {  in svc_cots_kdup()
780 		if (dr->dr_xid == xid &&  in svc_cots_kdup()
781 		    dr->dr_proc == req->rq_proc &&  in svc_cots_kdup()
782 		    dr->dr_prog == req->rq_prog &&  in svc_cots_kdup()
783 		    dr->dr_vers == req->rq_vers &&  in svc_cots_kdup()
784 		    dr->dr_addr.len == req->rq_xprt->xp_rtaddr.len &&  in svc_cots_kdup()
785 		    bcmp((caddr_t)dr->dr_addr.buf,  in svc_cots_kdup()
787 		    dr->dr_addr.len) == 0) {  in svc_cots_kdup()
788 			status = dr->dr_status;  in svc_cots_kdup()
790 				bcopy(dr->dr_resp.buf, res, size);  in svc_cots_kdup()
792 					*dupcachedp = (dr->dr_resfree != NULL);  in svc_cots_kdup()
796 				dr->dr_status = DUP_INPROGRESS;  in svc_cots_kdup()
797 				*drpp = dr;  in svc_cots_kdup()
806 		dr = dr->dr_chain;  in svc_cots_kdup()
814 		dr = kmem_alloc(sizeof (*dr), KM_NOSLEEP);  in svc_cots_kdup()
815 		if (dr == NULL) {  in svc_cots_kdup()
819 		dr->dr_resp.buf = NULL;  in svc_cots_kdup()
820 		dr->dr_resp.maxlen = 0;  in svc_cots_kdup()
821 		dr->dr_addr.buf = NULL;  in svc_cots_kdup()
822 		dr->dr_addr.maxlen = 0;  in svc_cots_kdup()
824 			dr->dr_next = cotsdrmru->dr_next;  in svc_cots_kdup()
825 			cotsdrmru->dr_next = dr;  in svc_cots_kdup()
827 			dr->dr_next = dr;  in svc_cots_kdup()
831 		dr = cotsdrmru->dr_next;  in svc_cots_kdup()
832 		while (dr->dr_status == DUP_INPROGRESS) {  in svc_cots_kdup()
833 			dr = dr->dr_next;  in svc_cots_kdup()
834 			if (dr == cotsdrmru->dr_next) {  in svc_cots_kdup()
840 		unhash(dr);  in svc_cots_kdup()
841 		if (dr->dr_resfree) {  in svc_cots_kdup()
842 			(*dr->dr_resfree)(dr->dr_resp.buf);  in svc_cots_kdup()
845 	dr->dr_resfree = NULL;  in svc_cots_kdup()
846 	cotsdrmru = dr;  in svc_cots_kdup()
848 	dr->dr_xid = REQTOXID(req);  in svc_cots_kdup()
849 	dr->dr_prog = req->rq_prog;  in svc_cots_kdup()
850 	dr->dr_vers = req->rq_vers;  in svc_cots_kdup()
851 	dr->dr_proc = req->rq_proc;  in svc_cots_kdup()
852 	if (dr->dr_addr.maxlen < req->rq_xprt->xp_rtaddr.len) {  in svc_cots_kdup()
853 		if (dr->dr_addr.buf != NULL)  in svc_cots_kdup()
854 			kmem_free(dr->dr_addr.buf, dr->dr_addr.maxlen);  in svc_cots_kdup()
855 		dr->dr_addr.maxlen = req->rq_xprt->xp_rtaddr.len;  in svc_cots_kdup()
856 		dr->dr_addr.buf = kmem_alloc(dr->dr_addr.maxlen, KM_NOSLEEP);  in svc_cots_kdup()
857 		if (dr->dr_addr.buf == NULL) {  in svc_cots_kdup()
858 			dr->dr_addr.maxlen = 0;  in svc_cots_kdup()
859 			dr->dr_status = DUP_DROP;  in svc_cots_kdup()
864 	dr->dr_addr.len = req->rq_xprt->xp_rtaddr.len;  in svc_cots_kdup()
865 	bcopy(req->rq_xprt->xp_rtaddr.buf, dr->dr_addr.buf, dr->dr_addr.len);  in svc_cots_kdup()
866 	if (dr->dr_resp.maxlen < size) {  in svc_cots_kdup()
867 		if (dr->dr_resp.buf != NULL)  in svc_cots_kdup()
868 			kmem_free(dr->dr_resp.buf, dr->dr_resp.maxlen);  in svc_cots_kdup()
869 		dr->dr_resp.maxlen = (unsigned int)size;  in svc_cots_kdup()
870 		dr->dr_resp.buf = kmem_alloc(size, KM_NOSLEEP);  in svc_cots_kdup()
871 		if (dr->dr_resp.buf == NULL) {  in svc_cots_kdup()
872 			dr->dr_resp.maxlen = 0;  in svc_cots_kdup()
873 			dr->dr_status = DUP_DROP;  in svc_cots_kdup()
878 	dr->dr_status = DUP_INPROGRESS;  in svc_cots_kdup()
880 	drhash = (uint32_t)DRHASH(dr);  in svc_cots_kdup()
881 	dr->dr_chain = cotsdrhashtbl[drhash];  in svc_cots_kdup()
882 	cotsdrhashtbl[drhash] = dr;  in svc_cots_kdup()
885 	*drpp = dr;  in svc_cots_kdup()
899 svc_cots_kdupdone(struct dupreq *dr, caddr_t res, void (*dis_resfree)(),  in svc_cots_kdupdone()  argument
902 	ASSERT(dr->dr_resfree == NULL);  in svc_cots_kdupdone()
904 		bcopy(res, dr->dr_resp.buf, size);  in svc_cots_kdupdone()
905 		dr->dr_resfree = dis_resfree;  in svc_cots_kdupdone()
907 	dr->dr_status = status;  in svc_cots_kdupdone()
914 unhash(struct dupreq *dr)  in unhash()  argument
922 	drhash = (uint32_t)DRHASH(dr);  in unhash()
925 		if (drt == dr) {  in unhash()