ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/gvpe/src/vpn.C
(Generate patch)

Comparing gvpe/src/vpn.C (file contents):
Revision 1.8 by pcg, Mon Apr 7 01:28:56 2003 UTC vs.
Revision 1.64 by root, Tue Dec 4 10:29:43 2012 UTC

1/* 1/*
2 vpn.C -- handle the protocol, encryption, handshaking etc. 2 vpn.C -- handle the protocol, encryption, handshaking etc.
3 Copyright (C) 2003-2008,2010,2011 Marc Lehmann <gvpe@schmorp.de>
3 4
5 This file is part of GVPE.
6
4 This program is free software; you can redistribute it and/or modify 7 GVPE is free software; you can redistribute it and/or modify it
5 it under the terms of the GNU General Public License as published by 8 under the terms of the GNU General Public License as published by the
6 the Free Software Foundation; either version 2 of the License, or 9 Free Software Foundation; either version 3 of the License, or (at your
7 (at your option) any later version. 10 option) any later version.
8 11
9 This program is distributed in the hope that it will be useful, 12 This program is distributed in the hope that it will be useful, but
10 but WITHOUT ANY WARRANTY; without even the implied warranty of 13 WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General
12 GNU General Public License for more details. 15 Public License for more details.
13 16
14 You should have received a copy of the GNU General Public License 17 You should have received a copy of the GNU General Public License along
15 along with this program; if not, write to the Free Software 18 with this program; if not, see <http://www.gnu.org/licenses/>.
16 Foundation, Inc. 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA 19
20 Additional permission under GNU GPL version 3 section 7
21
22 If you modify this Program, or any covered work, by linking or
23 combining it with the OpenSSL project's OpenSSL library (or a modified
24 version of that library), containing parts covered by the terms of the
25 OpenSSL or SSLeay licenses, the licensors of this Program grant you
26 additional permission to convey the resulting work. Corresponding
27 Source for a non-source form of such a combination shall include the
28 source code for the parts of OpenSSL used as well as that of the
29 covered work.
17*/ 30*/
18 31
19#include "config.h" 32#include "config.h"
20 33
21#include <list> 34#include <list>
22 35
36#include <cstdio>
37#include <cstring>
23#include <cstdlib> 38#include <cstdlib>
24#include <cstring>
25#include <cstdio>
26 39
27#include <sys/types.h> 40#include <sys/types.h>
28#include <sys/socket.h> 41#include <sys/socket.h>
29#include <sys/poll.h>
30#include <sys/wait.h> 42#include <sys/wait.h>
31#include <netinet/in.h> 43#include <sys/stat.h>
32#include <arpa/inet.h>
33#include <errno.h> 44#include <errno.h>
34#include <time.h> 45#include <time.h>
35#include <unistd.h> 46#include <unistd.h>
47#include <fcntl.h>
48#include <sys/socket.h>
49
50#include "netcompat.h"
36 51
37#include "pidfile.h" 52#include "pidfile.h"
38 53
39#include "connection.h" 54#include "connection.h"
40#include "util.h" 55#include "util.h"
41#include "vpn.h" 56#include "vpn.h"
42 57
58using namespace std;
59
60vpn network; // THE vpn (bad design...)
61
43///////////////////////////////////////////////////////////////////////////// 62/////////////////////////////////////////////////////////////////////////////
44 63
45const char *vpn::script_if_up () 64static void inline
65set_tos (int fd, int &tos_prev, int tos)
66{
67#if defined(SOL_IP) && defined(IP_TOS)
68 if (tos_prev == tos)
69 return;
70
71 tos_prev = tos;
72 setsockopt (fd, SOL_IP, IP_TOS, &tos, sizeof tos);
73#endif
74}
75
76void
77vpn::script_init_env ()
46{ 78{
47 // the tunnel device mtu should be the physical mtu - overhead 79 // the tunnel device mtu should be the physical mtu - overhead
48 // the tricky part is rounding to the cipher key blocksize 80 // the tricky part is rounding to the cipher key blocksize
49 int mtu = conf.mtu - ETH_OVERHEAD - VPE_OVERHEAD - MAX_OVERHEAD; 81 int mtu = conf.mtu - ETH_OVERHEAD - VPE_OVERHEAD - MAX_OVERHEAD;
50 mtu += ETH_OVERHEAD - 6 - 6; // now we have the data portion 82 mtu += ETH_OVERHEAD - 6 - 6; // now we have the data portion
51 mtu -= mtu % EVP_CIPHER_block_size (CIPHER); // round 83 mtu -= mtu % EVP_CIPHER_block_size (CIPHER); // round
52 mtu -= ETH_OVERHEAD - 6 - 6; // and get interface mtu again 84 mtu -= ETH_OVERHEAD - 6 - 6; // and get interface mtu again
53 85
54 char *env; 86 char *env;
55 asprintf (&env, "CONFBASE=%s", confbase); 87 asprintf (&env, "CONFBASE=%s", confbase); putenv (env);
56 putenv (env);
57 asprintf (&env, "NODENAME=%s", THISNODE->nodename);
58 putenv (env);
59 asprintf (&env, "NODEID=%d", THISNODE->id);
60 putenv (env);
61 asprintf (&env, "IFNAME=%s", tap->interface ()); 88 asprintf (&env, "IFNAME=%s", tap->interface ()); putenv (env);
62 putenv (env); 89 asprintf (&env, "IFTYPE=%s", IFTYPE); putenv (env);
90 asprintf (&env, "IFSUBTYPE=%s", IFSUBTYPE); putenv (env);
63 asprintf (&env, "MTU=%d", mtu); 91 asprintf (&env, "MTU=%d", mtu); putenv (env);
64 putenv (env); 92 asprintf (&env, "NODES=%d", conns.size ()); putenv (env);
65 asprintf (&env, "MAC=%02x:%02x:%02x:%02x:%02x:%02x", 93 asprintf (&env, "NODEID=%d", THISNODE->id); putenv (env);
66 0xfe, 0xfd, 0x80, 0x00, THISNODE->id >> 8,
67 THISNODE->id & 0xff);
68 putenv (env);
69 94
95 conns [THISNODE->id - 1]->script_init_env ("");
96
97 for (conns_vector::iterator c = conns.begin (); c != conns.end (); ++c)
98 {
99 char ext[16];
100 snprintf (ext, 16, "_%d", (*c)->conf->id);
101 (*c)->script_init_env (ext);
102 }
103}
104
105inline const char *
106vpn::script_if_init ()
107{
108 script_init_env ();
109
110 return tap->if_up ();
111}
112
113inline const char *
114vpn::script_if_up ()
115{
116 script_init_env ();
117
118 char *filename;
119 asprintf (&filename,
120 "%s/%s",
121 confbase,
70 return ::conf.script_if_up ? ::conf.script_if_up : "if-up"; 122 ::conf.script_if_up ? ::conf.script_if_up : "if-up");
123
124 return filename;
125}
126
127int
128vpn::setup_socket (u8 prot, int family, int type, int proto)
129{
130 int fd = socket (family, type, proto);
131
132 if (fd < 0)
133 {
134 slog (L_ERR, _("unable to create %s socket: %s."), strprotocol (prot), strerror (errno));
135 return fd;
136 }
137
138 fcntl (fd, F_SETFL, O_NONBLOCK);
139 fcntl (fd, F_SETFD, FD_CLOEXEC);
140
141#ifdef SO_MARK
142 if (::conf.nfmark)
143 if (setsockopt (fd, SOL_SOCKET, SO_MARK, &::conf.nfmark, sizeof ::conf.nfmark))
144 slog (L_WARN, _("unable to set nfmark on %s socket: %s"), strprotocol (prot), strerror (errno));
145#endif
146
147 return fd;
71} 148}
72 149
73int 150int
74vpn::setup () 151vpn::setup ()
75{ 152{
153 int success = 0;
154
155 ipv4_tos = -1;
76 ipv4_fd = -1; 156 ipv4_fd = -1;
77 157
78 if (THISNODE->protocols & PROT_IPv4 && ::conf.ip_proto) 158 if (THISNODE->protocols & PROT_IPv4 && ::conf.ip_proto)
79 { 159 {
80 ipv4_fd = socket (PF_INET, SOCK_RAW, ::conf.ip_proto); 160 ipv4_fd = setup_socket (PROT_IPv4, PF_INET, SOCK_RAW, ::conf.ip_proto);
81 161
82 if (ipv4_fd < 0) 162 if (ipv4_fd < 0)
83 return -1; 163 return -1;
84 164
85 sockinfo si (THISNODE, PROT_IPv4); 165#if defined(SOL_IP) && defined(IP_MTU_DISCOVER)
86
87 if (bind (ipv4_fd, si.sav4 (), si.salenv4 ()))
88 {
89 slog (L_ERR, _("can't bind ipv4 socket on %s: %s"), (const char *)si, strerror (errno));
90 exit (1);
91 }
92
93#ifdef IP_MTU_DISCOVER
94 // this I really consider a linux bug. I am neither connected 166 // this I really consider a linux bug. I am neither connected
95 // nor do I fragment myself. Linux still sets DF and doesn't 167 // nor do I fragment myself. Linux still sets DF and doesn't
96 // fragment for me sometimes. 168 // fragment for me sometimes.
97 { 169 {
98 int oval = IP_PMTUDISC_DONT; 170 int oval = IP_PMTUDISC_DONT;
99 setsockopt (ipv4_fd, SOL_IP, IP_MTU_DISCOVER, &oval, sizeof oval); 171 setsockopt (ipv4_fd, SOL_IP, IP_MTU_DISCOVER, &oval, sizeof oval);
100 } 172 }
101#endif 173#endif
102 174
175 sockinfo si (THISNODE, PROT_IPv4);
176
177 if (bind (ipv4_fd, si.sav4 (), si.salenv4 ()))
178 {
179 slog (L_ERR, _("can't bind ipv4 socket on %s: %s, exiting."), (const char *)si, strerror (errno));
180 return -1;
181 }
182
103 ipv4_ev_watcher.start (ipv4_fd, POLLIN); 183 ipv4_ev_watcher.start (ipv4_fd, EV_READ);
184 ++success;
104 } 185 }
186 else
187 THISNODE->protocols &= ~PROT_IPv4;
105 188
189 udpv4_tos = -1;
106 udpv4_fd = -1; 190 udpv4_fd = -1;
107 191
108 if (THISNODE->protocols & PROT_UDPv4 && THISNODE->udp_port) 192 if (THISNODE->protocols & PROT_UDPv4 && THISNODE->udp_port)
109 { 193 {
110 udpv4_fd = socket (PF_INET, SOCK_DGRAM, IPPROTO_UDP); 194 udpv4_fd = setup_socket (PROT_UDPv4, PF_INET, SOCK_DGRAM, IPPROTO_UDP);
111 195
112 if (udpv4_fd < 0) 196 if (udpv4_fd < 0)
113 return -1; 197 return -1;
114 198
115 // standard daemon practise... 199 // standard daemon practise...
116 { 200 {
117 int oval = 1; 201 int oval = 1;
118 setsockopt (udpv4_fd, SOL_SOCKET, SO_REUSEADDR, &oval, sizeof oval); 202 setsockopt (udpv4_fd, SOL_SOCKET, SO_REUSEADDR, &oval, sizeof oval);
119 } 203 }
120 204
121 sockinfo si (THISNODE, PROT_UDPv4); 205#if defined(SOL_IP) && defined(IP_MTU_DISCOVER)
122
123 if (bind (udpv4_fd, si.sav4 (), si.salenv4 ()))
124 {
125 slog (L_ERR, _("can't bind udpv4 on %s: %s"), (const char *)si, strerror (errno));
126 exit (1);
127 }
128
129#ifdef IP_MTU_DISCOVER
130 // this I really consider a linux bug. I am neither connected 206 // this I really consider a linux bug. I am neither connected
131 // nor do I fragment myself. Linux still sets DF and doesn't 207 // nor do I fragment myself. Linux still sets DF and doesn't
132 // fragment for me sometimes. 208 // fragment for me sometimes.
133 { 209 {
134 int oval = IP_PMTUDISC_DONT; 210 int oval = IP_PMTUDISC_DONT;
135 setsockopt (udpv4_fd, SOL_IP, IP_MTU_DISCOVER, &oval, sizeof oval); 211 setsockopt (udpv4_fd, SOL_IP, IP_MTU_DISCOVER, &oval, sizeof oval);
136 } 212 }
137#endif 213#endif
138 214
215 sockinfo si (THISNODE, PROT_UDPv4);
216
217 if (bind (udpv4_fd, si.sav4 (), si.salenv4 ()))
218 {
219 slog (L_ERR, _("can't bind udpv4 on %s: %s, exiting."), (const char *)si, strerror (errno));
220 return -1;
221 }
222
139 udpv4_ev_watcher.start (udpv4_fd, POLLIN); 223 udpv4_ev_watcher.start (udpv4_fd, EV_READ);
224 ++success;
225 }
226 else
227 THISNODE->protocols &= ~PROT_UDPv4;
228
229 icmpv4_tos = -1;
230 icmpv4_fd = -1;
231
232#if ENABLE_ICMP
233 if (THISNODE->protocols & PROT_ICMPv4)
234 {
235 icmpv4_fd = setup_socket (PROT_ICMPv4, PF_INET, SOCK_RAW, IPPROTO_ICMP);
236
237 if (icmpv4_fd < 0)
238 return -1;
239
240#ifdef ICMP_FILTER
241 {
242 icmp_filter oval;
243 oval.data = 0xffffffff;
244 if (::conf.icmp_type < 32)
245 oval.data &= ~(1 << ::conf.icmp_type);
246
247 setsockopt (icmpv4_fd, SOL_RAW, ICMP_FILTER, &oval, sizeof oval);
140 } 248 }
249#endif
250
251#if defined(SOL_IP) && defined(IP_MTU_DISCOVER)
252 // this I really consider a linux bug. I am neither connected
253 // nor do I fragment myself. Linux still sets DF and doesn't
254 // fragment for me sometimes.
255 {
256 int oval = IP_PMTUDISC_DONT;
257 setsockopt (icmpv4_fd, SOL_IP, IP_MTU_DISCOVER, &oval, sizeof oval);
258 }
259#endif
260
261 sockinfo si (THISNODE, PROT_ICMPv4);
262
263 if (bind (icmpv4_fd, si.sav4 (), si.salenv4 ()))
264 {
265 slog (L_ERR, _("can't bind icmpv4 on %s: %s, exiting."), (const char *)si, strerror (errno));
266 return -1;
267 }
268
269 icmpv4_ev_watcher.start (icmpv4_fd, EV_READ);
270 ++success;
271 }
272#endif
141 273
142 tcpv4_fd = -1; 274 tcpv4_fd = -1;
143 275
144#if ENABLE_TCP 276#if ENABLE_TCP
145 if (THISNODE->protocols & PROT_TCPv4 && THISNODE->tcp_port) 277 if (THISNODE->protocols & PROT_TCPv4 && THISNODE->tcp_port)
146 { 278 {
147 tcpv4_fd = socket (PF_INET, SOCK_STREAM, IPPROTO_TCP); 279 tcpv4_fd = setup_socket (PROT_TCPv4, PF_INET, SOCK_STREAM, IPPROTO_TCP);
148 280
149 if (tcpv4_fd < 0) 281 if (tcpv4_fd < 0)
150 return -1; 282 return -1;
151 283
152 // standard daemon practise... 284 // standard daemon practise...
157 289
158 sockinfo si (THISNODE, PROT_TCPv4); 290 sockinfo si (THISNODE, PROT_TCPv4);
159 291
160 if (bind (tcpv4_fd, si.sav4 (), si.salenv4 ())) 292 if (bind (tcpv4_fd, si.sav4 (), si.salenv4 ()))
161 { 293 {
162 slog (L_ERR, _("can't bind tcpv4 on %s: %s"), (const char *)si, strerror (errno)); 294 slog (L_ERR, _("can't bind tcpv4 on %s: %s, exiting."), (const char *)si, strerror (errno));
163 exit (1); 295 return -1;
164 } 296 }
165 297
166 if (listen (tcpv4_fd, 5)) 298 if (listen (tcpv4_fd, 5))
167 { 299 {
168 slog (L_ERR, _("can't listen tcpv4 on %s: %s"), (const char *)si, strerror (errno)); 300 slog (L_ERR, _("can't listen tcpv4 on %s: %s, exiting."), (const char *)si, strerror (errno));
169 exit (1); 301 return -1;
302 }
303
304 tcpv4_ev_watcher.start (tcpv4_fd, EV_READ);
305 ++success;
306 }
307 else
308 THISNODE->protocols &= ~PROT_TCPv4;
309#endif
310
311 dnsv4_tos = -1;
312 dnsv4_fd = -1;
313
314#if ENABLE_DNS
315 if (THISNODE->protocols & PROT_DNSv4)
316 {
317 dns_forwarder.set (::conf.dns_forw_host, ::conf.dns_forw_port, PROT_DNSv4);
318
319 dnsv4_fd = setup_socket (PROT_DNSv4, PF_INET, SOCK_DGRAM, IPPROTO_UDP);
320
321 if (dnsv4_fd < 0)
322 return -1;
323
324# if defined(SOL_IP) && defined(IP_MTU_DISCOVER)
325 // this I really consider a linux bug. I am neither connected
326 // nor do I fragment myself. Linux still sets DF and doesn't
327 // fragment for me sometimes.
328 {
329 int oval = IP_PMTUDISC_DONT;
330 setsockopt (dnsv4_fd, SOL_IP, IP_MTU_DISCOVER, &oval, sizeof oval);
170 } 331 }
171
172 tcpv4_ev_watcher.start (tcpv4_fd, POLLIN);
173 }
174#endif 332# endif
333
334 // standard daemon practise...
335 {
336 int oval = 1;
337 setsockopt (dnsv4_fd, SOL_SOCKET, SO_REUSEADDR, &oval, sizeof oval);
338 }
339
340 sockinfo si (THISNODE->dns_hostname,
341 THISNODE->dns_hostname ? THISNODE->dns_port : 0,
342 PROT_DNSv4);
343
344 if (bind (dnsv4_fd, si.sav4 (), si.salenv4 ()))
345 {
346 slog (L_ERR, _("can't bind dnsv4 on %s: %s, exiting."), (const char *)si, strerror (errno));
347 return -1;
348 }
349
350 dnsv4_ev_watcher.start (dnsv4_fd, EV_READ);
351 ++success;
352 }
353#endif
354
355 /////////////////////////////////////////////////////////////////////////////
356
357 if (!success)
358 {
359 slog (L_ERR, _("no protocols enabled."));
360 return -1;
361 }
362
363 reconnect_all ();
364
365 /////////////////////////////////////////////////////////////////////////////
175 366
176 tap = new tap_device (); 367 tap = new tap_device ();
177 if (!tap) //D this, of course, never catches 368 if (!tap) //D this, of course, never catches
178 { 369 {
179 slog (L_ERR, _("cannot create network interface '%s'"), conf.ifname); 370 slog (L_ERR, _("cannot create network interface '%s'."), conf.ifname);
180 exit (1); 371 return -1;
181 } 372 }
182 373
183 run_script (run_script_cb (this, &vpn::script_if_up), true); 374 fcntl (tap->fd, F_SETFD, FD_CLOEXEC);
184 375
376 run_script_cb cb;
377 cb.set<vpn, &vpn::script_if_init> (this);
378
379 if (tap->if_up () &&
380 !run_script (cb, true))
381 {
382 slog (L_ERR, _("interface initialization command '%s' failed."),
383 tap->if_up ());
384 return -1;
385 }
386
387 cb.set<vpn, &vpn::script_if_up> (this);
388 if (!run_script (cb, true))
389 {
390 slog (L_ERR, _("if-up command execution failed."));
391 return -1;
392 }
393
185 tap_ev_watcher.start (tap->fd, POLLIN); 394 tap_ev_watcher.start (tap->fd, EV_READ);
186
187 reconnect_all ();
188 395
189 return 0; 396 return 0;
190} 397}
191 398
192// send a vpn packet out to other hosts
193bool 399bool
194vpn::send_vpn_packet (vpn_packet *pkt, const sockinfo &si, int tos) 400vpn::drop_privileges ()
195{ 401{
196 switch (si.prot) 402 if (::conf.change_root)
403 {
404 if (!strcmp (::conf.change_root, "/"))
405 {
406 char dir [L_tmpnam];
407 if (!tmpnam (dir))
408 {
409 slog (L_CRIT, _("unable to create anonymous root path."));
410 return false;
411 }
412
413 if (mkdir (dir, 0700))
414 {
415 slog (L_CRIT, _("unable to crate anonymous root directory."));
416 return false;
417 }
418
419 if (chdir (dir))
420 {
421 slog (L_CRIT, _("unable to change to anonymous root directory."));
422 return false;
423 }
424
425 if (rmdir (dir))
426 slog (L_ERR, _("unable to remove anonymous root directory, continuing."));
427 }
428 else
429 {
430 if (chdir (::conf.change_root))
431 {
432 slog (L_CRIT, _("%s: unable to change to specified root directory."), ::conf.change_root);
433 return false;
434 }
435 }
436
437 if (chroot ("."))
438 {
439 slog (L_CRIT, _("unable to set new root directory."));
440 return false;
441 }
442
443 if (chdir ("/"))
444 {
445 slog (L_CRIT, _("unable to set cwd to new root directory."));
446 return false;
447 }
448 }
449
450 if (::conf.change_gid)
451 if (setgid (::conf.change_gid))
197 { 452 {
198 case PROT_IPv4: 453 slog (L_CRIT, _("unable to change group id to %d."), ::conf.change_gid);
199 return send_ipv4_packet (pkt, si, tos);
200
201 case PROT_UDPv4:
202 return send_udpv4_packet (pkt, si, tos);
203
204#if ENABLE_TCP
205 case PROT_TCPv4:
206 return send_tcpv4_packet (pkt, si, tos);
207#endif
208
209 default:
210 slog (L_CRIT, _("%s: FATAL: trying to send packet with unsupported protocol"), (const char *)si);
211 return false; 454 return false;
212 } 455 }
456
457 if (::conf.change_uid)
458 if (setuid (::conf.change_uid))
459 {
460 slog (L_CRIT, _("unable to change user id to %d."), ::conf.change_uid);
461 return false;
462 }
463
464 return true;
213} 465}
214 466
215bool 467bool
216vpn::send_ipv4_packet (vpn_packet *pkt, const sockinfo &si, int tos) 468vpn::send_ipv4_packet (vpn_packet *pkt, const sockinfo &si, int tos)
217{ 469{
218 setsockopt (ipv4_fd, SOL_IP, IP_TOS, &tos, sizeof tos); 470 set_tos (ipv4_fd, ipv4_tos, tos);
219 sendto (ipv4_fd, &((*pkt)[0]), pkt->len, 0, si.sav4 (), si.salenv4 ()); 471 sendto (ipv4_fd, &((*pkt)[0]), pkt->len, 0, si.sav4 (), si.salenv4 ());
220 472
221 return true; 473 return true;
222} 474}
475
476static u16
477ipv4_checksum (u16 *data, unsigned int len)
478{
479 // use 32 bit accumulator and fold back carry bits at the end
480 u32 sum = 0;
481
482 while (len > 1)
483 {
484 sum += *data++;
485 len -= 2;
486 }
487
488 // odd byte left?
489 if (len)
490 sum += *(u8 *)data;
491
492 // add back carry bits
493 sum = (sum >> 16) + (sum & 0xffff); // lo += hi
494 sum += (sum >> 16); // carry
495
496 return ~sum;
497}
498
499#if ENABLE_ICMP
500bool
501vpn::send_icmpv4_packet (vpn_packet *pkt, const sockinfo &si, int tos)
502{
503 pkt->unshift_hdr (4);
504
505 icmp_header *hdr = (icmp_header *)&((*pkt)[0]);
506 hdr->type = ::conf.icmp_type;
507 hdr->code = 255;
508 hdr->checksum = 0;
509 hdr->checksum = ipv4_checksum ((u16 *)hdr, pkt->len);
510
511 set_tos (icmpv4_fd, icmpv4_tos, tos);
512 sendto (icmpv4_fd, &((*pkt)[0]), pkt->len, 0, si.sav4 (), si.salenv4 ());
513
514 return true;
515}
516#endif
223 517
224bool 518bool
225vpn::send_udpv4_packet (vpn_packet *pkt, const sockinfo &si, int tos) 519vpn::send_udpv4_packet (vpn_packet *pkt, const sockinfo &si, int tos)
226{ 520{
227 setsockopt (udpv4_fd, SOL_IP, IP_TOS, &tos, sizeof tos); 521 set_tos (udpv4_fd, udpv4_tos, tos);
228 sendto (udpv4_fd, &((*pkt)[0]), pkt->len, 0, si.sav4 (), si.salenv4 ()); 522 sendto (udpv4_fd, &((*pkt)[0]), pkt->len, 0, si.sav4 (), si.salenv4 ());
229 523
230 return true; 524 return true;
525}
526
527void
528vpn::inject_data_packet (tap_packet *pkt, int dst)
529{
530 if (dst)
531 {
532 // unicast
533 if (dst != THISNODE->id)
534 conns[dst - 1]->inject_data_packet (pkt);
535 }
536 else
537 {
538 // broadcast, this is ugly, but due to the security policy
539 // we have to connect to all hosts...
540 for (conns_vector::iterator c = conns.begin (); c != conns.end (); ++c)
541 if ((*c)->conf != THISNODE)
542 (*c)->inject_data_packet (pkt);
543 }
231} 544}
232 545
233void 546void
234vpn::recv_vpn_packet (vpn_packet *pkt, const sockinfo &rsi) 547vpn::recv_vpn_packet (vpn_packet *pkt, const sockinfo &rsi)
235{ 548{
236 unsigned int src = pkt->src (); 549 unsigned int src = pkt->src ();
237 unsigned int dst = pkt->dst (); 550 unsigned int dst = pkt->dst ();
238 551
239 slog (L_NOISE, _("<<?/%s received possible vpn packet type %d from %d to %d, length %d"), 552 slog (L_NOISE, _("<<?/%s received possible vpn packet type %d from %d to %d, length %d."),
240 (const char *)rsi, pkt->typ (), pkt->src (), pkt->dst (), pkt->len); 553 (const char *)rsi, pkt->typ (), pkt->src (), pkt->dst (), pkt->len);
241 554
242 if (src == 0 || src > conns.size () 555 if (src == 0 || src > conns.size ()
243 || dst > conns.size () 556 || dst > conns.size ()
244 || pkt->typ () >= vpn_packet::PT_MAX) 557 || pkt->typ () >= vpn_packet::PT_MAX)
245 slog (L_WARN, _("(%s): received corrupted packet type %d (src %d, dst %d)"), 558 slog (L_WARN, _("(%s): received corrupted packet type %d (src %d, dst %d)."),
246 (const char *)rsi, pkt->typ (), pkt->src (), pkt->dst ());
247 else if (dst > conns.size ())
248 slog (L_WARN, _("(%s): received corrupted packet type %d (src %d, dst %d)"),
249 (const char *)rsi, pkt->typ (), pkt->src (), pkt->dst ()); 559 (const char *)rsi, pkt->typ (), pkt->src (), pkt->dst ());
250 else 560 else
251 { 561 {
252 connection *c = conns[src - 1]; 562 connection *c = conns[src - 1];
253 563
254 if (dst == 0 && !THISNODE->routerprio) 564 if (dst == 0)
255 slog (L_WARN, _("%s(%s): received broadcast, but we are no router"), 565 slog (L_WARN, _("%s(%s): received broadcast (protocol violation)."),
256 c->conf->nodename, (const char *)rsi); 566 c->conf->nodename, (const char *)rsi);
257 else if (dst != 0 && dst != THISNODE->id) 567 else if (dst != THISNODE->id)
258 { 568 {
259 if (THISNODE->routerprio) 569 if (THISNODE->routerprio)
260 // the tos setting gets lost here. who cares. 570 // the tos setting gets lost here. who cares.
261 conns[dst - 1]->inject_vpn_packet (pkt); 571 conns[dst - 1]->inject_vpn_packet (pkt);
262 else 572 else
263 slog (L_WARN, 573 slog (L_WARN,
264 _("%s(%s): forwarding request (=> %s), but we are no router"), 574 _("%s(%s): request to forward packet to %s, but we are no router (config mismatch?)."),
265 c->conf->nodename, (const char *)rsi, 575 c->conf->nodename, (const char *)rsi,
266 conns[dst - 1]->conf->nodename); 576 conns[dst - 1]->conf->nodename);
267 } 577 }
268 else 578 else
269 c->recv_vpn_packet (pkt, rsi); 579 c->recv_vpn_packet (pkt, rsi);
270 } 580 }
271} 581}
272 582
273void 583bool
274vpn::udpv4_ev (io_watcher &w, short revents) 584vpn::send_vpn_packet (vpn_packet *pkt, const sockinfo &si, int tos)
275{ 585{
276 if (revents & (POLLIN | POLLERR)) 586 switch (si.prot)
587 {
588 case PROT_IPv4:
589 return send_ipv4_packet (pkt, si, tos);
590
591 case PROT_UDPv4:
592 return send_udpv4_packet (pkt, si, tos);
593
594#if ENABLE_TCP
595 case PROT_TCPv4:
596 return send_tcpv4_packet (pkt, si, tos);
597#endif
598#if ENABLE_ICMP
599 case PROT_ICMPv4:
600 return send_icmpv4_packet (pkt, si, tos);
601#endif
602#if ENABLE_DNS
603 case PROT_DNSv4:
604 return send_dnsv4_packet (pkt, si, tos);
605#endif
606 default:
607 slog (L_CRIT, _("%s: FATAL: trying to send packet with unsupported protocol."), (const char *)si);
608 }
609
610 return false;
611}
612
613inline void
614vpn::ipv4_ev (ev::io &w, int revents)
615{
616 if (revents & EV_READ)
277 { 617 {
278 vpn_packet *pkt = new vpn_packet; 618 vpn_packet *pkt = new vpn_packet;
279 struct sockaddr_in sa; 619 struct sockaddr_in sa;
280 socklen_t sa_len = sizeof (sa); 620 socklen_t sa_len = sizeof (sa);
281 int len; 621 int len;
282 622
283 len = recvfrom (w.fd, &((*pkt)[0]), MAXSIZE, 0, (sockaddr *)&sa, &sa_len); 623 len = recvfrom (w.fd, &((*pkt)[0]), MAXSIZE, 0, (sockaddr *)&sa, &sa_len);
284 624
285 sockinfo si(sa, PROT_UDPv4); 625 sockinfo si(sa, PROT_IPv4);
286 626
287 if (len > 0) 627 if (len > 0)
288 { 628 {
289 pkt->len = len; 629 pkt->len = len;
290 630
631 // raw sockets deliver the ipv4 header, but don't expect it on sends
632 pkt->skip_hdr (pkt->ipv4_hdr_len ());
633
291 recv_vpn_packet (pkt, si); 634 recv_vpn_packet (pkt, si);
292 } 635 }
293 else 636 else
294 { 637 {
295 // probably ECONNRESET or somesuch 638 // probably ECONNRESET or somesuch
296 slog (L_DEBUG, _("%s: fd %d, %s"), (const char *)si, w.fd, strerror (errno)); 639 slog (L_DEBUG, _("%s: %s."), (const char *)si, strerror (errno));
297 } 640 }
298 641
299 delete pkt; 642 delete pkt;
300 } 643 }
301 else if (revents & POLLHUP)
302 {
303 // this cannot ;) happen on udp sockets
304 slog (L_ERR, _("FATAL: POLLHUP on udp v4 fd, terminating."));
305 exit (1);
306 }
307 else 644 else
308 { 645 {
309 slog (L_ERR, 646 slog (L_ERR,
310 _("FATAL: unknown revents %08x in socket, terminating\n"), 647 _("FATAL: unknown revents %08x in socket, exiting.\n"),
311 revents); 648 revents);
312 exit (1); 649 exit (EXIT_FAILURE);
313 } 650 }
314} 651}
315 652
316void 653#if ENABLE_ICMP
654inline void
317vpn::ipv4_ev (io_watcher &w, short revents) 655vpn::icmpv4_ev (ev::io &w, int revents)
318{ 656{
319 if (revents & (POLLIN | POLLERR)) 657 if (revents & EV_READ)
320 { 658 {
321 vpn_packet *pkt = new vpn_packet; 659 vpn_packet *pkt = new vpn_packet;
322 struct sockaddr_in sa; 660 struct sockaddr_in sa;
323 socklen_t sa_len = sizeof (sa); 661 socklen_t sa_len = sizeof (sa);
324 int len; 662 int len;
325 663
326 len = recvfrom (w.fd, &((*pkt)[0]), MAXSIZE, 0, (sockaddr *)&sa, &sa_len); 664 len = recvfrom (w.fd, &((*pkt)[0]), MAXSIZE, 0, (sockaddr *)&sa, &sa_len);
327 665
328 sockinfo si(sa, PROT_IPv4); 666 sockinfo si(sa, PROT_ICMPv4);
329 667
330 if (len > 0) 668 if (len > 0)
331 { 669 {
332 pkt->len = len; 670 pkt->len = len;
333 671
672 icmp_header *hdr = (icmp_header *)&((*pkt)[IP_OVERHEAD]);
673
674 if (hdr->type == ::conf.icmp_type
675 && hdr->code == 255)
676 {
334 // raw sockets deliver the ipv4, but don't expect it on sends 677 // raw sockets deliver the ipv4, but don't expect it on sends
335 // this is slow, but... 678 // this is slow, but...
336 pkt->skip_hdr (IP_OVERHEAD); 679 pkt->skip_hdr (pkt->ipv4_hdr_len () + (ICMP_OVERHEAD - IP_OVERHEAD));
680
681 recv_vpn_packet (pkt, si);
682 }
683 }
684 else
685 {
686 // probably ECONNRESET or somesuch
687 slog (L_DEBUG, _("%s: %s."), (const char *)si, strerror (errno));
688 }
689
690 delete pkt;
691 }
692 else
693 {
694 slog (L_ERR,
695 _("FATAL: unknown revents %08x in socket, exiting.\n"),
696 revents);
697 exit (EXIT_FAILURE);
698 }
699}
700#endif
701
702inline void
703vpn::udpv4_ev (ev::io &w, int revents)
704{
705 if (revents & EV_READ)
706 {
707 vpn_packet *pkt = new vpn_packet;
708 struct sockaddr_in sa;
709 socklen_t sa_len = sizeof (sa);
710 int len;
711
712 len = recvfrom (w.fd, &((*pkt)[0]), MAXSIZE, 0, (sockaddr *)&sa, &sa_len);
713
714 sockinfo si(sa, PROT_UDPv4);
715
716 if (len > 0)
717 {
718 pkt->len = len;
337 719
338 recv_vpn_packet (pkt, si); 720 recv_vpn_packet (pkt, si);
339 } 721 }
340 else 722 else
341 { 723 {
342 // probably ECONNRESET or somesuch 724 // probably ECONNRESET or somesuch
343 slog (L_DEBUG, _("%s: %s"), (const char *)si, strerror (errno)); 725 slog (L_DEBUG, _("%s: fd %d, %s."), (const char *)si, w.fd, strerror (errno));
344 } 726 }
345 727
346 delete pkt; 728 delete pkt;
347 } 729 }
348 else if (revents & POLLHUP)
349 {
350 // this cannot ;) happen on udp sockets
351 slog (L_ERR, _("FATAL: POLLHUP on ipv4 fd, terminating."));
352 exit (1);
353 }
354 else 730 else
355 { 731 {
356 slog (L_ERR, 732 slog (L_ERR,
357 _("FATAL: unknown revents %08x in socket, terminating\n"), 733 _("FATAL: unknown revents %08x in socket, exiting.\n"),
358 revents); 734 revents);
359 exit (1); 735 exit (EXIT_FAILURE);
360 } 736 }
361} 737}
362 738
363void 739inline void
364vpn::tap_ev (io_watcher &w, short revents) 740vpn::tap_ev (ev::io &w, int revents)
365{ 741{
366 if (revents & POLLIN) 742 if (revents & EV_READ)
367 { 743 {
368 /* process data */ 744 /* process data */
369 tap_packet *pkt; 745 tap_packet *pkt;
370 746
371 pkt = tap->recv (); 747 pkt = tap->recv ();
372 748
749 if (!pkt)
750 return;
751
752 if (pkt->len > 14)
753 {
373 int dst = mac2id (pkt->dst); 754 int dst = mac2id (pkt->dst);
374 int src = mac2id (pkt->src); 755 int src = mac2id (pkt->src);
375 756
376 if (src != THISNODE->id) 757 if (src != THISNODE->id)
377 {
378 slog (L_ERR, _("FATAL: tap packet not originating on current node received, terminating."));
379 exit (1);
380 }
381
382 if (dst == THISNODE->id)
383 {
384 slog (L_ERR, _("FATAL: tap packet destined for current node received, terminating."));
385 exit (1);
386 }
387
388 if (dst > conns.size ())
389 slog (L_ERR, _("tap packet for unknown node %d received, ignoring."), dst);
390 else
391 {
392 if (dst)
393 { 758 {
394 // unicast 759 slog (L_ERR, _("FATAL: tap packet not originating on current node received (if-up script not working properly?), exiting."));
395 if (dst != THISNODE->id) 760 exit (EXIT_FAILURE);
396 conns[dst - 1]->inject_data_packet (pkt);
397 } 761 }
762
763 if (dst == THISNODE->id)
764 {
765 slog (L_ERR, _("FATAL: tap packet destined for current node received, exiting."));
766 exit (EXIT_FAILURE);
767 }
768
769 if (dst > conns.size ())
770 slog (L_ERR, _("tap packet for unknown node %d received, ignoring."), dst);
398 else 771 else
399 {
400 // broadcast, first check router, then self, then english
401 connection *router = find_router ();
402
403 if (router)
404 router->inject_data_packet (pkt, true); 772 inject_data_packet (pkt, dst);
405 else
406 for (conns_vector::iterator c = conns.begin (); c != conns.end (); ++c)
407 if ((*c)->conf != THISNODE)
408 (*c)->inject_data_packet (pkt);
409 }
410 } 773 }
411 774
412 delete pkt; 775 delete pkt;
413 }
414 else if (revents & (POLLHUP | POLLERR))
415 {
416 slog (L_ERR, _("FATAL: POLLHUP or POLLERR on network device fd, terminating."));
417 exit (1);
418 } 776 }
419 else 777 else
420 abort (); 778 abort ();
421} 779}
422 780
423void 781inline void
424vpn::event_cb (time_watcher &w) 782vpn::event_cb (ev::timer &w, int)
425{ 783{
426 if (events) 784 if (events)
427 { 785 {
428 if (events & EVENT_SHUTDOWN) 786 if (events & EVENT_SHUTDOWN)
429 { 787 {
430 slog (L_INFO, _("preparing shutdown...")); 788 slog (L_INFO, _("preparing shutdown..."));
431 789
432 shutdown_all (); 790 shutdown_all ();
433
434 remove_pid (pidfilename); 791 remove_pid (conf.pidfilename);
435
436 slog (L_INFO, _("terminating")); 792 slog (L_INFO, _("exiting."));
437 793 exit (EXIT_SUCCESS);
438 exit (0);
439 } 794 }
440 795
441 if (events & EVENT_RECONNECT) 796 if (events & EVENT_RECONNECT)
442 { 797 {
443 slog (L_INFO, _("forced reconnect")); 798 slog (L_INFO, _("forced reconnect."));
444 799
445 reconnect_all (); 800 reconnect_all ();
446 } 801 }
447 802
448 events = 0; 803 events = 0;
449 } 804 }
450
451 w.at = TSTAMP_CANCEL;
452} 805}
453 806
454void 807void
455vpn::shutdown_all () 808vpn::shutdown_all ()
456{ 809{
466 819
467 conns.clear (); 820 conns.clear ();
468 821
469 connection_init (); 822 connection_init ();
470 823
471 for (configuration::node_vector::iterator i = conf.nodes.begin (); 824 for (configuration::node_vector::iterator i = conf.nodes.begin (); i != conf.nodes.end (); ++i)
472 i != conf.nodes.end (); ++i) 825 conns.push_back (new connection (this, *i));
473 {
474 connection *conn = new connection (this);
475 826
476 conn->conf = *i; 827 for (conns_vector::iterator c = conns.begin (); c != conns.end (); ++c)
477 conns.push_back (conn);
478
479 conn->establish_connection (); 828 (*c)->establish_connection ();
480 }
481} 829}
482 830
483connection *vpn::find_router () 831bool
832vpn::can_direct (conf_node *src, conf_node *dst) const
484{ 833{
485 u32 prio = 0; 834 return src != dst
835 && src->may_direct (dst)
836 && dst->may_direct (src)
837 && (((src->protocols & dst->protocols) && src->connectmode == conf_node::C_ALWAYS)
838 || (src->protocols & dst->connectable_protocols ()));
839}
840
841// only works for indirect and routed connections: find a router
842// from THISNODE to dst
843connection *
844vpn::find_router_for (const connection *dst)
845{
486 connection *router = 0; 846 connection *router = 0;
487 847
848 // first try to find a router with a direct connection, route there
849 // regardless of any other considerations.
850 {
851 u32 prio = 1;
852
853 for (conns_vector::iterator i = conns.begin (); i != conns.end (); ++i)
854 {
855 connection *c = *i;
856
857 if (c->conf->routerprio > prio
858 && c->conf != THISNODE
859 && can_direct (c->conf, dst->conf)
860 && c->ictx && c->octx)
861 {
862 prio = c->conf->routerprio;
863 router = c;
864 }
865 }
866 }
867
868 if (router)
869 return router;
870
871 // second try find the router with the highest priority, higher than ours
872 {
873 u32 prio = THISNODE->routerprio ? THISNODE->routerprio : 1;
874
875 for (conns_vector::iterator i = conns.begin (); i != conns.end (); ++i)
876 {
877 connection *c = *i;
878
879 if (c->conf->routerprio > prio
880 && c != dst
881 && c->conf != THISNODE
882 && c->ictx && c->octx)
883 {
884 prio = c->conf->routerprio;
885 router = c;
886 }
887 }
888 }
889
890 return router;
891}
892
893void
894vpn::connection_established (connection *c)
895{
488 for (conns_vector::iterator i = conns.begin (); i != conns.end (); ++i) 896 for (conns_vector::iterator i = conns.begin (); i != conns.end (); ++i)
489 { 897 {
490 connection *c = *i; 898 connection *o = *i;
491 899
492 if (c->conf->routerprio > prio 900 if (!o->is_direct
493 && c->connectmode == conf_node::C_ALWAYS 901 && o->si.valid ()
494 && c->conf != THISNODE 902 && c->si != o->si
495 && c->ictx && c->octx) 903 && c == find_router_for (o))
496 {
497 prio = c->conf->routerprio;
498 router = c;
499 } 904 {
905 slog (L_DEBUG, _("%s: can now route packets via %s, re-keying connection."),
906 o->conf->nodename, c->conf->nodename);
907 o->rekey ();
908 }
500 } 909 }
501
502 return router;
503} 910}
504 911
912void
505void vpn::send_connect_request (int id) 913vpn::send_connect_request (connection *c)
506{ 914{
507 connection *c = find_router (); 915 connection *r = find_router_for (c);
508 916
509 if (c) 917 if (r)
918 {
919 slog (L_TRACE, _("%s: no address known, sending mediated connection request via %s."),
920 c->conf->nodename, r->conf->nodename);
510 c->send_connect_request (id); 921 r->send_connect_request (c->conf->id);
922 }
511 else 923 else
512 // no router found, aggressively connect to all routers 924 slog (L_DEBUG, _("%s: no way to connect and no router found: unable to connect at this time."),
513 for (conns_vector::iterator i = conns.begin (); i != conns.end (); ++i) 925 c->conf->nodename);
514 if ((*i)->conf->routerprio)
515 (*i)->establish_connection ();
516} 926}
517 927
518void 928void
519connection::dump_status () 929connection::dump_status ()
520{ 930{
521 slog (L_NOTICE, _("node %s (id %d)"), conf->nodename, conf->id); 931 slog (L_NOTICE, _("node %s (id %d)"), conf->nodename, conf->id);
522 slog (L_NOTICE, _(" connectmode %d (%d) / sockaddr %s / minor %d"), 932 slog (L_NOTICE, _(" connectmode %d (%d) / sockaddr %s / minor %d"),
523 connectmode, conf->connectmode, (const char *)si, (int)prot_minor); 933 connectmode, conf->connectmode, (const char *)si, (int)prot_minor);
524 slog (L_NOTICE, _(" ictx/octx %08lx/%08lx / oseqno %d / retry_cnt %d"), 934 slog (L_NOTICE, _(" ictx/octx %08lx/%08lx / oseqno %d / retry_cnt %d"),
525 (long)ictx, (long)octx, (int)oseqno, (int)retry_cnt); 935 (long)ictx, (long)octx, (int)oseqno, (int)retry_cnt);
526 slog (L_NOTICE, _(" establish_conn %ld / rekey %ld / keepalive %ld"),
527 (long)(establish_connection.at), (long)(rekey.at), (long)(keepalive.at));
528} 936}
529 937
530void 938void
531vpn::dump_status () 939vpn::dump_status ()
532{ 940{
533 slog (L_NOTICE, _("BEGIN status dump (%ld)"), (long)NOW); 941 slog (L_NOTICE, _("BEGIN status dump (%ld)"), (long)ev_now ());
534 942
535 for (conns_vector::iterator c = conns.begin (); c != conns.end (); ++c) 943 for (conns_vector::iterator c = conns.begin (); c != conns.end (); ++c)
536 (*c)->dump_status (); 944 (*c)->dump_status ();
537 945
538 slog (L_NOTICE, _("END status dump")); 946 slog (L_NOTICE, _("END status dump"));
539} 947}
540 948
541vpn::vpn (void) 949vpn::vpn (void)
542: event(this, &vpn::event_cb) 950{
951 event .set<vpn, &vpn::event_cb > (this);
543, udpv4_ev_watcher(this, &vpn::udpv4_ev) 952 udpv4_ev_watcher .set<vpn, &vpn::udpv4_ev > (this);
544, ipv4_ev_watcher (this, &vpn::ipv4_ev) 953 ipv4_ev_watcher .set<vpn, &vpn::ipv4_ev > (this);
545, tap_ev_watcher (this, &vpn::tap_ev)
546#if ENABLE_TCP 954#if ENABLE_TCP
547, tcpv4_ev_watcher(this, &vpn::tcpv4_ev) 955 tcpv4_ev_watcher .set<vpn, &vpn::tcpv4_ev > (this);
548#endif 956#endif
549{ 957#if ENABLE_ICMP
958 icmpv4_ev_watcher.set<vpn, &vpn::icmpv4_ev> (this);
959#endif
960#if ENABLE_DNS
961 dnsv4_ev_watcher .set<vpn, &vpn::dnsv4_ev > (this);
962#endif
963 tap_ev_watcher .set<vpn, &vpn::tap_ev > (this);
550} 964}
551 965
552vpn::~vpn () 966vpn::~vpn ()
553{ 967{
554} 968}

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines