Catchup with _thread_suspend() changes.

3 files changed, 9 insertions, 3 deletions

diff --git a/lib/libthr/thread/thr_cond.c b/lib/libthr/thread/thr_cond.c
index 6a86b39..00dbb25 100644
--- a/lib/libthr/thread/thr_cond.c
+++ b/lib/libthr/thread/thr_cond.c
@@ -285,7 +285,7 @@ cond_wait_common(pthread_cond_t * cond, pthread_mutex_t * mutex,
 			_thread_critical_exit(curthread);
 			COND_UNLOCK(*cond);
 			rval = _thread_suspend(curthread, (struct timespec *)abstime);
-			if (rval == -1) {
+			if (rval != 0 && rval != EAGAIN && rval != EINTR) {
 				printf("foo");
 				fflush(stdout);
 				abort();
diff --git a/lib/libthr/thread/thr_join.c b/lib/libthr/thread/thr_join.c
index 8b57978..ed03367 100644
--- a/lib/libthr/thread/thr_join.c
+++ b/lib/libthr/thread/thr_join.c
@@ -122,7 +122,9 @@ _pthread_join(pthread_t pthread, void **thread_return)
 			_thread_critical_exit(curthread);
 			THREAD_LIST_UNLOCK;
 			DEAD_LIST_UNLOCK;
-			_thread_suspend(curthread, NULL);
+			ret = _thread_suspend(curthread, NULL);
+			if (ret != 0 && ret != EAGAIN && ret != EINTR)
+				PANIC("Unable to suspend in join.");
 
 			/*
 			 * XXX - For correctness reasons.
diff --git a/lib/libthr/thread/thr_mutex.c b/lib/libthr/thread/thr_mutex.c
index 067f0f0..7d7c455 100644
--- a/lib/libthr/thread/thr_mutex.c
+++ b/lib/libthr/thread/thr_mutex.c
@@ -1396,6 +1396,8 @@ get_muncontested(pthread_mutex_t mutexp, int nonblock)
 static void
 get_mcontested(pthread_mutex_t mutexp)
 {
+	int error;
+
 	_thread_critical_enter(curthread);
 
 	/*
@@ -1410,7 +1412,9 @@ get_mcontested(pthread_mutex_t mutexp)
 		curthread->data.mutex = mutexp;
 		_thread_critical_exit(curthread);
 		_SPINUNLOCK(&mutexp->lock);
-		_thread_suspend(curthread, NULL);
+		error = _thread_suspend(curthread, NULL);
+		if (error != 0 && error != EAGAIN && error != EINTR)
+			PANIC("Cannot suspend on mutex.");
 
 		_SPINLOCK(&mutexp->lock);
 		_thread_critical_enter(curthread);