Lines Matching full:cd

237 	struct cf_conn *cd;  in makefd_xprt()  local
248 cd = mem_alloc(sizeof(struct cf_conn)); in makefd_xprt()
249 if (cd == NULL) { in makefd_xprt()
255 cd->strm_stat = XPRT_IDLE; in makefd_xprt()
256 xdrrec_create(&(cd->xdrs), sendsize, recvsize, in makefd_xprt()
258 xprt->xp_p1 = cd; in makefd_xprt()
259 xprt->xp_verf.oa_base = cd->verf_body; in makefd_xprt()
277 struct cf_conn *cd; in rendezvous_request() local
326 cd = (struct cf_conn *)newxprt->xp_p1; in rendezvous_request()
328 cd->recvsize = r->recvsize; in rendezvous_request()
329 cd->sendsize = r->sendsize; in rendezvous_request()
330 cd->maxrec = r->maxrec; in rendezvous_request()
332 if (cd->maxrec != 0) { in rendezvous_request()
338 if (cd->recvsize > cd->maxrec) in rendezvous_request()
339 cd->recvsize = cd->maxrec; in rendezvous_request()
340 cd->nonblock = TRUE; in rendezvous_request()
341 __xdrrec_setnonblock(&cd->xdrs, cd->maxrec); in rendezvous_request()
343 cd->nonblock = FALSE; in rendezvous_request()
359 gettimeofday(&cd->last_recv_time, NULL); in rendezvous_request()
384 struct cf_conn *cd; in __svc_vc_dodestroy() local
387 cd = (struct cf_conn *)xprt->xp_p1; in __svc_vc_dodestroy()
398 XDR_DESTROY(&(cd->xdrs)); in __svc_vc_dodestroy()
399 mem_free(cd, sizeof(struct cf_conn)); in __svc_vc_dodestroy()
510 struct cf_conn *cd; in write_vc() local
516 cd = (struct cf_conn *)xprt->xp_p1; in write_vc()
518 if (cd->nonblock) in write_vc()
524 if (errno != EAGAIN || !cd->nonblock) { in write_vc()
525 cd->strm_stat = XPRT_DIED; in write_vc()
528 if (cd->nonblock) { in write_vc()
538 cd->strm_stat = XPRT_DIED; in write_vc()
552 struct cf_conn *cd; in svc_vc_stat() local
556 cd = (struct cf_conn *)(xprt->xp_p1); in svc_vc_stat()
558 if (cd->strm_stat == XPRT_DIED) in svc_vc_stat()
560 if (! xdrrec_eof(&(cd->xdrs))) in svc_vc_stat()
568 struct cf_conn *cd; in svc_vc_recv() local
574 cd = (struct cf_conn *)(xprt->xp_p1); in svc_vc_recv()
575 xdrs = &(cd->xdrs); in svc_vc_recv()
577 if (cd->nonblock) { in svc_vc_recv()
578 if (!__xdrrec_getrec(xdrs, &cd->strm_stat, TRUE)) in svc_vc_recv()
586 cd->x_id = msg->rm_xid; in svc_vc_recv()
589 cd->strm_stat = XPRT_DIED; in svc_vc_recv()
596 struct cf_conn *cd; in svc_vc_getargs() local
599 cd = (struct cf_conn *)(xprt->xp_p1); in svc_vc_getargs()
601 &cd->xdrs, xdr_args, args_ptr)); in svc_vc_getargs()
621 struct cf_conn *cd; in svc_vc_reply() local
631 cd = (struct cf_conn *)(xprt->xp_p1); in svc_vc_reply()
632 xdrs = &(cd->xdrs); in svc_vc_reply()
635 msg->rm_xid = cd->x_id; in svc_vc_reply()
740 struct cf_conn *cd; in __svc_clean_idle() local
752 cd = (struct cf_conn *)xprt->xp_p1; in __svc_clean_idle()
753 if (!cleanblock && !cd->nonblock) in __svc_clean_idle()
756 timersub(&tv, &cd->last_recv_time, &tdiff); in __svc_clean_idle()
763 if (tv.tv_sec - cd->last_recv_time.tv_sec > timeout) { in __svc_clean_idle()