MN: access timer_th.waiting with lock

`timer_th.waiting` should be protected by `timer_th.waiting_lock`
ko1 · Dec 24, 2023 · 486a971 · 486a971
1 parent daefbf8
commit 486a971
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/thread_pthread_mn.c b/thread_pthread_mn.c
@@ -660,10 +660,6 @@ timer_thread_register_waiting(rb_thread_t *th, int fd, enum thread_sched_waiting
 #if HAVE_SYS_EVENT_H
     struct kevent ke[2];
     int num_events = 0;
-
-    if (kqueue_already_registered(fd)) {
-        return false;
-    }
 #else
     uint32_t epoll_events = 0;
 #endif
@@ -708,6 +704,11 @@ timer_thread_register_waiting(rb_thread_t *th, int fd, enum thread_sched_waiting
     {
 #if HAVE_SYS_EVENT_H
         if (num_events > 0) {
+            if (kqueue_already_registered(fd)) {
+                rb_native_mutex_unlock(&timer_th.waiting_lock);
+                return false;
+            }
+
             if (kevent(timer_th.event_fd, ke, num_events, NULL, 0, NULL) == -1) {
                 RUBY_DEBUG_LOG("failed (%d)", errno);