From bbed0954b18de634a8fed50b8b08af6ea3bf3dae Mon Sep 17 00:00:00 2001
From: Niels Provos <provos@gmail.com>
Date: Sun, 11 Nov 2007 03:05:03 +0000
Subject: [PATCH] revert r505; it introduced errors in epoll

svn:r508
---
 ChangeLog |  2 +-
 epoll.c   | 37 +++++++++++++++++++++++++------------
 2 files changed, 26 insertions(+), 13 deletions(-)

diff --git a/ChangeLog b/ChangeLog
index dbebaebf..908b00af 100644
--- a/ChangeLog
+++ b/ChangeLog
@@ -35,7 +35,7 @@ Changes in current version:
  o added two additional libraries: libevent_core and libevent_extra in addition to the regular libevent.  libevent_core contains only the event core whereas libevent_extra contains dns, http and rpc support
  o Begin using libtool's library versioning support correctly.  If we don't mess up, this will more or less guarantee binaries linked against old versions of libevent continue working when we make changes to libevent that do not break backward compatibility.
  o Fix evhttp.h compilation when TAILQ_ENTRY is not defined.
- o Clean up code in epoll_dispatch() to reduce branch count and generally run better.  Patch from Christopher Layne.
+ o Small code cleanups in epoll_dispatch().
  o Increase the maximum number of addresses read from a packet in evdns to 32.
  o Remove support for the rtsig method: it hasn't compiled for a while, and nobody seems to miss it very much.  Let us know if there's a good reason to put it back in.
  o Rename the "class" field in evdns_server_request to dns_question_class, so that it won't break compilation under C++.  Use a macro so that old code won't break.  Mark the macro as deprecated.
diff --git a/epoll.c b/epoll.c
index 86a97a4c..5afc8307 100644
--- a/epoll.c
+++ b/epoll.c
@@ -209,23 +209,36 @@ epoll_dispatch(struct event_base *base, void *arg, struct timeval *tv)
 
 	for (i = 0; i < res; i++) {
 		int what = events[i].events;
-		struct event *evread, *evwrite;
+		struct event *evread = NULL, *evwrite = NULL;
 
 		evep = (struct evepoll *)events[i].data.ptr;
-		evread = evep->evread;
-		evwrite = evep->evwrite;
 
-		if (evread && what & (EPOLLIN|EPOLLHUP|EPOLLERR)) {
-			if (~evread->ev_events & EV_PERSIST)
-				event_del(evread);
-			event_active(evread, EV_READ, 1);
+		if (what & (EPOLLHUP|EPOLLERR)) {
+			evread = evep->evread;
+			evwrite = evep->evwrite;
+		} else {
+			if (what & EPOLLIN) {
+				evread = evep->evread;
+			}
+
+			if (what & EPOLLOUT) {
+				evwrite = evep->evwrite;
+			}
 		}
-		if (evwrite && what & (EPOLLOUT|EPOLLHUP|EPOLLERR)) {
-			if (~evwrite->ev_events & EV_PERSIST
-				&& evwrite != evread)
-				event_del(evwrite);
+
+		if (!(evread||evwrite))
+			continue;
+
+		if (evread != NULL && !(evread->ev_events & EV_PERSIST))
+			event_del(evread);
+		if (evwrite != NULL && evwrite != evread &&
+			!(evwrite->ev_events & EV_PERSIST))
+			event_del(evwrite);
+
+		if (evread != NULL)
+			event_active(evread, EV_READ, 1);
+		if (evwrite != NULL)
 			event_active(evwrite, EV_WRITE, 1);
-		}
 	}
 
 	return (0);
-- 
2.50.0