764 #define	DRHASH(dr)	XIDHASH((dr)->dr_xid)  argument
803 	struct dupreq *dr;  in svc_clts_kdup()  local
814 	dr = drhashtbl[XIDHASH(xid)];  in svc_clts_kdup()
815 	while (dr != NULL) {  in svc_clts_kdup()
816 		if (dr->dr_xid == xid &&  in svc_clts_kdup()
817 		    dr->dr_proc == req->rq_proc &&  in svc_clts_kdup()
818 		    dr->dr_prog == req->rq_prog &&  in svc_clts_kdup()
819 		    dr->dr_vers == req->rq_vers &&  in svc_clts_kdup()
820 		    dr->dr_addr.len == req->rq_xprt->xp_rtaddr.len &&  in svc_clts_kdup()
821 		    bcmp(dr->dr_addr.buf, req->rq_xprt->xp_rtaddr.buf,  in svc_clts_kdup()
822 		    dr->dr_addr.len) == 0) {  in svc_clts_kdup()
823 			status = dr->dr_status;  in svc_clts_kdup()
825 				bcopy(dr->dr_resp.buf, res, size);  in svc_clts_kdup()
827 					*dupcachedp = (dr->dr_resfree != NULL);  in svc_clts_kdup()
829 				dr->dr_status = DUP_INPROGRESS;  in svc_clts_kdup()
830 				*drpp = dr;  in svc_clts_kdup()
836 		dr = dr->dr_chain;  in svc_clts_kdup()
844 		dr = kmem_alloc(sizeof (*dr), KM_NOSLEEP);  in svc_clts_kdup()
845 		if (dr == NULL) {  in svc_clts_kdup()
849 		dr->dr_resp.buf = NULL;  in svc_clts_kdup()
850 		dr->dr_resp.maxlen = 0;  in svc_clts_kdup()
851 		dr->dr_addr.buf = NULL;  in svc_clts_kdup()
852 		dr->dr_addr.maxlen = 0;  in svc_clts_kdup()
854 			dr->dr_next = drmru->dr_next;  in svc_clts_kdup()
855 			drmru->dr_next = dr;  in svc_clts_kdup()
857 			dr->dr_next = dr;  in svc_clts_kdup()
861 		dr = drmru->dr_next;  in svc_clts_kdup()
862 		while (dr->dr_status == DUP_INPROGRESS) {  in svc_clts_kdup()
863 			dr = dr->dr_next;  in svc_clts_kdup()
864 			if (dr == drmru->dr_next) {  in svc_clts_kdup()
870 		unhash(dr);  in svc_clts_kdup()
871 		if (dr->dr_resfree) {  in svc_clts_kdup()
872 			(*dr->dr_resfree)(dr->dr_resp.buf);  in svc_clts_kdup()
875 	dr->dr_resfree = NULL;  in svc_clts_kdup()
876 	drmru = dr;  in svc_clts_kdup()
878 	dr->dr_xid = REQTOXID(req);  in svc_clts_kdup()
879 	dr->dr_prog = req->rq_prog;  in svc_clts_kdup()
880 	dr->dr_vers = req->rq_vers;  in svc_clts_kdup()
881 	dr->dr_proc = req->rq_proc;  in svc_clts_kdup()
882 	if (dr->dr_addr.maxlen < req->rq_xprt->xp_rtaddr.len) {  in svc_clts_kdup()
883 		if (dr->dr_addr.buf != NULL)  in svc_clts_kdup()
884 			kmem_free(dr->dr_addr.buf, dr->dr_addr.maxlen);  in svc_clts_kdup()
885 		dr->dr_addr.maxlen = req->rq_xprt->xp_rtaddr.len;  in svc_clts_kdup()
886 		dr->dr_addr.buf = kmem_alloc(dr->dr_addr.maxlen,  in svc_clts_kdup()
888 		if (dr->dr_addr.buf == NULL) {  in svc_clts_kdup()
889 			dr->dr_addr.maxlen = 0;  in svc_clts_kdup()
890 			dr->dr_status = DUP_DROP;  in svc_clts_kdup()
895 	dr->dr_addr.len = req->rq_xprt->xp_rtaddr.len;  in svc_clts_kdup()
896 	bcopy(req->rq_xprt->xp_rtaddr.buf, dr->dr_addr.buf, dr->dr_addr.len);  in svc_clts_kdup()
897 	if (dr->dr_resp.maxlen < size) {  in svc_clts_kdup()
898 		if (dr->dr_resp.buf != NULL)  in svc_clts_kdup()
899 			kmem_free(dr->dr_resp.buf, dr->dr_resp.maxlen);  in svc_clts_kdup()
900 		dr->dr_resp.maxlen = (unsigned int)size;  in svc_clts_kdup()
901 		dr->dr_resp.buf = kmem_alloc(size, KM_NOSLEEP);  in svc_clts_kdup()
902 		if (dr->dr_resp.buf == NULL) {  in svc_clts_kdup()
903 			dr->dr_resp.maxlen = 0;  in svc_clts_kdup()
904 			dr->dr_status = DUP_DROP;  in svc_clts_kdup()
909 	dr->dr_status = DUP_INPROGRESS;  in svc_clts_kdup()
911 	drhash = (uint32_t)DRHASH(dr);  in svc_clts_kdup()
912 	dr->dr_chain = drhashtbl[drhash];  in svc_clts_kdup()
913 	drhashtbl[drhash] = dr;  in svc_clts_kdup()
916 	*drpp = dr;  in svc_clts_kdup()
930 svc_clts_kdupdone(struct dupreq *dr, caddr_t res, void (*dis_resfree)(),  in svc_clts_kdupdone()  argument
934 	ASSERT(dr->dr_resfree == NULL);  in svc_clts_kdupdone()
936 		bcopy(res, dr->dr_resp.buf, size);  in svc_clts_kdupdone()
937 		dr->dr_resfree = dis_resfree;  in svc_clts_kdupdone()
939 	dr->dr_status = status;  in svc_clts_kdupdone()
946 unhash(struct dupreq *dr)  in unhash()  argument
954 	drhash = (uint32_t)DRHASH(dr);  in unhash()
957 		if (drt == dr) {  in unhash()