kcat/openal-soft
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Remove unused almtx stuff

Browse Source
This commit is contained in:
Chris Robinson 2018-11-26 22:36:55 -08:00
parent 2d45ec8dc3
commit 4c1fc3ae00
2 changed files with 2 additions and 157 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
common/threads.cpp
View File

@ -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)

101
common/threads.h
View File

@ -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 */