1 files changed, 14 insertions, 8 deletions
diff --git a/src/event/SocketMonitor.cxx b/src/event/SocketMonitor.cxx
index 9bb6e47cf..0b929dd72 100644
--- a/src/event/SocketMonitor.cxx
+++ b/src/event/SocketMonitor.cxx
@@ -135,6 +135,20 @@ SocketMonitor::Close()
 	close_socket(Steal());
 }
 
+void
+SocketMonitor::Schedule(unsigned flags)
+{
+	assert(IsDefined());
+
+	if (flags == GetScheduledFlags())
+		return;
+
+	poll.events = flags;
+	poll.revents &= flags;
+
+	loop.WakeUp();
+}
+
 SocketMonitor::ssize_t
 SocketMonitor::Read(void *data, size_t length)
 {
@@ -163,11 +177,3 @@ SocketMonitor::Write(const void *data, size_t length)
 
 	return send(Get(), (const char *)data, length, flags);
 }
-
-void
-SocketMonitor::CommitEventFlags()
-{
-	assert(IsDefined());
-
-	loop.WakeUp();
-}