Searched refs:pollfd (Results 1 – 6 of 6) sorted by relevance
222 std::vector<struct pollfd> pollfds; in EnsureNoProcessInDir()254 struct pollfd& pollfd = pollfds.emplace_back(); in EnsureNoProcessInDir() local255 pollfd.fd = pidfd.get(); in EnsureNoProcessInDir()256 pollfd.events = POLLIN; in EnsureNoProcessInDir()276 for (struct pollfd& pollfd : pollfds) { in EnsureNoProcessInDir() local277 if (pollfd.fd < 0) { in EnsureNoProcessInDir()280 if ((pollfd.revents & POLLIN) != 0) { in EnsureNoProcessInDir()281 const auto& [pid, name] = running_processes[pollfd.fd]; in EnsureNoProcessInDir()284 running_processes.erase(pollfd.fd); in EnsureNoProcessInDir()285 pollfd.fd = -1; in EnsureNoProcessInDir()
187 struct pollfd pollfd = { read_fd_, POLLRDHUP, 0 }; in ReadUpToMax() local188 res = TEMP_FAILURE_RETRY(poll(&pollfd, /*nfds*/1, /*timeout*/0)); in ReadUpToMax()189 if (res < 0 || (pollfd.revents & POLLERR) == POLLERR) { in ReadUpToMax()193 return ((pollfd.revents & (POLLRDHUP | POLLHUP)) == 0) ? IOResult::kOk : IOResult::kEOF; in ReadUpToMax()204 struct pollfd pollfds[2]; in ReadFully()
686 struct pollfd pollfds[4] = { in RunPollLoop()705 const struct pollfd& sleep_event_poll = pollfds[0]; in RunPollLoop()706 const struct pollfd& agent_control_sock_poll = pollfds[1]; in RunPollLoop()707 const struct pollfd& control_sock_poll = pollfds[2]; in RunPollLoop()708 const struct pollfd& adb_socket_poll = pollfds[3]; in RunPollLoop()
191 struct pollfd pfd; in WaitChildWithTimeout()
172 struct pollfd read_fd{in, POLLIN, 0}; in Drain()
218 struct pollfd read_fd{in, POLLIN, 0}; in Drain()