GithubStar/MMKV
1
0
Fork 0
mirror of https://github.com/Tencent/MMKV.git synced 2026-10-17 04:30:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

Harden MMKV close lifecycle handling #1669

Browse Source
This commit is contained in:
guoling
2026-07-29 14:56:48 +08:00
parent f3b27766a2
commit 4e3535f2c8
27 changed files with 316 additions and 73 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Core/ThreadLock.cpp
+29 -5
View File
@@ -38,28 +38,52 @@ ThreadLock::ThreadLock() : m_lock({}) {
}
ThreadLock::~ThreadLock() {
pthread_mutex_unlock(&m_lock);
while (m_lockCount > 0) {
auto ret = pthread_mutex_unlock(&m_lock);
if (ret != 0) {
MMKVError("fail to unlock %p while destroying, ret=%d, error=%s",
&m_lock, ret, strerror(ret));
break;
}
--m_lockCount;
}
pthread_mutex_destroy(&m_lock);
auto ret = pthread_mutex_destroy(&m_lock);
if (ret != 0) {
MMKVError("fail to destroy %p, ret=%d, error=%s", &m_lock, ret, strerror(ret));
}
}
void ThreadLock::lock() {
auto ret = pthread_mutex_lock(&m_lock);
if (ret != 0) {
MMKVError("fail to lock %p, ret=%d, errno=%s", &m_lock, ret, strerror(errno));
MMKVError("fail to lock %p, ret=%d, error=%s", &m_lock, ret, strerror(ret));
return;
}
++m_lockCount;
}
void ThreadLock::unlock() {
if (m_lockCount == 0) {
MMKVError("attempt to unlock unowned lock %p", &m_lock);
return;
}
--m_lockCount;
auto ret = pthread_mutex_unlock(&m_lock);
if (ret != 0) {
MMKVError("fail to unlock %p, ret=%d, errno=%s", &m_lock, ret, strerror(errno));
++m_lockCount;
MMKVError("fail to unlock %p, ret=%d, error=%s", &m_lock, ret, strerror(ret));
return;
}
}
bool ThreadLock::try_lock() {
auto ret = pthread_mutex_trylock(&m_lock);
return (ret == 0);
if (ret == 0) {
++m_lockCount;
return true;
}
return false;
}
void ThreadLock::initialize() {