event/DeferEvent: use class IntrusiveList instead of boost::intrusive::list

src/event/DeferEvent.cxx

@@ -20,14 +20,11 @@
 #include "DeferEvent.hxx"
 #include "Loop.hxx"
 
-void
-DeferEvent::Cancel() noexcept
-{
-	loop.RemoveDeferred(*this);
-}
-
 void
 DeferEvent::Schedule() noexcept
 {
+	if (!IsPending())
 		loop.AddDeferred(*this);
+
+	assert(IsPending());
 }

src/event/DeferEvent.hxx

@@ -21,8 +21,7 @@
 #define MPD_DEFER_EVENT_HXX
 
 #include "util/BindMethod.hxx"
-
+#include "util/IntrusiveList.hxx"
-#include <boost/intrusive/list_hook.hpp>
 
 class EventLoop;
 
@@ -34,10 +33,10 @@ class EventLoop;
  * This class is not thread-safe, all methods must be called from the
  * thread that runs the #EventLoop.
  */
-class DeferEvent final
+class DeferEvent final : AutoUnlinkIntrusiveListHook
-	: public boost::intrusive::list_base_hook<>
 {
 	friend class EventLoop;
+	friend class IntrusiveList<DeferEvent>;
 
 	EventLoop &loop;
 
@@ -51,23 +50,23 @@ public:
 	DeferEvent(const DeferEvent &) = delete;
 	DeferEvent &operator=(const DeferEvent &) = delete;
 
-	~DeferEvent() noexcept {
+	auto &GetEventLoop() const noexcept {
-		Cancel();
-	}
-
-	EventLoop &GetEventLoop() const noexcept {
 		return loop;
 	}
 
-	void Schedule() noexcept;
-	void Cancel() noexcept;
-
-private:
 	bool IsPending() const noexcept {
 		return is_linked();
 	}
 
-	void RunDeferred() noexcept {
+	void Schedule() noexcept;
+
+	void Cancel() noexcept {
+		if (IsPending())
+			unlink();
+	}
+
+private:
+	void Run() noexcept {
 		callback();
 	}
 };

src/event/Loop.cxx

@@ -198,29 +198,17 @@ EventLoop::HandleTimers() noexcept
 void
 EventLoop::AddDeferred(DeferEvent &d) noexcept
 {
-	if (d.IsPending())
+	defer.push_back(d);
-		return;
-
-	deferred.push_back(d);
 	again = true;
 }
 
-void
-EventLoop::RemoveDeferred(DeferEvent &d) noexcept
-{
-	if (d.IsPending())
-		deferred.erase(deferred.iterator_to(d));
-}
-
 void
 EventLoop::RunDeferred() noexcept
 {
-	while (!deferred.empty() && !quit) {
+	while (!defer.empty() && !quit) {
-		auto &m = deferred.front();
+		defer.pop_front_and_dispose([](DeferEvent *e){
-		assert(m.IsPending());
+			e->Run();
-
+		});
-		deferred.pop_front();
-		m.RunDeferred();
 	}
 }
 

src/event/Loop.hxx

@@ -79,11 +79,9 @@ class EventLoop final
 					   boost::intrusive::constant_time_size<false>>;
 	TimerSet timers;
 
-	using DeferList =
+	using DeferList = IntrusiveList<DeferEvent>;
-		boost::intrusive::list<DeferEvent,
+
-				       boost::intrusive::base_hook<boost::intrusive::list_base_hook<>>,
+	DeferList defer;
-				       boost::intrusive::constant_time_size<false>>;
-	DeferList deferred;
 
 	using IdleList = IntrusiveList<IdleEvent>;
 	IdleList idle;
@@ -214,12 +212,6 @@ public:
 	 */
 	void AddDeferred(DeferEvent &d) noexcept;
 
-	/**
-	 * Cancel a pending call to DeferEvent::RunDeferred().
-	 * However after returning, the call may still be running.
-	 */
-	void RemoveDeferred(DeferEvent &d) noexcept;
-
 #ifdef HAVE_THREADED_EVENT_LOOP
 	/**
 	 * Schedule a call to the InjectEvent.