61 int anetSetBlock(char *err, int fd, int non_block) {  in anetSetBlock()  argument
67     if ((flags = fcntl(fd, F_GETFL)) == -1) {  in anetSetBlock()
77     if (fcntl(fd, F_SETFL, flags) == -1) {  in anetSetBlock()
84 int anetNonBlock(char *err, int fd) {  in anetNonBlock()  argument
85     return anetSetBlock(err,fd,1);  in anetNonBlock()
88 int anetBlock(char *err, int fd) {  in anetBlock()  argument
89     return anetSetBlock(err,fd,0);  in anetBlock()
95 int anetKeepAlive(char *err, int fd, int interval)  in anetKeepAlive()  argument
99     if (setsockopt(fd, SOL_SOCKET, SO_KEEPALIVE, &val, sizeof(val)) == -1)  in anetKeepAlive()
112     if (setsockopt(fd, IPPROTO_TCP, TCP_KEEPIDLE, &val, sizeof(val)) < 0) {  in anetKeepAlive()
122     if (setsockopt(fd, IPPROTO_TCP, TCP_KEEPINTVL, &val, sizeof(val)) < 0) {  in anetKeepAlive()
130     if (setsockopt(fd, IPPROTO_TCP, TCP_KEEPCNT, &val, sizeof(val)) < 0) {  in anetKeepAlive()
141 static int anetSetTcpNoDelay(char *err, int fd, int val)  in anetSetTcpNoDelay()  argument
143     if (setsockopt(fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof(val)) == -1)  in anetSetTcpNoDelay()
151 int anetEnableTcpNoDelay(char *err, int fd)  in anetEnableTcpNoDelay()  argument
153     return anetSetTcpNoDelay(err, fd, 1);  in anetEnableTcpNoDelay()
156 int anetDisableTcpNoDelay(char *err, int fd)  in anetDisableTcpNoDelay()  argument
158     return anetSetTcpNoDelay(err, fd, 0);  in anetDisableTcpNoDelay()
162 int anetSetSendBuffer(char *err, int fd, int buffsize)  in anetSetSendBuffer()  argument
164     if (setsockopt(fd, SOL_SOCKET, SO_SNDBUF, &buffsize, sizeof(buffsize)) == -1)  in anetSetSendBuffer()
172 int anetTcpKeepAlive(char *err, int fd)  in anetTcpKeepAlive()  argument
175     if (setsockopt(fd, SOL_SOCKET, SO_KEEPALIVE, &yes, sizeof(yes)) == -1) {  in anetTcpKeepAlive()
184 int anetSendTimeout(char *err, int fd, long long ms) {  in anetSendTimeout()  argument
189     if (setsockopt(fd, SOL_SOCKET, SO_SNDTIMEO, &tv, sizeof(tv)) == -1) {  in anetSendTimeout()
238 static int anetSetReuseAddr(char *err, int fd) {  in anetSetReuseAddr()  argument
242     if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes)) == -1) {  in anetSetReuseAddr()
410 int anetRead(int fd, char *buf, int count)  in anetRead()  argument
414         nread = read(fd,buf,count-totlen);  in anetRead()
425 int anetWrite(int fd, char *buf, int count)  in anetWrite()  argument
429         nwritten = write(fd,buf,count-totlen);  in anetWrite()
529     int fd;  in anetGenericAccept()  local
531         fd = accept(s,sa,len);  in anetGenericAccept()
532         if (fd == -1) {  in anetGenericAccept()
542     return fd;  in anetGenericAccept()
546     int fd;  in anetTcpAccept()  local
549     if ((fd = anetGenericAccept(err,s,(struct sockaddr*)&sa,&salen)) == -1)  in anetTcpAccept()
561     return fd;  in anetTcpAccept()
565     int fd;  in anetUnixAccept()  local
568     if ((fd = anetGenericAccept(err,s,(struct sockaddr*)&sa,&salen)) == -1)  in anetUnixAccept()
571     return fd;  in anetUnixAccept()
574 int anetPeerToString(int fd, char *ip, size_t ip_len, int *port) {  in anetPeerToString()  argument
578     if (getpeername(fd,(struct sockaddr*)&sa,&salen) == -1) goto error;  in anetPeerToString()
619 int anetFormatPeer(int fd, char *buf, size_t buf_len) {  in anetFormatPeer()  argument
623     anetPeerToString(fd,ip,sizeof(ip),&port);  in anetFormatPeer()
627 int anetSockName(int fd, char *ip, size_t ip_len, int *port) {  in anetSockName()  argument
631     if (getsockname(fd,(struct sockaddr*)&sa,&salen) == -1) {  in anetSockName()
649 int anetFormatSock(int fd, char *fmt, size_t fmt_len) {  in anetFormatSock()  argument
653     anetSockName(fd,ip,sizeof(ip),&port);  in anetFormatSock()