|
@@ -61,7 +61,6 @@ int sem_wait(sem_t * sem)
|
|
|
volatile pthread_descr self = thread_self();
|
|
|
pthread_extricate_if extr;
|
|
|
int already_canceled = 0;
|
|
|
- int spurious_wakeup_count;
|
|
|
|
|
|
|
|
|
extr.pu_object = sem;
|
|
@@ -90,7 +89,6 @@ int sem_wait(sem_t * sem)
|
|
|
}
|
|
|
|
|
|
|
|
|
- spurious_wakeup_count = 0;
|
|
|
while (1)
|
|
|
{
|
|
|
suspend(self);
|
|
@@ -98,8 +96,7 @@ int sem_wait(sem_t * sem)
|
|
|
&& (THREAD_GETMEM(self, p_woken_by_cancel) == 0
|
|
|
|| THREAD_GETMEM(self, p_cancelstate) != PTHREAD_CANCEL_ENABLE))
|
|
|
{
|
|
|
-
|
|
|
- spurious_wakeup_count++;
|
|
|
+
|
|
|
continue;
|
|
|
}
|
|
|
break;
|
|
@@ -213,7 +210,6 @@ int sem_timedwait(sem_t *sem, const struct timespec *abstime)
|
|
|
pthread_descr self = thread_self();
|
|
|
pthread_extricate_if extr;
|
|
|
int already_canceled = 0;
|
|
|
- int spurious_wakeup_count;
|
|
|
|
|
|
__pthread_lock(&sem->__sem_lock, self);
|
|
|
if (sem->__sem_value > 0) {
|
|
@@ -250,7 +246,6 @@ int sem_timedwait(sem_t *sem, const struct timespec *abstime)
|
|
|
__pthread_do_exit(PTHREAD_CANCELED, CURRENT_STACK_FRAME);
|
|
|
}
|
|
|
|
|
|
- spurious_wakeup_count = 0;
|
|
|
while (1)
|
|
|
{
|
|
|
if (timedsuspend(self, abstime) == 0) {
|
|
@@ -277,8 +272,7 @@ int sem_timedwait(sem_t *sem, const struct timespec *abstime)
|
|
|
&& (THREAD_GETMEM(self, p_woken_by_cancel) == 0
|
|
|
|| THREAD_GETMEM(self, p_cancelstate) != PTHREAD_CANCEL_ENABLE))
|
|
|
{
|
|
|
-
|
|
|
- spurious_wakeup_count++;
|
|
|
+
|
|
|
continue;
|
|
|
}
|
|
|
break;
|