From 0922b28123b20270bab2912e2cf92d6496d7d121 Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Sun, 15 Dec 2024 12:16:24 +0800
Subject: [PATCH] update test case

---
 source/client/src/clientEnv.c               | 7 ++++++-
 source/dnode/mgmt/mgmt_dnode/src/dmWorker.c | 7 ++++++-
 source/dnode/mnode/impl/src/mndTelem.c      | 6 +++++-
 3 files changed, 17 insertions(+), 3 deletions(-)

diff --git a/source/client/src/clientEnv.c b/source/client/src/clientEnv.c
index 59eb2f88bc..2422a69870 100644
--- a/source/client/src/clientEnv.c
+++ b/source/client/src/clientEnv.c
@@ -797,6 +797,7 @@ void stopAllQueries(SRequestObj *pRequest) {
 void crashReportThreadFuncUnexpectedStopped(void) { atomic_store_32(&clientStop, -1); }
 
 static void *tscCrashReportThreadFp(void *param) {
+  int32_t code = 0;
   setThreadName("client-crashReport");
   char filepath[PATH_MAX] = {0};
   (void)snprintf(filepath, sizeof(filepath), "%s%s.taosCrashLog", tsLogDir, TD_DIRSEP);
@@ -818,7 +819,11 @@ static void *tscCrashReportThreadFp(void *param) {
     return NULL;
   }
   STelemAddrMgmt mgt;
-  taosTelemetryMgtInit(&mgt, tsTelemServer);
+  code = taosTelemetryMgtInit(&mgt, tsTelemServer);
+  if (code) {
+    tscError("failed to init telemetry management, code:%s", tstrerror(code));
+    return NULL;
+  }
 
   while (1) {
     if (clientStop > 0) break;
diff --git a/source/dnode/mgmt/mgmt_dnode/src/dmWorker.c b/source/dnode/mgmt/mgmt_dnode/src/dmWorker.c
index 2d6d5b59f3..7e2935dbc6 100644
--- a/source/dnode/mgmt/mgmt_dnode/src/dmWorker.c
+++ b/source/dnode/mgmt/mgmt_dnode/src/dmWorker.c
@@ -232,6 +232,7 @@ static void *dmAuditThreadFp(void *param) {
 }
 
 static void *dmCrashReportThreadFp(void *param) {
+  int32_t     code = 0;
   SDnodeMgmt *pMgmt = param;
   int64_t     lastTime = taosGetTimestampMs();
   setThreadName("dnode-crashReport");
@@ -246,7 +247,11 @@ static void *dmCrashReportThreadFp(void *param) {
   int32_t   loopTimes = reportPeriodNum;
 
   STelemAddrMgmt mgt = {0};
-  taosTelemetryMgtInit(&mgt, tsTelemServer);
+  code = taosTelemetryMgtInit(&mgt, tsTelemServer);
+  if (code != 0) {
+    dError("failed to init telemetry since %s", tstrerror(code));
+    return NULL;
+  }
 
   while (1) {
     if (pMgmt->pData->dropped || pMgmt->pData->stopped) break;
diff --git a/source/dnode/mnode/impl/src/mndTelem.c b/source/dnode/mnode/impl/src/mndTelem.c
index 21133ff50d..bd613d7e69 100644
--- a/source/dnode/mnode/impl/src/mndTelem.c
+++ b/source/dnode/mnode/impl/src/mndTelem.c
@@ -163,7 +163,11 @@ int32_t mndInitTelem(SMnode* pMnode) {
   (void)taosThreadMutexInit(&pMgmt->lock, NULL);
   if ((code = taosGetEmail(pMgmt->email, sizeof(pMgmt->email))) != 0)
     mWarn("failed to get email since %s", tstrerror(code));
-  taosTelemetryMgtInit(&pMgmt->addrMgt, tsTelemServer);
+  code = taosTelemetryMgtInit(&pMgmt->addrMgt, tsTelemServer);
+  if (code != 0) {
+    mError("failed to init telemetry management since %s", tstrerror(code));
+    return code;
+  }
   mndSetMsgHandle(pMnode, TDMT_MND_TELEM_TIMER, mndProcessTelemTimer);
 
   return 0;