Lines Matching defs:loop

98   RunImpl(MainLoopPosix &loop);
106   MainLoopPosix &loop;
119 MainLoopPosix::RunImpl::RunImpl(MainLoopPosix &loop) : loop(loop) {
120   in_events.reserve(loop.m_read_fds.size());
124   in_events.resize(loop.m_read_fds.size());
126   for (auto &fd : loop.m_read_fds)
130       kevent(loop.m_kqueue, in_events.data(), in_events.size(), out_events,
131              std::size(out_events), ToTimeSpec(loop.GetNextWakeupTime()));
135       // in case of EINTR, let the main loop run one iteration
147     if (loop.m_terminate_request)
151       loop.ProcessReadObject(out_events[i].ident);
159 MainLoopPosix::RunImpl::RunImpl(MainLoopPosix &loop) : loop(loop) {
160   read_fds.reserve(loop.m_read_fds.size());
182   for (const auto &fd : loop.m_read_fds) {
189   int ready = StartPoll(read_fds, loop.GetNextWakeupTime());
202     if (loop.m_terminate_request)
205     loop.ProcessReadObject(handle);
223       {interrupt_pipe_fd, [interrupt_pipe_fd](MainLoopBase &loop) {
229          // NB: This implicitly causes another loop iteration