xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Add config item alter lazy mode.

This commit is contained in:
xiao-77 2024-11-25 10:37:12 +08:00
parent 8ffa8811f5
commit a63c132fba
3 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
include/common/tglobal.h
View File

@ -305,6 +305,7 @@ int32_t setAllConfigs(SConfig *pCfg);
void printConfigNotMatch(SArray *array); void printConfigNotMatch(SArray *array);
int32_t compareSConfigItemArrays(SArray *mArray, const SArray *dArray, SArray *diffArray); int32_t compareSConfigItemArrays(SArray *mArray, const SArray *dArray, SArray *diffArray);
bool isConifgItemLazyMode(SConfigItem *item);
#ifdef __cplusplus #ifdef __cplusplus
} }
#endif #endif

8
source/common/src/tglobal.c
View File

@ -3036,4 +3036,12 @@ void printConfigNotMatch(SArray *array) {
} }
} }
} }
}
bool isConifgItemLazyMode(SConfigItem *item) {
if (item->dynScope == CFG_DYN_CLIENT_LAZY || item->dynScope == CFG_DYN_SERVER_LAZY ||
item->dynScope == CFG_DYN_BOTH_LAZY) {
return true;
}
return false;
} }

10
source/dnode/mgmt/mgmt_dnode/src/dmHandle.c
View File

@ -476,10 +476,11 @@ int32_t dmProcessConfigReq(SDnodeMgmt *pMgmt, SRpcMsg *pMsg) {
return code; return code;
} }
} }
TAOS_CHECK_RETURN(taosCfgDynamicOptions(pCfg, cfgReq.config, true)); if (isConifgItemLazyMode(pItem)) {
if (cfgReq.version > 0) { TAOS_CHECK_RETURN(taosCfgDynamicOptions(pCfg, cfgReq.config, true));
tsdmConfigVersion = cfgReq.version; return TSDB_CODE_INVALID_MSG;
} }
if (pItem->category == CFG_CATEGORY_GLOBAL) { if (pItem->category == CFG_CATEGORY_GLOBAL) {
code = taosPersistGlobalConfig(taosGetGlobalCfg(pCfg), pMgmt->path, tsdmConfigVersion); code = taosPersistGlobalConfig(taosGetGlobalCfg(pCfg), pMgmt->path, tsdmConfigVersion);
if (code != TSDB_CODE_SUCCESS) { if (code != TSDB_CODE_SUCCESS) {
@ -491,6 +492,9 @@ int32_t dmProcessConfigReq(SDnodeMgmt *pMgmt, SRpcMsg *pMsg) {
dError("failed to persist local config since %s", tstrerror(code)); dError("failed to persist local config since %s", tstrerror(code));
} }
} }
if (cfgReq.version > 0) {
tsdmConfigVersion = cfgReq.version;
}
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
} }