From 4b03091501e6fb612f60dde03e52e87b8300abb6 Mon Sep 17 00:00:00 2001 From: factosea <285808407@qq.com> Date: Fri, 10 Jan 2025 07:11:36 +0800 Subject: [PATCH] enh: crash thread --- source/util/src/tlog.c | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/source/util/src/tlog.c b/source/util/src/tlog.c index 2adf6601e3..fb625d7933 100644 --- a/source/util/src/tlog.c +++ b/source/util/src/tlog.c @@ -1295,6 +1295,7 @@ typedef struct crashBasicInfo { int signum; void *sigInfo; tsem_t sem; + int64_t reportThread; } crashBasicInfo; crashBasicInfo gCrashBasicInfo = {0}; @@ -1359,11 +1360,15 @@ int32_t initCrashLogWriter() { uError("failed to init sem for crashLogWriter, code:%d", code); return code; } + gCrashBasicInfo.reportThread = taosGetSelfPthreadId(); setCrashWriterStatus(CRASH_LOG_WRITER_INIT); return code; } void writeCrashLogToFile(int signum, void *sigInfo, char *nodeType, int64_t clusterId, int64_t startTime) { + if (gCrashBasicInfo.reportThread == taosGetSelfPthreadId()) { + return; + } if (setReportThreadWait()) { gCrashBasicInfo.clusterId = clusterId; gCrashBasicInfo.startTime = startTime;