From f0d5e24979a70a4bbc4db8fad6799af3f6f4fdf0 Mon Sep 17 00:00:00 2001
From: hardening <rdp.effort@gmail.com>
Date: Wed, 23 Jan 2013 21:59:01 +0100
Subject: [PATCH] Added preliminary support for eventfd

---
 CMakeLists.txt               |  1 +
 config.h.in                  |  2 +-
 winpr/libwinpr/synch/event.c | 36 +++++++++++++++++++++++++++++++++++-
 3 files changed, 37 insertions(+), 2 deletions(-)

diff --git a/CMakeLists.txt b/CMakeLists.txt
index 3e6098432..ef5a50065 100644
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -187,6 +187,7 @@ if(NOT ANDROID)
 endif()
 
 if(UNIX OR CYGWIN)
+	check_include_files(sys/eventfd.h HAVE_EVENTFD_H)
 	set(X11_FEATURE_TYPE "RECOMMENDED")
 else()
 	set(X11_FEATURE_TYPE "DISABLED")
diff --git a/config.h.in b/config.h.in
index 1bb2b647f..d0e0fba0c 100644
--- a/config.h.in
+++ b/config.h.in
@@ -28,7 +28,7 @@
 #cmakedefine HAVE_SYS_MODEM_H
 #cmakedefine HAVE_SYS_FILIO_H
 #cmakedefine HAVE_SYS_STRTIO_H
-
+#cmakedefine HAVE_EVENTFD_H
 #cmakedefine HAVE_TM_GMTOFF
 
 
diff --git a/winpr/libwinpr/synch/event.c b/winpr/libwinpr/synch/event.c
index dd9463fca..dfd8f5b7b 100644
--- a/winpr/libwinpr/synch/event.c
+++ b/winpr/libwinpr/synch/event.c
@@ -35,6 +35,11 @@
 #include <unistd.h>
 #endif
 
+#ifdef HAVE_EVENTFD_H
+#include <sys/eventfd.h>
+#include <errno.h>
+#endif
+
 CRITICAL_SECTION cs = { NULL, 0, 0, NULL, NULL, 0 };
 
 HANDLE CreateEventW(LPSECURITY_ATTRIBUTES lpEventAttributes, BOOL bManualReset, BOOL bInitialState, LPCWSTR lpName)
@@ -57,11 +62,20 @@ HANDLE CreateEventW(LPSECURITY_ATTRIBUTES lpEventAttributes, BOOL bManualReset,
 		event->pipe_fd[0] = -1;
 		event->pipe_fd[1] = -1;
 
+#ifdef HAVE_EVENTFD_H
+		event->pipe_fd[0] = eventfd(0, EFD_NONBLOCK);
+		if (event->pipe_fd[0] < 0)
+		{
+			printf("CreateEventW: failed to create event\n");
+			return NULL;
+		}
+#else
 		if (pipe(event->pipe_fd) < 0)
 		{
 			printf("CreateEventW: failed to create event\n");
 			return NULL;
 		}
+#endif
 
 		handle = winpr_Handle_Insert(HANDLE_TYPE_EVENT, event);
 	}
@@ -115,10 +129,20 @@ BOOL SetEvent(HANDLE hEvent)
 
 		if (!(WaitForSingleObject(hEvent, 0) == WAIT_OBJECT_0))
 		{
+#ifdef HAVE_EVENTFD_H
+			eventfd_t val = 1;
+			do 
+			{
+				length = eventfd_write(event->pipe_fd[0], val);
+			}
+			while(length < 0 && errno == EINTR);
+			status = (length == 0) ? TRUE : FALSE;
+#else
 			length = write(event->pipe_fd[1], "-", 1);
 
 			if (length == 1)
 				status = TRUE;
+#endif
 		}
 		else
 		{
@@ -149,13 +173,23 @@ BOOL ResetEvent(HANDLE hEvent)
 
 		while (WaitForSingleObject(hEvent, 0) == WAIT_OBJECT_0)
 		{
-			length = read(event->pipe_fd[0], &length, 1);
+#ifdef HAVE_EVENTFD_H
+			eventfd_t value;
+			do
+			{
+				length = eventfd_read(event->pipe_fd[0], &value);
+			}
+			while(length < 0 && errno == EINTR);
 
+			status = (length > 0) ? TRUE : FALSE;
+#else
+			length = read(event->pipe_fd[0], &length, 1);
 			if (length == 1)
 				status = TRUE;
 
 			if (length != 1)
 				break;
+#endif
 		}
 	}