Use rb_nogvl(..., RB_NOGVL_OFFLOAD_SAFE) for compatibility with the fiber scheduler.

Author: ioquatix

src/ruby/ext/grpc/rb_completion_queue.c

@@ -85,9 +85,10 @@ grpc_event rb_completion_queue_pluck(grpc_completion_queue* queue, void* tag,
   grpc_absl_log_str(GPR_DEBUG, "CQ pluck loop begin: ", reason);
   do {
     next_call.interrupted = 0;
-    rb_thread_call_without_gvl(grpc_rb_completion_queue_pluck_no_gil,
-                               (void*)&next_call, unblock_func,
-                               (void*)&next_call);
+    rb_nogvl(grpc_rb_completion_queue_pluck_no_gil,
+             (void*)&next_call, unblock_func,
+             (void*)&next_call,
+             RB_NOGVL_OFFLOAD_SAFE);
     if (next_call.event.type != GRPC_QUEUE_TIMEOUT) break;
   } while (next_call.interrupted);
   grpc_absl_log_str(GPR_DEBUG, "CQ pluck loop done: ", reason);

src/ruby/ext/grpc/rb_event_thread.c

@@ -124,9 +124,12 @@ static VALUE grpc_rb_event_thread(void* arg) {
   grpc_rb_event* event;
   (void)arg;
   while (true) {
-    event = (grpc_rb_event*)rb_thread_call_without_gvl(
+#ifdef RB_NOGVL_OFFLOAD_SAFE
+
+#endif
+    event = (grpc_rb_event*)rb_nogvl(
         grpc_rb_wait_for_event_no_gil, NULL, grpc_rb_event_unblocking_func,
-        NULL);
+        NULL, RB_NOGVL_OFFLOAD_SAFE);
     if (event == NULL) {
       // Indicates that the thread needs to shut down
       break;
@@ -160,8 +163,8 @@ void grpc_rb_event_queue_thread_stop() {
         "GRPC_RUBY: call credentials thread stop: thread not running");
     return;
   }
-  rb_thread_call_without_gvl(grpc_rb_event_unblocking_func_wrapper, NULL, NULL,
-                             NULL);
+  rb_nogvl(grpc_rb_event_unblocking_func_wrapper, NULL, NULL,
+           NULL, RB_NOGVL_OFFLOAD_SAFE);
   rb_funcall(g_event_thread, rb_intern("join"), 0);
   g_event_thread = Qnil;
 }

src/ruby/ext/grpc/rb_grpc.h

@@ -85,4 +85,9 @@ void grpc_ruby_init();
     abort();                                                      \
   }
 
+#ifndef RB_NOGVL_OFFLOAD_SAFE
+// Default to no-op if it's not defined:
+#define RB_NOGVL_OFFLOAD_SAFE 0
+#endif
+
 #endif /* GRPC_RB_H_ */