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

enh: avoid invalid access of log file handle

This commit is contained in:
kailixu 2024-11-14 10:00:07 +08:00
parent a546250239
commit 2028db3623
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/util/src/tlog.c
View File

@ -374,7 +374,7 @@ static OldFileKeeper *taosOpenNewFile() {
} }
TdFilePtr pOldFile = tsLogObj.logHandle->pFile; TdFilePtr pOldFile = tsLogObj.logHandle->pFile;
tsLogObj.logHandle->pFile = pFile; atomic_store_ptr(&tsLogObj.logHandle->pFile, pFile);
tsLogObj.lines = 0; tsLogObj.lines = 0;
tsLogObj.openInProgress = 0; tsLogObj.openInProgress = 0;
OldFileKeeper *oldFileKeeper = taosMemoryMalloc(sizeof(OldFileKeeper)); OldFileKeeper *oldFileKeeper = taosMemoryMalloc(sizeof(OldFileKeeper));
@ -666,7 +666,7 @@ static inline void taosPrintLogImp(ELogLevel level, int32_t dflag, const char *b
if (tsAsyncLog) { if (tsAsyncLog) {
TAOS_UNUSED(taosPushLogBuffer(tsLogObj.logHandle, buffer, len)); TAOS_UNUSED(taosPushLogBuffer(tsLogObj.logHandle, buffer, len));
} else { } else {
TAOS_UNUSED(taosWriteFile(tsLogObj.logHandle->pFile, buffer, len)); TAOS_UNUSED(taosWriteFile(atomic_load_ptr(tsLogObj.logHandle->pFile), buffer, len));
} }
if (tsNumOfLogLines > 0) { if (tsNumOfLogLines > 0) {