Lines Matching refs:ct_fd

118 	int		ct_fd;		/* connection's fd */  member
190 if ((flag = fcntl(ct->ct_fd, F_GETFL, 0)) < 0) { in set_blocking_connection()
197 if (fcntl(ct->ct_fd, F_SETFL, flag) != 0) { in set_blocking_connection()
305 ct->ct_fd = fd; in _clnt_vc_create_timed()
649 if (rpc_fd_lock(vctbl, ct->ct_fd)) { in clnt_vc_call()
652 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_call()
659 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_call()
693 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_call()
704 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_call()
709 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_call()
713 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_call()
720 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_call()
734 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_call()
741 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_call()
797 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_call()
809 if (rpc_fd_lock(vctbl, ct->ct_fd)) { in clnt_vc_send()
812 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_send()
835 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_send()
846 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_send()
859 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_send()
877 (void) rpc_fd_lock(vctbl, ct->ct_fd); in clnt_vc_freeres()
880 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_freeres()
895 if (rpc_fd_lock(vctbl, ct->ct_fd)) { in clnt_vc_control()
896 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_control()
903 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_control()
907 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_control()
919 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_control()
925 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_control()
931 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_control()
945 *(int *)info = ct->ct_fd; in clnt_vc_control()
958 if (t_snddis(ct->ct_fd, NULL) == -1) { in clnt_vc_control()
962 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_control()
965 ret = set_up_connection(ct->ct_fd, (struct netbuf *)info, in clnt_vc_control()
967 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_control()
970 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_control()
1020 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_control()
1027 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_control()
1050 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_control()
1077 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_control()
1080 rpc_fd_unlock(vctbl, ct->ct_fd); in clnt_vc_control()
1088 int ct_fd = ct->ct_fd; in clnt_vc_destroy() local
1090 (void) rpc_fd_lock(vctbl, ct_fd); in clnt_vc_destroy()
1098 (void) t_close(ct_fd); in clnt_vc_destroy()
1108 rpc_fd_unlock(vctbl, ct_fd); in clnt_vc_destroy()
1152 pfdp[0].fd = ct->ct_fd; in read_vc()
1263 switch (len = t_rcvall(ct->ct_fd, buf, len)) { in read_vc()
1326 if ((len = t_snd(ct->ct_fd, buf, (unsigned)len, 0)) == -1) { in write_vc()
1339 if ((i = t_snd(ct->ct_fd, buf, (unsigned)MIN(cnt, maxsz), in write_vc()
1597 result = writev(ct->ct_fd, iov, 2); in do_flush()
1599 result = t_snd(ct->ct_fd, ct->ct_bufferReadPtr, in do_flush()
1615 result = writev(ct->ct_fd, iov, 2); in do_flush()
1617 result = t_snd(ct->ct_fd, ct->ct_bufferReadPtr, in do_flush()
1674 result = t_snd(ct->ct_fd, buff, nBytes, 0); in nb_send()
1704 result = writev(ct->ct_fd, iov, i+1); in nb_send()