349 	struct cu_request *cr;  in clnt_dg_call()  local
353 	cr = malloc(sizeof(struct cu_request), M_RPC, M_WAITOK);  in clnt_dg_call()
359 		free(cr, M_RPC);  in clnt_dg_call()
372 	cr->cr_client = cl;  in clnt_dg_call()
373 	cr->cr_mrep = NULL;  in clnt_dg_call()
374 	cr->cr_error = 0;  in clnt_dg_call()
448 	cr->cr_xid = xid;  in clnt_dg_call()
469 	TAILQ_INSERT_TAIL(&cs->cs_pending, cr, cr_link);  in clnt_dg_call()
484 	reply_msg.acpted_rply.ar_verf.oa_base = cr->cr_verf;  in clnt_dg_call()
491 		TAILQ_REMOVE(&cs->cs_pending, cr, cr_link);  in clnt_dg_call()
506 	if (cr->cr_error) {  in clnt_dg_call()
507 		TAILQ_REMOVE(&cs->cs_pending, cr, cr_link);  in clnt_dg_call()
508 		errp->re_errno = cr->cr_error;  in clnt_dg_call()
517 	if (cr->cr_mrep) {  in clnt_dg_call()
518 		TAILQ_REMOVE(&cs->cs_pending, cr, cr_link);  in clnt_dg_call()
531 		TAILQ_REMOVE(&cs->cs_pending, cr, cr_link);  in clnt_dg_call()
553 				cr->cr_error = ESHUTDOWN;  in clnt_dg_call()
555 				error = msleep(cr, &cs->cs_lock,  in clnt_dg_call()
562 		TAILQ_REMOVE(&cs->cs_pending, cr, cr_link);  in clnt_dg_call()
575 			if (cr->cr_error) {  in clnt_dg_call()
576 				errp->re_errno = cr->cr_error;  in clnt_dg_call()
676 		TAILQ_INSERT_TAIL(&cs->cs_pending, cr, cr_link);  in clnt_dg_call()
689 	xdrmbuf_create(&xdrs, cr->cr_mrep, XDR_DECODE);  in clnt_dg_call()
691 	cr->cr_mrep = NULL;  in clnt_dg_call()
729 					    cr, cr_link);  in clnt_dg_call()
730 					cr->cr_mrep = NULL;  in clnt_dg_call()
763 	if (cr->cr_mrep)  in clnt_dg_call()
764 		m_freem(cr->cr_mrep);  in clnt_dg_call()
775 	free(cr, M_RPC);  in clnt_dg_call()
944 	struct cu_request *cr;  in clnt_dg_close()  local
967 	TAILQ_FOREACH(cr, &cs->cs_pending, cr_link) {  in clnt_dg_close()
968 		if (cr->cr_client == cl) {  in clnt_dg_close()
969 			cr->cr_xid = 0;  in clnt_dg_close()
970 			cr->cr_error = ESHUTDOWN;  in clnt_dg_close()
971 			wakeup(cr);  in clnt_dg_close()
1047 	struct cu_request *cr;  in clnt_dg_soupcall()  local
1073 			TAILQ_FOREACH(cr, &cs->cs_pending, cr_link) {  in clnt_dg_soupcall()
1074 				cr->cr_xid = 0;  in clnt_dg_soupcall()
1075 				cr->cr_error = error;  in clnt_dg_soupcall()
1076 				wakeup(cr);  in clnt_dg_soupcall()
1101 		TAILQ_FOREACH(cr, &cs->cs_pending, cr_link) {  in clnt_dg_soupcall()
1102 			if (cr->cr_xid == xid) {  in clnt_dg_soupcall()
1111 				cr->cr_xid = 0;  in clnt_dg_soupcall()
1112 				cr->cr_mrep = m;  in clnt_dg_soupcall()
1113 				cr->cr_error = 0;  in clnt_dg_soupcall()
1115 				wakeup(cr);  in clnt_dg_soupcall()