This change causes epoll_wait to only return events for a single FD o…

…n everycall.

With the use of EPOLLEXCLUSIVE we want to ensure that a single process is not being
woke to handle multiple FDs at once. This allows EPOLL to better distribute wake-ups to
processes that are actually ready to run. Without this a single process may be woken to handle
IO for multiple FDs, while other processes are available waiting for work.

io_wait_loop.h

@@ -175,7 +175,14 @@ inline static int io_wait_loop_epoll(io_wait_h* h, int t, int repeat)
 	unsigned int curr_time;
 
 again:
+#ifdef EPOLLEXCLUSIVE
+		/* When using EPOLLEXCLUSIVE we don't want a single wakeup to handle multiple fds at once
+		   as it could introduce latency in handling requests.
+		   Limit each wakeup to handling events from a single fd */
+		ret=n=epoll_wait(h->epfd, h->ep_array, 1, t*1000);
+#else
 		ret=n=epoll_wait(h->epfd, h->ep_array, h->fd_no, t*1000);
+#endif
 		if (n==-1){
 			if (errno == EINTR) {
 				goto again; /* signal, ignore it */