Lines Matching full:fd

90 	int (*fxstat)(int ver, int fd, struct stat *buf);
120 int fd; member
285 static void fd_store(int index, int fd, enum fd_type type, enum fd_fork_state state) in fd_store() argument
290 fdi->fd = fd; in fd_store()
295 static inline enum fd_type fd_get(int index, int *fd) in fd_get() argument
301 *fd = fdi->fd; in fd_get()
305 *fd = index; in fd_get()
315 return fdi ? fdi->fd : index; in fd_getd()
334 static enum fd_type fd_close(int index, int *fd) in fd_close() argument
342 *fd = fdi->fd; in fd_close()
347 *fd = index; in fd_close()
568 int fd; in bind() local
569 return (fd_get(socket, &fd) == fd_rsocket) ? in bind()
570 rbind(fd, addr, addrlen) : real.bind(fd, addr, addrlen); in bind()
575 int fd, ret; in listen() local
576 if (fd_get(socket, &fd) == fd_rsocket) { in listen()
577 ret = rlisten(fd, backlog); in listen()
579 ret = real.listen(fd, backlog); in listen()
581 fd_store(socket, fd, fd_normal, fd_fork_listen); in listen()
588 int fd, index, ret; in accept() local
590 if (fd_get(socket, &fd) == fd_rsocket) { in accept()
595 ret = raccept(fd, addr, addrlen); in accept()
597 fd_close(index, &fd); in accept()
608 ret = real.accept(fd, addr, addrlen); in accept()
610 fd_close(index, &fd); in accept()
617 return real.accept(fd, addr, addrlen); in accept()
746 static inline enum fd_type fd_fork_get(int index, int *fd) in fd_fork_get() argument
756 *fd = fdi->fd; in fd_fork_get()
760 *fd = index; in fd_fork_get()
767 int fd, ret; in connect() local
769 if (fd_get(socket, &fd) == fd_rsocket) { in connect()
770 ret = rconnect(fd, addr, addrlen); in connect()
778 rclose(fd); in connect()
779 fd = ret; in connect()
781 fd_store(socket, fd, fd_normal, fd_fork_active); in connect()
784 return real.connect(fd, addr, addrlen); in connect()
789 int fd; in recv() local
790 return (fd_fork_get(socket, &fd) == fd_rsocket) ? in recv()
791 rrecv(fd, buf, len, flags) : real.recv(fd, buf, len, flags); in recv()
797 int fd; in recvfrom() local
798 return (fd_fork_get(socket, &fd) == fd_rsocket) ? in recvfrom()
799 rrecvfrom(fd, buf, len, flags, src_addr, addrlen) : in recvfrom()
800 real.recvfrom(fd, buf, len, flags, src_addr, addrlen); in recvfrom()
805 int fd; in recvmsg() local
806 return (fd_fork_get(socket, &fd) == fd_rsocket) ? in recvmsg()
807 rrecvmsg(fd, msg, flags) : real.recvmsg(fd, msg, flags); in recvmsg()
812 int fd; in read() local
814 return (fd_fork_get(socket, &fd) == fd_rsocket) ? in read()
815 rread(fd, buf, count) : real.read(fd, buf, count); in read()
820 int fd; in readv() local
822 return (fd_fork_get(socket, &fd) == fd_rsocket) ? in readv()
823 rreadv(fd, iov, iovcnt) : real.readv(fd, iov, iovcnt); in readv()
828 int fd; in send() local
829 return (fd_fork_get(socket, &fd) == fd_rsocket) ? in send()
830 rsend(fd, buf, len, flags) : real.send(fd, buf, len, flags); in send()
836 int fd; in sendto() local
837 return (fd_fork_get(socket, &fd) == fd_rsocket) ? in sendto()
838 rsendto(fd, buf, len, flags, dest_addr, addrlen) : in sendto()
839 real.sendto(fd, buf, len, flags, dest_addr, addrlen); in sendto()
844 int fd; in sendmsg() local
845 return (fd_fork_get(socket, &fd) == fd_rsocket) ? in sendmsg()
846 rsendmsg(fd, msg, flags) : real.sendmsg(fd, msg, flags); in sendmsg()
851 int fd; in write() local
853 return (fd_fork_get(socket, &fd) == fd_rsocket) ? in write()
854 rwrite(fd, buf, count) : real.write(fd, buf, count); in write()
859 int fd; in writev() local
861 return (fd_fork_get(socket, &fd) == fd_rsocket) ? in writev()
862 rwritev(fd, iov, iovcnt) : real.writev(fd, iov, iovcnt); in writev()
888 if (fd_gett(fds[i].fd) == fd_rsocket) in poll()
900 rfds[i].fd = fd_getd(fds[i].fd); in poll()
916 int fd, events, i = 0; in select_to_rpoll() local
918 for (fd = 0; fd < *nfds; fd++) { in select_to_rpoll()
919 events = (readfds && FD_ISSET(fd, readfds)) ? POLLIN : 0; in select_to_rpoll()
920 if (writefds && FD_ISSET(fd, writefds)) in select_to_rpoll()
923 if (events || (exceptfds && FD_ISSET(fd, exceptfds))) { in select_to_rpoll()
924 fds[i].fd = fd_getd(fd); in select_to_rpoll()
935 int fd, rfd, i, cnt = 0; in rpoll_to_select() local
937 for (i = 0, fd = 0; i < nfds; fd++) { in rpoll_to_select()
938 rfd = fd_getd(fd); in rpoll_to_select()
939 if (rfd != fds[i].fd) in rpoll_to_select()
943 FD_SET(fd, readfds); in rpoll_to_select()
948 FD_SET(fd, writefds); in rpoll_to_select()
953 FD_SET(fd, exceptfds); in rpoll_to_select()
995 int fd; in shutdown() local
996 return (fd_get(socket, &fd) == fd_rsocket) ? in shutdown()
997 rshutdown(fd, how) : real.shutdown(fd, how); in shutdown()
1021 ret = (fdi->type == fd_rsocket) ? rclose(fdi->fd) : real.close(fdi->fd); in close()
1028 int fd; in getpeername() local
1029 return (fd_get(socket, &fd) == fd_rsocket) ? in getpeername()
1030 rgetpeername(fd, addr, addrlen) : in getpeername()
1031 real.getpeername(fd, addr, addrlen); in getpeername()
1036 int fd; in getsockname() local
1038 return (fd_get(socket, &fd) == fd_rsocket) ? in getsockname()
1039 rgetsockname(fd, addr, addrlen) : in getsockname()
1040 real.getsockname(fd, addr, addrlen); in getsockname()
1046 int fd; in setsockopt() local
1047 return (fd_get(socket, &fd) == fd_rsocket) ? in setsockopt()
1048 rsetsockopt(fd, level, optname, optval, optlen) : in setsockopt()
1049 real.setsockopt(fd, level, optname, optval, optlen); in setsockopt()
1055 int fd; in getsockopt() local
1056 return (fd_get(socket, &fd) == fd_rsocket) ? in getsockopt()
1057 rgetsockopt(fd, level, optname, optval, optlen) : in getsockopt()
1058 real.getsockopt(fd, level, optname, optval, optlen); in getsockopt()
1066 int fd, ret; in fcntl() local
1076 ret = (fd_get(socket, &fd) == fd_rsocket) ? in fcntl()
1077 rfcntl(fd, cmd) : real.fcntl(fd, cmd); in fcntl()
1088 ret = (fd_get(socket, &fd) == fd_rsocket) ? in fcntl()
1089 rfcntl(fd, cmd, lparam) : real.fcntl(fd, cmd, lparam); in fcntl()
1093 ret = (fd_get(socket, &fd) == fd_rsocket) ? in fcntl()
1094 rfcntl(fd, cmd, pparam) : real.fcntl(fd, cmd, pparam); in fcntl()
1140 newfdi->fd = oldfdi->fd; in dup2()
1156 int fd; in sendfile() local
1159 if (fd_get(out_fd, &fd) != fd_rsocket) in sendfile()
1160 return real.sendfile(fd, in_fd, offset, count); in sendfile()
1166 ret = rwrite(fd, file_addr, count); in sendfile()
1175 int fd, ret; in __fxstat() local
1178 if (fd_get(socket, &fd) == fd_rsocket) { in __fxstat()
1183 ret = real.fxstat(ver, fd, buf); in __fxstat()