kotovalexarian-likes-github/ruby--ruby
1
0
Fork 0
mirror of https://github.com/ruby/ruby.git synced 2022-11-09 12:17:21 -05:00
Code Releases Activity

separate rb_ractor_pub from rb_ractor_t

Browse source 
separate some fields from rb_ractor_t to rb_ractor_pub and put it
at the beggining of rb_ractor_t and declare it in vm_core.h so
vm_core.h can access rb_ractor_pub fields.

Now rb_ec_ractor_hooks() is a complete inline function and no
MJIT related issue.
This commit is contained in:
Koichi Sasada 2020-12-20 01:44:41 +09:00
parent a2950369bd
commit 02d9524cda
Notes: git 2020-12-22 00:03:34 +09:00 
Merged: https://github.com/ruby/ruby/pull/3943
9 changed files with 62 additions and 67 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
gc.c
View file

@ -12348,7 +12348,7 @@ rb_raw_obj_info(char *buff, const int buff_size, VALUE obj)
else if (rb_ractor_p(obj)) { else if (rb_ractor_p(obj)) {
rb_ractor_t *r = (void *)DATA_PTR(obj); rb_ractor_t *r = (void *)DATA_PTR(obj);
if (r) { if (r) {
APPENDF((BUFF_ARGS, "r:%d", r->id)); APPENDF((BUFF_ARGS, "r:%d", r->pub.id));
} }
} }
else { else {

74
ractor.c
View file

@ -34,7 +34,7 @@ ASSERT_ractor_unlocking(rb_ractor_t *r)
{ {
#if RACTOR_CHECK_MODE > 0 #if RACTOR_CHECK_MODE > 0
// GET_EC is NULL in an MJIT worker // GET_EC is NULL in an MJIT worker
if (GET_EC() != NULL && r->sync.locked_by == GET_RACTOR()->self) { if (GET_EC() != NULL && r->sync.locked_by == rb_ractor_self(GET_RACTOR())) {
rb_bug("recursive ractor locking"); rb_bug("recursive ractor locking");
} }
#endif #endif
@ -45,7 +45,7 @@ ASSERT_ractor_locking(rb_ractor_t *r)
{ {
#if RACTOR_CHECK_MODE > 0 #if RACTOR_CHECK_MODE > 0
// GET_EC is NULL in an MJIT worker // GET_EC is NULL in an MJIT worker
if (GET_EC() != NULL && r->sync.locked_by != GET_RACTOR()->self) { if (GET_EC() != NULL && r->sync.locked_by != rb_ractor_self(GET_RACTOR())) {
rp(r->sync.locked_by); rp(r->sync.locked_by);
rb_bug("ractor lock is not acquired."); rb_bug("ractor lock is not acquired.");
} }
@ -55,25 +55,25 @@ ASSERT_ractor_locking(rb_ractor_t *r)
static void static void
ractor_lock(rb_ractor_t *r, const char *file, int line) ractor_lock(rb_ractor_t *r, const char *file, int line)
{ {
RUBY_DEBUG_LOG2(file, line, "locking r:%u%s", r->id, GET_RACTOR() == r ? " (self)" : ""); RUBY_DEBUG_LOG2(file, line, "locking r:%u%s", r->pub.id, GET_RACTOR() == r ? " (self)" : "");
ASSERT_ractor_unlocking(r); ASSERT_ractor_unlocking(r);
rb_native_mutex_lock(&r->sync.lock); rb_native_mutex_lock(&r->sync.lock);
#if RACTOR_CHECK_MODE > 0 #if RACTOR_CHECK_MODE > 0
if (GET_EC() != NULL) { // GET_EC is NULL in an MJIT worker if (GET_EC() != NULL) { // GET_EC is NULL in an MJIT worker
r->sync.locked_by = GET_RACTOR()->self; r->sync.locked_by = rb_ractor_self(GET_RACTOR());
} }
#endif #endif
RUBY_DEBUG_LOG2(file, line, "locked r:%u%s", r->id, GET_RACTOR() == r ? " (self)" : ""); RUBY_DEBUG_LOG2(file, line, "locked r:%u%s", r->pub.id, GET_RACTOR() == r ? " (self)" : "");
} }
static void static void
ractor_lock_self(rb_ractor_t *cr, const char *file, int line) ractor_lock_self(rb_ractor_t *cr, const char *file, int line)
{ {
VM_ASSERT(cr == GET_RACTOR()); VM_ASSERT(cr == GET_RACTOR());
VM_ASSERT(cr->sync.locked_by != cr->self); VM_ASSERT(cr->sync.locked_by != cr->pub.self);
ractor_lock(cr, file, line); ractor_lock(cr, file, line);
} }
@ -86,14 +86,14 @@ ractor_unlock(rb_ractor_t *r, const char *file, int line)
#endif #endif
rb_native_mutex_unlock(&r->sync.lock); rb_native_mutex_unlock(&r->sync.lock);
RUBY_DEBUG_LOG2(file, line, "r:%u%s", r->id, GET_RACTOR() == r ? " (self)" : ""); RUBY_DEBUG_LOG2(file, line, "r:%u%s", r->pub.id, GET_RACTOR() == r ? " (self)" : "");
} }
static void static void
ractor_unlock_self(rb_ractor_t *cr, const char *file, int line) ractor_unlock_self(rb_ractor_t *cr, const char *file, int line)
{ {
VM_ASSERT(cr == GET_RACTOR()); VM_ASSERT(cr == GET_RACTOR());
VM_ASSERT(cr->sync.locked_by == cr->self); VM_ASSERT(cr->sync.locked_by == cr->pub.self);
ractor_unlock(cr, file, line); ractor_unlock(cr, file, line);
} }
@ -131,7 +131,7 @@ ractor_status_str(enum ractor_status status)
static void static void
ractor_status_set(rb_ractor_t *r, enum ractor_status status) ractor_status_set(rb_ractor_t *r, enum ractor_status status)
{ {
RUBY_DEBUG_LOG("r:%u [%s]->[%s]", r->id, ractor_status_str(r->status_), ractor_status_str(status)); RUBY_DEBUG_LOG("r:%u [%s]->[%s]", r->pub.id, ractor_status_str(r->status_), ractor_status_str(status));
// check 1 // check 1
if (r->status_ != ractor_created) { if (r->status_ != ractor_created) {
@ -197,7 +197,7 @@ ractor_mark(void *ptr)
rb_gc_mark(r->r_stdin); rb_gc_mark(r->r_stdin);
rb_gc_mark(r->r_stdout); rb_gc_mark(r->r_stdout);
rb_gc_mark(r->r_stderr); rb_gc_mark(r->r_stderr);
rb_hook_list_mark(&r->event_hooks); rb_hook_list_mark(&r->pub.hooks);
if (r->threads.cnt > 0) { if (r->threads.cnt > 0) {
rb_thread_t *th = 0; rb_thread_t *th = 0;
@ -231,7 +231,7 @@ ractor_free(void *ptr)
ractor_queue_free(&r->sync.incoming_queue); ractor_queue_free(&r->sync.incoming_queue);
ractor_waiting_list_free(&r->sync.taking_ractors); ractor_waiting_list_free(&r->sync.taking_ractors);
ractor_local_storage_free(r); ractor_local_storage_free(r);
rb_hook_list_free(&r->event_hooks); rb_hook_list_free(&r->pub.hooks);
ruby_xfree(r); ruby_xfree(r);
} }
@ -290,12 +290,6 @@ RACTOR_PTR(VALUE self)
return r; return r;
} }
uint32_t
rb_ractor_id(const rb_ractor_t *g)
{
return g->id;
}
static uint32_t ractor_last_id; static uint32_t ractor_last_id;
#if RACTOR_CHECK_MODE > 0 #if RACTOR_CHECK_MODE > 0
@ -306,7 +300,7 @@ rb_ractor_current_id(void)
return 1; // main ractor return 1; // main ractor
} }
else { else {
return GET_RACTOR()->id; return rb_ractor_id(GET_RACTOR());
} }
} }
#endif #endif
@ -925,7 +919,7 @@ static VALUE ractor_copy(VALUE obj); // in this file
static void static void
ractor_basket_setup(rb_execution_context_t *ec, struct rb_ractor_basket *basket, VALUE obj, VALUE move, bool exc, bool is_will) ractor_basket_setup(rb_execution_context_t *ec, struct rb_ractor_basket *basket, VALUE obj, VALUE move, bool exc, bool is_will)
{ {
basket->sender = rb_ec_ractor_ptr(ec)->self; basket->sender = rb_ec_ractor_ptr(ec)->pub.self;
basket->exception = exc; basket->exception = exc;
if (is_will) { if (is_will) {
@ -952,7 +946,7 @@ ractor_send(rb_execution_context_t *ec, rb_ractor_t *r, VALUE obj, VALUE move)
struct rb_ractor_basket basket; struct rb_ractor_basket basket;
ractor_basket_setup(ec, &basket, obj, move, false, false); ractor_basket_setup(ec, &basket, obj, move, false, false);
ractor_send_basket(ec, r, &basket); ractor_send_basket(ec, r, &basket);
return r->self; return r->pub.self;
} }
static VALUE static VALUE
@ -1045,7 +1039,7 @@ static VALUE
ractor_select(rb_execution_context_t *ec, const VALUE *rs, int alen, VALUE yielded_value, bool move, VALUE *ret_r) ractor_select(rb_execution_context_t *ec, const VALUE *rs, int alen, VALUE yielded_value, bool move, VALUE *ret_r)
{ {
rb_ractor_t *cr = rb_ec_ractor_ptr(ec); rb_ractor_t *cr = rb_ec_ractor_ptr(ec);
VALUE crv = cr->self; VALUE crv = cr->pub.self;
VALUE ret = Qundef; VALUE ret = Qundef;
int i; int i;
bool interrupted = false; bool interrupted = false;
@ -1170,7 +1164,7 @@ ractor_select(rb_execution_context_t *ec, const VALUE *rs, int alen, VALUE yield
case ractor_select_action_take: case ractor_select_action_take:
r = RACTOR_PTR(actions[i].v); r = RACTOR_PTR(actions[i].v);
if (ractor_sleeping_by(r, wait_yielding)) { if (ractor_sleeping_by(r, wait_yielding)) {
RUBY_DEBUG_LOG("wakeup_none, but r:%u is waiting for yielding", r->id); RUBY_DEBUG_LOG("wakeup_none, but r:%u is waiting for yielding", r->pub.id);
cr->sync.wait.wakeup_status = wakeup_by_retry; cr->sync.wait.wakeup_status = wakeup_by_retry;
goto skip_sleep; goto skip_sleep;
} }
@ -1297,7 +1291,7 @@ static VALUE
ractor_take(rb_execution_context_t *ec, rb_ractor_t *r) ractor_take(rb_execution_context_t *ec, rb_ractor_t *r)
{ {
VALUE ret_r; VALUE ret_r;
VALUE v = ractor_select(ec, &r->self, 1, Qundef, false, &ret_r); VALUE v = ractor_select(ec, &r->pub.self, 1, Qundef, false, &ret_r);
return v; return v;
} }
@ -1376,7 +1370,7 @@ ractor_next_id(void)
static void static void
vm_insert_ractor0(rb_vm_t *vm, rb_ractor_t *r, bool single_ractor_mode) vm_insert_ractor0(rb_vm_t *vm, rb_ractor_t *r, bool single_ractor_mode)
{ {
RUBY_DEBUG_LOG("r:%u ractor.cnt:%u++", r->id, vm->ractor.cnt); RUBY_DEBUG_LOG("r:%u ractor.cnt:%u++", r->pub.id, vm->ractor.cnt);
VM_ASSERT(single_ractor_mode || RB_VM_LOCKED_P()); VM_ASSERT(single_ractor_mode || RB_VM_LOCKED_P());
list_add_tail(&vm->ractor.set, &r->vmlr_node); list_add_tail(&vm->ractor.set, &r->vmlr_node);
@ -1460,7 +1454,7 @@ ractor_alloc(VALUE klass)
rb_ractor_t *r; rb_ractor_t *r;
VALUE rv = TypedData_Make_Struct(klass, rb_ractor_t, &ractor_data_type, r); VALUE rv = TypedData_Make_Struct(klass, rb_ractor_t, &ractor_data_type, r);
FL_SET_RAW(rv, RUBY_FL_SHAREABLE); FL_SET_RAW(rv, RUBY_FL_SHAREABLE);
r->self = rv; r->pub.self = rv;
VM_ASSERT(ractor_status_p(r, ractor_created)); VM_ASSERT(ractor_status_p(r, ractor_created));
return rv; return rv;
} }
@ -1474,10 +1468,10 @@ rb_ractor_main_alloc(void)
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
} }
MEMZERO(r, rb_ractor_t, 1); MEMZERO(r, rb_ractor_t, 1);
r->id = ++ractor_last_id; r->pub.id = ++ractor_last_id;
r->loc = Qnil; r->loc = Qnil;
r->name = Qnil; r->name = Qnil;
r->self = Qnil; r->pub.self = Qnil;
ruby_single_main_ractor = r; ruby_single_main_ractor = r;
return r; return r;
@ -1523,8 +1517,8 @@ ractor_init(rb_ractor_t *r, VALUE name, VALUE loc)
void void
rb_ractor_main_setup(rb_vm_t *vm, rb_ractor_t *r, rb_thread_t *th) rb_ractor_main_setup(rb_vm_t *vm, rb_ractor_t *r, rb_thread_t *th)
{ {
r->self = TypedData_Wrap_Struct(rb_cRactor, &ractor_data_type, r); r->pub.self = TypedData_Wrap_Struct(rb_cRactor, &ractor_data_type, r);
FL_SET_RAW(r->self, RUBY_FL_SHAREABLE); FL_SET_RAW(r->pub.self, RUBY_FL_SHAREABLE);
ractor_init(r, Qnil, Qnil); ractor_init(r, Qnil, Qnil);
r->threads.main = th; r->threads.main = th;
rb_ractor_living_threads_insert(r, th); rb_ractor_living_threads_insert(r, th);
@ -1543,8 +1537,8 @@ ractor_create(rb_execution_context_t *ec, VALUE self, VALUE loc, VALUE name, VAL
ractor_init(r, name, loc); ractor_init(r, name, loc);
// can block here // can block here
r->id = ractor_next_id(); r->pub.id = ractor_next_id();
RUBY_DEBUG_LOG("r:%u", r->id); RUBY_DEBUG_LOG("r:%u", r->pub.id);
r->r_stdin = rb_io_prep_stdin(); r->r_stdin = rb_io_prep_stdin();
r->r_stdout = rb_io_prep_stdout(); r->r_stdout = rb_io_prep_stdout();
@ -1647,12 +1641,6 @@ rb_ractor_send_parameters(rb_execution_context_t *ec, rb_ractor_t *r, VALUE args
} }
} }
VALUE
rb_ractor_self(const rb_ractor_t *r)
{
return r->self;
}
MJIT_FUNC_EXPORTED bool MJIT_FUNC_EXPORTED bool
rb_ractor_main_p_(void) rb_ractor_main_p_(void)
{ {
@ -1709,7 +1697,7 @@ rb_ractor_living_threads_insert(rb_ractor_t *r, rb_thread_t *th)
RACTOR_LOCK(r); RACTOR_LOCK(r);
{ {
RUBY_DEBUG_LOG("r(%d)->threads.cnt:%d++", r->id, r->threads.cnt); RUBY_DEBUG_LOG("r(%d)->threads.cnt:%d++", r->pub.id, r->threads.cnt);
list_add_tail(&r->threads.set, &th->lt_node); list_add_tail(&r->threads.set, &th->lt_node);
r->threads.cnt++; r->threads.cnt++;
} }
@ -2051,7 +2039,7 @@ rb_ractor_dump(void)
list_for_each(&vm->ractor.set, r, vmlr_node) { list_for_each(&vm->ractor.set, r, vmlr_node) {
if (r != vm->ractor.main_ractor) { if (r != vm->ractor.main_ractor) {
fprintf(stderr, "r:%u (%s)\n", r->id, ractor_status_str(r->status_)); fprintf(stderr, "r:%u (%s)\n", r->pub.id, ractor_status_str(r->status_));
} }
} }
} }
@ -2100,7 +2088,7 @@ rb_ractor_stdin_set(VALUE in)
} }
else { else {
rb_ractor_t *cr = GET_RACTOR(); rb_ractor_t *cr = GET_RACTOR();
RB_OBJ_WRITE(cr->self, &cr->r_stdin, in); RB_OBJ_WRITE(cr->pub.self, &cr->r_stdin, in);
} }
} }
@ -2112,7 +2100,7 @@ rb_ractor_stdout_set(VALUE out)
} }
else { else {
rb_ractor_t *cr = GET_RACTOR(); rb_ractor_t *cr = GET_RACTOR();
RB_OBJ_WRITE(cr->self, &cr->r_stdout, out); RB_OBJ_WRITE(cr->pub.self, &cr->r_stdout, out);
} }
} }
@ -2124,14 +2112,14 @@ rb_ractor_stderr_set(VALUE err)
} }
else { else {
rb_ractor_t *cr = GET_RACTOR(); rb_ractor_t *cr = GET_RACTOR();
RB_OBJ_WRITE(cr->self, &cr->r_stderr, err); RB_OBJ_WRITE(cr->pub.self, &cr->r_stderr, err);
} }
} }
rb_hook_list_t * rb_hook_list_t *
rb_ractor_hooks(rb_ractor_t *cr) rb_ractor_hooks(rb_ractor_t *cr)
{ {
return &cr->event_hooks; return &cr->pub.hooks;
} }
/// traverse function /// traverse function

10
ractor.rb
View file

@ -251,7 +251,7 @@ class Ractor
# Ractor.current #=> #<Ractor:#1 running> # Ractor.current #=> #<Ractor:#1 running>
def self.current def self.current
__builtin_cexpr! %q{ __builtin_cexpr! %q{
rb_ec_ractor_ptr(ec)->self rb_ractor_self(rb_ec_ractor_ptr(ec));
} }
end end
@ -650,10 +650,10 @@ class Ractor
} }
end end
def inspect # :nodoc: def inspect
loc = __builtin_cexpr! %q{RACTOR_PTR(self)->loc} loc = __builtin_cexpr! %q{ RACTOR_PTR(self)->loc }
name = __builtin_cexpr! %q{RACTOR_PTR(self)->name} name = __builtin_cexpr! %q{ RACTOR_PTR(self)->name }
id = __builtin_cexpr! %q{INT2FIX(RACTOR_PTR(self)->id)} id = __builtin_cexpr! %q{ INT2FIX(rb_ractor_id(RACTOR_PTR(self))) }
status = __builtin_cexpr! %q{ status = __builtin_cexpr! %q{
rb_str_new2(ractor_status_str(RACTOR_PTR(self)->status_)) rb_str_new2(ractor_status_str(RACTOR_PTR(self)->status_))
} }

21
ractor_core.h
View file

@ -79,6 +79,8 @@ struct rb_ractor_sync {
}; };
struct rb_ractor_struct { struct rb_ractor_struct {
struct rb_ractor_pub pub;
struct rb_ractor_sync sync; struct rb_ractor_sync sync;
VALUE receiving_mutex; VALUE receiving_mutex;
bool yield_atexit; bool yield_atexit;
@ -98,9 +100,6 @@ struct rb_ractor_struct {
} threads; } threads;
VALUE thgroup_default; VALUE thgroup_default;
// identity
VALUE self;
uint32_t id;
VALUE name; VALUE name;
VALUE loc; VALUE loc;
@ -138,8 +137,6 @@ struct rb_ractor_struct {
VALUE verbose; VALUE verbose;
VALUE debug; VALUE debug;
rb_hook_list_t event_hooks;
struct { struct {
struct RVALUE *freelist; struct RVALUE *freelist;
struct heap_page *using_page; struct heap_page *using_page;
@ -152,9 +149,15 @@ struct rb_ractor_struct {
} *mfd; } *mfd;
}; // rb_ractor_t is defined in vm_core.h }; // rb_ractor_t is defined in vm_core.h
static inline VALUE
rb_ractor_self(const rb_ractor_t *r)
{
return r->pub.self;
}
rb_ractor_t *rb_ractor_main_alloc(void); rb_ractor_t *rb_ractor_main_alloc(void);
void rb_ractor_main_setup(rb_vm_t *vm, rb_ractor_t *main_ractor, rb_thread_t *main_thread); void rb_ractor_main_setup(rb_vm_t *vm, rb_ractor_t *main_ractor, rb_thread_t *main_thread);
VALUE rb_ractor_self(const rb_ractor_t *g);
void rb_ractor_atexit(rb_execution_context_t *ec, VALUE result); void rb_ractor_atexit(rb_execution_context_t *ec, VALUE result);
void rb_ractor_atexit_exception(rb_execution_context_t *ec); void rb_ractor_atexit_exception(rb_execution_context_t *ec);
void rb_ractor_teardown(rb_execution_context_t *ec); void rb_ractor_teardown(rb_execution_context_t *ec);
@ -276,7 +279,11 @@ rb_ractor_set_current_ec(rb_ractor_t *cr, rb_execution_context_t *ec)
void rb_vm_ractor_blocking_cnt_inc(rb_vm_t *vm, rb_ractor_t *cr, const char *file, int line); void rb_vm_ractor_blocking_cnt_inc(rb_vm_t *vm, rb_ractor_t *cr, const char *file, int line);
void rb_vm_ractor_blocking_cnt_dec(rb_vm_t *vm, rb_ractor_t *cr, const char *file, int line); void rb_vm_ractor_blocking_cnt_dec(rb_vm_t *vm, rb_ractor_t *cr, const char *file, int line);
uint32_t rb_ractor_id(const rb_ractor_t *r); static inline uint32_t
rb_ractor_id(const rb_ractor_t *r)
{
return r->pub.id;
}
#if RACTOR_CHECK_MODE > 0 #if RACTOR_CHECK_MODE > 0
uint32_t rb_ractor_current_id(void); uint32_t rb_ractor_current_id(void);

15
vm_core.h
View file

@ -1970,18 +1970,17 @@ rb_exec_event_hook_orig(rb_execution_context_t *ec, rb_hook_list_t *hooks, rb_ev
rb_exec_event_hooks(&trace_arg, hooks, pop_p); rb_exec_event_hooks(&trace_arg, hooks, pop_p);
} }
rb_hook_list_t *rb_ractor_hooks(rb_ractor_t *cr);; struct rb_ractor_pub {
VALUE self;
uint32_t id;
rb_hook_list_t hooks;
};
static inline rb_hook_list_t * static inline rb_hook_list_t *
rb_ec_ractor_hooks(const rb_execution_context_t *ec) rb_ec_ractor_hooks(const rb_execution_context_t *ec)
{ {
rb_hook_list_t *hooks = rb_ractor_hooks(rb_ec_ractor_ptr(ec)); struct rb_ractor_pub *cr_pub = (struct rb_ractor_pub *)rb_ec_ractor_ptr(ec);
if (LIKELY(hooks == NULL)) { return &cr_pub->hooks;
return NULL;
}
else {
return hooks;
}
} }
#define EXEC_EVENT_HOOK(ec_, flag_, self_, id_, called_id_, klass_, data_) \ #define EXEC_EVENT_HOOK(ec_, flag_, self_, id_, called_id_, klass_, data_) \

2
vm_insnhelper.c
View file

@ -2948,7 +2948,7 @@ vm_call_bmethod_body(rb_execution_context_t *ec, struct rb_calling_info *calling
VALUE procv = cme->def->body.bmethod.proc; VALUE procv = cme->def->body.bmethod.proc;
if (!RB_OBJ_SHAREABLE_P(procv) && if (!RB_OBJ_SHAREABLE_P(procv) &&
cme->def->body.bmethod.defined_ractor != rb_ec_ractor_ptr(ec)->self) { cme->def->body.bmethod.defined_ractor != rb_ractor_self(rb_ec_ractor_ptr(ec))) {
rb_raise(rb_eRuntimeError, "defined in a different Ractor"); rb_raise(rb_eRuntimeError, "defined in a different Ractor");
} }

2
vm_method.c
View file

@ -469,7 +469,7 @@ rb_method_definition_set(const rb_method_entry_t *me, rb_method_definition_t *de
} }
case VM_METHOD_TYPE_BMETHOD: case VM_METHOD_TYPE_BMETHOD:
RB_OBJ_WRITE(me, &def->body.bmethod.proc, (VALUE)opts); RB_OBJ_WRITE(me, &def->body.bmethod.proc, (VALUE)opts);
RB_OBJ_WRITE(me, &def->body.bmethod.defined_ractor, GET_THREAD()->ractor->self); RB_OBJ_WRITE(me, &def->body.bmethod.defined_ractor, rb_ractor_self(GET_RACTOR()));
return; return;
case VM_METHOD_TYPE_NOTIMPLEMENTED: case VM_METHOD_TYPE_NOTIMPLEMENTED:
setup_method_cfunc_struct(UNALIGNED_MEMBER_PTR(def, body.cfunc), rb_f_notimplement, -1); setup_method_cfunc_struct(UNALIGNED_MEMBER_PTR(def, body.cfunc), rb_f_notimplement, -1);

2
vm_sync.c
View file

@ -49,7 +49,7 @@ vm_lock_enter(rb_ractor_t *cr, rb_vm_t *vm, bool locked, bool no_barrier, unsign
else { else {
#if RACTOR_CHECK_MODE #if RACTOR_CHECK_MODE
// locking ractor and acquire VM lock will cause deadlock // locking ractor and acquire VM lock will cause deadlock
VM_ASSERT(cr->sync.locked_by != cr->self); VM_ASSERT(cr->sync.locked_by != rb_ractor_self(cr));
#endif #endif
// lock // lock

1
vm_trace.c
View file

@ -68,6 +68,7 @@ static void clean_hooks(const rb_execution_context_t *ec, rb_hook_list_t *list);
void void
rb_hook_list_free(rb_hook_list_t *hooks) rb_hook_list_free(rb_hook_list_t *hooks)
{ {
hooks->need_clean = TRUE;
clean_hooks(GET_EC(), hooks); clean_hooks(GET_EC(), hooks);
} }