Use select to query the uv kqueue
authorRyan Patterson <cgamesplay@cgamesplay.com>
Tue, 3 May 2016 06:54:21 +0000 (23:54 -0700)
committerRyan Patterson <cgamesplay@cgamesplay.com>
Tue, 3 May 2016 06:54:21 +0000 (23:54 -0700)
This resolves #38. I've verified that events still get processed like they
should on El Capitan 10.11.3 (15D21).

atom/common/node_bindings_mac.cc
atom/common/node_bindings_mac.h

index 877497d5a1e2b0748072fc539596a5d7b3b1f417..9e61d27f496be877715df46d50d227aaf1c4675f 100644 (file)
@@ -5,6 +5,7 @@
 #include "atom/common/node_bindings_mac.h"
 
 #include <errno.h>
+#include <sys/select.h>
 #include <sys/sysctl.h>
 #include <sys/time.h>
 #include <sys/types.h>
 namespace atom {
 
 NodeBindingsMac::NodeBindingsMac(bool is_browser)
-    : NodeBindings(is_browser),
-      kqueue_(kqueue()) {
-  // Add uv's backend fd to kqueue.
-  struct kevent ev;
-  EV_SET(&ev, uv_backend_fd(uv_loop_), EVFILT_READ, EV_ADD | EV_ENABLE,
-         0, 0, 0);
-  kevent(kqueue_, &ev, 1, NULL, 0, NULL);
+    : NodeBindings(is_browser) {
 }
 
 NodeBindingsMac::~NodeBindingsMac() {
@@ -44,19 +39,22 @@ void NodeBindingsMac::OnWatcherQueueChanged(uv_loop_t* loop) {
 }
 
 void NodeBindingsMac::PollEvents() {
-  struct timespec spec;
+  struct timeval tv;
   int timeout = uv_backend_timeout(uv_loop_);
   if (timeout != -1) {
-    spec.tv_sec = timeout / 1000;
-    spec.tv_nsec = (timeout % 1000) * 1000000;
+    tv.tv_sec = timeout / 1000;
+    tv.tv_usec = (timeout % 1000) * 1000;
   }
 
+  fd_set readset;
+  int fd = uv_backend_fd(uv_loop_);
+  FD_ZERO(&readset);
+  FD_SET(fd, &readset);
+
   // Wait for new libuv events.
   int r;
   do {
-    struct kevent ev;
-    r = ::kevent(kqueue_, NULL, 0, &ev, 1,
-                 timeout == -1 ? NULL : &spec);
+    r = select(fd + 1, &readset, NULL, NULL, timeout == -1 ? NULL : &tv);
   } while (r == -1 && errno == EINTR);
 }
 
index 03152ada3ea698af3c9d6297f219cdd9127ecbe9..96c79ec6f0df4e28bdb02c3a46fd15fb7a5fe561 100644 (file)
@@ -23,9 +23,6 @@ class NodeBindingsMac : public NodeBindings {
 
   void PollEvents() override;
 
-  // Kqueue to poll for uv's backend fd.
-  int kqueue_;
-
   DISALLOW_COPY_AND_ASSIGN(NodeBindingsMac);
 };