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

[TBASE-1164]

This commit is contained in:
slguan 2019-11-16 16:55:41 +08:00
parent 9c7fb6b00f
commit 8c55d4860a
5 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/os/darwin/src/tdarwin.c
View File

@ -204,7 +204,6 @@ int taosOpenUDServerSocket(char *ip, short port) {
char name[128];
pTrace("open ud socket:%s", name);
// if (tsAllowLocalhost) ip = "0.0.0.0";
sprintf(name, "%s.%d", ip, port);
bzero((char *)&serverAdd, sizeof(serverAdd));

1
src/os/linux/src/tlinux.c
View File

@ -197,7 +197,6 @@ int taosOpenUDServerSocket(char *ip, short port) {
char name[128];
pTrace("open ud socket:%s", name);
// if (tsAllowLocalhost) ip = "0.0.0.0";
sprintf(name, "%s.%d", ip, port);
bzero((char *)&serverAdd, sizeof(serverAdd));

3
src/rpc/src/ttcpserver.c
View File

@ -195,8 +195,9 @@ static void taosProcessTcpData(void *param) {
void *buffer = malloc(1024);
int headLen = taosReadMsg(pFdObj->fd, buffer, sizeof(STaosHeader));
if (headLen != sizeof(STaosHeader)) {
tError("%s read error, headLen:%d", pThreadObj->label, headLen);
tError("%s read error, headLen:%d, errno:%d", pThreadObj->label, headLen, errno);
taosCleanUpFdObj(pFdObj);
tfree(buffer);
continue;

2
src/util/src/tglobalcfg.c
View File

@ -77,7 +77,7 @@ float tsRatioOfQueryThreads = 0.5;
char tsPublicIp[TSDB_IPv4ADDR_LEN] = {0};
char tsInternalIp[TSDB_IPv4ADDR_LEN] = {0};
char tsPrivateIp[TSDB_IPv4ADDR_LEN] = {0};
char tsServerIpStr[TSDB_IPv4ADDR_LEN] = "0.0.0.0";
char tsServerIpStr[TSDB_IPv4ADDR_LEN] = "127.0.0.1";
short tsNumOfVnodesPerCore = 8;
short tsNumOfTotalVnodes = 0;
short tsCheckHeaderFile = 0;

4
src/util/src/tsocket.c
View File

@ -280,7 +280,6 @@ int taosOpenUdpSocket(char *ip, short port) {
int bufSize = 8192000;
pTrace("open udp socket:%s:%d", ip, port);
// if (tsAllowLocalhost) ip = "0.0.0.0";
memset((char *)&localAddr, 0, sizeof(localAddr));
localAddr.sin_family = AF_INET;
@ -345,7 +344,6 @@ int taosOpenTcpClientSocket(char *destIp, short destPort, char *clientIp) {
int ret;
pTrace("open tcp client socket:%s:%d", destIp, destPort);
// if (tsAllowLocalhost) destIp = "0.0.0.0";
sockFd = (int)socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
@ -441,7 +439,6 @@ int taosOpenTcpServerSocket(char *ip, short port) {
int reuse;
pTrace("open tcp server socket:%s:%d", ip, port);
// if (tsAllowLocalhost) ip = "0.0.0.0";
bzero((char *)&serverAdd, sizeof(serverAdd));
serverAdd.sin_family = AF_INET;
@ -483,7 +480,6 @@ int taosOpenRawSocket(char *ip) {
struct sockaddr_in rawAdd;
pTrace("open udp raw socket:%s", ip);
// if (tsAllowLocalhost) ip = "0.0.0.0";
fd = (int)socket(AF_INET, SOCK_RAW, IPPROTO_UDP);
if (fd < 0) {