dovecot/core-2.2: src/lib/network.c annotate

annotate src/lib/network.c @ 11564:c24ee1ebb159 HEAD

net_disconnect(): Ignore ECONNRESET error.

author	Timo Sirainen <tss@iki.fi>
date	Thu, 17 Jun 2010 14:47:16 +0100
parents	bdb46ba87203
children	5ea9394b5ced

rev	line source
10582 615eef3139c2 Updated copyright notices to include year 2010. Timo Sirainen <tss@iki.fi> parents: 10158 diff changeset	1 /* Copyright (c) 1999-2010 Dovecot authors, see the included COPYING file */
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	2
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	3 #include "lib.h"
4011 323c09be5f00 Moved dupliated close_save_errno() code to public close_keep_errno() function. Timo Sirainen <timo.sirainen@movial.fi> parents: 3863 diff changeset	4 #include "close-keep-errno.h"
3621 3ae2df67459c Added fd_set_nonblock() and changed net_set_nonblock() to use it. Timo Sirainen <tss@iki.fi> parents: 3577 diff changeset	5 #include "fd-set-nonblock.h"
10158 1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	6 #include "time-util.h"
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	7 #include "network.h"
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	8
7919 423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	9 #include <stdlib.h>
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	10 #include <unistd.h>
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	11 #include <fcntl.h>
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	12 #include <ctype.h>
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	13 #include <sys/un.h>
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	14 #include <netinet/tcp.h>
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	15
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	16 union sockaddr_union {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	17 struct sockaddr sa;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	18 struct sockaddr_in sin;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	19 #ifdef HAVE_IPV6
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	20 struct sockaddr_in6 sin6;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	21 #endif
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	22 };
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	23
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	24 #ifdef HAVE_IPV6
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	25 # define SIZEOF_SOCKADDR(so) ((so).sa.sa_family == AF_INET6 ? \
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	26 sizeof(so.sin6) : sizeof(so.sin))
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	27 #else
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	28 # define SIZEOF_SOCKADDR(so) (sizeof(so.sin))
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	29 #endif
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	30
3863 55df57c028d4 Added "bool" type and changed all ints that were used as booleans to bool. Timo Sirainen <tss@iki.fi> parents: 3681 diff changeset	31 bool net_ip_compare(const struct ip_addr ip1, const struct ip_addr ip2)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	32 {
10789 a4666cc8cb7b liblib: Added net_ip_cmp(). Timo Sirainen <tss@iki.fi> parents: 10582 diff changeset	33 return net_ip_cmp(ip1, ip2) == 0;
a4666cc8cb7b liblib: Added net_ip_cmp(). Timo Sirainen <tss@iki.fi> parents: 10582 diff changeset	34 }
a4666cc8cb7b liblib: Added net_ip_cmp(). Timo Sirainen <tss@iki.fi> parents: 10582 diff changeset	35
a4666cc8cb7b liblib: Added net_ip_cmp(). Timo Sirainen <tss@iki.fi> parents: 10582 diff changeset	36 int net_ip_cmp(const struct ip_addr ip1, const struct ip_addr ip2)
a4666cc8cb7b liblib: Added net_ip_cmp(). Timo Sirainen <tss@iki.fi> parents: 10582 diff changeset	37 {
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	38 if (ip1->family != ip2->family)
10789 a4666cc8cb7b liblib: Added net_ip_cmp(). Timo Sirainen <tss@iki.fi> parents: 10582 diff changeset	39 return ip1->family - ip2->family;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	40
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	41 #ifdef HAVE_IPV6
10789 a4666cc8cb7b liblib: Added net_ip_cmp(). Timo Sirainen <tss@iki.fi> parents: 10582 diff changeset	42 if (ip1->family == AF_INET6)
a4666cc8cb7b liblib: Added net_ip_cmp(). Timo Sirainen <tss@iki.fi> parents: 10582 diff changeset	43 return memcmp(&ip1->u.ip6, &ip2->u.ip6, sizeof(ip1->u.ip6));
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	44 #endif
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	45
10789 a4666cc8cb7b liblib: Added net_ip_cmp(). Timo Sirainen <tss@iki.fi> parents: 10582 diff changeset	46 return memcmp(&ip1->u.ip4, &ip2->u.ip4, sizeof(ip1->u.ip4));
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	47 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	48
5865 22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	49 unsigned int net_ip_hash(const struct ip_addr *ip)
22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	50 {
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	51 const unsigned char *p;
5865 22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	52 unsigned int len, g, h = 0;
22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	53
22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	54 #ifdef HAVE_IPV6
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	55 if (ip->family == AF_INET6) {
74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	56 p = ip->u.ip6.s6_addr;
74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	57 len = sizeof(ip->u.ip6);
74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	58 } else
5865 22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	59 #endif
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	60 {
74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	61 return ip->u.ip4.s_addr;
74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	62 }
5865 22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	63
22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	64 for (; len > 0; len--, p++) {
22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	65 h = (h << 4) + *p;
22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	66 if ((g = h & 0xf0000000UL)) {
22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	67 h = h ^ (g >> 24);
22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	68 h = h ^ g;
22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	69 }
22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	70 }
22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	71
22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	72 return h;
22b300677807 Added net_ip_hash(). Timo Sirainen <tss@iki.fi> parents: 5675 diff changeset	73 }
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	74
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	75 /* copy IP to sockaddr */
903 fd8888f6f037 Naming style changes, finally got tired of most of the typedefs. Also the Timo Sirainen <tss@iki.fi> parents: 807 diff changeset	76 static inline void
fd8888f6f037 Naming style changes, finally got tired of most of the typedefs. Also the Timo Sirainen <tss@iki.fi> parents: 807 diff changeset	77 sin_set_ip(union sockaddr_union so, const struct ip_addr ip)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	78 {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	79 if (ip == NULL) {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	80 #ifdef HAVE_IPV6
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	81 so->sin6.sin6_family = AF_INET6;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	82 so->sin6.sin6_addr = in6addr_any;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	83 #else
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	84 so->sin.sin_family = AF_INET;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	85 so->sin.sin_addr.s_addr = INADDR_ANY;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	86 #endif
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	87 return;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	88 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	89
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	90 so->sin.sin_family = ip->family;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	91 #ifdef HAVE_IPV6
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	92 if (ip->family == AF_INET6)
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	93 memcpy(&so->sin6.sin6_addr, &ip->u.ip6, sizeof(ip->u.ip6));
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	94 else
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	95 #endif
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	96 memcpy(&so->sin.sin_addr, &ip->u.ip4, sizeof(ip->u.ip4));
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	97 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	98
903 fd8888f6f037 Naming style changes, finally got tired of most of the typedefs. Also the Timo Sirainen <tss@iki.fi> parents: 807 diff changeset	99 static inline void
fd8888f6f037 Naming style changes, finally got tired of most of the typedefs. Also the Timo Sirainen <tss@iki.fi> parents: 807 diff changeset	100 sin_get_ip(const union sockaddr_union so, struct ip_addr ip)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	101 {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	102 ip->family = so->sin.sin_family;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	103
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	104 #ifdef HAVE_IPV6
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	105 if (ip->family == AF_INET6)
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	106 memcpy(&ip->u.ip6, &so->sin6.sin6_addr, sizeof(ip->u.ip6));
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	107 else
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	108 #endif
3400 ddfa507bb74f Don't return random data if net_getpeername() or net_getsockname() is used Timo Sirainen <tss@iki.fi> parents: 3373 diff changeset	109 if (ip->family == AF_INET)
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	110 memcpy(&ip->u.ip4, &so->sin.sin_addr, sizeof(ip->u.ip4));
3400 ddfa507bb74f Don't return random data if net_getpeername() or net_getsockname() is used Timo Sirainen <tss@iki.fi> parents: 3373 diff changeset	111 else
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	112 memset(&ip->u, 0, sizeof(ip->u));
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	113 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	114
349 fd32faeb7ba5 keep the port unsigned. Timo Sirainen <tss@iki.fi> parents: 183 diff changeset	115 static inline void sin_set_port(union sockaddr_union *so, unsigned int port)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	116 {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	117 #ifdef HAVE_IPV6
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	118 if (so->sin.sin_family == AF_INET6)
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	119 so->sin6.sin6_port = htons((unsigned short) port);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	120 else
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	121 #endif
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	122 so->sin.sin_port = htons((unsigned short) port);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	123 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	124
349 fd32faeb7ba5 keep the port unsigned. Timo Sirainen <tss@iki.fi> parents: 183 diff changeset	125 static inline unsigned int sin_get_port(union sockaddr_union *so)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	126 {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	127 #ifdef HAVE_IPV6
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	128 if (so->sin.sin_family == AF_INET6)
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	129 return ntohs(so->sin6.sin6_port);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	130 #endif
3400 ddfa507bb74f Don't return random data if net_getpeername() or net_getsockname() is used Timo Sirainen <tss@iki.fi> parents: 3373 diff changeset	131 if (so->sin.sin_family == AF_INET)
ddfa507bb74f Don't return random data if net_getpeername() or net_getsockname() is used Timo Sirainen <tss@iki.fi> parents: 3373 diff changeset	132 return ntohs(so->sin.sin_port);
ddfa507bb74f Don't return random data if net_getpeername() or net_getsockname() is used Timo Sirainen <tss@iki.fi> parents: 3373 diff changeset	133
ddfa507bb74f Don't return random data if net_getpeername() or net_getsockname() is used Timo Sirainen <tss@iki.fi> parents: 3373 diff changeset	134 return 0;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	135 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	136
6876 ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	137 #ifdef __FreeBSD__
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	138 static int net_connect_ip_freebsd(const struct ip_addr *ip, unsigned int port,
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	139 const struct ip_addr *my_ip);
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	140
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	141 int net_connect_ip(const struct ip_addr *ip, unsigned int port,
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	142 const struct ip_addr *my_ip)
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	143 {
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	144 int fd, try;
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	145
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	146 for (try = 0;;) {
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	147 fd = net_connect_ip_freebsd(ip, port, my_ip);
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	148 if (fd != -1 \|\| ++try == 5 \|\|
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	149 (errno != EADDRINUSE && errno != EACCES))
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	150 break;
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	151 /*
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	152 This may be just a temporary problem:
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	153
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	154 EADDRINUSE: busy
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	155 EACCES: pf may cause this if another connection used
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	156 the same port recently
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	157 */
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	158 }
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	159 return fd;
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	160 }
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	161 /* then some kludging: */
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	162 #define net_connect_ip net_connect_ip_freebsd
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	163 static
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	164 #endif
ed6693fc06d6 FreeBSD: If connect() fails with EADDRINUSE or EACCES, try again max. 3 times. Timo Sirainen <tss@iki.fi> parents: 6825 diff changeset	165
903 fd8888f6f037 Naming style changes, finally got tired of most of the typedefs. Also the Timo Sirainen <tss@iki.fi> parents: 807 diff changeset	166 int net_connect_ip(const struct ip_addr *ip, unsigned int port,
fd8888f6f037 Naming style changes, finally got tired of most of the typedefs. Also the Timo Sirainen <tss@iki.fi> parents: 807 diff changeset	167 const struct ip_addr *my_ip)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	168 {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	169 union sockaddr_union so;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	170 int fd, ret, opt = 1;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	171
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	172 if (my_ip != NULL && ip->family != my_ip->family) {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	173 i_warning("net_connect_ip(): ip->family != my_ip->family");
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	174 my_ip = NULL;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	175 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	176
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	177 /* create the socket */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	178 memset(&so, 0, sizeof(so));
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	179 so.sin.sin_family = ip->family;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	180 fd = socket(ip->family, SOCK_STREAM, 0);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	181
3523 d1ed3b3548db Added some more error messages. Also if net_connect_ip() gives my_ip Timo Sirainen <tss@iki.fi> parents: 3400 diff changeset	182 if (fd == -1) {
d1ed3b3548db Added some more error messages. Also if net_connect_ip() gives my_ip Timo Sirainen <tss@iki.fi> parents: 3400 diff changeset	183 i_error("socket() failed: %m");
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	184 return -1;
3523 d1ed3b3548db Added some more error messages. Also if net_connect_ip() gives my_ip Timo Sirainen <tss@iki.fi> parents: 3400 diff changeset	185 }
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	186
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	187 /* set socket options */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	188 setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	189 setsockopt(fd, SOL_SOCKET, SO_KEEPALIVE, &opt, sizeof(opt));
2639 a307ddd22a3a net_connect() should be nonblocking (currently unused in Dovecot) Timo Sirainen <tss@iki.fi> parents: 2113 diff changeset	190 net_set_nonblock(fd, TRUE);
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	191
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	192 /* set our own address */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	193 if (my_ip != NULL) {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	194 sin_set_ip(&so, my_ip);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	195 if (bind(fd, &so.sa, SIZEOF_SOCKADDR(so)) == -1) {
3523 d1ed3b3548db Added some more error messages. Also if net_connect_ip() gives my_ip Timo Sirainen <tss@iki.fi> parents: 3400 diff changeset	196 i_error("bind(%s) failed: %m", net_ip2addr(my_ip));
4011 323c09be5f00 Moved dupliated close_save_errno() code to public close_keep_errno() function. Timo Sirainen <timo.sirainen@movial.fi> parents: 3863 diff changeset	197 close_keep_errno(fd);
3523 d1ed3b3548db Added some more error messages. Also if net_connect_ip() gives my_ip Timo Sirainen <tss@iki.fi> parents: 3400 diff changeset	198 return -1;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	199 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	200 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	201
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	202 /* connect */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	203 sin_set_ip(&so, ip);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	204 sin_set_port(&so, port);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	205 ret = connect(fd, &so.sa, SIZEOF_SOCKADDR(so));
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	206
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	207 #ifndef WIN32
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	208 if (ret < 0 && errno != EINPROGRESS)
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	209 #else
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	210 if (ret < 0 && WSAGetLastError() != WSAEWOULDBLOCK)
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	211 #endif
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	212 {
4011 323c09be5f00 Moved dupliated close_save_errno() code to public close_keep_errno() function. Timo Sirainen <timo.sirainen@movial.fi> parents: 3863 diff changeset	213 close_keep_errno(fd);
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	214 return -1;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	215 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	216
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	217 return fd;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	218 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	219
11340 40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	220 int net_try_bind(const struct ip_addr *ip)
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	221 {
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	222 union sockaddr_union so;
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	223 int fd;
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	224
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	225 /* create the socket */
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	226 memset(&so, 0, sizeof(so));
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	227 so.sin.sin_family = ip->family;
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	228 fd = socket(ip->family, SOCK_STREAM, 0);
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	229 if (fd == -1) {
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	230 i_error("socket() failed: %m");
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	231 return -1;
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	232 }
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	233
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	234 sin_set_ip(&so, ip);
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	235 if (bind(fd, &so.sa, SIZEOF_SOCKADDR(so)) == -1) {
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	236 close_keep_errno(fd);
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	237 return -1;
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	238 }
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	239 (void)close(fd);
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	240 return 0;
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	241 }
40964653930c liblib: Added net_try_bind() Timo Sirainen <tss@iki.fi> parents: 11086 diff changeset	242
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	243 int net_connect_unix(const char *path)
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	244 {
5985 8ae4b8d78a25 More union usage to avoid casting. Timo Sirainen <tss@iki.fi> parents: 5984 diff changeset	245 union {
8ae4b8d78a25 More union usage to avoid casting. Timo Sirainen <tss@iki.fi> parents: 5984 diff changeset	246 struct sockaddr sa;
8ae4b8d78a25 More union usage to avoid casting. Timo Sirainen <tss@iki.fi> parents: 5984 diff changeset	247 struct sockaddr_un un;
8ae4b8d78a25 More union usage to avoid casting. Timo Sirainen <tss@iki.fi> parents: 5984 diff changeset	248 } sa;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	249 int fd, ret;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	250
807 35abd7a5d381 Buffer related cleanups. Use PATH_MAX instead of hardcoded 1024 for paths. Timo Sirainen <tss@iki.fi> parents: 805 diff changeset	251 memset(&sa, 0, sizeof(sa));
5985 8ae4b8d78a25 More union usage to avoid casting. Timo Sirainen <tss@iki.fi> parents: 5984 diff changeset	252 sa.un.sun_family = AF_UNIX;
6422 18173a52f721 Renamed strocpy() to i_strocpy(). Timo Sirainen <tss@iki.fi> parents: 6411 diff changeset	253 if (i_strocpy(sa.un.sun_path, path, sizeof(sa.un.sun_path)) < 0) {
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	254 /* too long path */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	255 errno = EINVAL;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	256 return -1;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	257 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	258
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	259 /* create the socket */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	260 fd = socket(PF_UNIX, SOCK_STREAM, 0);
3523 d1ed3b3548db Added some more error messages. Also if net_connect_ip() gives my_ip Timo Sirainen <tss@iki.fi> parents: 3400 diff changeset	261 if (fd == -1) {
d1ed3b3548db Added some more error messages. Also if net_connect_ip() gives my_ip Timo Sirainen <tss@iki.fi> parents: 3400 diff changeset	262 i_error("socket(%s) failed: %m", path);
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	263 return -1;
3523 d1ed3b3548db Added some more error messages. Also if net_connect_ip() gives my_ip Timo Sirainen <tss@iki.fi> parents: 3400 diff changeset	264 }
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	265
3076 8d15fea729c2 Use nonblocking connecting for unix sockets. Timo Sirainen <tss@iki.fi> parents: 3075 diff changeset	266 net_set_nonblock(fd, TRUE);
8d15fea729c2 Use nonblocking connecting for unix sockets. Timo Sirainen <tss@iki.fi> parents: 3075 diff changeset	267
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	268 /* connect */
5985 8ae4b8d78a25 More union usage to avoid casting. Timo Sirainen <tss@iki.fi> parents: 5984 diff changeset	269 ret = connect(fd, &sa.sa, sizeof(sa));
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	270 if (ret < 0 && errno != EINPROGRESS) {
4011 323c09be5f00 Moved dupliated close_save_errno() code to public close_keep_errno() function. Timo Sirainen <timo.sirainen@movial.fi> parents: 3863 diff changeset	271 close_keep_errno(fd);
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	272 return -1;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	273 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	274
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	275 return fd;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	276 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	277
10158 1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	278 int net_connect_unix_with_retries(const char *path, unsigned int msecs)
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	279 {
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	280 struct timeval start, now;
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	281 int fd;
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	282
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	283 if (gettimeofday(&start, NULL) < 0)
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	284 i_panic("gettimeofday() failed: %m");
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	285
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	286 do {
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	287 fd = net_connect_unix(path);
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	288 if (fd != -1 \|\| (errno != EAGAIN && errno != ECONNREFUSED))
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	289 break;
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	290
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	291 /* busy. wait for a while. */
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	292 usleep(((rand() % 10) + 1) * 10000);
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	293 if (gettimeofday(&now, NULL) < 0)
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	294 i_panic("gettimeofday() failed: %m");
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	295 } while (timeval_diff_msecs(&now, &start) < (int)msecs);
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	296 return fd;
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	297 }
1bc88aa1373f Added net_connect_unix_with_retries(). Timo Sirainen <tss@iki.fi> parents: 9843 diff changeset	298
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	299 void net_disconnect(int fd)
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	300 {
11564 c24ee1ebb159 net_disconnect(): Ignore ECONNRESET error. Timo Sirainen <tss@iki.fi> parents: 11448 diff changeset	301 /* FreeBSD's close() fails with ECONNRESET if socket still has unsent
c24ee1ebb159 net_disconnect(): Ignore ECONNRESET error. Timo Sirainen <tss@iki.fi> parents: 11448 diff changeset	302 data in transmit buffer. We don't care. */
c24ee1ebb159 net_disconnect(): Ignore ECONNRESET error. Timo Sirainen <tss@iki.fi> parents: 11448 diff changeset	303 if (close(fd) < 0 && errno != ECONNRESET)
388 792fc5b3daa4 Send error message if close() fails in net_disconnect(). Timo Sirainen <tss@iki.fi> parents: 349 diff changeset	304 i_error("net_disconnect() failed: %m");
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	305 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	306
3863 55df57c028d4 Added "bool" type and changed all ints that were used as booleans to bool. Timo Sirainen <tss@iki.fi> parents: 3681 diff changeset	307 void net_set_nonblock(int fd, bool nonblock)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	308 {
3621 3ae2df67459c Added fd_set_nonblock() and changed net_set_nonblock() to use it. Timo Sirainen <tss@iki.fi> parents: 3577 diff changeset	309 if (fd_set_nonblock(fd, nonblock) < 0)
3ae2df67459c Added fd_set_nonblock() and changed net_set_nonblock() to use it. Timo Sirainen <tss@iki.fi> parents: 3577 diff changeset	310 i_fatal("fd_set_nonblock(%d) failed: %m", fd);
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	311 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	312
6411 6a64e64fa3a3 Renamed __attr___ to ATTR_. Renamed __attrs_used__ to ATTRS_DEFINED. Timo Sirainen <tss@iki.fi> parents: 5985 diff changeset	313 int net_set_cork(int fd ATTR_UNUSED, bool cork ATTR_UNUSED)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	314 {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	315 #ifdef TCP_CORK
3863 55df57c028d4 Added "bool" type and changed all ints that were used as booleans to bool. Timo Sirainen <tss@iki.fi> parents: 3681 diff changeset	316 int val = cork;
55df57c028d4 Added "bool" type and changed all ints that were used as booleans to bool. Timo Sirainen <tss@iki.fi> parents: 3681 diff changeset	317
55df57c028d4 Added "bool" type and changed all ints that were used as booleans to bool. Timo Sirainen <tss@iki.fi> parents: 3681 diff changeset	318 return setsockopt(fd, IPPROTO_TCP, TCP_CORK, &val, sizeof(val));
410 1f0e7229ee58 Split IOBuffer into mmaped IBuffer, file IBuffer, memory data IBuffer and Timo Sirainen <tss@iki.fi> parents: 404 diff changeset	319 #else
1f0e7229ee58 Split IOBuffer into mmaped IBuffer, file IBuffer, memory data IBuffer and Timo Sirainen <tss@iki.fi> parents: 404 diff changeset	320 errno = ENOPROTOOPT;
1f0e7229ee58 Split IOBuffer into mmaped IBuffer, file IBuffer, memory data IBuffer and Timo Sirainen <tss@iki.fi> parents: 404 diff changeset	321 return -1;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	322 #endif
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	323 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	324
903 fd8888f6f037 Naming style changes, finally got tired of most of the typedefs. Also the Timo Sirainen <tss@iki.fi> parents: 807 diff changeset	325 void net_get_ip_any4(struct ip_addr *ip)
780 1cc947617c8b imap_listen and imaps_listen accepts now "" as "all IPv4 interfaces" and Timo Sirainen <tss@iki.fi>* parents: 680 diff changeset	326 {
1cc947617c8b imap_listen and imaps_listen accepts now "" as "all IPv4 interfaces" and Timo Sirainen <tss@iki.fi>* parents: 680 diff changeset	327 ip->family = AF_INET;
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	328 ip->u.ip4.s_addr = INADDR_ANY;
780 1cc947617c8b imap_listen and imaps_listen accepts now "" as "all IPv4 interfaces" and Timo Sirainen <tss@iki.fi>* parents: 680 diff changeset	329 }
1cc947617c8b imap_listen and imaps_listen accepts now "" as "all IPv4 interfaces" and Timo Sirainen <tss@iki.fi>* parents: 680 diff changeset	330
903 fd8888f6f037 Naming style changes, finally got tired of most of the typedefs. Also the Timo Sirainen <tss@iki.fi> parents: 807 diff changeset	331 void net_get_ip_any6(struct ip_addr *ip)
780 1cc947617c8b imap_listen and imaps_listen accepts now "" as "all IPv4 interfaces" and Timo Sirainen <tss@iki.fi>* parents: 680 diff changeset	332 {
1cc947617c8b imap_listen and imaps_listen accepts now "" as "all IPv4 interfaces" and Timo Sirainen <tss@iki.fi>* parents: 680 diff changeset	333 #ifdef HAVE_IPV6
1cc947617c8b imap_listen and imaps_listen accepts now "" as "all IPv4 interfaces" and Timo Sirainen <tss@iki.fi>* parents: 680 diff changeset	334 ip->family = AF_INET6;
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	335 ip->u.ip6 = in6addr_any;
780 1cc947617c8b imap_listen and imaps_listen accepts now "" as "all IPv4 interfaces" and Timo Sirainen <tss@iki.fi>* parents: 680 diff changeset	336 #else
903 fd8888f6f037 Naming style changes, finally got tired of most of the typedefs. Also the Timo Sirainen <tss@iki.fi> parents: 807 diff changeset	337 memset(ip, 0, sizeof(struct ip_addr));
780 1cc947617c8b imap_listen and imaps_listen accepts now "" as "all IPv4 interfaces" and Timo Sirainen <tss@iki.fi>* parents: 680 diff changeset	338 #endif
1cc947617c8b imap_listen and imaps_listen accepts now "" as "all IPv4 interfaces" and Timo Sirainen <tss@iki.fi>* parents: 680 diff changeset	339 }
1cc947617c8b imap_listen and imaps_listen accepts now "" as "all IPv4 interfaces" and Timo Sirainen <tss@iki.fi>* parents: 680 diff changeset	340
3075 9cb91ed5a110 Added backlog parameter for net_listen(). Timo Sirainen <tss@iki.fi>* parents: 2639 diff changeset	341 int net_listen(const struct ip_addr my_ip, unsigned int port, int backlog)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	342 {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	343 union sockaddr_union so;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	344 int ret, fd, opt = 1;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	345 socklen_t len;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	346
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	347 memset(&so, 0, sizeof(so));
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	348 sin_set_port(&so, *port);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	349 sin_set_ip(&so, my_ip);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	350
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	351 /* create the socket */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	352 fd = socket(so.sin.sin_family, SOCK_STREAM, 0);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	353 #ifdef HAVE_IPV6
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	354 if (fd == -1 && (errno == EINVAL \|\| errno == EAFNOSUPPORT)) {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	355 /* IPv6 is not supported by OS */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	356 so.sin.sin_family = AF_INET;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	357 so.sin.sin_addr.s_addr = INADDR_ANY;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	358
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	359 fd = socket(AF_INET, SOCK_STREAM, 0);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	360 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	361 #endif
3523 d1ed3b3548db Added some more error messages. Also if net_connect_ip() gives my_ip Timo Sirainen <tss@iki.fi> parents: 3400 diff changeset	362 if (fd == -1) {
d1ed3b3548db Added some more error messages. Also if net_connect_ip() gives my_ip Timo Sirainen <tss@iki.fi> parents: 3400 diff changeset	363 i_error("socket() failed: %m");
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	364 return -1;
3523 d1ed3b3548db Added some more error messages. Also if net_connect_ip() gives my_ip Timo Sirainen <tss@iki.fi> parents: 3400 diff changeset	365 }
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	366
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	367 /* set socket options */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	368 setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	369 setsockopt(fd, SOL_SOCKET, SO_KEEPALIVE, &opt, sizeof(opt));
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	370
7274 da971cec0395 [::] listens only for IPv6 addresses now. This gets rid of IPv4-mapped IPv6 Timo Sirainen <tss@iki.fi> parents: 7086 diff changeset	371 /* If using IPv6, bind only to IPv6 if possible. This avoids
da971cec0395 [::] listens only for IPv6 addresses now. This gets rid of IPv4-mapped IPv6 Timo Sirainen <tss@iki.fi> parents: 7086 diff changeset	372 ambiguities with IPv4-mapped IPv6 addresses. */
3373 690dcc51cdc1 if using IPv6, bind both on the IPv4 and IPv6 addresses if IPV6_V6ONLY is Timo Sirainen <tss@iki.fi> parents: 3076 diff changeset	373 #ifdef IPV6_V6ONLY
690dcc51cdc1 if using IPv6, bind both on the IPv4 and IPv6 addresses if IPV6_V6ONLY is Timo Sirainen <tss@iki.fi> parents: 3076 diff changeset	374 if (so.sin.sin_family == AF_INET6) {
7274 da971cec0395 [::] listens only for IPv6 addresses now. This gets rid of IPv4-mapped IPv6 Timo Sirainen <tss@iki.fi> parents: 7086 diff changeset	375 opt = 1;
3373 690dcc51cdc1 if using IPv6, bind both on the IPv4 and IPv6 addresses if IPV6_V6ONLY is Timo Sirainen <tss@iki.fi> parents: 3076 diff changeset	376 setsockopt(fd, IPPROTO_IPV6, IPV6_V6ONLY, &opt, sizeof(opt));
690dcc51cdc1 if using IPv6, bind both on the IPv4 and IPv6 addresses if IPV6_V6ONLY is Timo Sirainen <tss@iki.fi> parents: 3076 diff changeset	377 }
690dcc51cdc1 if using IPv6, bind both on the IPv4 and IPv6 addresses if IPV6_V6ONLY is Timo Sirainen <tss@iki.fi> parents: 3076 diff changeset	378 #endif
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	379 /* specify the address/port we want to listen in */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	380 ret = bind(fd, &so.sa, SIZEOF_SOCKADDR(so));
3537 5ff3b88db948 net_listen(): Print bind() errors only if it's not EADDRINUSE. Also do the Timo Sirainen <tss@iki.fi> parents: 3523 diff changeset	381 if (ret < 0) {
5ff3b88db948 net_listen(): Print bind() errors only if it's not EADDRINUSE. Also do the Timo Sirainen <tss@iki.fi> parents: 3523 diff changeset	382 if (errno != EADDRINUSE) {
5ff3b88db948 net_listen(): Print bind() errors only if it's not EADDRINUSE. Also do the Timo Sirainen <tss@iki.fi> parents: 3523 diff changeset	383 i_error("bind(%s, %u) failed: %m",
5ff3b88db948 net_listen(): Print bind() errors only if it's not EADDRINUSE. Also do the Timo Sirainen <tss@iki.fi> parents: 3523 diff changeset	384 net_ip2addr(my_ip), *port);
5ff3b88db948 net_listen(): Print bind() errors only if it's not EADDRINUSE. Also do the Timo Sirainen <tss@iki.fi> parents: 3523 diff changeset	385 }
5ff3b88db948 net_listen(): Print bind() errors only if it's not EADDRINUSE. Also do the Timo Sirainen <tss@iki.fi> parents: 3523 diff changeset	386 } else {
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	387 /* get the actual port we started listen */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	388 len = SIZEOF_SOCKADDR(so);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	389 ret = getsockname(fd, &so.sa, &len);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	390 if (ret >= 0) {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	391 *port = sin_get_port(&so);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	392
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	393 /* start listening */
3075 9cb91ed5a110 Added backlog parameter for net_listen(). Timo Sirainen <tss@iki.fi>* parents: 2639 diff changeset	394 if (listen(fd, backlog) >= 0)
3537 5ff3b88db948 net_listen(): Print bind() errors only if it's not EADDRINUSE. Also do the Timo Sirainen <tss@iki.fi> parents: 3523 diff changeset	395 return fd;
5ff3b88db948 net_listen(): Print bind() errors only if it's not EADDRINUSE. Also do the Timo Sirainen <tss@iki.fi> parents: 3523 diff changeset	396
5ff3b88db948 net_listen(): Print bind() errors only if it's not EADDRINUSE. Also do the Timo Sirainen <tss@iki.fi> parents: 3523 diff changeset	397 if (errno != EADDRINUSE)
5ff3b88db948 net_listen(): Print bind() errors only if it's not EADDRINUSE. Also do the Timo Sirainen <tss@iki.fi> parents: 3523 diff changeset	398 i_error("listen() failed: %m");
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	399 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	400 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	401
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	402 /* error */
4011 323c09be5f00 Moved dupliated close_save_errno() code to public close_keep_errno() function. Timo Sirainen <timo.sirainen@movial.fi> parents: 3863 diff changeset	403 close_keep_errno(fd);
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	404 return -1;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	405 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	406
3075 9cb91ed5a110 Added backlog parameter for net_listen(). Timo Sirainen <tss@iki.fi>* parents: 2639 diff changeset	407 int net_listen_unix(const char *path, int backlog)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	408 {
5985 8ae4b8d78a25 More union usage to avoid casting. Timo Sirainen <tss@iki.fi> parents: 5984 diff changeset	409 union {
8ae4b8d78a25 More union usage to avoid casting. Timo Sirainen <tss@iki.fi> parents: 5984 diff changeset	410 struct sockaddr sa;
8ae4b8d78a25 More union usage to avoid casting. Timo Sirainen <tss@iki.fi> parents: 5984 diff changeset	411 struct sockaddr_un un;
8ae4b8d78a25 More union usage to avoid casting. Timo Sirainen <tss@iki.fi> parents: 5984 diff changeset	412 } sa;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	413 int fd;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	414
807 35abd7a5d381 Buffer related cleanups. Use PATH_MAX instead of hardcoded 1024 for paths. Timo Sirainen <tss@iki.fi> parents: 805 diff changeset	415 memset(&sa, 0, sizeof(sa));
5985 8ae4b8d78a25 More union usage to avoid casting. Timo Sirainen <tss@iki.fi> parents: 5984 diff changeset	416 sa.un.sun_family = AF_UNIX;
6422 18173a52f721 Renamed strocpy() to i_strocpy(). Timo Sirainen <tss@iki.fi> parents: 6411 diff changeset	417 if (i_strocpy(sa.un.sun_path, path, sizeof(sa.un.sun_path)) < 0) {
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	418 /* too long path */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	419 errno = EINVAL;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	420 return -1;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	421 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	422
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	423 /* create the socket */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	424 fd = socket(PF_UNIX, SOCK_STREAM, 0);
3523 d1ed3b3548db Added some more error messages. Also if net_connect_ip() gives my_ip Timo Sirainen <tss@iki.fi> parents: 3400 diff changeset	425 if (fd == -1) {
d1ed3b3548db Added some more error messages. Also if net_connect_ip() gives my_ip Timo Sirainen <tss@iki.fi> parents: 3400 diff changeset	426 i_error("socket() failed: %m");
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	427 return -1;
3523 d1ed3b3548db Added some more error messages. Also if net_connect_ip() gives my_ip Timo Sirainen <tss@iki.fi> parents: 3400 diff changeset	428 }
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	429
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	430 /* bind */
5985 8ae4b8d78a25 More union usage to avoid casting. Timo Sirainen <tss@iki.fi> parents: 5984 diff changeset	431 if (bind(fd, &sa.sa, sizeof(sa)) < 0) {
3545 0b6539bc22b9 Don't log extra bind() errors for net_listen_unix() either Timo Sirainen <tss@iki.fi> parents: 3537 diff changeset	432 if (errno != EADDRINUSE)
0b6539bc22b9 Don't log extra bind() errors for net_listen_unix() either Timo Sirainen <tss@iki.fi> parents: 3537 diff changeset	433 i_error("bind(%s) failed: %m", path);
0b6539bc22b9 Don't log extra bind() errors for net_listen_unix() either Timo Sirainen <tss@iki.fi> parents: 3537 diff changeset	434 } else {
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	435 /* start listening */
3075 9cb91ed5a110 Added backlog parameter for net_listen(). Timo Sirainen <tss@iki.fi>* parents: 2639 diff changeset	436 if (listen(fd, backlog) == 0)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	437 return fd;
3545 0b6539bc22b9 Don't log extra bind() errors for net_listen_unix() either Timo Sirainen <tss@iki.fi> parents: 3537 diff changeset	438
0b6539bc22b9 Don't log extra bind() errors for net_listen_unix() either Timo Sirainen <tss@iki.fi> parents: 3537 diff changeset	439 if (errno != EADDRINUSE)
0b6539bc22b9 Don't log extra bind() errors for net_listen_unix() either Timo Sirainen <tss@iki.fi> parents: 3537 diff changeset	440 i_error("listen() failed: %m");
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	441 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	442
4011 323c09be5f00 Moved dupliated close_save_errno() code to public close_keep_errno() function. Timo Sirainen <timo.sirainen@movial.fi> parents: 3863 diff changeset	443 close_keep_errno(fd);
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	444 return -1;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	445 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	446
8219 ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	447 int net_listen_unix_unlink_stale(const char *path, int backlog)
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	448 {
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	449 unsigned int i = 0;
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	450 int fd;
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	451
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	452 while ((fd = net_listen_unix(path, backlog)) == -1) {
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	453 if (errno != EADDRINUSE \|\| ++i == 2)
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	454 return -1;
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	455
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	456 /* see if it really exists */
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	457 fd = net_connect_unix(path);
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	458 if (fd != -1 \|\| errno != ECONNREFUSED) {
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	459 if (fd != -1) (void)close(fd);
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	460 errno = EADDRINUSE;
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	461 return -1;
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	462 }
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	463
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	464 /* delete and try again */
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	465 if (unlink(path) < 0 && errno != ENOENT) {
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	466 i_error("unlink(%s) failed: %m", path);
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	467 errno = EADDRINUSE;
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	468 return -1;
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	469 }
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	470 }
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	471 return fd;
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	472 }
ec83f6dcb585 Added net_listen_unix_unlink_stale() and use it where needed to avoid code duplication. Timo Sirainen <tss@iki.fi> parents: 7919 diff changeset	473
903 fd8888f6f037 Naming style changes, finally got tired of most of the typedefs. Also the Timo Sirainen <tss@iki.fi> parents: 807 diff changeset	474 int net_accept(int fd, struct ip_addr addr, unsigned int port)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	475 {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	476 union sockaddr_union so;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	477 int ret;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	478 socklen_t addrlen;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	479
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	480 i_assert(fd >= 0);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	481
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	482 addrlen = sizeof(so);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	483 ret = accept(fd, &so.sa, &addrlen);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	484
680 84e398270f7f net_accept() returns now -2 for fatal failures. Timo Sirainen <tss@iki.fi> parents: 628 diff changeset	485 if (ret < 0) {
5358 a977ad033903 net_listen_unix() API changed a bit. -1 is now returned for errors that can Timo Sirainen <tss@iki.fi> parents: 4745 diff changeset	486 if (errno == EAGAIN \|\| errno == ECONNABORTED)
a977ad033903 net_listen_unix() API changed a bit. -1 is now returned for errors that can Timo Sirainen <tss@iki.fi> parents: 4745 diff changeset	487 return -1;
a977ad033903 net_listen_unix() API changed a bit. -1 is now returned for errors that can Timo Sirainen <tss@iki.fi> parents: 4745 diff changeset	488 else
680 84e398270f7f net_accept() returns now -2 for fatal failures. Timo Sirainen <tss@iki.fi> parents: 628 diff changeset	489 return -2;
84e398270f7f net_accept() returns now -2 for fatal failures. Timo Sirainen <tss@iki.fi> parents: 628 diff changeset	490 }
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	491
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	492 if (addr != NULL) sin_get_ip(&so, addr);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	493 if (port != NULL) *port = sin_get_port(&so);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	494
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	495 return ret;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	496 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	497
183 4a7ab9e94f25 size_t fixes for lib/. Changed OFF_T_FORMAT to PRIuOFF_T which is more Timo Sirainen <tss@iki.fi> parents: 159 diff changeset	498 ssize_t net_receive(int fd, void *buf, size_t len)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	499 {
183 4a7ab9e94f25 size_t fixes for lib/. Changed OFF_T_FORMAT to PRIuOFF_T which is more Timo Sirainen <tss@iki.fi> parents: 159 diff changeset	500 ssize_t ret;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	501
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	502 i_assert(fd >= 0);
183 4a7ab9e94f25 size_t fixes for lib/. Changed OFF_T_FORMAT to PRIuOFF_T which is more Timo Sirainen <tss@iki.fi> parents: 159 diff changeset	503 i_assert(len <= SSIZE_T_MAX);
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	504
3681 771cd6776d4b Use read() instead of recv() in net_receive(), so it works even with Timo Sirainen <tss@iki.fi> parents: 3621 diff changeset	505 ret = read(fd, buf, len);
781 9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	506 if (ret == 0) {
9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	507 /* disconnected */
9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	508 errno = 0;
9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	509 return -2;
9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	510 }
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	511
6825 85385079b044 Use likely() and unlikely() macros to make commonly checked error handling Timo Sirainen <tss@iki.fi> parents: 6666 diff changeset	512 if (unlikely(ret < 0)) {
781 9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	513 if (errno == EINTR \|\| errno == EAGAIN)
9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	514 return 0;
9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	515
9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	516 if (errno == ECONNRESET \|\| errno == ETIMEDOUT) {
9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	517 /* treat as disconnection */
9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	518 return -2;
9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	519 }
9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	520 }
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	521
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	522 return ret;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	523 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	524
183 4a7ab9e94f25 size_t fixes for lib/. Changed OFF_T_FORMAT to PRIuOFF_T which is more Timo Sirainen <tss@iki.fi> parents: 159 diff changeset	525 ssize_t net_transmit(int fd, const void *data, size_t len)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	526 {
183 4a7ab9e94f25 size_t fixes for lib/. Changed OFF_T_FORMAT to PRIuOFF_T which is more Timo Sirainen <tss@iki.fi> parents: 159 diff changeset	527 ssize_t ret;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	528
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	529 i_assert(fd >= 0);
183 4a7ab9e94f25 size_t fixes for lib/. Changed OFF_T_FORMAT to PRIuOFF_T which is more Timo Sirainen <tss@iki.fi> parents: 159 diff changeset	530 i_assert(len <= SSIZE_T_MAX);
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	531
64 83ae914a583a added t_strdup_noconst() which can be used instead of (char ) t_strdup(). Timo Sirainen <tss@iki.fi>* parents: 34 diff changeset	532 ret = send(fd, data, len, 0);
6825 85385079b044 Use likely() and unlikely() macros to make commonly checked error handling Timo Sirainen <tss@iki.fi> parents: 6666 diff changeset	533 if (unlikely(ret == -1 && (errno == EINTR \|\| errno == EAGAIN)))
781 9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	534 return 0;
9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	535
6825 85385079b044 Use likely() and unlikely() macros to make commonly checked error handling Timo Sirainen <tss@iki.fi> parents: 6666 diff changeset	536 if (unlikely(errno == EPIPE))
781 9cb7022749e7 net_receive, net_transmit: Return -2 for regular disconnection errors. Don't Timo Sirainen <tss@iki.fi> parents: 780 diff changeset	537 return -2;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	538
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	539 return ret;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	540 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	541
4745 7ee0bb1b2d97 Changed ips_count to unsigned int in net_gethostbyname(). Also removed Timo Sirainen <tss@iki.fi> parents: 4699 diff changeset	542 int net_gethostbyname(const char addr, struct ip_addr *ips,
7ee0bb1b2d97 Changed ips_count to unsigned int in net_gethostbyname(). Also removed Timo Sirainen <tss@iki.fi> parents: 4699 diff changeset	543 unsigned int *ips_count)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	544 {
805 5ac361acb316 Marked all non-trivial buffer modifications with @UNSAFE tag. Several Timo Sirainen <tss@iki.fi> parents: 781 diff changeset	545 /* @UNSAFE */
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	546 #ifdef HAVE_IPV6
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	547 union sockaddr_union *so;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	548 struct addrinfo hints, ai, origai;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	549 int host_error;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	550 #else
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	551 struct hostent *hp;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	552 #endif
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	553 int count;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	554
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	555 *ips = NULL;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	556 *ips_count = 0;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	557
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	558 #ifdef HAVE_IPV6
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	559 memset(&hints, 0, sizeof(struct addrinfo));
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	560 hints.ai_socktype = SOCK_STREAM;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	561
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	562 /* save error to host_error for later use */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	563 host_error = getaddrinfo(addr, NULL, &hints, &ai);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	564 if (host_error != 0)
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	565 return host_error;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	566
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	567 /* get number of IPs */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	568 origai = ai;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	569 for (count = 0; ai != NULL; ai = ai->ai_next)
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	570 count++;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	571
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	572 *ips_count = count;
903 fd8888f6f037 Naming style changes, finally got tired of most of the typedefs. Also the Timo Sirainen <tss@iki.fi> parents: 807 diff changeset	573 ips = t_malloc(sizeof(struct ip_addr) count);
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	574
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	575 count = 0;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	576 for (ai = origai; ai != NULL; ai = ai->ai_next, count++) {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	577 so = (union sockaddr_union *) ai->ai_addr;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	578
2113 c5817f302aa6 net_gethostbyname() was broken with IPv6 enabled (wasn't really used with Timo Sirainen <tss@iki.fi> parents: 2098 diff changeset	579 sin_get_ip(so, &(*ips)[count]);
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	580 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	581 freeaddrinfo(origai);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	582 #else
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	583 hp = gethostbyname(addr);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	584 if (hp == NULL)
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	585 return h_errno;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	586
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	587 /* get number of IPs */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	588 count = 0;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	589 while (hp->h_addr_list[count] != NULL)
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	590 count++;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	591
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	592 *ips_count = count;
903 fd8888f6f037 Naming style changes, finally got tired of most of the typedefs. Also the Timo Sirainen <tss@iki.fi> parents: 807 diff changeset	593 ips = t_malloc(sizeof(struct ip_addr) count);
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	594
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	595 while (count > 0) {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	596 count--;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	597
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	598 (*ips)[count].family = AF_INET;
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	599 memcpy(&(*ips)[count].u.ip4, hp->h_addr_list[count],
74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	600 sizeof((*ips)[count].u.ip4));
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	601 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	602 #endif
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	603
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	604 return 0;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	605 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	606
903 fd8888f6f037 Naming style changes, finally got tired of most of the typedefs. Also the Timo Sirainen <tss@iki.fi> parents: 807 diff changeset	607 int net_getsockname(int fd, struct ip_addr addr, unsigned int port)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	608 {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	609 union sockaddr_union so;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	610 socklen_t addrlen;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	611
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	612 i_assert(fd >= 0);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	613
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	614 addrlen = sizeof(so);
4018 989dd95aa8b9 Enable -Wstrict-aliasing=2 warning and fixed a couple of warnings it gave. Timo Sirainen <tss@iki.fi> parents: 4011 diff changeset	615 if (getsockname(fd, &so.sa, &addrlen) == -1)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	616 return -1;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	617
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	618 if (addr != NULL) sin_get_ip(&so, addr);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	619 if (port != NULL) *port = sin_get_port(&so);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	620
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	621 return 0;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	622 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	623
2098 24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	624 int net_getpeername(int fd, struct ip_addr addr, unsigned int port)
24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	625 {
24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	626 union sockaddr_union so;
24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	627 socklen_t addrlen;
24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	628
24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	629 i_assert(fd >= 0);
24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	630
24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	631 addrlen = sizeof(so);
4018 989dd95aa8b9 Enable -Wstrict-aliasing=2 warning and fixed a couple of warnings it gave. Timo Sirainen <tss@iki.fi> parents: 4011 diff changeset	632 if (getpeername(fd, &so.sa, &addrlen) == -1)
2098 24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	633 return -1;
24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	634
24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	635 if (addr != NULL) sin_get_ip(&so, addr);
24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	636 if (port != NULL) *port = sin_get_port(&so);
24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	637
24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	638 return 0;
24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	639 }
24e382b88232 Added net_getpeername() Timo Sirainen <tss@iki.fi> parents: 1915 diff changeset	640
9843 95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	641 int net_getunixname(int fd, const char **name_r)
95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	642 {
95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	643 struct sockaddr_un sa;
95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	644 socklen_t addrlen = sizeof(sa);
95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	645
95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	646 if (getsockname(fd, (void *)&sa, &addrlen) < 0)
95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	647 return -1;
95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	648 if (sa.sun_family != AF_UNIX) {
95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	649 errno = ENOTSOCK;
95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	650 return -1;
95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	651 }
95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	652 *name_r = t_strdup(sa.sun_path);
95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	653 return 0;
95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	654 }
95fba8612a87 Added net_getunixname(). Timo Sirainen <tss@iki.fi> parents: 8590 diff changeset	655
1485 8c28289a15a1 s/host/addr/ in a few network functions Timo Sirainen <tss@iki.fi> parents: 1268 diff changeset	656 const char net_ip2addr(const struct ip_addr ip)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	657 {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	658 #ifdef HAVE_IPV6
1485 8c28289a15a1 s/host/addr/ in a few network functions Timo Sirainen <tss@iki.fi> parents: 1268 diff changeset	659 char addr[MAX_IP_LEN+1];
805 5ac361acb316 Marked all non-trivial buffer modifications with @UNSAFE tag. Several Timo Sirainen <tss@iki.fi> parents: 781 diff changeset	660
1485 8c28289a15a1 s/host/addr/ in a few network functions Timo Sirainen <tss@iki.fi> parents: 1268 diff changeset	661 addr[MAX_IP_LEN] = '\0';
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	662 if (inet_ntop(ip->family, &ip->u.ip6, addr, MAX_IP_LEN) == NULL)
805 5ac361acb316 Marked all non-trivial buffer modifications with @UNSAFE tag. Several Timo Sirainen <tss@iki.fi> parents: 781 diff changeset	663 return NULL;
5ac361acb316 Marked all non-trivial buffer modifications with @UNSAFE tag. Several Timo Sirainen <tss@iki.fi> parents: 781 diff changeset	664
1485 8c28289a15a1 s/host/addr/ in a few network functions Timo Sirainen <tss@iki.fi> parents: 1268 diff changeset	665 return t_strdup(addr);
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	666 #else
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	667 unsigned long ip4;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	668
805 5ac361acb316 Marked all non-trivial buffer modifications with @UNSAFE tag. Several Timo Sirainen <tss@iki.fi> parents: 781 diff changeset	669 if (ip->family != AF_INET)
5ac361acb316 Marked all non-trivial buffer modifications with @UNSAFE tag. Several Timo Sirainen <tss@iki.fi> parents: 781 diff changeset	670 return NULL;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	671
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	672 ip4 = ntohl(ip->u.ip4.s_addr);
805 5ac361acb316 Marked all non-trivial buffer modifications with @UNSAFE tag. Several Timo Sirainen <tss@iki.fi> parents: 781 diff changeset	673 return t_strdup_printf("%lu.%lu.%lu.%lu",
5ac361acb316 Marked all non-trivial buffer modifications with @UNSAFE tag. Several Timo Sirainen <tss@iki.fi> parents: 781 diff changeset	674 (ip4 & 0xff000000UL) >> 24,
5ac361acb316 Marked all non-trivial buffer modifications with @UNSAFE tag. Several Timo Sirainen <tss@iki.fi> parents: 781 diff changeset	675 (ip4 & 0x00ff0000) >> 16,
5ac361acb316 Marked all non-trivial buffer modifications with @UNSAFE tag. Several Timo Sirainen <tss@iki.fi> parents: 781 diff changeset	676 (ip4 & 0x0000ff00) >> 8,
5ac361acb316 Marked all non-trivial buffer modifications with @UNSAFE tag. Several Timo Sirainen <tss@iki.fi> parents: 781 diff changeset	677 (ip4 & 0x000000ff));
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	678 #endif
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	679 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	680
1485 8c28289a15a1 s/host/addr/ in a few network functions Timo Sirainen <tss@iki.fi> parents: 1268 diff changeset	681 int net_addr2ip(const char addr, struct ip_addr ip)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	682 {
11448 bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	683 int ret;
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	684
1485 8c28289a15a1 s/host/addr/ in a few network functions Timo Sirainen <tss@iki.fi> parents: 1268 diff changeset	685 if (strchr(addr, ':') != NULL) {
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	686 /* IPv6 */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	687 ip->family = AF_INET6;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	688 #ifdef HAVE_IPV6
11448 bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	689 T_BEGIN {
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	690 if (addr[0] == '[') {
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	691 /* allow [ipv6 addr] */
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	692 unsigned int len = strlen(addr);
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	693 if (addr[len-1] == ']')
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	694 addr = t_strndup(addr+1, len-2);
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	695 }
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	696 ret = inet_pton(AF_INET6, addr, &ip->u.ip6);
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	697 } T_END;
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	698 if (ret == 0)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	699 return -1;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	700 #else
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	701 ip->u.ip4.s_addr = 0;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	702 #endif
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	703 } else {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	704 /* IPv4 */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	705 ip->family = AF_INET;
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	706 if (inet_aton(addr, &ip->u.ip4) == 0)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	707 return -1;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	708 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	709
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	710 return 0;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	711 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	712
4684 4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	713 int net_ipv6_mapped_ipv4_convert(const struct ip_addr *src,
4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	714 struct ip_addr *dest)
4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	715 {
4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	716 #ifdef HAVE_IPV6
4699 9e4cc68b71b2 Fix net_ipv6_mapped_ipv4_convert() to be actually portable. Timo Sirainen <tss@iki.fi> parents: 4684 diff changeset	717 static uint8_t v4_prefix[] =
9e4cc68b71b2 Fix net_ipv6_mapped_ipv4_convert() to be actually portable. Timo Sirainen <tss@iki.fi> parents: 4684 diff changeset	718 { 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0xff, 0xff };
9e4cc68b71b2 Fix net_ipv6_mapped_ipv4_convert() to be actually portable. Timo Sirainen <tss@iki.fi> parents: 4684 diff changeset	719
4684 4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	720 if (!IPADDR_IS_V6(src))
4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	721 return -1;
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	722 if (memcmp(src->u.ip6.s6_addr, v4_prefix, sizeof(v4_prefix)) != 0)
4684 4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	723 return -1;
4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	724
4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	725 dest->family = AF_INET;
5984 74a6130211c2 Changed struct ip_addr to use union for ipv4/ipv6 structs so we don't have Timo Sirainen <tss@iki.fi> parents: 5865 diff changeset	726 memcpy(&dest->u.ip6, &src->u.ip6.s6_addr[3*4], 4);
4684 4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	727 return 0;
4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	728 #else
4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	729 return -1;
4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	730 #endif
4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	731 }
4f1df4b90500 Added net_ipv6_mapped_ipv4_convert(). Timo Sirainen <tss@iki.fi> parents: 4018 diff changeset	732
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	733 int net_geterror(int fd)
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	734 {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	735 int data;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	736 socklen_t len = sizeof(data);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	737
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	738 if (getsockopt(fd, SOL_SOCKET, SO_ERROR, &data, &len) == -1)
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	739 return -1;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	740
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	741 return data;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	742 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	743
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	744 const char *net_gethosterror(int error)
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	745 {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	746 #ifdef HAVE_IPV6
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	747 i_assert(error != 0);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	748
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	749 return gai_strerror(error);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	750 #else
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	751 switch (error) {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	752 case HOST_NOT_FOUND:
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	753 return "Host not found";
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	754 case NO_ADDRESS:
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	755 return "No IP address found for name";
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	756 case NO_RECOVERY:
6666 fc5e27a49c87 Typofix in error message. Timo Sirainen <tss@iki.fi> parents: 6429 diff changeset	757 return "A non-recoverable name server error occurred";
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	758 case TRY_AGAIN:
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	759 return "A temporary error on an authoritative name server";
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	760 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	761
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	762 /* unknown error */
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	763 return NULL;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	764 #endif
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	765 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	766
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	767 int net_hosterror_notfound(int error)
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	768 {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	769 #ifdef HAVE_IPV6
1915 79790750c349 importing new index code. mbox still broken. Timo Sirainen <tss@iki.fi> parents: 1871 diff changeset	770 #ifdef EAI_NODATA /* NODATA is depricated */
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	771 return error != 1 && (error == EAI_NONAME \|\| error == EAI_NODATA);
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	772 #else
1915 79790750c349 importing new index code. mbox still broken. Timo Sirainen <tss@iki.fi> parents: 1871 diff changeset	773 return error != 1 && (error == EAI_NONAME);
79790750c349 importing new index code. mbox still broken. Timo Sirainen <tss@iki.fi> parents: 1871 diff changeset	774 #endif
79790750c349 importing new index code. mbox still broken. Timo Sirainen <tss@iki.fi> parents: 1871 diff changeset	775 #else
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	776 return error == HOST_NOT_FOUND \|\| error == NO_ADDRESS;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	777 #endif
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	778 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	779
2113 c5817f302aa6 net_gethostbyname() was broken with IPv6 enabled (wasn't really used with Timo Sirainen <tss@iki.fi> parents: 2098 diff changeset	780 const char *net_getservbyport(unsigned short port)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	781 {
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	782 struct servent *entry;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	783
349 fd32faeb7ba5 keep the port unsigned. Timo Sirainen <tss@iki.fi> parents: 183 diff changeset	784 entry = getservbyport(htons(port), "tcp");
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	785 return entry == NULL ? NULL : entry->s_name;
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	786 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	787
3863 55df57c028d4 Added "bool" type and changed all ints that were used as booleans to bool. Timo Sirainen <tss@iki.fi> parents: 3681 diff changeset	788 bool is_ipv4_address(const char *addr)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	789 {
1485 8c28289a15a1 s/host/addr/ in a few network functions Timo Sirainen <tss@iki.fi> parents: 1268 diff changeset	790 while (*addr != '\0') {
8c28289a15a1 s/host/addr/ in a few network functions Timo Sirainen <tss@iki.fi> parents: 1268 diff changeset	791 if (addr != '.' && !i_isdigit(addr))
3863 55df57c028d4 Added "bool" type and changed all ints that were used as booleans to bool. Timo Sirainen <tss@iki.fi> parents: 3681 diff changeset	792 return FALSE;
1485 8c28289a15a1 s/host/addr/ in a few network functions Timo Sirainen <tss@iki.fi> parents: 1268 diff changeset	793 addr++;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	794 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	795
3863 55df57c028d4 Added "bool" type and changed all ints that were used as booleans to bool. Timo Sirainen <tss@iki.fi> parents: 3681 diff changeset	796 return TRUE;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	797 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	798
3863 55df57c028d4 Added "bool" type and changed all ints that were used as booleans to bool. Timo Sirainen <tss@iki.fi> parents: 3681 diff changeset	799 bool is_ipv6_address(const char *addr)
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	800 {
11448 bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	801 bool have_prefix = FALSE;
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	802
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	803 if (*addr == '[') {
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	804 have_prefix = TRUE;
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	805 addr++;
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	806 }
1485 8c28289a15a1 s/host/addr/ in a few network functions Timo Sirainen <tss@iki.fi> parents: 1268 diff changeset	807 while (*addr != '\0') {
11448 bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	808 if (addr != ':' && !i_isxdigit(addr)) {
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	809 if (have_prefix && *addr == ']' && addr[1] == '\0')
bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	810 break;
3863 55df57c028d4 Added "bool" type and changed all ints that were used as booleans to bool. Timo Sirainen <tss@iki.fi> parents: 3681 diff changeset	811 return FALSE;
11448 bdb46ba87203 Added support for [] around ipv6 addresses everywhere. Timo Sirainen <tss@iki.fi> parents: 11340 diff changeset	812 }
1485 8c28289a15a1 s/host/addr/ in a few network functions Timo Sirainen <tss@iki.fi> parents: 1268 diff changeset	813 addr++;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	814 }
3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	815
3863 55df57c028d4 Added "bool" type and changed all ints that were used as booleans to bool. Timo Sirainen <tss@iki.fi> parents: 3681 diff changeset	816 return TRUE;
0 3b1985cbc908 Initial revision Timo Sirainen <tss@iki.fi> parents: diff changeset	817 }
7517 e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	818
7919 423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	819 int net_parse_range(const char network, struct ip_addr ip_r,
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	820 unsigned int *bits_r)
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	821 {
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	822 const char *p;
11086 260e190306b0 Started using str_to_() functions instead of libc's ones. Timo Sirainen <tss@iki.fi>* parents: 10789 diff changeset	823 unsigned int bits, max_bits;
7919 423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	824
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	825 p = strchr(network, '/');
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	826 if (p != NULL)
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	827 network = t_strdup_until(network, p++);
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	828
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	829 if (net_addr2ip(network, ip_r) < 0)
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	830 return -1;
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	831
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	832 max_bits = IPADDR_IS_V4(ip_r) ? 32 : 128;
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	833 if (p == NULL) {
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	834 /* full IP address must match */
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	835 bits = max_bits;
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	836 } else {
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	837 /* get the network mask */
11086 260e190306b0 Started using str_to_() functions instead of libc's ones. Timo Sirainen <tss@iki.fi>* parents: 10789 diff changeset	838 if (str_to_uint(p, &bits) < 0 \|\| bits > max_bits)
7919 423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	839 return -1;
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	840 }
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	841 *bits_r = bits;
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	842 return 0;
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	843 }
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	844
7517 e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	845 bool net_is_in_network(const struct ip_addr *ip,
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	846 const struct ip_addr *net_ip, unsigned int bits)
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	847 {
7919 423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	848 struct ip_addr tmp_ip;
7517 e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	849 const uint32_t ip1, ip2;
7520 85203e817f90 net_is_in_network(): Fixed to work with big endian machines. Timo Sirainen <tss@iki.fi> parents: 7517 diff changeset	850 uint32_t mask, i1, i2;
7517 e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	851 unsigned int pos, i;
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	852
7919 423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	853 if (net_ipv6_mapped_ipv4_convert(ip, &tmp_ip) == 0) {
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	854 /* IPv4 address mapped disguised as IPv6 address */
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	855 ip = &tmp_ip;
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	856 }
423b8e3fedbb Created net_parse_range() from auth code. Timo Sirainen <tss@iki.fi> parents: 7520 diff changeset	857
7517 e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	858 if (IPADDR_IS_V4(ip) != IPADDR_IS_V4(net_ip)) {
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	859 /* one is IPv6 and one is IPv4 */
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	860 return FALSE;
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	861 }
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	862 i_assert(IPADDR_IS_V6(ip) == IPADDR_IS_V6(net_ip));
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	863
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	864 if (IPADDR_IS_V4(ip)) {
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	865 ip1 = &ip->u.ip4.s_addr;
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	866 ip2 = &net_ip->u.ip4.s_addr;
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	867 } else {
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	868 #ifdef HAVE_IPV6
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	869 ip1 = (const void *)&ip->u.ip6;
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	870 ip2 = (const void *)&net_ip->u.ip6;
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	871 #else
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	872 /* shouldn't get here */
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	873 return FALSE;
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	874 #endif
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	875 }
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	876
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	877 /* check first the full 32bit ints */
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	878 for (pos = 0, i = 0; pos + 32 <= bits; pos += 32, i++) {
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	879 if (ip1[i] != ip2[i])
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	880 return FALSE;
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	881 }
7520 85203e817f90 net_is_in_network(): Fixed to work with big endian machines. Timo Sirainen <tss@iki.fi> parents: 7517 diff changeset	882 i1 = htonl(ip1[i]);
85203e817f90 net_is_in_network(): Fixed to work with big endian machines. Timo Sirainen <tss@iki.fi> parents: 7517 diff changeset	883 i2 = htonl(ip2[i]);
7517 e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	884
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	885 /* check the last full bytes */
7520 85203e817f90 net_is_in_network(): Fixed to work with big endian machines. Timo Sirainen <tss@iki.fi> parents: 7517 diff changeset	886 for (mask = 0xff000000; pos + 8 <= bits; pos += 8, mask >>= 8) {
85203e817f90 net_is_in_network(): Fixed to work with big endian machines. Timo Sirainen <tss@iki.fi> parents: 7517 diff changeset	887 if ((i1 & mask) != (i2 & mask))
7517 e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	888 return FALSE;
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	889 }
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	890
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	891 /* check the last bits, they're reversed in bytes */
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	892 bits -= pos;
7520 85203e817f90 net_is_in_network(): Fixed to work with big endian machines. Timo Sirainen <tss@iki.fi> parents: 7517 diff changeset	893 for (mask = 0x80000000 >> (pos % 32); bits > 0; bits--, mask >>= 1) {
85203e817f90 net_is_in_network(): Fixed to work with big endian machines. Timo Sirainen <tss@iki.fi> parents: 7517 diff changeset	894 if ((i1 & mask) != (i2 & mask))
7517 e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	895 return FALSE;
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	896 }
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	897 return TRUE;
e0007da64cdc Moved net_is_in_network() to lib/network.c. Timo Sirainen <tss@iki.fi> parents: 7274 diff changeset	898 }

Mercurial > dovecot > core-2.2

annotate src/lib/network.c @ 11564:c24ee1ebb159 HEAD