Mercurial > dovecot > core-2.2

annotate src/lib/network.c @ 10158:1bc88aa1373f HEAD

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