GitHub/paho.mqtt-sn.embedded-c
1
0
Fork 0
mirror of https://github.com/eclipse/paho.mqtt-sn.embedded-c.git synced 2025-12-12 23:16:51 +01:00
Code Issues Projects Releases Wiki Activity

waste removal

Browse Source 
Signed-off-by: tomoaki <tomoaki@tomy-tech.com>e
This commit is contained in:
tomoaki
2021-05-16 15:45:38 +09:00
parent dc3142f2f0
commit ae0cc2ec61
1 changed files with 16 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
MQTTSNGateway/src/linux/Threading.cpp
View File

@@ -121,44 +121,37 @@ Mutex::~Mutex(void)
void Mutex::lock(void)
{
int rc = 0;
if (_pmutex)
{
pthread_mutex_lock(_pmutex);
rc = pthread_mutex_lock(_pmutex);
}
else
{
try
{
if (pthread_mutex_lock(&_mutex))
{
throw Exception("Mutex lock error", errno);
}
} catch (char* errmsg)
{
throw Exception("The same thread can't acquire a mutex twice", errno);
}
rc = pthread_mutex_lock(&_mutex);
}
if (rc)
{
throw Exception("Mutex lock error", errno);
}
}
void Mutex::unlock(void)
{
int rc = 0;
if (_pmutex)
{
pthread_mutex_unlock(_pmutex);
rc = pthread_mutex_unlock(_pmutex);
}
else
{
try
{
if (pthread_mutex_unlock(&_mutex))
{
throw Exception("Mutex unlock error", errno);
}
} catch (char* errmsg)
{
throw Exception("Mutex can't unlock.", -1);
}
rc = pthread_mutex_unlock(&_mutex);
}
if (rc)
{
throw Exception("Mutex lock error", errno);
}
}