From bb2af791e9cea7addaa51e83d175461395af0ff4 Mon Sep 17 00:00:00 2001 From: Max Kellermann Date: Sat, 10 Aug 2013 10:10:40 +0200 Subject: event/MultiSocketMonitor: add struct SingleFD Prepare for migrating away from GLib. --- src/event/MultiSocketMonitor.cxx | 2 +- src/event/MultiSocketMonitor.hxx | 38 +++++++++++++++++++++++++++++++------- 2 files changed, 32 insertions(+), 8 deletions(-) (limited to 'src/event') diff --git a/src/event/MultiSocketMonitor.cxx b/src/event/MultiSocketMonitor.cxx index 6ea0cb030..dcc5edb38 100644 --- a/src/event/MultiSocketMonitor.cxx +++ b/src/event/MultiSocketMonitor.cxx @@ -74,7 +74,7 @@ MultiSocketMonitor::Check() const return true; for (const auto &i : fds) - if (i.revents != 0) + if (i.GetReturnedEvents() != 0) return true; return false; diff --git a/src/event/MultiSocketMonitor.hxx b/src/event/MultiSocketMonitor.hxx index f6ce43d52..39fd2da3c 100644 --- a/src/event/MultiSocketMonitor.hxx +++ b/src/event/MultiSocketMonitor.hxx @@ -51,10 +51,34 @@ class MultiSocketMonitor { MultiSocketMonitor *monitor; }; + struct SingleFD { + GPollFD pfd; + + constexpr SingleFD(gcc_unused MultiSocketMonitor &m, + int fd, unsigned events) + :pfd{fd, gushort(events), 0} {} + + constexpr int GetFD() const { + return pfd.fd; + } + + constexpr unsigned GetEvents() const { + return pfd.events; + } + + constexpr unsigned GetReturnedEvents() const { + return pfd.revents; + } + + void SetEvents(unsigned _events) { + pfd.events = _events; + } + }; + EventLoop &loop; Source *source; uint64_t absolute_timeout_us; - std::forward_list fds; + std::forward_list fds; public: static constexpr unsigned READ = G_IO_IN; @@ -80,8 +104,8 @@ public: } void AddSocket(int fd, unsigned events) { - fds.push_front({fd, gushort(events), 0}); - g_source_add_poll(&source->base, &fds.front()); + fds.emplace_front(*this, fd, events); + g_source_add_poll(&source->base, &fds.front().pfd); } template @@ -89,14 +113,14 @@ public: for (auto prev = fds.before_begin(), end = fds.end(), i = std::next(prev); i != end; i = std::next(prev)) { - assert(i->events != 0); + assert(i->GetEvents() != 0); - unsigned events = e(i->fd); + unsigned events = e(i->GetFD()); if (events != 0) { - i->events = events; + i->SetEvents(events); prev = i; } else { - g_source_remove_poll(&source->base, &*i); + g_source_remove_poll(&source->base, &i->pfd); fds.erase_after(prev); } } -- cgit v1.2.3