/* * Copyright (c) 2019 TAOS Data, Inc. * * This program is free software: you can use, redistribute, and/or modify * it under the terms of the GNU Affero General Public License, version 3 * or later ("AGPL"), as published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, but WITHOUT * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * FITNESS FOR A PARTICULAR PURPOSE. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . */ #include "os.h" #include #include #include #include #include #include #include void taosWinSocketInit() { static char flag = 0; if (flag == 0) { WORD wVersionRequested; WSADATA wsaData; wVersionRequested = MAKEWORD(1, 1); if (WSAStartup(wVersionRequested, &wsaData) == 0) { flag = 1; } } } int taosSetNonblocking(SOCKET sock, int on) { u_long mode; if (on) { mode = 1; ioctlsocket(sock, FIONBIO, &mode); } else { mode = 0; ioctlsocket(sock, FIONBIO, &mode); } return 0; } void taosBlockSIGPIPE() {} int taosSetSockOpt(SOCKET socketfd, int level, int optname, void *optval, int optlen) { if (level == SOL_SOCKET && optname == TCP_KEEPCNT) { return 0; } if (level == SOL_TCP && optname == TCP_KEEPIDLE) { return 0; } if (level == SOL_TCP && optname == TCP_KEEPINTVL) { return 0; } if (level == SOL_TCP && optname == TCP_KEEPCNT) { return 0; } return setsockopt(socketfd, level, optname, optval, optlen); } #ifdef TAOS_OS_FUNC_SOCKET_INET uint32_t taosInetAddr(char *ipAddr) { uint32_t value; int ret = inet_pton(AF_INET, ipAddr, &value); if (ret <= 0) { return INADDR_NONE; } else { return value; } } const char *taosInetNtoa(struct in_addr ipInt) { // not thread safe, only for debug usage while print log static char tmpDstStr[16]; return inet_ntop(AF_INET, &ipInt, tmpDstStr, INET6_ADDRSTRLEN); } #endif