summaryrefslogtreecommitdiff
path: root/thread.c
diff options
context:
space:
mode:
authorJean Boussier <jean.boussier@gmail.com>2025-12-16 00:43:41 +0100
committerJean Boussier <jean.boussier@gmail.com>2025-12-16 09:51:07 +0100
commite42bcd7ce76e75601ef3adf35467edf277471af2 (patch)
tree1e2925bda2a38dd2495f62379320331c6c7867f6 /thread.c
parent28b195fc67788c03be59c2a4cbf0cad52ac3b90f (diff)
Rename fiber_serial into ec_serial
Since it now live in the EC.
Diffstat (limited to 'thread.c')
-rw-r--r--thread.c10
1 files changed, 5 insertions, 5 deletions
diff --git a/thread.c b/thread.c
index cea8e7fe75..3e1bb1dbe7 100644
--- a/thread.c
+++ b/thread.c
@@ -453,7 +453,7 @@ rb_threadptr_unlock_all_locking_mutexes(rb_thread_t *th)
th->keeping_mutexes = mutex->next_mutex;
// rb_warn("mutex #<%p> was not unlocked by thread #<%p>", (void *)mutex, (void*)th);
- VM_ASSERT(mutex->fiber_serial);
+ VM_ASSERT(mutex->ec_serial);
const char *error_message = rb_mutex_unlock_th(mutex, th, 0);
if (error_message) rb_bug("invalid keeping_mutexes: %s", error_message);
}
@@ -5283,7 +5283,7 @@ rb_thread_shield_owned(VALUE self)
rb_mutex_t *m = mutex_ptr(mutex);
- return m->fiber_serial == rb_ec_fiber_serial(GET_EC());
+ return m->ec_serial == rb_ec_serial(GET_EC());
}
/*
@@ -5302,7 +5302,7 @@ rb_thread_shield_wait(VALUE self)
if (!mutex) return Qfalse;
m = mutex_ptr(mutex);
- if (m->fiber_serial == rb_ec_fiber_serial(GET_EC())) return Qnil;
+ if (m->ec_serial == rb_ec_serial(GET_EC())) return Qnil;
rb_thread_shield_waiting_inc(self);
rb_mutex_lock(mutex);
rb_thread_shield_waiting_dec(self);
@@ -5820,7 +5820,7 @@ debug_deadlock_check(rb_ractor_t *r, VALUE msg)
if (th->locking_mutex) {
rb_mutex_t *mutex = mutex_ptr(th->locking_mutex);
rb_str_catf(msg, " mutex:%llu cond:%"PRIuSIZE,
- (unsigned long long)mutex->fiber_serial, rb_mutex_num_waiting(mutex));
+ (unsigned long long)mutex->ec_serial, rb_mutex_num_waiting(mutex));
}
{
@@ -5860,7 +5860,7 @@ rb_check_deadlock(rb_ractor_t *r)
}
else if (th->locking_mutex) {
rb_mutex_t *mutex = mutex_ptr(th->locking_mutex);
- if (mutex->fiber_serial == rb_ec_fiber_serial(th->ec) || (!mutex->fiber_serial && !ccan_list_empty(&mutex->waitq))) {
+ if (mutex->ec_serial == rb_ec_serial(th->ec) || (!mutex->ec_serial && !ccan_list_empty(&mutex->waitq))) {
found = 1;
}
}