event/SocketMonitor: un-inline Schedule()

Merge with CommitEventFlags().

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();
-}

src/event/SocketMonitor.hxx

@@ -86,37 +86,32 @@ public:
 
 	void Close();
 
-	void Schedule(unsigned flags) {
+	unsigned GetScheduledFlags() const {
 		assert(IsDefined());
 
-		poll.events = flags;
+		return poll.events;
-		poll.revents &= flags;
-		CommitEventFlags();
 	}
 
+	void Schedule(unsigned flags);
+
 	void Cancel() {
-		poll.events = 0;
+		Schedule(0);
-		CommitEventFlags();
 	}
 
 	void ScheduleRead() {
-		poll.events |= READ|HANGUP|ERROR;
+		Schedule(GetScheduledFlags() | READ | HANGUP | ERROR);
-		CommitEventFlags();
 	}
 
 	void ScheduleWrite() {
-		poll.events |= WRITE;
+		Schedule(GetScheduledFlags() | WRITE);
-		CommitEventFlags();
 	}
 
 	void CancelRead() {
-		poll.events &= ~(READ|HANGUP|ERROR);
+		Schedule(GetScheduledFlags() & ~(READ|HANGUP|ERROR));
-		CommitEventFlags();
 	}
 
 	void CancelWrite() {
-		poll.events &= ~WRITE;
+		Schedule(GetScheduledFlags() & ~WRITE);
-		CommitEventFlags();
 	}
 
 	ssize_t Read(void *data, size_t length);
@@ -136,8 +131,6 @@ public:
 				 gpointer user_data);
 
 private:
-	void CommitEventFlags();
-
 	bool Check() const {
 		assert(IsDefined());