libc/rpc/svc_vc.c

252 	struct cf_conn *cd;
263 	cd = mem_alloc(sizeof(struct cf_conn));
264 	if (cd == NULL) {
270 	cd->strm_stat = XPRT_IDLE;
271 	xdrrec_create(&(cd->xdrs), sendsize, recvsize,
273 	xprt->xp_p1 = cd;
274 	xprt->xp_verf.oa_base = cd->verf_body;
294 	struct cf_conn *cd;
343 	cd = (struct cf_conn *)newxprt->xp_p1;
345 	cd->recvsize = r->recvsize;
346 	cd->sendsize = r->sendsize;
347 	cd->maxrec = r->maxrec;
349 	if (cd->maxrec != 0) {
355 		if (cd->recvsize > cd->maxrec)
356 			cd->recvsize = cd->maxrec;
357 		cd->nonblock = TRUE;
358 		__xdrrec_setnonblock(&cd->xdrs, cd->maxrec);
360 		cd->nonblock = FALSE;
362 	gettimeofday(&cd->last_recv_time, NULL);
390 	struct cf_conn *cd;
393 	cd = (struct cf_conn *)xprt->xp_p1;
404 		XDR_DESTROY(&(cd->xdrs));
405 		mem_free(cd, sizeof(struct cf_conn));
530 	struct cf_conn *cd;
536 	cd = (struct cf_conn *)xprt->xp_p1;
538 	if (cd->nonblock)
544 			if (errno != EAGAIN || !cd->nonblock) {
545 				cd->strm_stat = XPRT_DIED;
548 			if (cd->nonblock) {
558 					cd->strm_stat = XPRT_DIED;
573 	struct cf_conn *cd;
577 	cd = (struct cf_conn *)(xprt->xp_p1);
579 	if (cd->strm_stat == XPRT_DIED)
581 	if (! xdrrec_eof(&(cd->xdrs)))
591 	struct cf_conn *cd;
597 	cd = (struct cf_conn *)(xprt->xp_p1);
598 	xdrs = &(cd->xdrs);
600 	if (cd->nonblock) {
601 		if (!__xdrrec_getrec(xdrs, &cd->strm_stat, TRUE))
609 		cd->x_id = msg->rm_xid;
612 	cd->strm_stat = XPRT_DIED;
622 	struct cf_conn *cd;
625 	cd = (struct cf_conn *)(xprt->xp_p1);
627 		&cd->xdrs, xdr_args, args_ptr));
652 	struct cf_conn *cd;
662 	cd = (struct cf_conn *)(xprt->xp_p1);
663 	xdrs = &(cd->xdrs);
666 	msg->rm_xid = cd->x_id;
773 	struct cf_conn *cd;
785 			cd = (struct cf_conn *)xprt->xp_p1;
786 			if (!cleanblock && !cd->nonblock)
789 				timersub(&tv, &cd->last_recv_time, &tdiff);
796 			if (tv.tv_sec - cd->last_recv_time.tv_sec > timeout) {