22 #include "JackPosixMutex.h"
23 #include "JackError.h"
28 JackBasePosixMutex::JackBasePosixMutex(
const char* name)
31 int res = pthread_mutex_init(&fMutex, NULL);
32 ThrowIf(res != 0, JackException(
"JackBasePosixMutex: could not init the mutex"));
35 JackBasePosixMutex::~JackBasePosixMutex()
37 pthread_mutex_destroy(&fMutex);
40 bool JackBasePosixMutex::Lock()
42 pthread_t current_thread = pthread_self();
44 if (!pthread_equal(current_thread, fOwner)) {
45 int res = pthread_mutex_lock(&fMutex);
47 fOwner = current_thread;
50 jack_error(
"JackBasePosixMutex::Lock res = %d", res);
54 jack_error(
"JackBasePosixMutex::Lock mutex already locked by thread = %d", current_thread);
59 bool JackBasePosixMutex::Trylock()
61 pthread_t current_thread = pthread_self();
63 if (!pthread_equal(current_thread, fOwner)) {
64 int res = pthread_mutex_trylock(&fMutex);
66 fOwner = current_thread;
72 jack_error(
"JackBasePosixMutex::Trylock mutex already locked by thread = %d", current_thread);
77 bool JackBasePosixMutex::Unlock()
79 if (pthread_equal(pthread_self(), fOwner)) {
81 int res = pthread_mutex_unlock(&fMutex);
85 jack_error(
"JackBasePosixMutex::Unlock res = %d", res);
89 jack_error(
"JackBasePosixMutex::Unlock mutex not locked by thread = %d owner %d", pthread_self(), fOwner);
94 JackPosixMutex::JackPosixMutex(
const char* name)
97 pthread_mutexattr_t mutex_attr;
99 res = pthread_mutexattr_init(&mutex_attr);
100 ThrowIf(res != 0, JackException(
"JackBasePosixMutex: could not init the mutex attribute"));
101 res = pthread_mutexattr_settype(&mutex_attr, PTHREAD_MUTEX_RECURSIVE);
102 ThrowIf(res != 0, JackException(
"JackBasePosixMutex: could not settype the mutex"));
103 res = pthread_mutex_init(&fMutex, &mutex_attr);
104 ThrowIf(res != 0, JackException(
"JackBasePosixMutex: could not init the mutex"));
105 pthread_mutexattr_destroy(&mutex_attr);
108 JackPosixMutex::~JackPosixMutex()
110 pthread_mutex_destroy(&fMutex);
113 bool JackPosixMutex::Lock()
115 int res = pthread_mutex_lock(&fMutex);
117 jack_log(
"JackPosixMutex::Lock res = %d", res);
122 bool JackPosixMutex::Trylock()
124 return (pthread_mutex_trylock(&fMutex) == 0);
127 bool JackPosixMutex::Unlock()
129 int res = pthread_mutex_unlock(&fMutex);
131 jack_log(
"JackPosixMutex::Unlock res = %d", res);
SERVER_EXPORT void jack_error(const char *fmt,...)
SERVER_EXPORT void jack_log(const char *fmt,...)