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

add rpc update interface

This commit is contained in:
yihaoDeng 2023-09-01 21:21:11 +08:00
parent 2045fd4605
commit 30e6a9fdc5
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
source/libs/transport/src/transSvr.c
View File

@ -189,24 +189,27 @@ static void uvHandleActivityTimeout(uv_timer_t* handle) {
tDebug("%p timeout since no activity", conn); tDebug("%p timeout since no activity", conn);
} }
static bool uvCheckIp(char* range, char* ip) { static bool uvCheckIp(char* range, char* ip) {
// impl later // impl later
return strcmp(range, ip) == 0; return strcmp(range, ip) == 0;
} }
static bool uvFilteByWhiteList(SWorkThrd* pThrd, char* user, uint32_t ip) { static bool uvFilteByWhiteList(SWorkThrd* pThrd, char* user, uint32_t ip) {
// impl check // impl check
bool valid = false;
SArray** pWhite = taosHashGet(pThrd->pWhiteList, user, strlen(user)); SArray** pWhite = taosHashGet(pThrd->pWhiteList, user, strlen(user));
if (pWhite == NULL || *pWhite == NULL) { if (pWhite == NULL || *pWhite == NULL) {
return true; return true;
} }
bool valid = false;
char userIp[64] = {0}; char userIp[64] = {0};
tinet_ntoa(userIp, ip); tinet_ntoa(userIp, ip);
for (int i = 0; i < taosArrayGetSize(*pWhite); i++) { for (int i = 0; i < taosArrayGetSize(*pWhite); i++) {
char* range = taosArrayGetP(*pWhite, i); char* range = taosArrayGetP(*pWhite, i);
valid = uvCheckIp(range, userIp); if (uvCheckIp(range, userIp)) {
if (valid) { valid = true;
return valid; break;
} }
} }
return valid; return valid;