Lines Matching refs:loop
47 RunImpl(MainLoopPosix &loop);
54 MainLoopPosix &loop; member in MainLoopPosix::RunImpl
73 MainLoopPosix::RunImpl::RunImpl(MainLoopPosix &loop) : loop(loop) { in RunImpl() argument
74 in_events.reserve(loop.m_read_fds.size()); in RunImpl()
78 in_events.resize(loop.m_read_fds.size()); in Poll()
80 for (auto &fd : loop.m_read_fds) in Poll()
83 num_events = kevent(loop.m_kqueue, in_events.data(), in_events.size(), in Poll()
100 if (loop.m_terminate_request) in ProcessEvents()
104 loop.ProcessReadObject(out_events[i].ident); in ProcessEvents()
107 loop.ProcessSignal(out_events[i].ident); in ProcessEvents()
115 MainLoopPosix::RunImpl::RunImpl(MainLoopPosix &loop) : loop(loop) { in RunImpl() argument
117 read_fds.reserve(loop.m_read_fds.size()); in RunImpl()
127 for (const auto &sig : loop.m_signals) in get_sigmask()
142 for (const auto &fd : loop.m_read_fds) { in Poll()
174 for (const auto &fd : loop.m_read_fds) { in Poll()
197 for (const auto &fd : loop.m_read_fds)
208 if (loop.m_terminate_request)
211 loop.ProcessReadObject(handle);
215 for (const auto &entry : loop.m_signals)
220 if (loop.m_terminate_request)
223 loop.ProcessSignal(signal);
232 m_read_fds.insert({trigger_pipe_fd, [trigger_pipe_fd](MainLoopBase &loop) { argument