From 89a19fdbe19a9e4d11e938a6707e69a1d95248e4 Mon Sep 17 00:00:00 2001 From: Shengliang Guan Date: Mon, 1 Nov 2021 20:22:16 +0800 Subject: [PATCH] fix compile errors --- source/dnode/mgmt/inc/dnodeDnode.h | 4 ++-- source/dnode/mgmt/inc/dnodeVnodes.h | 4 ++-- source/dnode/mgmt/src/dnodeConfig.c | 2 +- source/dnode/mgmt/src/dnodeDnode.c | 26 +++++++++++++------------- source/dnode/mgmt/src/dnodeInt.c | 24 ++++++++++++------------ 5 files changed, 30 insertions(+), 30 deletions(-) diff --git a/source/dnode/mgmt/inc/dnodeDnode.h b/source/dnode/mgmt/inc/dnodeDnode.h index 35f68f0306..b126b39d1c 100644 --- a/source/dnode/mgmt/inc/dnodeDnode.h +++ b/source/dnode/mgmt/inc/dnodeDnode.h @@ -21,8 +21,8 @@ extern "C" { #endif #include "dnodeInt.h" -int32_t dnodeInitMsg(); -void dnodeCleanupMsg(); +int32_t dnodeInitDnode(); +void dnodeCleanupDnode(); void dnodeProcessStatusRsp(SRpcMsg *pMsg); void dnodeProcessStartupReq(SRpcMsg *pMsg); void dnodeProcessConfigDnodeReq(SRpcMsg *pMsg); diff --git a/source/dnode/mgmt/inc/dnodeVnodes.h b/source/dnode/mgmt/inc/dnodeVnodes.h index d54fda654a..33848042bd 100644 --- a/source/dnode/mgmt/inc/dnodeVnodes.h +++ b/source/dnode/mgmt/inc/dnodeVnodes.h @@ -21,8 +21,8 @@ extern "C" { #endif #include "dnodeInt.h" -int32_t dnodeInitMsg(); -void dnodeCleanupMsg(); +int32_t dnodeInitDnode(); +void dnodeCleanupDnode(); void dnodeProcessStatusRsp(SRpcMsg *pMsg); void dnodeProcessStartupReq(SRpcMsg *pMsg); void dnodeProcessCreateMnodeReq(SRpcMsg *pMsg); diff --git a/source/dnode/mgmt/src/dnodeConfig.c b/source/dnode/mgmt/src/dnodeConfig.c index d6189eb632..2a0374ffaf 100644 --- a/source/dnode/mgmt/src/dnodeConfig.c +++ b/source/dnode/mgmt/src/dnodeConfig.c @@ -30,7 +30,7 @@ static struct { pthread_mutex_t mutex; } tsConfig; -vstaticoid dnodeGetEpSetForPeer(SRpcEpSet *epSet) { +void dnodeGetEpSetForPeer(SRpcEpSet *epSet) { pthread_mutex_lock(&tsConfig.mutex); *epSet = tsConfig.mnodeEpSetForPeer; pthread_mutex_unlock(&tsConfig.mutex); diff --git a/source/dnode/mgmt/src/dnodeDnode.c b/source/dnode/mgmt/src/dnodeDnode.c index 0a598527b4..3c6a743e05 100644 --- a/source/dnode/mgmt/src/dnodeDnode.c +++ b/source/dnode/mgmt/src/dnodeDnode.c @@ -25,7 +25,7 @@ static struct { pthread_t *threadId; bool stop; uint32_t rebootTime; -} tsMsg; +} tsDnode; static void dnodeSendStatusMsg() { int32_t contLen = sizeof(SStatusMsg) + TSDB_MAX_VNODES * sizeof(SVnodeLoad); @@ -39,7 +39,7 @@ static void dnodeSendStatusMsg() { pStatus->dnodeId = htonl(dnodeGetDnodeId()); tstrncpy(pStatus->dnodeEp, tsLocalEp, TSDB_EP_LEN); pStatus->clusterId = htobe64(dnodeGetClusterId()); - pStatus->lastReboot = htonl(tsMsg.rebootTime); + pStatus->lastReboot = htonl(tsDnode.rebootTime); pStatus->numOfCores = htonl(tsNumOfCores); pStatus->diskAvailable = tsAvailDataDirGB; @@ -93,17 +93,17 @@ void dnodeProcessStatusRsp(SRpcMsg *pMsg) { static void *dnodeThreadRoutine(void *param) { int32_t ms = tsStatusInterval * 1000; - while (!tsMsg.stop) { + while (!tsDnode.stop) { taosMsleep(ms); dnodeSendStatusMsg(); } } -int32_t dnodeInitMsg() { - tsMsg.stop = false; - tsMsg.rebootTime = taosGetTimestampSec(); - tsMsg.threadId = taosCreateThread(dnodeThreadRoutine, NULL); - if (tsMsg.threadId == NULL) { +int32_t dnodeInitDnode() { + tsDnode.stop = false; + tsDnode.rebootTime = taosGetTimestampSec(); + tsDnode.threadId = taosCreateThread(dnodeThreadRoutine, NULL); + if (tsDnode.threadId == NULL) { return -1; } @@ -111,11 +111,11 @@ int32_t dnodeInitMsg() { return 0; } -void dnodeCleanupMsg() { - if (tsMsg.threadId != NULL) { - tsMsg.stop = true; - taosDestoryThread(tsMsg.threadId); - tsMsg.threadId = NULL; +void dnodeCleanupDnode() { + if (tsDnode.threadId != NULL) { + tsDnode.stop = true; + taosDestoryThread(tsDnode.threadId); + tsDnode.threadId = NULL; } dInfo("dnode msg is cleanuped"); diff --git a/source/dnode/mgmt/src/dnodeInt.c b/source/dnode/mgmt/src/dnodeInt.c index de1d03ae7a..6368fe95f7 100644 --- a/source/dnode/mgmt/src/dnodeInt.c +++ b/source/dnode/mgmt/src/dnodeInt.c @@ -31,27 +31,27 @@ static struct { EDnStat runStatus; SStartupStep startup; SSteps *steps; -} tsDnode; +} tsInt; -EDnStat dnodeGetRunStat() { return tsDnode.runStatus; } +EDnStat dnodeGetRunStat() { return tsInt.runStatus; } -void dnodeSetRunStat(EDnStat stat) { tsDnode.runStatus = stat; } +void dnodeSetRunStat(EDnStat stat) { tsInt.runStatus = stat; } void dnodeReportStartup(char *name, char *desc) { - SStartupStep *startup = &tsDnode.startup; + SStartupStep *startup = &tsInt.startup; tstrncpy(startup->name, name, strlen(startup->name)); tstrncpy(startup->desc, desc, strlen(startup->desc)); startup->finished = 0; } static void dnodeReportStartupFinished(char *name, char *desc) { - SStartupStep *startup = &tsDnode.startup; + SStartupStep *startup = &tsInt.startup; tstrncpy(startup->name, name, strlen(startup->name)); tstrncpy(startup->desc, desc, strlen(startup->desc)); startup->finished = 1; } -void dnodeGetStartup(SStartupStep *pStep) { memcpy(pStep, &tsDnode.startup, sizeof(SStartupStep)); } +void dnodeGetStartup(SStartupStep *pStep) { memcpy(pStep, &tsInt.startup, sizeof(SStartupStep)); } static int32_t dnodeInitVnode() { return vnodeInit(); @@ -72,7 +72,7 @@ static int32_t dnodeInitMnode() { static int32_t dnodeInitTfs() {} static int32_t dnodeInitMain() { - tsDnode.runStatus = DN_RUN_STAT_STOPPED; + tsInt.runStatus = DN_RUN_STAT_STOPPED; tscEmbedded = 1; taosIgnSIGPIPE(); taosBlockSIGPIPE(); @@ -175,10 +175,10 @@ int32_t dnodeInit() { taosStepAdd(steps, "dnode-vnode", dnodeInitVnode, vnodeCleanup); taosStepAdd(steps, "dnode-mnode", dnodeInitMnode, mnodeCleanup); taosStepAdd(steps, "dnode-trans", dnodeInitTrans, dnodeCleanupTrans); - taosStepAdd(steps, "dnode-msg", dnodeInitMsg, dnodeCleanupMsg); + taosStepAdd(steps, "dnode-msg", dnodeInitDnode, dnodeCleanupDnode); - tsDnode.steps = steps; - taosStepExec(tsDnode.steps); + tsInt.steps = steps; + taosStepExec(tsInt.steps); dnodeSetRunStat(DN_RUN_STAT_RUNNING); dnodeReportStartupFinished("TDengine", "initialized successfully"); @@ -190,8 +190,8 @@ int32_t dnodeInit() { void dnodeCleanup() { if (dnodeGetRunStat() != DN_RUN_STAT_STOPPED) { dnodeSetRunStat(DN_RUN_STAT_STOPPED); - taosStepCleanup(tsDnode.steps); - tsDnode.steps = NULL; + taosStepCleanup(tsInt.steps); + tsInt.steps = NULL; } } -- GitLab