summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMax Kellermann <max@duempel.org>2013-08-10 10:10:40 +0200
committerMax Kellermann <max@duempel.org>2013-08-10 11:52:31 +0200
commitbb2af791e9cea7addaa51e83d175461395af0ff4 (patch)
tree8126e7eaeaf5bcf4cc64183945a2b879cd9a98dc
parentf3f4b332aefdc624d97dcc058a6cad1c7fc7c2ec (diff)
event/MultiSocketMonitor: add struct SingleFD
Prepare for migrating away from GLib.
-rw-r--r--src/event/MultiSocketMonitor.cxx2
-rw-r--r--src/event/MultiSocketMonitor.hxx38
2 files changed, 32 insertions, 8 deletions
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<GPollFD> fds;
+ std::forward_list<SingleFD> 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<typename E>
@@ -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);
}
}