Lines Matching refs:FD
99 : FD(SocketFD), SocketPath(SocketPath), PipeFD{PipeFD[0], PipeFD[1]} {} in getSocketFD()
102 : FD(LS.FD.load()), SocketPath(LS.SocketPath), in getSocketFD()
105 LS.FD = -1; in getSocketFD()
194 struct pollfd FD[2]; in getSocketFD() local
195 FD[0].events = POLLIN; in getSocketFD()
198 FD[0].fd = WinServerSock; in getSocketFD()
200 FD[0].fd = getActiveFD(); in getSocketFD()
204 FD[1].events = POLLIN; in getSocketFD()
205 FD[1].fd = CancelFD.value(); in getSocketFD()
228 PollStatus = WSAPoll(FD, FDCount, RemainingTimeout.count()); in getSocketFD()
232 PollStatus = ::poll(FD, FDCount, RemainingTimeout.count()); in getSocketFD()
239 if (getActiveFD() == -1 || (CancelFD.has_value() && FD[1].revents & POLLIN)) in getSocketFD()
249 if (FD[0].revents & POLLNVAL) in getSocketFD()
256 auto getActiveFD = [this]() -> int { return FD; }; in accept()
263 SOCKET WinAcceptSock = ::accept(_get_osfhandle(FD), NULL, NULL); in accept()
266 AcceptFD = ::accept(FD, NULL, NULL); in accept()
276 int ObservedFD = FD.load(); in shutdown()
283 if (!FD.compare_exchange_strong(ObservedFD, -1)) in shutdown()
325 Expected<int> FD = getSocketFD(SocketPath); in createConnectedUnix() local
326 if (!FD) in createConnectedUnix()
327 return FD.takeError(); in createConnectedUnix()
328 return std::make_unique<raw_socket_stream>(*FD); in createConnectedUnix()