From 7669aec9bfd7ec4e60b4642cbed21fe9cb59155a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=B8=A3=E8=88=9F?= <ray.dr@alibaba-inc.com>
Date: Wed, 11 Sep 2024 14:36:22 +0800
Subject: [PATCH] KQueue event submitt always use immediate

---
 io/kqueue.cpp | 17 ++++++++---------
 1 file changed, 8 insertions(+), 9 deletions(-)

diff --git a/io/kqueue.cpp b/io/kqueue.cpp
index 289b4087..4a0842dd 100644
--- a/io/kqueue.cpp
+++ b/io/kqueue.cpp
@@ -111,7 +111,7 @@ class KQueue : public MasterEventEngine, public CascadingEventEngine, public Res
         nev += ret;
         for (int i = 0; i < ret; ++i) {
             if (_events[i].filter == EVFILT_USER) continue;
-            event_callback(_events[i].udata);
+            event_callback((thread*)_events[i].udata);
         }
         if (ret == (int) LEN(_events)) {  // there may be more events
             tm.tv_sec = tm.tv_nsec = 0;
@@ -124,18 +124,18 @@ class KQueue : public MasterEventEngine, public CascadingEventEngine, public Res
         if (unlikely(interests == 0))
             return 0;
         short ev = (interests == EVENT_READ) ? EVFILT_READ : EVFILT_WRITE;
-        enqueue(fd, ev, EV_ADD | EV_ONESHOT, 0, CURRENT, timeout.expired());
+        auto current = CURRENT;
+        enqueue(fd, ev, EV_ADD | EV_ONESHOT, 0, current, true);
         if (timeout.expired()) {
             int ret = -1;
-            do_wait_and_fire_events(0, [&](void* data) {
-                auto th = (thread*)data;
-                if (th == CURRENT)
+            do_wait_and_fire_events(0, [current, &ret](thread* th) {
+                if (th == current)
                     ret = 0;
                 else
                     thread_interrupt(th);
             });
             if (ret <0) {
-                enqueue(fd, ev, EV_DELETE, 0, CURRENT, true);
+                enqueue(fd, ev, EV_DELETE, 0, current, true);
                 errno = ETIMEDOUT;
             }
             return ret;
@@ -147,13 +147,12 @@ class KQueue : public MasterEventEngine, public CascadingEventEngine, public Res
         }
     
         errno = (ret == 0) ? ETIMEDOUT : err.no;
-        enqueue(fd, ev, EV_DELETE, 0, CURRENT, true);
+        enqueue(fd, ev, EV_DELETE, 0, current, true);
         return -1;
     }
 
     ssize_t wait_and_fire_events(uint64_t timeout) override {
-        return do_wait_and_fire_events(timeout, [](void* data) {
-            auto th = (thread*)data;
+        return do_wait_and_fire_events(timeout, [](thread* th) {
             thread_interrupt(th);
         });
     }