From be3d2188d6a8fc03379d55cec0a9b02980c3df9d Mon Sep 17 00:00:00 2001
From: Max Kellermann <max@duempel.org>
Date: Wed, 30 Jan 2013 15:01:34 +0100
Subject: event/SocketMonitor: wake up the event loop after flag change

---
 src/event/SocketMonitor.cxx | 6 ++++++
 src/event/SocketMonitor.hxx | 8 ++++++++
 2 files changed, 14 insertions(+)

(limited to 'src/event')

diff --git a/src/event/SocketMonitor.cxx b/src/event/SocketMonitor.cxx
index bf9fcdc5..6efa6964 100644
--- a/src/event/SocketMonitor.cxx
+++ b/src/event/SocketMonitor.cxx
@@ -159,3 +159,9 @@ SocketMonitor::Write(const void *data, size_t length)
 
 	return send(Get(), (const char *)data, length, flags);
 }
+
+void
+SocketMonitor::CommitEventFlags()
+{
+	loop.WakeUp();
+}
diff --git a/src/event/SocketMonitor.hxx b/src/event/SocketMonitor.hxx
index c815e4f5..c60b8efd 100644
--- a/src/event/SocketMonitor.hxx
+++ b/src/event/SocketMonitor.hxx
@@ -89,26 +89,32 @@ public:
 	void Schedule(unsigned flags) {
 		poll.events = flags;
 		poll.revents &= flags;
+		CommitEventFlags();
 	}
 
 	void Cancel() {
 		poll.events = 0;
+		CommitEventFlags();
 	}
 
 	void ScheduleRead() {
 		poll.events |= READ|HANGUP|ERROR;
+		CommitEventFlags();
 	}
 
 	void ScheduleWrite() {
 		poll.events |= WRITE;
+		CommitEventFlags();
 	}
 
 	void CancelRead() {
 		poll.events &= ~(READ|HANGUP|ERROR);
+		CommitEventFlags();
 	}
 
 	void CancelWrite() {
 		poll.events &= ~WRITE;
+		CommitEventFlags();
 	}
 
 	ssize_t Read(void *data, size_t length);
@@ -128,6 +134,8 @@ public:
 				 gpointer user_data);
 
 private:
+	void CommitEventFlags();
+
 	bool Check() const {
 		return (poll.revents & poll.events) != 0;
 	}
-- 
cgit v1.2.3