summaryrefslogtreecommitdiff
path: root/condvar.c
diff options
context:
space:
mode:
authorrpj <rpj>1998-08-03 15:27:21 +0000
committerrpj <rpj>1998-08-03 15:27:21 +0000
commit10f173691b6929033d5714cde8a33f4477aaba28 (patch)
tree4b84ccc5f4226332d00aea6b41f98013deaf7b31 /condvar.c
parentbd354ffc95e1f3ef53f781b9c15641d9b6da9208 (diff)
Tue Aug 4 00:09:30 1998 Ross Johnson <rpj@ixobrychus.canberra.edu.au>
* implement.h(_pthread_virgins): Add extern. (_pthread_virgin_next): Ditto. (_pthread_reuse): Ditto. (_pthread_reuse_top): Ditto. (_pthread_win32handle_map): Ditto. (_pthread_threads_mutex_table): Ditto. * global.c (_pthread_virgins): Changed from array to pointer. Storage allocation for the array moved into dll.c. (_pthread_reuse): Ditto. (_pthread_win32handle_map): Ditto. (_pthread_threads_mutex_table): Ditto. * dll.c (PthreadsEntryPoint): Set up thread admin storage when DLL is loaded. * fork.c (pthread_atfork): Fix function pointer arg to all _pthread_handler_push() calls. Change "arg" arg to NULL in child push. * exit.c: Add windows.h and process.h includes. (_pthread_exit): Add local detachstate declaration. (_pthread_exit): Fix incorrect name for pthread_attr_getdetachstate(). * pthread.h (_POSIX_THREAD_ATTR_STACKSIZE): Move from global.c (_POSIX_THREAD_ATTR_STACKADDR): Ditto. * create.c (pthread_create): Fix #if should be #ifdef. (_pthread_start_call): Remove usused variables. * process.h: Create. * windows.h: Move _beginthreadex and _endthreadex into process.h Mon Aug 3 21:19:57 1998 Ross Johnson <rpj@ixobrychus.canberra.edu.au> * condvar.c (pthread_cond_init): Add NULL attr to pthread_mutex_init() call - default attributes will be used. (cond_wait): Fix typo. (cond_wait): Fix typo - cv was ev. (pthread_cond_broadcast): Fix two identical typos. * cleanup.c (_pthread_destructor_pop_all): Remove _ prefix from PTHREAD_DESTRUCTOR_ITERATIONS. * pthread.h: Move _POSIX_* values into posix.h * pthread.h: Fix typo in pthread_mutex_init() prototype. * attr.c (pthread_attr_init): Fix error in priority member init. * windows.h (THREAD_PRIORITY_NORMAL): Add. * pthread.h (sched_param): Add missing ';' to struct definition. * attr.c (pthread_attr_init): Remove obsolete pthread_attr_t member initialisation - cancelstate, canceltype, cancel_pending. (is_attr): Make arg "attr" a const. * implement.h (_PTHREAD_HANDLER_POP_LIFO): Remove definition. (_PTHREAD_HANDLER_POP_FIFO): Ditto. (_PTHREAD_VALID): Add missing newline escape (\). (_pthread_handler_node): Make element "next" a pointer.
Diffstat (limited to 'condvar.c')
-rw-r--r--condvar.c12
1 files changed, 6 insertions, 6 deletions
diff --git a/condvar.c b/condvar.c
index d11c322..0f7a8c8 100644
--- a/condvar.c
+++ b/condvar.c
@@ -46,8 +46,8 @@ pthread_cond_init(pthread_cond_t *cv, const pthread_condattr_t *attr)
/* Initialize the count to 0. */
cv->waiters_count = 0;
- /* Initialize the "mutex". */
- pthread_mutex_init(cv->waiters_count_lock);
+ /* Initialize the "mutex". FIXME: Check attributes arg. */
+ pthread_mutex_init(cv->waiters_count_lock, NULL);
/* Create an auto-reset event. */
cv->events[SIGNAL] = CreateEvent (NULL, /* no security */
@@ -84,7 +84,7 @@ cond_wait(pthread_cond_t *cv, pthread_mutex_t *mutex, DWORD abstime)
/* Avoid race conditions. */
EnterCriticalSection (&cv->waiters_count_lock);
- cv->waiters_count_++;
+ cv->waiters_count++;
LeaveCriticalSection (&cv->waiters_count_lock);
/* It's okay to release the mutex here since Win32 manual-reset
@@ -97,7 +97,7 @@ cond_wait(pthread_cond_t *cv, pthread_mutex_t *mutex, DWORD abstime)
pthread_cond_signal() being called or pthread_cond_broadcast()
being called. */
- result = WaitForMultipleObjects (2, ev->events, FALSE, abstime);
+ result = WaitForMultipleObjects (2, cv->events, FALSE, abstime);
EnterCriticalSection (&cv->waiters_count_lock);
cv->waiters_count--;
@@ -156,9 +156,9 @@ pthread_cond_broadcast (pthread_cond_t *cv)
}
/* Avoid race conditions. */
- EnterCriticalSection (&cv->waiters_count_lock_);
+ EnterCriticalSection (&cv->waiters_count_lock);
have_waiters = (cv->waiters_count > 0);
- LeaveCriticalSection (&cv->waiters_count_lock_);
+ LeaveCriticalSection (&cv->waiters_count_lock);
if (have_waiters) {
SetEvent(cv->events[BROADCAST]);