xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

set wr lock to write priority

This commit is contained in:
xiao-77 2024-09-14 15:59:01 +08:00
parent 1bbcb7c980
commit 0a19bc974b
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
source/libs/wal/src/walMgmt.c
View File

@ -81,6 +81,15 @@ void walCleanUp() {
}
}
static int32_t walInitLock(SWal *pWal) {
TdThreadRwlockAttr attr;
(void)taosThreadRwlockAttrInit(&attr);
(void)taosThreadRwlockAttrSetKindNP(&attr, PTHREAD_RWLOCK_PREFER_WRITER_NONRECURSIVE_NP);
(void)taosThreadRwlockInit(&pWal->mutex, &attr);
(void)taosThreadRwlockAttrDestroy(&attr);
return 0;
}
SWal *walOpen(const char *path, SWalCfg *pCfg) {
SWal *pWal = taosMemoryCalloc(1, sizeof(SWal));
if (pWal == NULL) {
@ -88,7 +97,7 @@ SWal *walOpen(const char *path, SWalCfg *pCfg) {
return NULL;
}
if (taosThreadRwlockInit(&pWal->mutex, NULL) < 0) {
if (walInitLock(pWal) < 0) {
terrno = TAOS_SYSTEM_ERROR(errno);
taosMemoryFree(pWal);
return NULL;