diff options
-rw-r--r-- | common.mk | 1 | ||||
-rw-r--r-- | ractor.c | 3 |
2 files changed, 3 insertions, 1 deletions
@@ -10213,6 +10213,7 @@ ractor.$(OBJEXT): $(top_srcdir)/internal/serial.h ractor.$(OBJEXT): $(top_srcdir)/internal/static_assert.h ractor.$(OBJEXT): $(top_srcdir)/internal/string.h ractor.$(OBJEXT): $(top_srcdir)/internal/struct.h +ractor.$(OBJEXT): $(top_srcdir)/internal/thread.h ractor.$(OBJEXT): $(top_srcdir)/internal/vm.h ractor.$(OBJEXT): $(top_srcdir)/internal/warnings.h ractor.$(OBJEXT): {$(VPATH)}assert.h @@ -12,6 +12,7 @@ #include "internal/hash.h" #include "internal/rational.h" #include "internal/struct.h" +#include "internal/thread.h" #include "variable.h" #include "gc.h" #include "transient_heap.h" @@ -473,7 +474,7 @@ ractor_basket_accept(struct rb_ractor_basket *b) static void ractor_recursive_receive_if(rb_ractor_t *r) { - if (r->receiving_mutex && rb_mutex_locked_p(r->receiving_mutex)) { + if (r->receiving_mutex && rb_mutex_owned_p(r->receiving_mutex)) { rb_raise(rb_eRactorError, "can not call receive/receive_if recursively"); } } |