354 	struct cu_request *cr;  in clnt_dg_call()  local
358 	cr = malloc(sizeof(struct cu_request), M_RPC, M_WAITOK);  in clnt_dg_call()
364 		free(cr, M_RPC);  in clnt_dg_call()
377 	cr->cr_client = cl;  in clnt_dg_call()
378 	cr->cr_mrep = NULL;  in clnt_dg_call()
379 	cr->cr_error = 0;  in clnt_dg_call()
453 	cr->cr_xid = xid;  in clnt_dg_call()
474 	TAILQ_INSERT_TAIL(&cs->cs_pending, cr, cr_link);  in clnt_dg_call()
489 	reply_msg.acpted_rply.ar_verf.oa_base = cr->cr_verf;  in clnt_dg_call()
496 		TAILQ_REMOVE(&cs->cs_pending, cr, cr_link);  in clnt_dg_call()
511 	if (cr->cr_error) {  in clnt_dg_call()
512 		TAILQ_REMOVE(&cs->cs_pending, cr, cr_link);  in clnt_dg_call()
513 		errp->re_errno = cr->cr_error;  in clnt_dg_call()
522 	if (cr->cr_mrep) {  in clnt_dg_call()
523 		TAILQ_REMOVE(&cs->cs_pending, cr, cr_link);  in clnt_dg_call()
536 		TAILQ_REMOVE(&cs->cs_pending, cr, cr_link);  in clnt_dg_call()
558 				cr->cr_error = ESHUTDOWN;  in clnt_dg_call()
560 				error = msleep(cr, &cs->cs_lock,  in clnt_dg_call()
567 		TAILQ_REMOVE(&cs->cs_pending, cr, cr_link);  in clnt_dg_call()
580 			if (cr->cr_error) {  in clnt_dg_call()
581 				errp->re_errno = cr->cr_error;  in clnt_dg_call()
681 		TAILQ_INSERT_TAIL(&cs->cs_pending, cr, cr_link);  in clnt_dg_call()
694 	xdrmbuf_create(&xdrs, cr->cr_mrep, XDR_DECODE);  in clnt_dg_call()
696 	cr->cr_mrep = NULL;  in clnt_dg_call()
734 					    cr, cr_link);  in clnt_dg_call()
735 					cr->cr_mrep = NULL;  in clnt_dg_call()
768 	if (cr->cr_mrep)  in clnt_dg_call()
769 		m_freem(cr->cr_mrep);  in clnt_dg_call()
780 	free(cr, M_RPC);  in clnt_dg_call()
949 	struct cu_request *cr;  in clnt_dg_close()  local
972 	TAILQ_FOREACH(cr, &cs->cs_pending, cr_link) {  in clnt_dg_close()
973 		if (cr->cr_client == cl) {  in clnt_dg_close()
974 			cr->cr_xid = 0;  in clnt_dg_close()
975 			cr->cr_error = ESHUTDOWN;  in clnt_dg_close()
976 			wakeup(cr);  in clnt_dg_close()
1052 	struct cu_request *cr;  in clnt_dg_soupcall()  local
1078 			TAILQ_FOREACH(cr, &cs->cs_pending, cr_link) {  in clnt_dg_soupcall()
1079 				cr->cr_xid = 0;  in clnt_dg_soupcall()
1080 				cr->cr_error = error;  in clnt_dg_soupcall()
1081 				wakeup(cr);  in clnt_dg_soupcall()
1106 		TAILQ_FOREACH(cr, &cs->cs_pending, cr_link) {  in clnt_dg_soupcall()
1107 			if (cr->cr_xid == xid) {  in clnt_dg_soupcall()
1116 				cr->cr_xid = 0;  in clnt_dg_soupcall()
1117 				cr->cr_mrep = m;  in clnt_dg_soupcall()
1118 				cr->cr_error = 0;  in clnt_dg_soupcall()
1120 				wakeup(cr);  in clnt_dg_soupcall()