From 48329cac28d1c1165c8efbf40c46391f111421dd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=B8=A3=E8=88=9F?= <ray.dr@alibaba-inc.com>
Date: Thu, 12 Sep 2024 10:39:03 +0800
Subject: [PATCH] Fix kqueue response for wait_for_fd with interests=0

---
 io/epoll.cpp  |  2 +-
 io/kqueue.cpp | 17 +++++++++--------
 2 files changed, 10 insertions(+), 9 deletions(-)

diff --git a/io/epoll.cpp b/io/epoll.cpp
index 8a3a3142..ec8a3fa7 100644
--- a/io/epoll.cpp
+++ b/io/epoll.cpp
@@ -322,7 +322,7 @@ ok:     entry.interests |= eint;
             }
             return ret;
         }
-        ret = thread_usleep(timeout.timeout() ? timeout : Timeout(10));
+        ret = thread_usleep(timeout);
         ERRNO err;
         if (ret == -1 && err.no == EOK) {
             return 0;  // Event arrived
diff --git a/io/kqueue.cpp b/io/kqueue.cpp
index c80d659e..e8b54daa 100644
--- a/io/kqueue.cpp
+++ b/io/kqueue.cpp
@@ -77,9 +77,6 @@ class KQueue : public MasterEventEngine, public CascadingEventEngine, public Res
     }
 
     int enqueue(int fd, short event, uint16_t action, uint32_t event_flags, void* udata, bool immediate = false) {
-        // if (fd == _kq) debug_breakpoint();
-        // immediate = true;
-        // LOG_DEBUG(VALUE(_kq), VALUE(fd), VALUE(event), VALUE(action), VALUE(event_flags), VALUE(udata), VALUE(immediate));
         assert(_n < LEN(_events));
         auto entry = &_events[_n++];
         EV_SET(entry, fd, event, action, event_flags, 0, udata);
@@ -87,7 +84,6 @@ class KQueue : public MasterEventEngine, public CascadingEventEngine, public Res
             struct timespec tm{0, 0};
             int ret = kevent(_kq, _events, _n, nullptr, 0, &tm);
             if (ret < 0) {
-                // debug_breakpoint();
                 LOG_ERRNO_RETURN(0, -1, "failed to submit events with kevent()");
             }
             _n = 0;
@@ -122,11 +118,16 @@ class KQueue : public MasterEventEngine, public CascadingEventEngine, public Res
     }
 
     int wait_for_fd(int fd, uint32_t interests, Timeout timeout) override {
+        if (unlikely(interests == 0)) {
+            errno = ENOSYS;
+            return -1;
+        }
         short ev = (interests == EVENT_READ) ? EVFILT_READ : EVFILT_WRITE;
         auto current = CURRENT;
-        enqueue(fd, ev, EV_ADD | EV_ONESHOT, 0, current, true);
+        int ret = enqueue(fd, ev, EV_ADD | EV_ONESHOT, 0, current);
+        if (ret < 0) return ret;
         if (timeout.expired()) {
-            int ret = -1;
+            ret = -1;
             do_wait_and_fire_events(0, [current, &ret](thread* th) {
                 if (th == current)
                     ret = 0;
@@ -139,14 +140,14 @@ class KQueue : public MasterEventEngine, public CascadingEventEngine, public Res
             }
             return ret;
         }
-        int ret = thread_usleep(timeout);
+        ret = thread_usleep(timeout);
         ERRNO err;
         if (ret == -1 && err.no == EOK) {
             return 0;  // event arrived
         }
 
-        errno = (ret == 0) ? ETIMEDOUT : err.no;
         enqueue(fd, ev, EV_DELETE, 0, current, true);
+        errno = (ret == 0) ? ETIMEDOUT : err.no;
         return -1;
     }