WIP

Author: byroot

cont.c

@@ -2656,6 +2656,7 @@ fiber_check_killed(rb_fiber_t *fiber)
 static inline VALUE
 fiber_switch(rb_fiber_t *fiber, int argc, const VALUE *argv, int kw_splat, rb_fiber_t *resuming_fiber, bool yielding)
 {
+    fprintf(stderr, "fiber_switch\n");
     VALUE value;
     rb_context_t *cont = &fiber->cont;
     rb_thread_t *th = GET_THREAD();

ractor.c

@@ -3,6 +3,7 @@
 #include "ruby/ruby.h"
 #include "ruby/thread.h"
 #include "ruby/ractor.h"
+#include "ruby/fiber/scheduler.h"
 #include "ruby/thread_native.h"
 #include "vm_core.h"
 #include "eval_intern.h"
@@ -1236,6 +1237,11 @@ ractor_take(rb_execution_context_t *ec, rb_ractor_t *r)
         .sender = 0,
     };
 
+    VALUE scheduler = rb_fiber_scheduler_current();
+    if (!NIL_P(scheduler)) {
+        rb_fiber_scheduler_block(scheduler, r->pub.self, Qnil);
+    }
+
     ractor_register_take(cr, r, &take_basket, true, NULL, false);
 
     while (UNDEF_P(v = ractor_try_take(cr, r, &take_basket))) {