X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=src%2Fozone%2Fwayland%2Fdisplay_poll_thread.cc;h=f1b9e9e1f2e83284ad66bfc518a4af3463a656bc;hb=be01dd7b4ffa2dbdac624d3a46a6172cafd31a1f;hp=421d67e4cecd2dd826c6a056792f92486dde2377;hpb=a3137fbf780cf581b1011fd9024eff767a6c1d4b;p=platform%2Fframework%2Fweb%2Fcrosswalk.git

diff --git a/src/ozone/wayland/display_poll_thread.cc b/src/ozone/wayland/display_poll_thread.cc
index 421d67e..f1b9e9e 100644
--- a/src/ozone/wayland/display_poll_thread.cc
+++ b/src/ozone/wayland/display_poll_thread.cc
@@ -6,7 +6,7 @@
 
 #include <errno.h>
 #include <fcntl.h>
-#include <sys/epoll.h>
+#include <poll.h>
 #include <sys/socket.h>
 #include <sys/types.h>
 #include <wayland-client.h>
@@ -16,45 +16,6 @@
 
 namespace ozonewayland {
 const int MAX_EVENTS = 16;
-// os-compatibility
-extern "C" {
-int osEpollCreateCloExec(void);
-
-static int setCloExecOrClose(int fd) {
-  int flags;
-
-  if (fd == -1)
-    return -1;
-
-  flags = fcntl(fd, F_GETFD);
-  if (flags == -1)
-    goto err;
-
-  if (fcntl(fd, F_SETFD, flags | FD_CLOEXEC) == -1)
-    goto err;
-
-  return fd;
-
-  err:
-    close(fd);
-    return -1;
-}
-
-int osEpollCreateCloExec(void) {
-  int fd;
-
-#ifdef EPOLL_CLOEXEC
-  fd = epoll_create1(EPOLL_CLOEXEC);
-  if (fd >= 0)
-    return fd;
-  if (errno != EINVAL)
-    return -1;
-#endif
-
-  fd = epoll_create(1);
-  return setCloExecOrClose(fd);
-}
-}  // os-compatibility
 
 WaylandDisplayPollThread::WaylandDisplayPollThread(wl_display* display)
     : base::Thread("WaylandDisplayPollThread"),
@@ -62,9 +23,6 @@ WaylandDisplayPollThread::WaylandDisplayPollThread(wl_display* display)
       polling_(true, false),
       stop_polling_(true, false) {
   DCHECK(display_);
-  epoll_fd_ = osEpollCreateCloExec();
-  if (epoll_fd_ < 0)
-    LOG(ERROR) << "Epoll creation failed.";
 }
 
 WaylandDisplayPollThread::~WaylandDisplayPollThread() {
@@ -72,7 +30,7 @@ WaylandDisplayPollThread::~WaylandDisplayPollThread() {
 }
 
 void WaylandDisplayPollThread::StartProcessingEvents() {
-  DCHECK(!polling_.IsSignaled() && epoll_fd_);
+  DCHECK(!polling_.IsSignaled());
   base::Thread::Options options;
   options.message_loop_type = base::MessageLoop::TYPE_IO;
   StartWithOptions(options);
@@ -90,25 +48,15 @@ void WaylandDisplayPollThread::StopProcessingEvents() {
 
 void WaylandDisplayPollThread::CleanUp() {
   SetThreadWasQuitProperly(true);
-  if (epoll_fd_)
-    close(epoll_fd_);
 }
 
 void  WaylandDisplayPollThread::DisplayRun(WaylandDisplayPollThread* data) {
-  struct epoll_event ep[MAX_EVENTS];
+  struct pollfd ep;
   int i, ret, count = 0;
   uint32_t event = 0;
-  bool epoll_err = false;
   unsigned display_fd = wl_display_get_fd(data->display_);
-  int epoll_fd = data->epoll_fd_;
-  ep[0].events = EPOLLIN;
-  ep[0].data.ptr = 0;
-  if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, display_fd, &ep[0]) < 0) {
-    close(epoll_fd);
-    data->epoll_fd_ = 0;
-    LOG(ERROR) << "epoll_ctl Add failed";
-    return;
-  }
+  ep.fd = display_fd;
+  ep.events = POLLIN | POLLERR | POLLHUP;
 
   // Set the signal state. This is used to query from other threads (i.e.
   // StopProcessingEvents on Main thread), if this thread is still polling.
@@ -119,11 +67,7 @@ void  WaylandDisplayPollThread::DisplayRun(WaylandDisplayPollThread* data) {
   while (1) {
     wl_display_dispatch_pending(data->display_);
     ret = wl_display_flush(data->display_);
-    if (ret < 0 && errno == EAGAIN) {
-      ep[0].events = EPOLLIN | EPOLLERR | EPOLLHUP;
-      epoll_ctl(epoll_fd, EPOLL_CTL_MOD, display_fd, &ep[0]);
-    } else if (ret < 0) {
-      epoll_err = true;
+    if (ret < 0 && errno != EAGAIN) {
       break;
     }
     // StopProcessingEvents has been called or we have been asked to stop
@@ -131,37 +75,31 @@ void  WaylandDisplayPollThread::DisplayRun(WaylandDisplayPollThread* data) {
     if (data->stop_polling_.IsSignaled())
       break;
 
-    count = epoll_wait(epoll_fd, ep, MAX_EVENTS, -1);
+    count = poll(&ep, 1, -1);
     // Break if epoll wait returned value less than 0 and we aren't interrupted
     // by a signal.
     if (count < 0 && errno != EINTR) {
-      LOG(ERROR) << "epoll_wait returned an error." << errno;
-      epoll_err = true;
+      LOG(ERROR) << "poll returned an error." << errno;
       break;
     }
 
-    for (i = 0; i < count; i++) {
-      event = ep[i].events;
-      // We can have cases where EPOLLIN and EPOLLHUP are both set for
+    if (count == 1) {
+      event = ep.revents;
+      // We can have cases where POLLIN and POLLHUP are both set for
       // example. Don't break if both flags are set.
-      if ((event & EPOLLERR || event & EPOLLHUP) &&
-             !(event & EPOLLIN)) {
-        epoll_err = true;
+      if ((event & POLLERR || event & POLLHUP) &&
+             !(event & POLLIN)) {
         break;
       }
 
-      if (event & EPOLLIN) {
+      if (event & POLLIN) {
         ret = wl_display_dispatch(data->display_);
         if (ret == -1) {
           LOG(ERROR) << "wl_display_dispatch failed with an error." << errno;
-          epoll_err = true;
           break;
         }
       }
     }
-
-    if (epoll_err)
-      break;
   }
 
   data->polling_.Reset();