aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorChris Robinson <[email protected]>2018-11-26 22:36:55 -0800
committerChris Robinson <[email protected]>2018-11-26 22:36:55 -0800
commit4c1fc3ae00ad4890708a8789539eea4556b0634c (patch)
tree129c6d28d716fdb3ee8bb9640cfad2d7a6bcfb6c
parent2d45ec8dc360cbdf9f813db0b8286d8e11a432d9 (diff)
Remove unused almtx stuff
-rw-r--r--common/threads.cpp58
-rw-r--r--common/threads.h101
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 */