#if defined(OPENSSL_THREADS) && !defined(CRYPTO_TDEBUG) && !defined(OPENSSL_SYS_WINDOWS)
+# ifdef PTHREAD_RWLOCK_INITIALIZER
+# define USE_RWLOCK
+# endif
+
CRYPTO_RWLOCK *CRYPTO_THREAD_lock_new(void)
{
+# ifdef USE_RWLOCK
CRYPTO_RWLOCK *lock = OPENSSL_zalloc(sizeof(pthread_rwlock_t));
if (lock == NULL)
return NULL;
OPENSSL_free(lock);
return NULL;
}
+# else
+ pthread_mutexattr_t attr;
+ CRYPTO_RWLOCK *lock = OPENSSL_zalloc(sizeof(pthread_mutex_t));
+ if (lock == NULL)
+ return NULL;
+
+ 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
return lock;
}
int CRYPTO_THREAD_read_lock(CRYPTO_RWLOCK *lock)
{
+# ifdef USE_RWLOCK
if (pthread_rwlock_rdlock(lock) != 0)
return 0;
+# else
+ if (pthread_mutex_lock(lock) != 0)
+ return 0;
+# endif
return 1;
}
int CRYPTO_THREAD_write_lock(CRYPTO_RWLOCK *lock)
{
+# ifdef USE_RWLOCK
if (pthread_rwlock_wrlock(lock) != 0)
return 0;
+# else
+ if (pthread_mutex_lock(lock) != 0)
+ return 0;
+# endif
return 1;
}
int CRYPTO_THREAD_unlock(CRYPTO_RWLOCK *lock)
{
+# ifdef USE_RWLOCK
if (pthread_rwlock_unlock(lock) != 0)
return 0;
+# else
+ if (pthread_mutex_unlock(lock) != 0)
+ return 0;
+# endif
return 1;
}
if (lock == NULL)
return;
+# ifdef USE_RWLOCK
pthread_rwlock_destroy(lock);
+# else
+ pthread_mutex_destroy(lock);
+# endif
OPENSSL_free(lock);
return;
int CRYPTO_atomic_add(int *val, int amount, int *ret, CRYPTO_RWLOCK *lock)
{
# if defined(__GNUC__) && defined(__ATOMIC_ACQ_REL)
- *ret = __atomic_add_fetch(val, amount, __ATOMIC_ACQ_REL);
-# else
+ if (__atomic_is_lock_free(sizeof(*val), val)) {
+ *ret = __atomic_add_fetch(val, amount, __ATOMIC_ACQ_REL);
+ return 1;
+ }
+# endif
if (!CRYPTO_THREAD_write_lock(lock))
return 0;
if (!CRYPTO_THREAD_unlock(lock))
return 0;
-# endif
return 1;
}