summaryrefslogtreecommitdiff
path: root/condvar.c
diff options
context:
space:
mode:
Diffstat (limited to 'condvar.c')
-rw-r--r--condvar.c31
1 files changed, 20 insertions, 11 deletions
diff --git a/condvar.c b/condvar.c
index 80dc1c4..ce46ebf 100644
--- a/condvar.c
+++ b/condvar.c
@@ -327,7 +327,7 @@ pthread_cond_init (pthread_cond_t * cond, const pthread_condattr_t * attr)
*/
{
int result = EAGAIN;
- pthread_cond_t cv;
+ pthread_cond_t cv = NULL;
if (cond == NULL)
{
@@ -443,16 +443,20 @@ pthread_cond_destroy (pthread_cond_t * cond)
cv = *cond;
- if (cv->waiters > 0)
+ if (cv != (pthread_cond_t) _PTHREAD_OBJECT_AUTO_INIT)
{
- return EBUSY;
- }
+ if (cv->waiters > 0)
+ {
+ return EBUSY;
+ }
- (void) _pthread_sem_destroy (&(cv->sema));
- (void) pthread_mutex_destroy (&(cv->waitersLock));
- (void) CloseHandle (cv->waitersDone);
+ (void) _pthread_sem_destroy (&(cv->sema));
+ (void) pthread_mutex_destroy (&(cv->waitersLock));
+ (void) CloseHandle (cv->waitersDone);
+
+ free(cv);
+ }
- free(cv);
*cond = NULL;
return (result);
@@ -473,19 +477,24 @@ cond_timedwait (pthread_cond_t * cond,
return EINVAL;
}
- cv = *cond;
-
/*
* We do a quick check to see if we need to do more work
* to initialise a static condition variable. We check
* again inside the guarded section of _cond_check_need_init()
* to avoid race conditions.
*/
- if (cv == (pthread_cond_t) _PTHREAD_OBJECT_AUTO_INIT)
+ if (*cond == (pthread_cond_t) _PTHREAD_OBJECT_AUTO_INIT)
{
result = _cond_check_need_init(cond);
}
+ if (result != 0 && result != EBUSY)
+ {
+ return result;
+ }
+
+ cv = *cond;
+
/*
* OK to increment cond->waiters because the caller locked 'mutex'
*/