This commit is contained in:
Shengliang Guan 2022-03-17 15:36:30 +08:00
parent 86b947af3b
commit 0f6e5e01e1
2 changed files with 1 additions and 2 deletions

View File

@ -41,7 +41,6 @@ void dndProcessStartupReq(SDnode *pDnode, SRpcMsg *pMsg);
void dndProcessRpcMsg(SMgmtWrapper *pWrapper, SRpcMsg *pMsg, SEpSet *pEpSet); void dndProcessRpcMsg(SMgmtWrapper *pWrapper, SRpcMsg *pMsg, SEpSet *pEpSet);
// dndExec.c // dndExec.c
bool dndRequireNode(SMgmtWrapper *pWrapper);
int32_t dndOpenNode(SMgmtWrapper *pWrapper); int32_t dndOpenNode(SMgmtWrapper *pWrapper);
void dndCloseNode(SMgmtWrapper *pWrapper); void dndCloseNode(SMgmtWrapper *pWrapper);
int32_t dndRun(SDnode *pDnode); int32_t dndRun(SDnode *pDnode);

View File

@ -25,7 +25,7 @@ static void dndResetLog(SMgmtWrapper *pMgmt) {
taosInitLog(logname, 1); taosInitLog(logname, 1);
} }
bool dndRequireNode(SMgmtWrapper *pMgmt) { static bool dndRequireNode(SMgmtWrapper *pMgmt) {
bool required = (*pMgmt->fp.requiredFp)(pMgmt); bool required = (*pMgmt->fp.requiredFp)(pMgmt);
if (!required) { if (!required) {
dDebug("node:%s, no need to start", pMgmt->name); dDebug("node:%s, no need to start", pMgmt->name);