thread_cond.c (apr-1.6.5.tar.bz2) | : | thread_cond.c (apr-1.7.0.tar.bz2) | ||
---|---|---|---|---|
skipping to change at line 26 | skipping to change at line 26 | |||
#include "apr_general.h" | #include "apr_general.h" | |||
#include "apr_lib.h" | #include "apr_lib.h" | |||
#include "apr_strings.h" | #include "apr_strings.h" | |||
#include "apr_portable.h" | #include "apr_portable.h" | |||
#include "apr_arch_thread_mutex.h" | #include "apr_arch_thread_mutex.h" | |||
#include "apr_arch_thread_cond.h" | #include "apr_arch_thread_cond.h" | |||
#include "apr_arch_file_io.h" | #include "apr_arch_file_io.h" | |||
#include <string.h> | #include <string.h> | |||
#ifndef DCE_POSTONE | ||||
#define DCE_POSTONE 0x0800 // Post one flag | ||||
#endif | ||||
static apr_status_t thread_cond_cleanup(void *data) | ||||
{ | ||||
apr_thread_cond_t *cv = data; | ||||
if (cv->semaphore) { | ||||
DosCloseEventSem(cv->semaphore); | ||||
} | ||||
if (cv->mutex) { | ||||
DosCloseMutexSem(cv->mutex); | ||||
} | ||||
return APR_SUCCESS; | ||||
} | ||||
APR_DECLARE(apr_status_t) apr_thread_cond_create(apr_thread_cond_t **cond, | APR_DECLARE(apr_status_t) apr_thread_cond_create(apr_thread_cond_t **cond, | |||
apr_pool_t *pool) | apr_pool_t *pool) | |||
{ | { | |||
return APR_ENOTIMPL; | int rc; | |||
apr_thread_cond_t *cv; | ||||
cv = apr_pcalloc(pool, sizeof(**cond)); | ||||
rc = DosCreateEventSem(NULL, &cv->semaphore, DCE_POSTONE, FALSE); | ||||
if (rc == 0) { | ||||
rc = DosCreateMutexSem(NULL, &cv->mutex, 0, FALSE); | ||||
} | ||||
*cond = cv; | ||||
cv->pool = pool; | ||||
apr_pool_cleanup_register(cv->pool, cv, thread_cond_cleanup, | ||||
apr_pool_cleanup_null); | ||||
return APR_FROM_OS_ERROR(rc); | ||||
} | ||||
static apr_status_t thread_cond_timedwait(apr_thread_cond_t *cond, | ||||
apr_thread_mutex_t *mutex, | ||||
ULONG timeout_ms ) | ||||
{ | ||||
ULONG rc; | ||||
apr_status_t rv = APR_SUCCESS; | ||||
int wake = FALSE; | ||||
unsigned long generation; | ||||
DosRequestMutexSem(cond->mutex, SEM_INDEFINITE_WAIT); | ||||
cond->num_waiting++; | ||||
generation = cond->generation; | ||||
DosReleaseMutexSem(cond->mutex); | ||||
apr_thread_mutex_unlock(mutex); | ||||
do { | ||||
rc = DosWaitEventSem(cond->semaphore, timeout_ms); | ||||
DosRequestMutexSem(cond->mutex, SEM_INDEFINITE_WAIT); | ||||
if (cond->num_wake) { | ||||
if (cond->generation != generation) { | ||||
cond->num_wake--; | ||||
cond->num_waiting--; | ||||
rv = APR_SUCCESS; | ||||
break; | ||||
} else { | ||||
wake = TRUE; | ||||
} | ||||
} | ||||
else if (rc != 0) { | ||||
cond->num_waiting--; | ||||
rv = APR_TIMEUP; | ||||
break; | ||||
} | ||||
DosReleaseMutexSem(cond->mutex); | ||||
if (wake) { | ||||
wake = FALSE; | ||||
DosPostEventSem(cond->semaphore); | ||||
} | ||||
} while (1); | ||||
DosReleaseMutexSem(cond->mutex); | ||||
apr_thread_mutex_lock(mutex); | ||||
return rv; | ||||
} | } | |||
APR_DECLARE(apr_status_t) apr_thread_cond_wait(apr_thread_cond_t *cond, | APR_DECLARE(apr_status_t) apr_thread_cond_wait(apr_thread_cond_t *cond, | |||
apr_thread_mutex_t *mutex) | apr_thread_mutex_t *mutex) | |||
{ | { | |||
return APR_ENOTIMPL; | return thread_cond_timedwait(cond, mutex, SEM_INDEFINITE_WAIT); | |||
} | } | |||
APR_DECLARE(apr_status_t) apr_thread_cond_timedwait(apr_thread_cond_t *cond, | APR_DECLARE(apr_status_t) apr_thread_cond_timedwait(apr_thread_cond_t *cond, | |||
apr_thread_mutex_t *mutex, | apr_thread_mutex_t *mutex, | |||
apr_interval_time_t timeout) | apr_interval_time_t timeout) | |||
{ | { | |||
return APR_ENOTIMPL; | ULONG timeout_ms = (timeout >= 0) ? apr_time_as_msec(timeout) | |||
: SEM_INDEFINITE_WAIT; | ||||
return thread_cond_timedwait(cond, mutex, timeout_ms); | ||||
} | } | |||
APR_DECLARE(apr_status_t) apr_thread_cond_signal(apr_thread_cond_t *cond) | APR_DECLARE(apr_status_t) apr_thread_cond_signal(apr_thread_cond_t *cond) | |||
{ | { | |||
return APR_ENOTIMPL; | int wake = FALSE; | |||
DosRequestMutexSem(cond->mutex, SEM_INDEFINITE_WAIT); | ||||
if (cond->num_waiting > cond->num_wake) { | ||||
wake = TRUE; | ||||
cond->num_wake++; | ||||
cond->generation++; | ||||
} | ||||
DosReleaseMutexSem(cond->mutex); | ||||
if (wake) { | ||||
DosPostEventSem(cond->semaphore); | ||||
} | ||||
return APR_SUCCESS; | ||||
} | } | |||
APR_DECLARE(apr_status_t) apr_thread_cond_broadcast(apr_thread_cond_t *cond) | APR_DECLARE(apr_status_t) apr_thread_cond_broadcast(apr_thread_cond_t *cond) | |||
{ | { | |||
return APR_ENOTIMPL; | unsigned long num_wake = 0; | |||
DosRequestMutexSem(cond->mutex, SEM_INDEFINITE_WAIT); | ||||
if (cond->num_waiting > cond->num_wake) { | ||||
num_wake = cond->num_waiting - cond->num_wake; | ||||
cond->num_wake = cond->num_waiting; | ||||
cond->generation++; | ||||
} | ||||
DosReleaseMutexSem(cond->mutex); | ||||
for (; num_wake; num_wake--) { | ||||
DosPostEventSem(cond->semaphore); | ||||
} | ||||
return APR_SUCCESS; | ||||
} | } | |||
APR_DECLARE(apr_status_t) apr_thread_cond_destroy(apr_thread_cond_t *cond) | APR_DECLARE(apr_status_t) apr_thread_cond_destroy(apr_thread_cond_t *cond) | |||
{ | { | |||
return APR_ENOTIMPL; | return apr_pool_cleanup_run(cond->pool, cond, thread_cond_cleanup); | |||
} | } | |||
APR_POOL_IMPLEMENT_ACCESSOR(thread_cond) | APR_POOL_IMPLEMENT_ACCESSOR(thread_cond) | |||
End of changes. 7 change blocks. | ||||
8 lines changed or deleted | 126 lines changed or added |