From e523d3d6a4079f4ee598da44ca002fc2b98f771f Mon Sep 17 00:00:00 2001 From: kailixu Date: Tue, 26 Sep 2023 14:34:42 +0800 Subject: [PATCH] chore: remove obsolete codes --- source/dnode/mgmt/node_mgmt/src/dmMgmt.c | 98 ------------------------ 1 file changed, 98 deletions(-) diff --git a/source/dnode/mgmt/node_mgmt/src/dmMgmt.c b/source/dnode/mgmt/node_mgmt/src/dmMgmt.c index 233c28a29a..15697dc448 100644 --- a/source/dnode/mgmt/node_mgmt/src/dmMgmt.c +++ b/source/dnode/mgmt/node_mgmt/src/dmMgmt.c @@ -24,90 +24,6 @@ #include "tcompression.h" #endif -#if 0 -static bool dmRequireNode(SDnode *pDnode, SMgmtWrapper *pWrapper) { - SMgmtInputOpt input = dmBuildMgmtInputOpt(pWrapper); - - bool required = false; - int32_t code = (*pWrapper->func.requiredFp)(&input, &required); - if (!required) { - dDebug("node:%s, does not require startup", pWrapper->name); - } else { - dDebug("node:%s, required to startup", pWrapper->name); - } - - return required; -} - -static int32_t dmInitVars(SDnode *pDnode) { - SDnodeData *pData = &pDnode->data; - pData->dnodeId = 0; - pData->clusterId = 0; - pData->dnodeVer = 0; - pData->updateTime = 0; - pData->rebootTime = taosGetTimestampMs(); - pData->dropped = 0; - pData->stopped = 0; - - pData->dnodeHash = taosHashInit(4, taosGetDefaultHashFunction(TSDB_DATA_TYPE_INT), true, HASH_NO_LOCK); - if (pData->dnodeHash == NULL) { - dError("failed to init dnode hash"); - terrno = TSDB_CODE_OUT_OF_MEMORY; - return -1; - } - - if (dmReadEps(pData) != 0) { - dError("failed to read file since %s", terrstr()); - return -1; - } - - if (pData->dropped) { - dError("dnode will not start since its already dropped"); - return -1; - } - - taosThreadRwlockInit(&pData->lock, NULL); - taosThreadMutexInit(&pDnode->mutex, NULL); - return 0; -} - -static void dmClearVars(SDnode *pDnode) { - for (EDndNodeType ntype = DNODE; ntype < NODE_END; ++ntype) { - SMgmtWrapper *pWrapper = &pDnode->wrappers[ntype]; - taosMemoryFreeClear(pWrapper->path); - taosThreadRwlockDestroy(&pWrapper->lock); - } - if (pDnode->lockfile != NULL) { - taosUnLockFile(pDnode->lockfile); - taosCloseFile(&pDnode->lockfile); - pDnode->lockfile = NULL; - } - - SDnodeData *pData = &pDnode->data; - taosThreadRwlockWrlock(&pData->lock); - if (pData->oldDnodeEps != NULL) { - if (dmWriteEps(pData) == 0) { - dmRemoveDnodePairs(pData); - } - taosArrayDestroy(pData->oldDnodeEps); - pData->oldDnodeEps = NULL; - } - if (pData->dnodeEps != NULL) { - taosArrayDestroy(pData->dnodeEps); - pData->dnodeEps = NULL; - } - if (pData->dnodeHash != NULL) { - taosHashCleanup(pData->dnodeHash); - pData->dnodeHash = NULL; - } - taosThreadRwlockUnlock(&pData->lock); - - taosThreadRwlockDestroy(&pData->lock); - taosThreadMutexDestroy(&pDnode->mutex); - memset(&pDnode->mutex, 0, sizeof(pDnode->mutex)); -} -#endif - int32_t dmInitDnode(SDnode *pDnode) { dDebug("start to create dnode"); int32_t code = -1; @@ -145,25 +61,11 @@ int32_t dmInitDnode(SDnode *pDnode) { pWrapper->required = dmRequireNode(pDnode, pWrapper); } - // if (dmInitMsgHandle(pDnode) != 0) { - // dError("failed to init msg handles since %s", terrstr()); - // goto _OVER; - // } - pDnode->lockfile = dmCheckRunning(tsDataDir); if (pDnode->lockfile == NULL) { goto _OVER; } - // if (dmInitServer(pDnode) != 0) { - // dError("failed to init transport since %s", terrstr()); - // goto _OVER; - // } - - // if (dmInitClient(pDnode) != 0) { - // goto _OVER; - // } - if(dmInitModule(pDnode) != 0) { goto _OVER; }