Lines Matching refs:m_fd
140 m_fd = ::accept(sock_fd, &accept_addr.sockaddr(), &sa_len); in Listen()
142 if (m_fd == -1) { in Listen()
153 ::close(m_fd); in Listen()
154 m_fd = -1; in Listen()
179 SetSocketOption(m_fd, IPPROTO_TCP, TCP_NODELAY, 1); in Listen()
192 m_fd = ::socket(address.GetFamily(), SOCK_STREAM, IPPROTO_TCP); in Connect()
193 if (m_fd == -1) in Connect()
197 SetSocketOption(m_fd, SOL_SOCKET, SO_REUSEADDR, 1); in Connect()
201 if (-1 == ::connect(m_fd, &address.sockaddr(), address.GetLength())) { in Connect()
205 SetSocketOption(m_fd, IPPROTO_TCP, TCP_NODELAY, 1); in Connect()
219 m_fd = fd; in useFD()
231 m_fd = -1; in ConnectToService()
234 m_fd = ::lockdown_get_socket(m_ld_conn); in ConnectToService()
235 if (m_fd == -1) { in ConnectToService()
246 m_fd = open(path, O_RDWR); in OpenFile()
247 if (m_fd == -1) { in OpenFile()
254 if (::tcgetattr(m_fd, &stdin_termios) == 0) { in OpenFile()
257 ::tcsetattr(m_fd, TCSANOW, &stdin_termios); in OpenFile()
273 m_fd = -1; in Disconnect()
278 return ClosePort(m_fd, save_errno); in Disconnect()
288 if (m_fd == -1) in Read()
294 ssize_t bytesread = read(m_fd, buf, sizeof(buf)); in Read()
301 err.LogThreaded("::read ( %i, %p, %llu ) => %i", m_fd, buf, sizeof(buf), in Read()
307 m_fd = -1; in Read()
310 m_fd = -1; in Read()
323 if (m_fd == -1) in Write()
327 ssize_t bytessent = write(m_fd, buffer, length); in Write()
333 m_fd, buffer, length, (uint64_t)bytessent); in Write()