748 #define	DRHASH(dr)	XIDHASH((dr)->dr_xid)  argument
787 	struct dupreq *dr;  in svc_clts_kdup()  local
798 	dr = drhashtbl[XIDHASH(xid)];  in svc_clts_kdup()
799 	while (dr != NULL) {  in svc_clts_kdup()
800 		if (dr->dr_xid == xid &&  in svc_clts_kdup()
801 		    dr->dr_proc == req->rq_proc &&  in svc_clts_kdup()
802 		    dr->dr_prog == req->rq_prog &&  in svc_clts_kdup()
803 		    dr->dr_vers == req->rq_vers &&  in svc_clts_kdup()
804 		    dr->dr_addr.len == req->rq_xprt->xp_rtaddr.len &&  in svc_clts_kdup()
805 		    bcmp(dr->dr_addr.buf, req->rq_xprt->xp_rtaddr.buf,  in svc_clts_kdup()
806 		    dr->dr_addr.len) == 0) {  in svc_clts_kdup()
807 			status = dr->dr_status;  in svc_clts_kdup()
809 				bcopy(dr->dr_resp.buf, res, size);  in svc_clts_kdup()
811 					*dupcachedp = (dr->dr_resfree != NULL);  in svc_clts_kdup()
813 				dr->dr_status = DUP_INPROGRESS;  in svc_clts_kdup()
814 				*drpp = dr;  in svc_clts_kdup()
820 		dr = dr->dr_chain;  in svc_clts_kdup()
828 		dr = kmem_alloc(sizeof (*dr), KM_NOSLEEP);  in svc_clts_kdup()
829 		if (dr == NULL) {  in svc_clts_kdup()
833 		dr->dr_resp.buf = NULL;  in svc_clts_kdup()
834 		dr->dr_resp.maxlen = 0;  in svc_clts_kdup()
835 		dr->dr_addr.buf = NULL;  in svc_clts_kdup()
836 		dr->dr_addr.maxlen = 0;  in svc_clts_kdup()
838 			dr->dr_next = drmru->dr_next;  in svc_clts_kdup()
839 			drmru->dr_next = dr;  in svc_clts_kdup()
841 			dr->dr_next = dr;  in svc_clts_kdup()
845 		dr = drmru->dr_next;  in svc_clts_kdup()
846 		while (dr->dr_status == DUP_INPROGRESS) {  in svc_clts_kdup()
847 			dr = dr->dr_next;  in svc_clts_kdup()
848 			if (dr == drmru->dr_next) {  in svc_clts_kdup()
854 		unhash(dr);  in svc_clts_kdup()
855 		if (dr->dr_resfree) {  in svc_clts_kdup()
856 			(*dr->dr_resfree)(dr->dr_resp.buf);  in svc_clts_kdup()
859 	dr->dr_resfree = NULL;  in svc_clts_kdup()
860 	drmru = dr;  in svc_clts_kdup()
862 	dr->dr_xid = REQTOXID(req);  in svc_clts_kdup()
863 	dr->dr_prog = req->rq_prog;  in svc_clts_kdup()
864 	dr->dr_vers = req->rq_vers;  in svc_clts_kdup()
865 	dr->dr_proc = req->rq_proc;  in svc_clts_kdup()
866 	if (dr->dr_addr.maxlen < req->rq_xprt->xp_rtaddr.len) {  in svc_clts_kdup()
867 		if (dr->dr_addr.buf != NULL)  in svc_clts_kdup()
868 			kmem_free(dr->dr_addr.buf, dr->dr_addr.maxlen);  in svc_clts_kdup()
869 		dr->dr_addr.maxlen = req->rq_xprt->xp_rtaddr.len;  in svc_clts_kdup()
870 		dr->dr_addr.buf = kmem_alloc(dr->dr_addr.maxlen,  in svc_clts_kdup()
872 		if (dr->dr_addr.buf == NULL) {  in svc_clts_kdup()
873 			dr->dr_addr.maxlen = 0;  in svc_clts_kdup()
874 			dr->dr_status = DUP_DROP;  in svc_clts_kdup()
879 	dr->dr_addr.len = req->rq_xprt->xp_rtaddr.len;  in svc_clts_kdup()
880 	bcopy(req->rq_xprt->xp_rtaddr.buf, dr->dr_addr.buf, dr->dr_addr.len);  in svc_clts_kdup()
881 	if (dr->dr_resp.maxlen < size) {  in svc_clts_kdup()
882 		if (dr->dr_resp.buf != NULL)  in svc_clts_kdup()
883 			kmem_free(dr->dr_resp.buf, dr->dr_resp.maxlen);  in svc_clts_kdup()
884 		dr->dr_resp.maxlen = (unsigned int)size;  in svc_clts_kdup()
885 		dr->dr_resp.buf = kmem_alloc(size, KM_NOSLEEP);  in svc_clts_kdup()
886 		if (dr->dr_resp.buf == NULL) {  in svc_clts_kdup()
887 			dr->dr_resp.maxlen = 0;  in svc_clts_kdup()
888 			dr->dr_status = DUP_DROP;  in svc_clts_kdup()
893 	dr->dr_status = DUP_INPROGRESS;  in svc_clts_kdup()
895 	drhash = (uint32_t)DRHASH(dr);  in svc_clts_kdup()
896 	dr->dr_chain = drhashtbl[drhash];  in svc_clts_kdup()
897 	drhashtbl[drhash] = dr;  in svc_clts_kdup()
900 	*drpp = dr;  in svc_clts_kdup()
914 svc_clts_kdupdone(struct dupreq *dr, caddr_t res, void (*dis_resfree)(),  in svc_clts_kdupdone()  argument
918 	ASSERT(dr->dr_resfree == NULL);  in svc_clts_kdupdone()
920 		bcopy(res, dr->dr_resp.buf, size);  in svc_clts_kdupdone()
921 		dr->dr_resfree = dis_resfree;  in svc_clts_kdupdone()
923 	dr->dr_status = status;  in svc_clts_kdupdone()
930 unhash(struct dupreq *dr)  in unhash()  argument
938 	drhash = (uint32_t)DRHASH(dr);  in unhash()
941 		if (drt == dr) {  in unhash()