diff options
author | Chris Robinson <[email protected]> | 2018-11-26 22:36:55 -0800 |
---|---|---|
committer | Chris Robinson <[email protected]> | 2018-11-26 22:36:55 -0800 |
commit | 4c1fc3ae00ad4890708a8789539eea4556b0634c (patch) | |
tree | 129c6d28d716fdb3ee8bb9640cfad2d7a6bcfb6c | |
parent | 2d45ec8dc360cbdf9f813db0b8286d8e11a432d9 (diff) |
Remove unused almtx stuff
-rw-r--r-- | common/threads.cpp | 58 | ||||
-rw-r--r-- | common/threads.h | 101 |
2 files changed, 2 insertions, 157 deletions
diff --git a/common/threads.cpp b/common/threads.cpp index 489e5f5b..b4f471d7 100644 --- a/common/threads.cpp +++ b/common/threads.cpp @@ -78,24 +78,6 @@ void althrd_setname(const char *name) } -int almtx_init(almtx_t *mtx, int type) -{ - if(!mtx) return althrd_error; - - type &= ~almtx_recursive; - if(type != almtx_plain) - return althrd_error; - - InitializeCriticalSection(mtx); - return althrd_success; -} - -void almtx_destroy(almtx_t *mtx) -{ - DeleteCriticalSection(mtx); -} - - int alsem_init(alsem_t *sem, unsigned int initial) { *sem = CreateSemaphore(NULL, initial, INT_MAX, NULL); @@ -158,46 +140,6 @@ void althrd_setname(const char *name) } -int almtx_init(almtx_t *mtx, int type) -{ - int ret; - - if(!mtx) return althrd_error; - if((type&~almtx_recursive) != 0) - return althrd_error; - - if(type == almtx_plain) - ret = pthread_mutex_init(mtx, NULL); - else - { - pthread_mutexattr_t attr; - - ret = pthread_mutexattr_init(&attr); - if(ret) return althrd_error; - - if(type == almtx_recursive) - { - ret = pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE); -#ifdef HAVE_PTHREAD_MUTEXATTR_SETKIND_NP - if(ret != 0) - ret = pthread_mutexattr_setkind_np(&attr, PTHREAD_MUTEX_RECURSIVE); -#endif - } - else - ret = 1; - if(ret == 0) - ret = pthread_mutex_init(mtx, &attr); - pthread_mutexattr_destroy(&attr); - } - return ret ? althrd_error : althrd_success; -} - -void almtx_destroy(almtx_t *mtx) -{ - pthread_mutex_destroy(mtx); -} - - #ifdef __APPLE__ int alsem_init(alsem_t *sem, unsigned int initial) diff --git a/common/threads.h b/common/threads.h index 53b56147..064b8482 100644 --- a/common/threads.h +++ b/common/threads.h @@ -14,6 +14,8 @@ #endif #ifdef __cplusplus +#include <mutex> + extern "C" { #endif @@ -25,17 +27,11 @@ enum { althrd_busy }; -enum { - almtx_plain = 0, - almtx_recursive = 1, -}; - #ifdef _WIN32 #define WIN32_LEAN_AND_MEAN #include <windows.h> -typedef CRITICAL_SECTION almtx_t; typedef HANDLE alsem_t; @@ -44,21 +40,6 @@ inline void althrd_yield(void) SwitchToThread(); } - -inline int almtx_lock(almtx_t *mtx) -{ - if(!mtx) return althrd_error; - EnterCriticalSection(mtx); - return althrd_success; -} - -inline int almtx_unlock(almtx_t *mtx) -{ - if(!mtx) return althrd_error; - LeaveCriticalSection(mtx); - return althrd_success; -} - #else #include <stdint.h> @@ -70,7 +51,6 @@ inline int almtx_unlock(almtx_t *mtx) #include <semaphore.h> #endif /* __APPLE__ */ -typedef pthread_mutex_t almtx_t; #ifdef __APPLE__ typedef dispatch_semaphore_t alsem_t; #else /* !__APPLE__ */ @@ -84,27 +64,10 @@ inline void althrd_yield(void) } -inline int almtx_lock(almtx_t *mtx) -{ - if(pthread_mutex_lock(mtx) != 0) - return althrd_error; - return althrd_success; -} - -inline int almtx_unlock(almtx_t *mtx) -{ - if(pthread_mutex_unlock(mtx) != 0) - return althrd_error; - return althrd_success; -} - #endif void althrd_setname(const char *name); -int almtx_init(almtx_t *mtx, int type); -void almtx_destroy(almtx_t *mtx); - int alsem_init(alsem_t *sem, unsigned int initial); void alsem_destroy(alsem_t *sem); int alsem_post(alsem_t *sem); @@ -113,66 +76,6 @@ int alsem_trywait(alsem_t *sem); #ifdef __cplusplus } // extern "C" - -#include <mutex> - -/* Add specializations for std::lock_guard and std::unique_lock which take an - * almtx_t and call the appropriate almtx_* functions. - */ -namespace std { - -template<> -class lock_guard<almtx_t> { - almtx_t &mMtx; - -public: - using mutex_type = almtx_t; - - explicit lock_guard(almtx_t &mtx) : mMtx(mtx) { almtx_lock(&mMtx); } - lock_guard(almtx_t &mtx, std::adopt_lock_t) noexcept : mMtx(mtx) { } - ~lock_guard() { almtx_unlock(&mMtx); } - - lock_guard(const lock_guard&) = delete; - lock_guard& operator=(const lock_guard&) = delete; -}; - -template<> -class unique_lock<almtx_t> { - almtx_t *mMtx{nullptr}; - bool mLocked{false}; - -public: - using mutex_type = almtx_t; - - unique_lock() noexcept = default; - explicit unique_lock(almtx_t &mtx) : mMtx(&mtx) { almtx_lock(mMtx); mLocked = true; } - unique_lock(unique_lock&& rhs) noexcept : mMtx(rhs.mMtx), mLocked(rhs.mLocked) - { rhs.mMtx = nullptr; rhs.mLocked = false; } - ~unique_lock() { if(mLocked) almtx_unlock(mMtx); } - - unique_lock& operator=(const unique_lock&) = delete; - unique_lock& operator=(unique_lock&& rhs) - { - if(mLocked) - almtx_unlock(mMtx); - mMtx = rhs.mMtx; rhs.mMtx = nullptr; - mLocked = rhs.mLocked; rhs.mLocked = false; - return *this; - } - - void lock() - { - almtx_lock(mMtx); - mLocked = true; - } - void unlock() - { - mLocked = false; - almtx_unlock(mMtx); - } -}; - -} // namespace std #endif #endif /* AL_THREADS_H */ |