Skip to content

Commit

Permalink
Disable public interface for now.
Browse files Browse the repository at this point in the history
  • Loading branch information
ioquatix committed Mar 30, 2021
1 parent 92449e0 commit 3d32c21
Show file tree
Hide file tree
Showing 2 changed files with 19 additions and 15 deletions.
8 changes: 5 additions & 3 deletions include/ruby/fiber/scheduler.h
Original file line number Diff line number Diff line change
Expand Up @@ -22,12 22,14 @@ VALUE rb_fiber_scheduler_make_timeout(struct timeval *timeout);

VALUE rb_fiber_scheduler_close(VALUE scheduler);

VALUE rb_fiber_scheduler_timeout_raise(VALUE scheduler, VALUE timeout, VALUE exception, VALUE message);
VALUE rb_fiber_scheduler_timeout_raisev(VALUE scheduler, int argc, VALUE * argv);

VALUE rb_fiber_scheduler_kernel_sleep(VALUE scheduler, VALUE duration);
VALUE rb_fiber_scheduler_kernel_sleepv(VALUE scheduler, int argc, VALUE * argv);

#if 0
VALUE rb_fiber_scheduler_timeout_after(VALUE scheduler, VALUE timeout, VALUE exception, VALUE message);
VALUE rb_fiber_scheduler_timeout_afterv(VALUE scheduler, int argc, VALUE * argv);
#endif

int rb_fiber_scheduler_supports_process_wait(VALUE scheduler);
VALUE rb_fiber_scheduler_process_wait(VALUE scheduler, rb_pid_t pid, int flags);

Expand Down
26 changes: 14 additions & 12 deletions scheduler.c
Original file line number Diff line number Diff line change
Expand Up @@ -111,32 111,34 @@ rb_fiber_scheduler_make_timeout(struct timeval *timeout)
}

VALUE
rb_fiber_scheduler_timeout_after(VALUE scheduler, VALUE timeout, VALUE exception, VALUE message)
rb_fiber_scheduler_kernel_sleep(VALUE scheduler, VALUE timeout)
{
VALUE arguments[] = {
timeout, exception, message
};

return rb_check_funcall(scheduler, id_timeout_after, 3, arguments);
return rb_funcall(scheduler, id_kernel_sleep, 1, timeout);
}

VALUE
rb_fiber_scheduler_timeout_afterv(VALUE scheduler, int argc, VALUE * argv)
rb_fiber_scheduler_kernel_sleepv(VALUE scheduler, int argc, VALUE * argv)
{
return rb_check_funcall(scheduler, id_timeout_after, argc, argv);
return rb_funcallv(scheduler, id_kernel_sleep, argc, argv);
}

#if 0
VALUE
rb_fiber_scheduler_kernel_sleep(VALUE scheduler, VALUE timeout)
rb_fiber_scheduler_timeout_after(VALUE scheduler, VALUE timeout, VALUE exception, VALUE message)
{
return rb_funcall(scheduler, id_kernel_sleep, 1, timeout);
VALUE arguments[] = {
timeout, exception, message
};

return rb_check_funcall(scheduler, id_timeout_after, 3, arguments);
}

VALUE
rb_fiber_scheduler_kernel_sleepv(VALUE scheduler, int argc, VALUE * argv)
rb_fiber_scheduler_timeout_afterv(VALUE scheduler, int argc, VALUE * argv)
{
return rb_funcallv(scheduler, id_kernel_sleep, argc, argv);
return rb_check_funcall(scheduler, id_timeout_after, argc, argv);
}
#endif

VALUE
rb_fiber_scheduler_process_wait(VALUE scheduler, rb_pid_t pid, int flags)
Expand Down

0 comments on commit 3d32c21

Please sign in to comment.