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

fix:[TS-4921]refactor reporting logic for slow log

This commit is contained in:
wangmm0220 2024-07-02 16:19:02 +08:00
parent a410f4bb05
commit d3fcab5c0d
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
source/client/src/clientMonitor.c
View File

@ -427,7 +427,7 @@ static char* readFile(TdFilePtr pFile, int64_t *offset, int64_t size){
*offset += (len+1); *offset += (len+1);
} }
uDebug("[monitor] monitorReadSendSlowLog slow log:%s", pCont); uDebug("[monitor] readFile slow log:%s", pCont);
return pCont; return pCont;
} }
@ -693,6 +693,9 @@ static void* monitorThreadFunc(void *param){
if (slowLogFlag > 0) { if (slowLogFlag > 0) {
if(quitCnt == 0){ if(quitCnt == 0){
monitorSendAllSlowLogAtQuit(); monitorSendAllSlowLogAtQuit();
if(quitCnt == 0){
break;
}
quitTime = taosGetMonoTimestampMs(); quitTime = taosGetMonoTimestampMs();
} }
if(taosGetMonoTimestampMs() - quitTime > 500){ //quit at most 500ms if(taosGetMonoTimestampMs() - quitTime > 500){ //quit at most 500ms
@ -726,7 +729,9 @@ static void* monitorThreadFunc(void *param){
monitorFreeSlowLogData(slowLogData); monitorFreeSlowLogData(slowLogData);
taosFreeQitem(slowLogData); taosFreeQitem(slowLogData);
if (quitCnt == 0) {
monitorSendAllSlowLog(); monitorSendAllSlowLog();
}
tsem2_timewait(&monitorSem, 100); tsem2_timewait(&monitorSem, 100);
} }