This commit is contained in:
dmchen 2024-07-29 06:45:12 +00:00
parent 863ec7b558
commit bc62678992
1 changed files with 3 additions and 1 deletions

View File

@ -142,10 +142,12 @@ static int32_t mndProcessTelemTimer(SRpcMsg* pReq) {
}
int32_t mndInitTelem(SMnode* pMnode) {
int32_t code = 0;
STelemMgmt* pMgmt = &pMnode->telemMgmt;
(void)taosThreadMutexInit(&pMgmt->lock, NULL);
TAOS_CHECK_RETURN(taosGetEmail(pMgmt->email, sizeof(pMgmt->email)));
if ((code = taosGetEmail(pMgmt->email, sizeof(pMgmt->email))) != 0)
mWarn("failed to get email since %s", tstrerror(code));
mndSetMsgHandle(pMnode, TDMT_MND_TELEM_TIMER, mndProcessTelemTimer);
return 0;