diff options
| -rw-r--r-- | src/common/compat_pthreads.c | 16 | ||||
| -rw-r--r-- | src/common/compat_threads.h | 1 | ||||
| -rw-r--r-- | src/common/compat_winthreads.c | 6 |
3 files changed, 23 insertions, 0 deletions
diff --git a/src/common/compat_pthreads.c b/src/common/compat_pthreads.c index e58b3f7b57..59b54a600a 100644 --- a/src/common/compat_pthreads.c +++ b/src/common/compat_pthreads.c @@ -96,6 +96,22 @@ tor_mutex_init(tor_mutex_t *mutex) tor_fragile_assert(); } } + +/** As tor_mutex_init, but initialize a mutex suitable for use with a + * condition variable. */ +void +tor_mutex_init_for_cond(tor_mutex_t *mutex) +{ + int err; + if (PREDICT_UNLIKELY(!threads_initialized)) + tor_threads_init(); + err = pthread_mutex_init(&mutex->mutex, NULL); + if (PREDICT_UNLIKELY(err)) { + log_err(LD_GENERAL, "Error %d creating a mutex.", err); + tor_fragile_assert(); + } +} + /** Wait until <b>m</b> is free, then acquire it. */ void tor_mutex_acquire(tor_mutex_t *m) diff --git a/src/common/compat_threads.h b/src/common/compat_threads.h index 6d3ba3ae21..581d8dd7b9 100644 --- a/src/common/compat_threads.h +++ b/src/common/compat_threads.h @@ -47,6 +47,7 @@ typedef struct tor_mutex_t { tor_mutex_t *tor_mutex_new(void); void tor_mutex_init(tor_mutex_t *m); +void tor_mutex_init_for_cond(tor_mutex_t *m); void tor_mutex_acquire(tor_mutex_t *m); void tor_mutex_release(tor_mutex_t *m); void tor_mutex_free(tor_mutex_t *m); diff --git a/src/common/compat_winthreads.c b/src/common/compat_winthreads.c index 11f91c63df..2b1527ad34 100644 --- a/src/common/compat_winthreads.c +++ b/src/common/compat_winthreads.c @@ -49,6 +49,12 @@ tor_mutex_init(tor_mutex_t *m) InitializeCriticalSection(&m->mutex); } void +tor_mutex_init_for_cond(tor_mutex_t *m) +{ + InitializeCriticalSection(&m->mutex); +} + +void tor_mutex_uninit(tor_mutex_t *m) { DeleteCriticalSection(&m->mutex); |