123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171 |
- #if defined(_WIN32)
- # include <windows.h>
- #endif
- #include <openssl/crypto.h>
- #if defined(OPENSSL_THREADS) && !defined(CRYPTO_TDEBUG) && defined(OPENSSL_SYS_WINDOWS)
- CRYPTO_RWLOCK *CRYPTO_THREAD_lock_new(void)
- {
- CRYPTO_RWLOCK *lock;
- if ((lock = OPENSSL_zalloc(sizeof(CRITICAL_SECTION))) == NULL) {
-
- return NULL;
- }
- # if !defined(_WIN32_WCE)
-
- if (!InitializeCriticalSectionAndSpinCount(lock, 0x400)) {
- OPENSSL_free(lock);
- return NULL;
- }
- # else
- InitializeCriticalSection(lock);
- # endif
- return lock;
- }
- int CRYPTO_THREAD_read_lock(CRYPTO_RWLOCK *lock)
- {
- EnterCriticalSection(lock);
- return 1;
- }
- int CRYPTO_THREAD_write_lock(CRYPTO_RWLOCK *lock)
- {
- EnterCriticalSection(lock);
- return 1;
- }
- int CRYPTO_THREAD_unlock(CRYPTO_RWLOCK *lock)
- {
- LeaveCriticalSection(lock);
- return 1;
- }
- void CRYPTO_THREAD_lock_free(CRYPTO_RWLOCK *lock)
- {
- if (lock == NULL)
- return;
- DeleteCriticalSection(lock);
- OPENSSL_free(lock);
- return;
- }
- # define ONCE_UNINITED 0
- # define ONCE_ININIT 1
- # define ONCE_DONE 2
- int CRYPTO_THREAD_run_once(CRYPTO_ONCE *once, void (*init)(void))
- {
- LONG volatile *lock = (LONG *)once;
- LONG result;
- if (*lock == ONCE_DONE)
- return 1;
- do {
- result = InterlockedCompareExchange(lock, ONCE_ININIT, ONCE_UNINITED);
- if (result == ONCE_UNINITED) {
- init();
- *lock = ONCE_DONE;
- return 1;
- }
- } while (result == ONCE_ININIT);
- return (*lock == ONCE_DONE);
- }
- int CRYPTO_THREAD_init_local(CRYPTO_THREAD_LOCAL *key, void (*cleanup)(void *))
- {
- *key = TlsAlloc();
- if (*key == TLS_OUT_OF_INDEXES)
- return 0;
- return 1;
- }
- void *CRYPTO_THREAD_get_local(CRYPTO_THREAD_LOCAL *key)
- {
- DWORD last_error;
- void *ret;
-
- last_error = GetLastError();
- ret = TlsGetValue(*key);
- SetLastError(last_error);
- return ret;
- }
- int CRYPTO_THREAD_set_local(CRYPTO_THREAD_LOCAL *key, void *val)
- {
- if (TlsSetValue(*key, val) == 0)
- return 0;
- return 1;
- }
- int CRYPTO_THREAD_cleanup_local(CRYPTO_THREAD_LOCAL *key)
- {
- if (TlsFree(*key) == 0)
- return 0;
- return 1;
- }
- CRYPTO_THREAD_ID CRYPTO_THREAD_get_current_id(void)
- {
- return GetCurrentThreadId();
- }
- int CRYPTO_THREAD_compare_id(CRYPTO_THREAD_ID a, CRYPTO_THREAD_ID b)
- {
- return (a == b);
- }
- int CRYPTO_atomic_add(int *val, int amount, int *ret, CRYPTO_RWLOCK *lock)
- {
- *ret = (int)InterlockedExchangeAdd((long volatile *)val, (long)amount) + amount;
- return 1;
- }
- int openssl_init_fork_handlers(void)
- {
- return 0;
- }
- int openssl_get_fork_id(void)
- {
- return 0;
- }
- #endif
|