Introduce Fiber Scheduler `blocking_region` hook. (#11963)

1 files changed, 12 insertions, 0 deletions

diff --git a/thread.c b/thread.c
index 2a937ca278..91278e718d 100644
--- a/thread.c
+++ b/thread.c
@@ -1523,6 +1523,18 @@ rb_nogvl(void *(*func)(void *), void *data1,
          rb_unblock_function_t *ubf, void *data2,
          int flags)
 {
+    VALUE scheduler = rb_fiber_scheduler_current();
+    if (scheduler != Qnil) {
+        struct rb_fiber_scheduler_blocking_region_state state;
+
+        VALUE result = rb_fiber_scheduler_blocking_region(scheduler, func, data1, ubf, data2, flags, &state);
+
+        if (!UNDEF_P(result)) {
+            rb_errno_set(state.saved_errno);
+            return state.result;
+        }
+    }
+
     void *val = 0;
     rb_execution_context_t *ec = GET_EC();
     rb_thread_t *th = rb_ec_thread_ptr(ec);