diff options
author | ko1 <ko1@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2017-01-31 06:39:01 +0000 |
---|---|---|
committer | ko1 <ko1@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2017-01-31 06:39:01 +0000 |
commit | 5d0c4376c9ea925b814ab4082bb02dd7d93cc6ef (patch) | |
tree | 189f27fbe919929848ea82df12b756d72ddece79 | |
parent | 6fe000eb036831acb1d9f66ca2e73e18d11a8459 (diff) | |
download | ruby-5d0c4376c9ea925b814ab4082bb02dd7d93cc6ef.tar.gz |
define rb_thread_sleep_deadly_allow_spurious_wakeup().
* thread.c, thread_sync.c: define new function
rb_thread_sleep_deadly_allow_spurious_wakeup() and use it instead of
using sleep_forever() directly.
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@57478 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
-rw-r--r-- | thread.c | 8 | ||||
-rw-r--r-- | thread_sync.c | 2 |
2 files changed, 9 insertions, 1 deletions
@@ -85,6 +85,7 @@ static ID id_locals; static void sleep_timeval(rb_thread_t *th, struct timeval time, int spurious_check); static void sleep_wait_for_interrupt(rb_thread_t *th, double sleepsec, int spurious_check); static void sleep_forever(rb_thread_t *th, int nodeadlock, int spurious_check); +static void rb_thread_sleep_deadly_allow_spurious_wakeup(void); static double timeofday(void); static int rb_threadptr_dead(rb_thread_t *th); static void rb_check_deadlock(rb_vm_t *vm); @@ -1146,6 +1147,13 @@ rb_thread_sleep_deadly(void) sleep_forever(GET_THREAD(), TRUE, TRUE); } +static void +rb_thread_sleep_deadly_allow_spurious_wakeup(void) +{ + thread_debug("rb_thread_sleep_deadly_allow_spurious_wakeup\n"); + sleep_forever(GET_THREAD(), TRUE, FALSE); +} + static double timeofday(void) { diff --git a/thread_sync.c b/thread_sync.c index 9fbe3b0383..ce280cea1a 100644 --- a/thread_sync.c +++ b/thread_sync.c @@ -420,7 +420,7 @@ rb_mutex_abandon_all(rb_mutex_t *mutexes) static VALUE rb_mutex_sleep_forever(VALUE time) { - sleep_forever(GET_THREAD(), TRUE, FALSE); /* permit spurious check */ + rb_thread_sleep_deadly_allow_spurious_wakeup(); return Qnil; } |