annotate src/lib/network.c @ 12138:e403f4dc95ea

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