1berry/ruby
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update scheduler.c to use RUBY_ASSERT. (#12129)

Browse Source
This commit is contained in:
Samuel Williams 2024-11-21 12:00:55 +13:00 committed by GitHub
parent bf718cef59
commit 03ff7db5fe
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
Notes: git 2024-11-20 23:01:14 +00:00 
Merged-By: ioquatix <samuel@codeotaku.com>
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
scheduler.c
View File

@ -140,10 +140,10 @@ Init_Fiber_Scheduler(void)
VALUE VALUE
rb_fiber_scheduler_get(void) rb_fiber_scheduler_get(void)
{ {
VM_ASSERT(ruby_thread_has_gvl_p()); RUBY_ASSERT(ruby_thread_has_gvl_p());
rb_thread_t *thread = GET_THREAD(); rb_thread_t *thread = GET_THREAD();
VM_ASSERT(thread); RUBY_ASSERT(thread);
return thread->scheduler; return thread->scheduler;
} }
@ -186,10 +186,10 @@ fiber_scheduler_close_ensure(VALUE _thread)
VALUE VALUE
rb_fiber_scheduler_set(VALUE scheduler) rb_fiber_scheduler_set(VALUE scheduler)
{ {
VM_ASSERT(ruby_thread_has_gvl_p()); RUBY_ASSERT(ruby_thread_has_gvl_p());
rb_thread_t *thread = GET_THREAD(); rb_thread_t *thread = GET_THREAD();
VM_ASSERT(thread); RUBY_ASSERT(thread);
if (scheduler != Qnil) { if (scheduler != Qnil) {
verify_interface(scheduler); verify_interface(scheduler);
@ -212,7 +212,7 @@ rb_fiber_scheduler_set(VALUE scheduler)
static VALUE static VALUE
rb_fiber_scheduler_current_for_threadptr(rb_thread_t *thread) rb_fiber_scheduler_current_for_threadptr(rb_thread_t *thread)
{ {
VM_ASSERT(thread); RUBY_ASSERT(thread);
if (thread->blocking == 0) { if (thread->blocking == 0) {
return thread->scheduler; return thread->scheduler;
@ -246,7 +246,7 @@ VALUE rb_fiber_scheduler_current_for_thread(VALUE thread)
VALUE VALUE
rb_fiber_scheduler_close(VALUE scheduler) rb_fiber_scheduler_close(VALUE scheduler)
{ {
VM_ASSERT(ruby_thread_has_gvl_p()); RUBY_ASSERT(ruby_thread_has_gvl_p());
VALUE result; VALUE result;
@ -408,7 +408,7 @@ rb_fiber_scheduler_block(VALUE scheduler, VALUE blocker, VALUE timeout)
VALUE VALUE
rb_fiber_scheduler_unblock(VALUE scheduler, VALUE blocker, VALUE fiber) rb_fiber_scheduler_unblock(VALUE scheduler, VALUE blocker, VALUE fiber)
{ {
VM_ASSERT(rb_obj_is_fiber(fiber)); RUBY_ASSERT(rb_obj_is_fiber(fiber));
return rb_funcall(scheduler, id_unblock, 2, blocker, fiber); return rb_funcall(scheduler, id_unblock, 2, blocker, fiber);
} }