From 30e6a9fdc54fc7b37417129b53904ae8e93a7605 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Fri, 1 Sep 2023 21:21:11 +0800 Subject: [PATCH] add rpc update interface --- source/libs/transport/src/transSvr.c | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/source/libs/transport/src/transSvr.c b/source/libs/transport/src/transSvr.c index c98f5a3543..5e768e6246 100644 --- a/source/libs/transport/src/transSvr.c +++ b/source/libs/transport/src/transSvr.c @@ -189,24 +189,27 @@ static void uvHandleActivityTimeout(uv_timer_t* handle) { tDebug("%p timeout since no activity", conn); } + static bool uvCheckIp(char* range, char* ip) { // impl later return strcmp(range, ip) == 0; } static bool uvFilteByWhiteList(SWorkThrd* pThrd, char* user, uint32_t ip) { // impl check + bool valid = false; SArray** pWhite = taosHashGet(pThrd->pWhiteList, user, strlen(user)); if (pWhite == NULL || *pWhite == NULL) { return true; } - bool valid = false; + char userIp[64] = {0}; tinet_ntoa(userIp, ip); + for (int i = 0; i < taosArrayGetSize(*pWhite); i++) { char* range = taosArrayGetP(*pWhite, i); - valid = uvCheckIp(range, userIp); - if (valid) { - return valid; + if (uvCheckIp(range, userIp)) { + valid = true; + break; } } return valid;