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

refactor(sync): add test syncRaftIdCheck

This commit is contained in:
Minghao Li 2022-06-14 20:19:56 +08:00
parent e4da993c15
commit b25840ebd4
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
source/libs/sync/src/syncUtil.c
View File

@ -14,7 +14,6 @@
*/ */
#include "syncUtil.h" #include "syncUtil.h"
#include <netdb.h>
#include <stdio.h> #include <stdio.h>
#include "syncEnv.h" #include "syncEnv.h"
@ -24,6 +23,14 @@ void addEpIntoEpSet(SEpSet* pEpSet, const char* fqdn, uint16_t port);
// ---- encode / decode // ---- encode / decode
uint64_t syncUtilAddr2U64(const char* host, uint16_t port) { uint64_t syncUtilAddr2U64(const char* host, uint16_t port) {
uint64_t u64; uint64_t u64;
uint32_t hostU32 = taosGetIpv4FromFqdn(host);
if (hostU32 == (uint32_t)-1) {
sError("Get IP address error");
return -1;
}
/*
uint32_t hostU32 = (uint32_t)taosInetAddr(host); uint32_t hostU32 = (uint32_t)taosInetAddr(host);
if (hostU32 == (uint32_t)-1) { if (hostU32 == (uint32_t)-1) {
struct hostent* hostEnt = gethostbyname(host); struct hostent* hostEnt = gethostbyname(host);
@ -39,6 +46,8 @@ uint64_t syncUtilAddr2U64(const char* host, uint16_t port) {
} }
// ASSERT(hostU32 != (uint32_t)-1); // ASSERT(hostU32 != (uint32_t)-1);
} }
*/
u64 = (((uint64_t)hostU32) << 32) | (((uint32_t)port) << 16); u64 = (((uint64_t)hostU32) << 32) | (((uint32_t)port) << 16);
return u64; return u64;
} }