summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--eval.c6
-rw-r--r--eval_error.c2
-rw-r--r--eval_intern.h2
-rw-r--r--thread.c6
-rw-r--r--vm_trace.c56
5 files changed, 36 insertions, 36 deletions
diff --git a/eval.c b/eval.c
index e810ad78d8..49411ddd32 100644
--- a/eval.c
+++ b/eval.c
@@ -524,7 +524,7 @@ setup_exception(rb_execution_context_t *ec, int tag, volatile VALUE mesg, VALUE
rb_ivar_set(mesg, idBt_locations, at);
set_backtrace(mesg, at);
}
- rb_threadptr_reset_raised(rb_ec_thread_ptr(ec));
+ rb_ec_reset_raised(ec);
}
EC_POP_TAG();
if (state) goto fatal;
@@ -563,7 +563,7 @@ setup_exception(rb_execution_context_t *ec, int tag, volatile VALUE mesg, VALUE
ec->errinfo = mesg;
}
else if (state) {
- rb_threadptr_reset_raised(rb_ec_thread_ptr(ec));
+ rb_ec_reset_raised(ec);
EC_JUMP_TAG(ec, state);
}
}
@@ -571,7 +571,7 @@ setup_exception(rb_execution_context_t *ec, int tag, volatile VALUE mesg, VALUE
if (rb_threadptr_set_raised(rb_ec_thread_ptr(ec))) {
fatal:
ec->errinfo = exception_error;
- rb_threadptr_reset_raised(rb_ec_thread_ptr(ec));
+ rb_ec_reset_raised(ec);
EC_JUMP_TAG(ec, TAG_FATAL);
}
diff --git a/eval_error.c b/eval_error.c
index 1e763046a7..ed2e43facc 100644
--- a/eval_error.c
+++ b/eval_error.c
@@ -324,6 +324,6 @@ error_handle(int ex)
unknown_longjmp_status(ex);
break;
}
- rb_threadptr_reset_raised(rb_ec_thread_ptr(ec));
+ rb_ec_reset_raised(ec);
return status;
}
diff --git a/eval_intern.h b/eval_intern.h
index 6eadc0da19..e9b9ba0b14 100644
--- a/eval_intern.h
+++ b/eval_intern.h
@@ -281,11 +281,11 @@ enum {
RAISED_NOMEMORY = 4
};
int rb_threadptr_set_raised(rb_thread_t *th);
-int rb_threadptr_reset_raised(rb_thread_t *th);
#define rb_thread_raised_set(th, f) ((th)->ec->raised_flag |= (f))
#define rb_thread_raised_reset(th, f) ((th)->ec->raised_flag &= ~(f))
#define rb_thread_raised_p(th, f) (((th)->ec->raised_flag & (f)) != 0)
#define rb_thread_raised_clear(th) ((th)->ec->raised_flag = 0)
+int rb_ec_reset_raised(rb_execution_context_t *th);
int rb_ec_stack_check(rb_execution_context_t *ec);
VALUE rb_f_eval(int argc, const VALUE *argv, VALUE self);
diff --git a/thread.c b/thread.c
index 4dcd9eab3b..5084e9789e 100644
--- a/thread.c
+++ b/thread.c
@@ -2177,12 +2177,12 @@ rb_threadptr_set_raised(rb_thread_t *th)
}
int
-rb_threadptr_reset_raised(rb_thread_t *th)
+rb_ec_reset_raised(rb_execution_context_t *ec)
{
- if (!(th->ec->raised_flag & RAISED_EXCEPTION)) {
+ if (!(ec->raised_flag & RAISED_EXCEPTION)) {
return 0;
}
- th->ec->raised_flag &= ~RAISED_EXCEPTION;
+ ec->raised_flag &= ~RAISED_EXCEPTION;
return 1;
}
diff --git a/vm_trace.c b/vm_trace.c
index 0171539808..6af7eab423 100644
--- a/vm_trace.c
+++ b/vm_trace.c
@@ -238,7 +238,7 @@ clean_hooks(rb_hook_list_t *list)
}
static void
-exec_hooks_body(rb_thread_t *th, rb_hook_list_t *list, const rb_trace_arg_t *trace_arg)
+exec_hooks_body(const rb_execution_context_t *ec, rb_hook_list_t *list, const rb_trace_arg_t *trace_arg)
{
rb_event_hook_t *hook;
@@ -255,10 +255,10 @@ exec_hooks_body(rb_thread_t *th, rb_hook_list_t *list, const rb_trace_arg_t *tra
}
static int
-exec_hooks_precheck(rb_thread_t *th, rb_hook_list_t *list, const rb_trace_arg_t *trace_arg)
+exec_hooks_precheck(const rb_execution_context_t *ec, rb_hook_list_t *list, const rb_trace_arg_t *trace_arg)
{
if (UNLIKELY(list->need_clean != FALSE)) {
- if (th->vm->trace_running <= 1) { /* only running this hooks */
+ if (rb_ec_vm_ptr(ec)->trace_running <= 1) { /* only running this hooks */
clean_hooks(list);
}
}
@@ -267,32 +267,32 @@ exec_hooks_precheck(rb_thread_t *th, rb_hook_list_t *list, const rb_trace_arg_t
}
static void
-exec_hooks_unprotected(rb_thread_t *th, rb_hook_list_t *list, const rb_trace_arg_t *trace_arg)
+exec_hooks_unprotected(const rb_execution_context_t *ec, rb_hook_list_t *list, const rb_trace_arg_t *trace_arg)
{
- if (exec_hooks_precheck(th, list, trace_arg) == 0) return;
- exec_hooks_body(th, list, trace_arg);
+ if (exec_hooks_precheck(ec, list, trace_arg) == 0) return;
+ exec_hooks_body(ec, list, trace_arg);
}
static int
-exec_hooks_protected(rb_thread_t *th, rb_hook_list_t *list, const rb_trace_arg_t *trace_arg)
+exec_hooks_protected(rb_execution_context_t *ec, rb_hook_list_t *list, const rb_trace_arg_t *trace_arg)
{
enum ruby_tag_type state;
volatile int raised;
- if (exec_hooks_precheck(th, list, trace_arg) == 0) return 0;
+ if (exec_hooks_precheck(ec, list, trace_arg) == 0) return 0;
- raised = rb_threadptr_reset_raised(th);
+ raised = rb_ec_reset_raised(ec);
/* TODO: Support !RUBY_EVENT_HOOK_FLAG_SAFE hooks */
- EC_PUSH_TAG(th->ec);
+ EC_PUSH_TAG(ec);
if ((state = EC_EXEC_TAG()) == TAG_NONE) {
- exec_hooks_body(th, list, trace_arg);
+ exec_hooks_body(ec, list, trace_arg);
}
EC_POP_TAG();
if (raised) {
- rb_threadptr_set_raised(th);
+ rb_threadptr_set_raised(rb_ec_thread_ptr(ec));
}
return state;
@@ -302,8 +302,8 @@ static void
rb_threadptr_exec_event_hooks_orig(rb_trace_arg_t *trace_arg, int pop_p)
{
rb_execution_context_t *ec = trace_arg->ec;
- rb_thread_t *th = rb_ec_thread_ptr(ec);
- rb_vm_t *vm = th->vm;
+ rb_vm_t *vm = rb_ec_vm_ptr(ec);
+ rb_hook_list_t *th_event_hooks = &rb_ec_thread_ptr(ec)->event_hooks;
if (trace_arg->event & RUBY_INTERNAL_EVENT_MASK) {
if (ec->trace_arg && (ec->trace_arg->event & RUBY_INTERNAL_EVENT_MASK)) {
@@ -313,8 +313,8 @@ rb_threadptr_exec_event_hooks_orig(rb_trace_arg_t *trace_arg, int pop_p)
rb_trace_arg_t *prev_trace_arg = ec->trace_arg;
vm->trace_running++;
ec->trace_arg = trace_arg;
- exec_hooks_unprotected(th, &th->event_hooks, trace_arg);
- exec_hooks_unprotected(th, &vm->event_hooks, trace_arg);
+ exec_hooks_unprotected(ec, th_event_hooks, trace_arg);
+ exec_hooks_unprotected(ec, &vm->event_hooks, trace_arg);
ec->trace_arg = prev_trace_arg;
vm->trace_running--;
}
@@ -333,11 +333,11 @@ rb_threadptr_exec_event_hooks_orig(rb_trace_arg_t *trace_arg, int pop_p)
ec->trace_arg = trace_arg;
{
/* thread local traces */
- state = exec_hooks_protected(th, &th->event_hooks, trace_arg);
+ state = exec_hooks_protected(ec, th_event_hooks, trace_arg);
if (state) goto terminate;
/* vm global traces */
- state = exec_hooks_protected(th, &vm->event_hooks, trace_arg);
+ state = exec_hooks_protected(ec, &vm->event_hooks, trace_arg);
if (state) goto terminate;
ec->errinfo = errinfo;
@@ -379,35 +379,35 @@ rb_suppress_tracing(VALUE (*func)(VALUE), VALUE arg)
{
volatile int raised;
VALUE result = Qnil;
- rb_thread_t *volatile th = GET_THREAD();
+ rb_execution_context_t *ec = GET_EC();
enum ruby_tag_type state;
- const int volatile tracing = th->ec->trace_arg ? 1 : 0;
+ const int volatile tracing = ec->trace_arg ? 1 : 0;
rb_trace_arg_t dummy_trace_arg;
dummy_trace_arg.event = 0;
- if (!tracing) th->vm->trace_running++;
- if (!th->ec->trace_arg) th->ec->trace_arg = &dummy_trace_arg;
+ if (!tracing) rb_ec_vm_ptr(ec)->trace_running++;
+ if (!ec->trace_arg) ec->trace_arg = &dummy_trace_arg;
- raised = rb_threadptr_reset_raised(th);
+ raised = rb_ec_reset_raised(ec);
- EC_PUSH_TAG(th->ec);
+ EC_PUSH_TAG(ec);
if ((state = EC_EXEC_TAG()) == TAG_NONE) {
result = (*func)(arg);
}
EC_POP_TAG();
if (raised) {
- rb_threadptr_set_raised(th);
+ rb_ec_reset_raised(ec);
}
- if (th->ec->trace_arg == &dummy_trace_arg) th->ec->trace_arg = 0;
- if (!tracing) th->vm->trace_running--;
+ if (ec->trace_arg == &dummy_trace_arg) ec->trace_arg = NULL;
+ if (!tracing) rb_ec_vm_ptr(ec)->trace_running--;
if (state) {
#if defined RUBY_USE_SETJMPEX && RUBY_USE_SETJMPEX
RB_GC_GUARD(result);
#endif
- EC_JUMP_TAG(th->ec, state);
+ EC_JUMP_TAG(ec, state);
}
return result;
generated by cgit v1.2.3 (git 2.25.1) at 2024-05-11 09:31:59 +0000