Lines Matching refs:cu_fd
122 int cu_fd; /* connections fd */
284 cu->cu_fd = fd;
291 EV_SET(&cu->cu_kin, cu->cu_fd, EVFILT_READ, EV_ADD, 0, 0, 0);
344 while (dg_fd_locks[cu->cu_fd])
345 cond_wait(&dg_cv[cu->cu_fd], &clnt_fd_lock);
350 dg_fd_locks[cu->cu_fd] = rpc_lock_value;
359 if (_connect(cu->cu_fd, (struct sockaddr *)&cu->cu_raddr,
425 if (_sendto(cu->cu_fd, cu->cu_outbuf, outlen, 0, sa, salen) != outlen) {
477 recvlen = _recvfrom(cu->cu_fd, cu->cu_inbuf,
605 release_fd_lock(cu->cu_fd, mask);
629 while (dg_fd_locks[cu->cu_fd])
630 cond_wait(&dg_cv[cu->cu_fd], &clnt_fd_lock);
635 cond_signal(&dg_cv[cu->cu_fd]);
657 while (dg_fd_locks[cu->cu_fd])
658 cond_wait(&dg_cv[cu->cu_fd], &clnt_fd_lock);
663 dg_fd_locks[cu->cu_fd] = rpc_lock_value;
668 release_fd_lock(cu->cu_fd, mask);
672 release_fd_lock(cu->cu_fd, mask);
678 release_fd_lock(cu->cu_fd, mask);
684 release_fd_lock(cu->cu_fd, mask);
698 release_fd_lock(cu->cu_fd, mask);
707 *(int *)info = cu->cu_fd;
718 release_fd_lock(cu->cu_fd, mask);
781 release_fd_lock(cu->cu_fd, mask);
784 release_fd_lock(cu->cu_fd, mask);
792 int cu_fd = cu->cu_fd;
799 while (dg_fd_locks[cu_fd])
800 cond_wait(&dg_cv[cu_fd], &clnt_fd_lock);
802 (void)_close(cu_fd);
814 cond_signal(&dg_cv[cu_fd]);