add rpc update interface

This commit is contained in:
yihaoDeng 2023-09-11 21:02:50 +08:00
parent 39d04ed15b
commit 0a8b1ebe46
4 changed files with 4 additions and 3 deletions

View File

@ -36,6 +36,7 @@ static void dmMayShouldUpdateIpWhiteList(SDnodeMgmt *pMgmt, int64_t ver) {
if (ver == 0) {
dInfo("disable ip-white-dnode ver: %" PRId64 ", status ver: %" PRId64 "", pMgmt->ipWhiteVer, ver);
rpcSetIpWhite(pMgmt->msgCb.serverRpc, NULL);
pMgmt->ipWhiteVer = ver;
}
return;
}

View File

@ -33,7 +33,7 @@ int32_t mndCheckTopicPrivilegeByName(SMnode *pMnode, const char *user, EOperType
int32_t mndCheckShowPrivilege(SMnode *pMnode, const char *user, EShowType showType, const char *dbname);
int32_t mndCheckAlterUserPrivilege(SUserObj *pOperUser, SUserObj *pUser, SAlterUserReq *pAlter);
int32_t mndSetUserAuthRsp(SMnode *pMnode, SUserObj *pUser, SGetUserAuthRsp *pRsp);
int32_t mndCheckIpWhiteList(SMnode *pMnode);
int32_t mndEnableIpWhiteList(SMnode *pMnode);
#ifdef __cplusplus
}

View File

@ -43,5 +43,5 @@ int32_t mndSetUserAuthRsp(SMnode *pMnode, SUserObj *pUser, SGetUserAuthRsp *pRsp
return 0;
}
int32_t mndCheckIpWhiteList(SMnode *pMnode) { return 0; }
int32_t mndEnableIpWhiteList(SMnode *pMnode) { return 0; }
#endif

View File

@ -193,7 +193,7 @@ int64_t mndGetIpWhiteVer(SMnode *pMnode) {
taosThreadRwlockUnlock(&ipWhiteMgt.rw);
mInfo("ip-white-mnode ver, %" PRId64 "", ver);
if (mndCheckIpWhiteList(pMnode) == 0 || tsEnableWhiteList == false) {
if (mndEnableIpWhiteList(pMnode) == 0 || tsEnableWhiteList == false) {
return 0;
}
return ver;