Searched refs:reader_fd (Results 1 – 9 of 9) sorted by relevance
393 int reader_fd[2]; /* for comm. with the tcp children read */ in fork_tcp_process() local401 reader_fd[0]=reader_fd[1]=-1; in fork_tcp_process()416 if (socketpair(AF_UNIX, SOCK_STREAM, 0, reader_fd)<0){ in fork_tcp_process()420 if (tcp_fix_child_sockets(reader_fd)<0){ in fork_tcp_process()477 close(reader_fd[0]); in fork_tcp_process()478 if (reader_fd_1) *reader_fd_1=reader_fd[1]; in fork_tcp_process()510 close(reader_fd[1]); in fork_tcp_process()516 tcp_children[r].unix_sock=reader_fd[0]; in fork_tcp_process()524 if (reader_fd[0]!=-1) close(reader_fd[0]); in fork_tcp_process()525 if (reader_fd[1]!=-1) close(reader_fd[1]); in fork_tcp_process()
46 self.reader_fd = self.reader.fileno()72 return pipe.reader_fd, pipe.writer_fd
87 int reader_fd; // Reader end of the pipe. member110 n = read(out->reader_fd, cur, n); in read_main()150 out->reader_fd = fds[0]; in capture()168 xclose(&out->reader_fd); in stop_capture()
90 self.reader_fd = sock.fileno()121 self.reader_fd = self.reader.fileno()129 return os.read(self.reader_fd, n)136 fcntl.fcntl(self.reader_fd, fcntl.F_SETFL, os.O_NONBLOCK)1464 rlist_in.append(qh.sock.reader_fd)1473 rlist_in.append(qh.sock.reader_fd)1485 finished_fds.append(qh.sock.reader_fd)1508 finished_fds.append(qh.sock.reader_fd)1515 rlist_in.remove(qh.sock.reader_fd)1551 query_meta[qh.sock.reader_fd] = qh[all …]
6 @property reader_fd {
66 self.reader_fd = self.reader.fileno()
88 self.reader_fd = self.reader.fileno()
89 self.reader_fd = self.reader.fileno()