From 469cf6d6078c74313fc0cd01163b5a8ce3dc3b46 Mon Sep 17 00:00:00 2001 From: Jeff Tao Date: Sun, 21 Jun 2020 14:38:54 +0000 Subject: [PATCH] remove re-useaddr for UDP socket --- src/util/src/tsocket.c | 29 +---------------------------- 1 file changed, 1 insertion(+), 28 deletions(-) diff --git a/src/util/src/tsocket.c b/src/util/src/tsocket.c index 98ed8d1ed7..e19d91837f 100644 --- a/src/util/src/tsocket.c +++ b/src/util/src/tsocket.c @@ -222,9 +222,7 @@ int taosReadn(int fd, char *ptr, int nbytes) { int taosOpenUdpSocket(uint32_t ip, uint16_t port) { struct sockaddr_in localAddr; int sockFd; - int ttl = 128; - int reuse, nocheck; - int bufSize = 8192000; + int bufSize = 1024000; uTrace("open udp socket:0x%x:%hu", ip, port); @@ -238,31 +236,6 @@ int taosOpenUdpSocket(uint32_t ip, uint16_t port) { return -1; } - reuse = 1; - if (taosSetSockOpt(sockFd, SOL_SOCKET, SO_REUSEADDR, (void *)&reuse, sizeof(reuse)) < 0) { - uError("setsockopt SO_REUSEADDR failed): %d (%s)", errno, strerror(errno)); - close(sockFd); - return -1; - }; - - nocheck = 1; - if (taosSetSockOpt(sockFd, SOL_SOCKET, SO_NO_CHECK, (void *)&nocheck, sizeof(nocheck)) < 0) { - if (!taosSkipSocketCheck()) { - uError("setsockopt SO_NO_CHECK failed: %d (%s)", errno, strerror(errno)); - close(sockFd); - return -1; - } else { - uPrint("Skipping setsockopt SO_NO_CHECK error: %d (%s)", errno, strerror(errno)); - } - } - - ttl = 128; - if (taosSetSockOpt(sockFd, IPPROTO_IP, IP_TTL, (void *)&ttl, sizeof(ttl)) < 0) { - uError("setsockopt IP_TTL failed: %d (%s)", errno, strerror(errno)); - close(sockFd); - return -1; - } - if (taosSetSockOpt(sockFd, SOL_SOCKET, SO_SNDBUF, (void *)&bufSize, sizeof(bufSize)) != 0) { uError("failed to set the send buffer size for UDP socket\n"); close(sockFd); -- GitLab