Handle IOError from closed selector

bryanp · Jun 28, 2023 · 5510a4b · 5510a4b
1 parent 7425e40
commit 5510a4b
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/lib/goru/reactor.rb b/lib/goru/reactor.rb
@@ -105,7 +105,9 @@ def finished?
     # [public]
     #
     def wakeup
-      @selector.wakeup rescue IOError
+      @selector.wakeup
+    rescue IOError
+      # nothing to do
     end
 
     # [public]

diff --git a/lib/goru/scheduler.rb b/lib/goru/scheduler.rb
@@ -85,7 +85,7 @@ def wait
       @waiting = true
       @reactors.each(&:wakeup)
       @selector.select while @waiting
-    rescue Interrupt
+    rescue IOError, Interrupt
       # nothing to do
     ensure
       stop
@@ -110,7 +110,9 @@ def signal
     end
 
     def wakeup
-      @selector.wakeup rescue IOError
+      @selector.wakeup
+    rescue IOError
+      # nothing to do
     end
   end
 end