diff --git a/src/client/src/tscSystem.c b/src/client/src/tscSystem.c index 9dee3ee347c661a6f5fb5d97992cdd5459aadc38..d4072f43d688f8d884351d3313301bf6945d672b 100644 --- a/src/client/src/tscSystem.c +++ b/src/client/src/tscSystem.c @@ -124,11 +124,11 @@ void taos_init_imp(void) { } tscTmr = taosTmrInit(tsMaxConnections * 2, 200, 60000, "TSC"); - if (0 == tscEmbedded) { - taosTmrReset(tscCheckDiskUsage, 10, NULL, tscTmr, &tscCheckDiskUsageTmr); + if(0 == tscEmbedded){ + taosTmrReset(tscCheckDiskUsage, 10, NULL, tscTmr, &tscCheckDiskUsageTmr); } - int64_t refreshTime = 10; // 10 seconds by default + int64_t refreshTime = 10; // 10 seconds by default if (tscMetaCache == NULL) { tscMetaCache = taosCacheInit(TSDB_DATA_TYPE_BINARY, refreshTime, false, tscFreeTableMetaHelper, "tableMeta"); tscObjRef = taosOpenRef(40960, tscFreeRegisteredSqlObj); diff --git a/src/dnode/inc/dnodeStep.h b/src/dnode/inc/dnodeStep.h index 8b1065dfd8d4cf326995d3581cb8f07ee6a10215..e181e19c4633aa6c844d92db15cee1a9930a41ac 100644 --- a/src/dnode/inc/dnodeStep.h +++ b/src/dnode/inc/dnodeStep.h @@ -30,4 +30,4 @@ void dnodeSendStartupStep(SRpcMsg *pMsg); } #endif -#endif +#endif \ No newline at end of file diff --git a/src/dnode/inc/dnodeVMgmt.h b/src/dnode/inc/dnodeVMgmt.h index 9421a789249706a0c9bad2408566e859eee26a6b..821196defc9b827961ec4ae8140be82186192f62 100644 --- a/src/dnode/inc/dnodeVMgmt.h +++ b/src/dnode/inc/dnodeVMgmt.h @@ -29,4 +29,4 @@ void dnodeDispatchToVMgmtQueue(SRpcMsg *rpcMsg); } #endif -#endif +#endif \ No newline at end of file diff --git a/src/dnode/inc/dnodeVnodes.h b/src/dnode/inc/dnodeVnodes.h index 9ecbd5f0527775fa0df62d5942077d579b5cdc6a..e60dd290ce478f214c26410194f345fd4840dfb8 100644 --- a/src/dnode/inc/dnodeVnodes.h +++ b/src/dnode/inc/dnodeVnodes.h @@ -31,4 +31,4 @@ void dnodeSendStatusMsgToMnode(); } #endif -#endif +#endif \ No newline at end of file diff --git a/src/dnode/src/dnodeMInfos.c b/src/dnode/src/dnodeMInfos.c index e4f5d33bf401b922e345658569358fc87c809fbb..dc89487f8b4c5ef2d2434e815d2ba1d8a0311515 100644 --- a/src/dnode/src/dnodeMInfos.c +++ b/src/dnode/src/dnodeMInfos.c @@ -305,7 +305,7 @@ void dnodeSendRedirectMsg(SRpcMsg *rpcMsg, bool forShell) { } else { dnodeGetEpSetForPeer(&epSet); } - + dDebug("msg:%s will be redirected, dnodeIp:%s user:%s, numOfEps:%d inUse:%d", taosMsg[rpcMsg->msgType], taosIpStr(connInfo.clientIp), connInfo.user, epSet.numOfEps, epSet.inUse); @@ -323,4 +323,4 @@ void dnodeSendRedirectMsg(SRpcMsg *rpcMsg, bool forShell) { } rpcSendRedirectRsp(rpcMsg->handle, &epSet); -} +} \ No newline at end of file diff --git a/src/dnode/src/dnodeShell.c b/src/dnode/src/dnodeShell.c index 9419068587126e714a72685bbbfadd26845de3de..79cc70005b6e83bc1c455abb7cd3709ae29a8643 100644 --- a/src/dnode/src/dnodeShell.c +++ b/src/dnode/src/dnodeShell.c @@ -231,4 +231,4 @@ SStatisInfo dnodeGetStatisInfo() { } return info; -} +} \ No newline at end of file diff --git a/src/dnode/src/dnodeStep.c b/src/dnode/src/dnodeStep.c index 367f9223b51cb1b6ffc79159a39ac2ec14d4d705..2354b1d5a382d4ca7dea523cfe675883ae9d1570 100644 --- a/src/dnode/src/dnodeStep.c +++ b/src/dnode/src/dnodeStep.c @@ -71,4 +71,4 @@ int32_t dnodeStepInit(SStep *pSteps, int32_t stepSize) { void dnodeStepCleanup(SStep *pSteps, int32_t stepSize) { return taosStepCleanupImp(pSteps, stepSize - 1); -} +} \ No newline at end of file diff --git a/src/dnode/src/dnodeVnodes.c b/src/dnode/src/dnodeVnodes.c index 6c6c6aef52821f2f245301d629886d08c9033317..03b51feb9c9b0de20aec5c3b4e5f0fdae1b8f60a 100644 --- a/src/dnode/src/dnodeVnodes.c +++ b/src/dnode/src/dnodeVnodes.c @@ -271,7 +271,7 @@ static void dnodeSendStatusMsg(void *handle, void *tmrId) { vnodeBuildStatusMsg(pStatus); contLen = sizeof(SStatusMsg) + pStatus->openVnodes * sizeof(SVnodeLoad); pStatus->openVnodes = htons(pStatus->openVnodes); - + SRpcMsg rpcMsg = { .pCont = pStatus, .contLen = contLen, @@ -288,4 +288,4 @@ void dnodeSendStatusMsgToMnode() { dInfo("force send status msg to mnode"); taosTmrReset(dnodeSendStatusMsg, 3, NULL, tsDnodeTmr, &tsStatusTimer); } -} +} \ No newline at end of file diff --git a/src/inc/vnode.h b/src/inc/vnode.h index a4f7c00b6616f98660abb29c3ec8b73126350af3..cbe64484b11462fcf3f107625cb0e00b0ac682f4 100644 --- a/src/inc/vnode.h +++ b/src/inc/vnode.h @@ -89,4 +89,4 @@ int32_t vnodeProcessRead(void *pVnode, SVReadMsg *pRead); } #endif -#endif +#endif \ No newline at end of file diff --git a/src/vnode/inc/vnodeMain.h b/src/vnode/inc/vnodeMain.h index ecfdb15d62d19094a10bdbdb7914cbae06499670..e1ddcdc36aa1fbf434b138f8d6fef5966e1fbc3e 100644 --- a/src/vnode/inc/vnodeMain.h +++ b/src/vnode/inc/vnodeMain.h @@ -35,4 +35,4 @@ void vnodeDestroy(SVnodeObj *pVnode); } #endif -#endif +#endif \ No newline at end of file diff --git a/src/vnode/inc/vnodeStatus.h b/src/vnode/inc/vnodeStatus.h index 791af29c5f361855e799c1038cb55d4d4d630fba..00ac47df65fba91b9d7ef4b92ab5210de3652330 100644 --- a/src/vnode/inc/vnodeStatus.h +++ b/src/vnode/inc/vnodeStatus.h @@ -44,4 +44,4 @@ bool vnodeInResetStatus(SVnodeObj* pVnode); } #endif -#endif +#endif \ No newline at end of file diff --git a/src/vnode/inc/vnodeSync.h b/src/vnode/inc/vnodeSync.h index 65e96a61311913d2beb416dda5cb38441628efbb..ae02ca17cb50ed35480916d624004e33c74cc611 100644 --- a/src/vnode/inc/vnodeSync.h +++ b/src/vnode/inc/vnodeSync.h @@ -36,4 +36,4 @@ void vnodeConfirmForward(void *pVnode, uint64_t version, int32_t code); } #endif -#endif +#endif \ No newline at end of file diff --git a/src/vnode/inc/vnodeWorker.h b/src/vnode/inc/vnodeWorker.h index 7530baf7d9a0dd1d1aee87db552f28c83a6db3d0..01d9d42900ef7e0c56bd396f5c698a43c4b501f8 100644 --- a/src/vnode/inc/vnodeWorker.h +++ b/src/vnode/inc/vnodeWorker.h @@ -30,4 +30,4 @@ int32_t vnodeDestroyInMWorker(SVnodeObj *pVnode); } #endif -#endif +#endif \ No newline at end of file diff --git a/src/vnode/inc/vnodeWrite.h b/src/vnode/inc/vnodeWrite.h index c69da3567a7025d1e041f5fa21266491f1f92a79..8b3f0fdb58c8a510bcfc6da3aa36adb85297efca 100644 --- a/src/vnode/inc/vnodeWrite.h +++ b/src/vnode/inc/vnodeWrite.h @@ -32,4 +32,4 @@ int32_t vnodeProcessWrite(void *pVnode, void *pHead, int32_t qtype, void *pRspRe } #endif -#endif +#endif \ No newline at end of file diff --git a/src/vnode/src/vnodeMgmt.c b/src/vnode/src/vnodeMgmt.c index 45909723c24be0adf5da5945c7d75969ee082bf7..8469ab12c1ef5833e73058c167afb2777ac76ba9 100644 --- a/src/vnode/src/vnodeMgmt.c +++ b/src/vnode/src/vnodeMgmt.c @@ -194,4 +194,4 @@ void vnodeSetAccess(SVgroupAccess *pAccess, int32_t numOfVnodes) { vnodeRelease(pVnode); } } -} +} \ No newline at end of file