1berry/ruby
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

* thread_pthread.c (native_cond_*): Check return code.

Browse Source 
(Some OSs except Linux return error code).



git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@29962 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
ko1 2010-11-28 12:55:43 +00:00
parent 16d4733ee4
commit 7a4b99129b
2 changed files with 22 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
ChangeLog
View File

@ -1,3 +1,8 @@
Mon Nov 29 05:54:22 2010 Koichi Sasada <ko1@atdot.net>
* thread_pthread.c (native_cond_*): Check return code.
(Some OSs except Linux return error code).
Sun Nov 28 21:46:21 2010 Nobuyoshi Nakada <nobu@ruby-lang.org> Sun Nov 28 21:46:21 2010 Nobuyoshi Nakada <nobu@ruby-lang.org>
* thread_pthread.c (thread_start_func_1): initialize native thread * thread_pthread.c (thread_start_func_1): initialize native thread

21
thread_pthread.c
View File

@ -259,25 +259,38 @@ native_cond_destroy(pthread_cond_t *cond)
static void static void
native_cond_signal(pthread_cond_t *cond) native_cond_signal(pthread_cond_t *cond)
{ {
pthread_cond_signal(cond); int r = pthread_cond_signal(cond);
if (r != 0) {
rb_bug_errno("pthread_cond_signal", r);
}
} }
static void static void
native_cond_broadcast(pthread_cond_t *cond) native_cond_broadcast(pthread_cond_t *cond)
{ {
pthread_cond_broadcast(cond); int r = pthread_cond_broadcast(cond);
if (r != 0) {
rb_bug_errno("native_cond_broadcast", r);
}
} }
static void static void
native_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex) native_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex)
{ {
pthread_cond_wait(cond, mutex); int r = pthread_cond_wait(cond, mutex);
if (r != 0) {
rb_bug_errno("pthread_cond_wait", r);
}
} }
static int static int
native_cond_timedwait(pthread_cond_t *cond, pthread_mutex_t *mutex, struct timespec *ts) native_cond_timedwait(pthread_cond_t *cond, pthread_mutex_t *mutex, struct timespec *ts)
{ {
return pthread_cond_timedwait(cond, mutex, ts); int r = pthread_cond_timedwait(cond, mutex, ts);
if (r != 0 && r != ETIMEDOUT && r != EINTR /* Linux */) {
rb_bug_errno("pthread_cond_timedwait", r);
}
return r;
} }
static void static void