51 static void anetSetError(char *err, const char *fmt, ...)  in anetSetError()  argument
55     if (!err) return;  in anetSetError()
57     vsnprintf(err, ANET_ERR_LEN, fmt, ap);  in anetSetError()
61 int anetSetBlock(char *err, int fd, int non_block) {  in anetSetBlock()  argument
68         anetSetError(err, "fcntl(F_GETFL): %s", strerror(errno));  in anetSetBlock()
78         anetSetError(err, "fcntl(F_SETFL,O_NONBLOCK): %s", strerror(errno));  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
101         anetSetError(err, "setsockopt SO_KEEPALIVE: %s", strerror(errno));  in anetKeepAlive()
113         anetSetError(err, "setsockopt TCP_KEEPIDLE: %s\n", strerror(errno));  in anetKeepAlive()
123         anetSetError(err, "setsockopt TCP_KEEPINTVL: %s\n", strerror(errno));  in anetKeepAlive()
131         anetSetError(err, "setsockopt TCP_KEEPCNT: %s\n", strerror(errno));  in anetKeepAlive()
141 static int anetSetTcpNoDelay(char *err, int fd, int val)  in anetSetTcpNoDelay()  argument
145         anetSetError(err, "setsockopt TCP_NODELAY: %s", strerror(errno));  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
166         anetSetError(err, "setsockopt SO_SNDBUF: %s", strerror(errno));  in anetSetSendBuffer()
172 int anetTcpKeepAlive(char *err, int fd)  in anetTcpKeepAlive()  argument
176         anetSetError(err, "setsockopt SO_KEEPALIVE: %s", strerror(errno));  in anetTcpKeepAlive()
184 int anetSendTimeout(char *err, int fd, long long ms) {  in anetSendTimeout()  argument
190         anetSetError(err, "setsockopt SO_SNDTIMEO: %s", strerror(errno));  in anetSendTimeout()
203 int anetGenericResolve(char *err, char *host, char *ipbuf, size_t ipbuf_len,  in anetGenericResolve()  argument
215         anetSetError(err, "%s", gai_strerror(rv));  in anetGenericResolve()
230 int anetResolve(char *err, char *host, char *ipbuf, size_t ipbuf_len) {  in anetResolve()  argument
231     return anetGenericResolve(err,host,ipbuf,ipbuf_len,ANET_NONE);  in anetResolve()
234 int anetResolveIP(char *err, char *host, char *ipbuf, size_t ipbuf_len) {  in anetResolveIP()  argument
235     return anetGenericResolve(err,host,ipbuf,ipbuf_len,ANET_IP_ONLY);  in anetResolveIP()
238 static int anetSetReuseAddr(char *err, int fd) {  in anetSetReuseAddr()  argument
243         anetSetError(err, "setsockopt SO_REUSEADDR: %s", strerror(errno));  in anetSetReuseAddr()
249 static int anetCreateSocket(char *err, int domain) {  in anetCreateSocket()  argument
252         anetSetError(err, "creating socket: %s", strerror(errno));  in anetCreateSocket()
258     if (anetSetReuseAddr(err,s) == ANET_ERR) {  in anetCreateSocket()
268 static int anetTcpGenericConnect(char *err, char *addr, int port,  in anetTcpGenericConnect()  argument
281         anetSetError(err, "%s", gai_strerror(rv));  in anetTcpGenericConnect()
290         if (anetSetReuseAddr(err,s) == ANET_ERR) goto error;  in anetTcpGenericConnect()
291         if (flags & ANET_CONNECT_NONBLOCK && anetNonBlock(err,s) != ANET_OK)  in anetTcpGenericConnect()
298                 anetSetError(err, "%s", gai_strerror(rv));  in anetTcpGenericConnect()
309                 anetSetError(err, "bind: %s", strerror(errno));  in anetTcpGenericConnect()
328         anetSetError(err, "creating socket: %s", strerror(errno));  in anetTcpGenericConnect()
342         return anetTcpGenericConnect(err,addr,port,NULL,flags);  in anetTcpGenericConnect()
348 int anetTcpConnect(char *err, char *addr, int port)  in anetTcpConnect()  argument
350     return anetTcpGenericConnect(err,addr,port,NULL,ANET_CONNECT_NONE);  in anetTcpConnect()
353 int anetTcpNonBlockConnect(char *err, char *addr, int port)  in anetTcpNonBlockConnect()  argument
355     return anetTcpGenericConnect(err,addr,port,NULL,ANET_CONNECT_NONBLOCK);  in anetTcpNonBlockConnect()
358 int anetTcpNonBlockBindConnect(char *err, char *addr, int port,  in anetTcpNonBlockBindConnect()  argument
361     return anetTcpGenericConnect(err,addr,port,source_addr,  in anetTcpNonBlockBindConnect()
365 int anetTcpNonBlockBestEffortBindConnect(char *err, char *addr, int port,  in anetTcpNonBlockBestEffortBindConnect()  argument
368     return anetTcpGenericConnect(err,addr,port,source_addr,  in anetTcpNonBlockBestEffortBindConnect()
372 int anetUnixGenericConnect(char *err, char *path, int flags)  in anetUnixGenericConnect()  argument
377     if ((s = anetCreateSocket(err,AF_LOCAL)) == ANET_ERR)  in anetUnixGenericConnect()
383         if (anetNonBlock(err,s) != ANET_OK)  in anetUnixGenericConnect()
391         anetSetError(err, "connect: %s", strerror(errno));  in anetUnixGenericConnect()
398 int anetUnixConnect(char *err, char *path)  in anetUnixConnect()  argument
400     return anetUnixGenericConnect(err,path,ANET_CONNECT_NONE);  in anetUnixConnect()
403 int anetUnixNonBlockConnect(char *err, char *path)  in anetUnixNonBlockConnect()  argument
405     return anetUnixGenericConnect(err,path,ANET_CONNECT_NONBLOCK);  in anetUnixNonBlockConnect()
438 static int anetListen(char *err, int s, struct sockaddr *sa, socklen_t len, int backlog) {  in anetListen()  argument
440         anetSetError(err, "bind: %s", strerror(errno));  in anetListen()
446         anetSetError(err, "listen: %s", strerror(errno));  in anetListen()
453 static int anetV6Only(char *err, int s) {  in anetV6Only()  argument
456         anetSetError(err, "setsockopt: %s", strerror(errno));  in anetV6Only()
463 static int _anetTcpServer(char *err, int port, char *bindaddr, int af, int backlog)  in _anetTcpServer()  argument
476         anetSetError(err, "%s", gai_strerror(rv));  in _anetTcpServer()
483         if (af == AF_INET6 && anetV6Only(err,s) == ANET_ERR) goto error;  in _anetTcpServer()
484         if (anetSetReuseAddr(err,s) == ANET_ERR) goto error;  in _anetTcpServer()
485         if (anetListen(err,s,p->ai_addr,p->ai_addrlen,backlog) == ANET_ERR) goto error;  in _anetTcpServer()
489         anetSetError(err, "unable to bind socket");  in _anetTcpServer()
500 int anetTcpServer(char *err, int port, char *bindaddr, int backlog)  in anetTcpServer()  argument
502     return _anetTcpServer(err, port, bindaddr, AF_INET, backlog);  in anetTcpServer()
505 int anetTcp6Server(char *err, int port, char *bindaddr, int backlog)  in anetTcp6Server()  argument
507     return _anetTcpServer(err, port, bindaddr, AF_INET6, backlog);  in anetTcp6Server()
510 int anetUnixServer(char *err, char *path, mode_t perm, int backlog)  in anetUnixServer()  argument
515     if ((s = anetCreateSocket(err,AF_LOCAL)) == ANET_ERR)  in anetUnixServer()
521     if (anetListen(err,s,(struct sockaddr*)&sa,sizeof(sa),backlog) == ANET_ERR)  in anetUnixServer()
528 static int anetGenericAccept(char *err, int s, struct sockaddr *sa, socklen_t *len) {  in anetGenericAccept()  argument
536                 anetSetError(err, "accept: %s", strerror(errno));  in anetGenericAccept()
545 int anetTcpAccept(char *err, int s, char *ip, size_t ip_len, int *port) {  in anetTcpAccept()  argument
549     if ((fd = anetGenericAccept(err,s,(struct sockaddr*)&sa,&salen)) == -1)  in anetTcpAccept()
564 int anetUnixAccept(char *err, int s) {  in anetUnixAccept()  argument
568     if ((fd = anetGenericAccept(err,s,(struct sockaddr*)&sa,&salen)) == -1)  in anetUnixAccept()