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

fix:[TS-4921] errors in test

This commit is contained in:
wangmm0220 2024-06-27 00:01:07 +08:00
parent 32ff8a7d99
commit a58ba79046
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -568,6 +568,7 @@ static void* monitorThreadFunc(void *param){
uError("open queue error since %s", terrstr()); uError("open queue error since %s", terrstr());
return NULL; return NULL;
} }
uDebug("monitorThreadFunc start");
while (1) { while (1) {
if (slowLogFlag > 0) break; if (slowLogFlag > 0) break;
@ -665,6 +666,9 @@ int32_t monitorPutData2MonitorQueue(int64_t clusterId, char* value){
slowLogData->clusterId = clusterId; slowLogData->clusterId = clusterId;
slowLogData->value = value; slowLogData->value = value;
uDebug("[monitor] write slow log to queue, clusterId:%"PRIx64 " value:%s", slowLogData->clusterId, slowLogData->value); uDebug("[monitor] write slow log to queue, clusterId:%"PRIx64 " value:%s", slowLogData->clusterId, slowLogData->value);
while (monitorQueue == NULL) {
taosMsleep(100);
}
if (taosWriteQitem(monitorQueue, slowLogData) == 0){ if (taosWriteQitem(monitorQueue, slowLogData) == 0){
tsem2_post(&monitorSem); tsem2_post(&monitorSem);
}else{ }else{