diff --git a/crypto/threads_pthread.c b/crypto/threads_pthread.c index f10757c5dc..4ba47966a6 100644 --- a/crypto/threads_pthread.c +++ b/crypto/threads_pthread.c @@ -11,13 +11,13 @@ #if defined(OPENSSL_THREADS) && !defined(CRYPTO_TDEBUG) && !defined(OPENSSL_SYS_WINDOWS) -#ifdef PTHREAD_RWLOCK_INITIALIZER - #define OPENSSL_THREADS_HAVE_PTHREAD_RWLOCK -#endif +# ifdef PTHREAD_RWLOCK_INITIALIZER +# define USE_RWLOCK +# endif CRYPTO_RWLOCK *CRYPTO_THREAD_lock_new(void) { -#ifdef OPENSSL_THREADS_HAVE_PTHREAD_RWLOCK +# ifdef USE_RWLOCK CRYPTO_RWLOCK *lock = OPENSSL_zalloc(sizeof(pthread_rwlock_t)); if (lock == NULL) return NULL; @@ -26,62 +26,63 @@ CRYPTO_RWLOCK *CRYPTO_THREAD_lock_new(void) OPENSSL_free(lock); return NULL; } -#else +# else + pthread_mutexattr_t attr; + CRYPTO_RWLOCK *lock = OPENSSL_zalloc(sizeof(pthread_mutex_t)); if (lock == NULL) return NULL; - pthread_mutexattr_t attr; pthread_mutexattr_init(&attr); pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE); - + if (pthread_mutex_init(lock, &attr) != 0) { pthread_mutexattr_destroy(&attr); OPENSSL_free(lock); return NULL; } - + pthread_mutexattr_destroy(&attr); -#endif +# endif return lock; } int CRYPTO_THREAD_read_lock(CRYPTO_RWLOCK *lock) { -#ifdef OPENSSL_THREADS_HAVE_PTHREAD_RWLOCK +# ifdef USE_RWLOCK if (pthread_rwlock_rdlock(lock) != 0) return 0; -#else +# else if (pthread_mutex_lock(lock) != 0) return 0; -#endif +# endif return 1; } int CRYPTO_THREAD_write_lock(CRYPTO_RWLOCK *lock) { -#ifdef OPENSSL_THREADS_HAVE_PTHREAD_RWLOCK +# ifdef USE_RWLOCK if (pthread_rwlock_wrlock(lock) != 0) return 0; -#else +# else if (pthread_mutex_lock(lock) != 0) return 0; -#endif +# endif return 1; } int CRYPTO_THREAD_unlock(CRYPTO_RWLOCK *lock) { -#ifdef OPENSSL_THREADS_HAVE_PTHREAD_RWLOCK +# ifdef USE_RWLOCK if (pthread_rwlock_unlock(lock) != 0) return 0; -#else +# else if (pthread_mutex_unlock(lock) != 0) return 0; -#endif +# endif return 1; } @@ -91,11 +92,11 @@ void CRYPTO_THREAD_lock_free(CRYPTO_RWLOCK *lock) if (lock == NULL) return; -#ifdef OPENSSL_THREADS_HAVE_PTHREAD_RWLOCK +# ifdef USE_RWLOCK pthread_rwlock_destroy(lock); -#else +# else pthread_mutex_destroy(lock); -#endif +# endif OPENSSL_free(lock); return;