Commit 7f9a2f8a authored by Max Kellermann's avatar Max Kellermann

event/Loop: schedule and cancel the WakeFD in Run()

This is only needed while Run() is alive, and moving it there avoids problems with thread-checking assertions.
parent cd0e9287
......@@ -23,6 +23,7 @@
#include "SocketMonitor.hxx"
#include "IdleMonitor.hxx"
#include "DeferredMonitor.hxx"
#include "util/ScopeExit.hxx"
#include <algorithm>
......@@ -30,17 +31,12 @@ EventLoop::EventLoop()
:SocketMonitor(*this)
{
SocketMonitor::Open(SocketDescriptor(wake_fd.Get()));
SocketMonitor::Schedule(SocketMonitor::READ);
}
EventLoop::~EventLoop()
{
assert(idle.empty());
assert(timers.empty());
/* this is necessary to get a well-defined destruction
order */
SocketMonitor::Cancel();
}
void
......@@ -144,6 +140,9 @@ EventLoop::Run()
assert(!quit);
assert(busy);
SocketMonitor::Schedule(SocketMonitor::READ);
AtScopeExit(this) { SocketMonitor::Cancel(); };
do {
now = std::chrono::steady_clock::now();
again = false;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment