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