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

Comparing gvpe/src/conf.C (file contents):
Revision 1.8 by pcg, Wed Apr 2 03:25:17 2003 UTC vs.
Revision 1.65 by root, Fri Oct 11 07:56:07 2013 UTC

1/* 1/*
2 conf.c -- configuration code 2 conf.C -- configuration code
3 Copyright (C) 1998 Robert van der Meulen 3 Copyright (C) 2003-2008,2011 Marc Lehmann <gvpe@schmorp.de>
4 1998-2002 Ivo Timmermans <ivo@o2w.nl>
5 2000-2002 Guus Sliepen <guus@sliepen.eu.org>
6 2000 Cris van Pelt <tribbel@arise.dhs.org>
7 2003 Marc Lehmann <pcg@goof.com>
8 4
5 This file is part of GVPE.
6
9 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
10 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
11 the Free Software Foundation; either version 2 of the License, or 9 Free Software Foundation; either version 3 of the License, or (at your
12 (at your option) any later version. 10 option) any later version.
13 11
14 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
15 but WITHOUT ANY WARRANTY; without even the implied warranty of 13 WITHOUT ANY WARRANTY; without even the implied warranty of
16 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General
17 GNU General Public License for more details. 15 Public License for more details.
18 16
19 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
20 along with this program; if not, write to the Free Software 18 with this program; if not, see <http://www.gnu.org/licenses/>.
21 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.
22*/ 30*/
23 31
24#include "config.h" 32#include "config.h"
25 33
26#include <cstdio> 34#include <cstdio>
30#include <errno.h> 38#include <errno.h>
31#include <netdb.h> 39#include <netdb.h>
32#include <sys/stat.h> 40#include <sys/stat.h>
33#include <sys/types.h> 41#include <sys/types.h>
34#include <unistd.h> 42#include <unistd.h>
43#include <pwd.h>
35 44
36#include <netinet/in.h> 45#include "netcompat.h"
37 46
38#include <openssl/err.h> 47#include <openssl/err.h>
39#include <openssl/pem.h> 48#include <openssl/pem.h>
40#include <openssl/rsa.h> 49#include <openssl/rsa.h>
41#include <openssl/rand.h> 50#include <openssl/rand.h>
42 51#include <openssl/bn.h>
43#include "gettext.h"
44 52
45#include "conf.h" 53#include "conf.h"
46#include "slog.h" 54#include "slog.h"
47#include "util.h" 55#include "util.h"
48 56
49char *confbase; 57char *confbase;
50char *thisnode; 58char *thisnode;
51char *identname; 59char *identname;
52char *pidfilename;
53 60
54struct configuration conf; 61struct configuration conf;
55 62
63u8
56u8 best_protocol (u8 protset) 64best_protocol (u8 protset)
57{ 65{
58 if (protset & PROT_IPv4) 66 if (protset & PROT_IPv4 ) return PROT_IPv4;
59 return PROT_IPv4; 67 if (protset & PROT_ICMPv4) return PROT_ICMPv4;
68 if (protset & PROT_UDPv4 ) return PROT_UDPv4;
69 if (protset & PROT_TCPv4 ) return PROT_TCPv4;
70 if (protset & PROT_DNSv4 ) return PROT_DNSv4;
60 71
61 return PROT_UDPv4; 72 return 0;
62} 73}
63 74
75const char *
64const char *strprotocol (u8 protocol) 76strprotocol (u8 protocol)
65{ 77{
66 if (protocol & PROT_IPv4 ) return "rawip"; 78 if (protocol & PROT_IPv4 ) return "rawip";
79 if (protocol & PROT_ICMPv4) return "icmp";
67 if (protocol & PROT_UDPv4) return "udp"; 80 if (protocol & PROT_UDPv4 ) return "udp";
81 if (protocol & PROT_TCPv4 ) return "tcp";
82 if (protocol & PROT_DNSv4 ) return "dns";
68 83
69 return "<unknown>"; 84 return "<unknown>";
70} 85}
71 86
72configuration::configuration () 87static bool
88match_list (const vector<const char *> &list, const char *str)
73{ 89{
74 init (); 90 for (vector<const char *>::const_iterator i = list.end (); i-- > list.begin (); )
75} 91 if ((*i)[0] == '*' && !(*i)[1])
92 return true;
93 else if (!strcmp (*i, str))
94 return true;
76 95
77configuration::~configuration () 96 return false;
78{
79 cleanup ();
80} 97}
81 98
99bool
100conf_node::may_direct (struct conf_node *other)
101{
102 if (match_list (allow_direct, other->nodename))
103 return true;
104
105 if (match_list (deny_direct, other->nodename))
106 return false;
107
108 return true;
109}
110
111conf_node::~conf_node ()
112{
113#if 0
114 // does not work, because string pointers etc. are shared
115 // is not called, however
116 if (rsa_key)
117 RSA_free (rsa_key);
118
119 free (nodename);
120 free (hostname);
121 free (if_up_data);
122#if ENABLE_DNS
123 free (domain);
124 free (dns_hostname);
125#endif
126#endif
127}
128
129void
82void configuration::init () 130configuration::init ()
83{ 131{
84 memset (this, 0, sizeof (*this)); 132 memset (this, 0, sizeof (*this));
85 133
134 mtu = DEFAULT_MTU;
135 nfmark = 0;
86 rekey = DEFAULT_REKEY; 136 rekey = DEFAULT_REKEY;
87 keepalive = DEFAULT_KEEPALIVE; 137 keepalive = DEFAULT_KEEPALIVE;
88 llevel = L_INFO; 138 llevel = L_INFO;
89 ip_proto = IPPROTO_GRE; 139 ip_proto = IPPROTO_GRE;
140#if ENABLE_ICMP
141 icmp_type = ICMP_ECHOREPLY;
142#endif
90 143
91 default_node.udp_port = DEFAULT_UDPPORT; 144 default_node.udp_port = DEFAULT_UDPPORT;
92 default_node.tcp_port = DEFAULT_UDPPORT; 145 default_node.tcp_port = DEFAULT_UDPPORT; // ehrm
93 default_node.connectmode = conf_node::C_ALWAYS; 146 default_node.connectmode = conf_node::C_ALWAYS;
94 default_node.compress = true; 147 default_node.compress = true;
95 default_node.protocols = PROT_UDPv4; 148 default_node.protocols = 0;
96} 149 default_node.max_retry = DEFAULT_MAX_RETRY;
150 default_node.max_ttl = DEFAULT_MAX_TTL;
151 default_node.max_queue = DEFAULT_MAX_QUEUE;
152 default_node.if_up_data = strdup ("");
97 153
154#if ENABLE_DNS
155 default_node.dns_port = 0; // default is 0 == client
156
157 dns_case_preserving = true;
158 dns_forw_host = strdup ("127.0.0.1");
159 dns_forw_port = 53;
160 dns_timeout_factor = DEFAULT_DNS_TIMEOUT_FACTOR;
161 dns_send_interval = DEFAULT_DNS_SEND_INTERVAL;
162 dns_overlap_factor = DEFAULT_DNS_OVERLAP_FACTOR;
163 dns_max_outstanding = DEFAULT_DNS_MAX_OUTSTANDING;
164#endif
165
166 pidfilename = strdup (LOCALSTATEDIR "/run/gvpe.pid");
167 seed_dev = strdup ("/dev/urandom");
168 reseed = DEFAULT_RESEED;
169}
170
171void
98void configuration::cleanup() 172configuration::cleanup ()
99{ 173{
100 if (rsa_key) 174 if (rsa_key)
101 RSA_free (rsa_key); 175 RSA_free (rsa_key);
102 176
103 free (ifname);
104
105 rsa_key = 0; 177 rsa_key = 0;
106 ifname = 0; 178
179 free (seed_dev); seed_dev = 0;
180 free (pidfilename); pidfilename = 0;
181 free (ifname); ifname = 0;
182#if ENABLE_HTTP_PROXY
183 free (proxy_host); proxy_host = 0;
184 free (proxy_auth); proxy_auth = 0;
185#endif
186#if ENABLE_DNS
187 free (dns_forw_host); dns_forw_host = 0;
188#endif
189 free (change_root); change_root = 0;
190 free (script_if_up); script_if_up = 0;
191 free (script_node_up); script_node_up = 0;
192 free (script_node_change); script_node_change = 0;
193 free (script_node_down); script_node_down = 0;
107} 194}
108 195
109void 196void
110configuration::clear_config () 197configuration::clear ()
111{ 198{
112 for (configuration::node_vector::iterator i = nodes.begin(); i != nodes.end(); ++i) 199 for (configuration::node_vector::iterator i = nodes.begin(); i != nodes.end(); ++i)
113 delete *i; 200 delete *i;
114 201
115 nodes.clear (); 202 nodes.clear ();
116 203
117 cleanup (); 204 cleanup ();
118 init (); 205 init ();
119} 206}
120 207
208conf_node *
209configuration::find_node (const char *name)
210{
211 for (configuration::node_vector::iterator i = conf.nodes.begin(); i != conf.nodes.end(); ++i)
212 if (!strcmp ((*i)->nodename, name))
213 return *i;
214
215 return 0;
216}
217
218//static bool
219//is_true (const char *name)
220//{
221 //re
222//}
223
121#define parse_bool(target,name,trueval,falseval) \ 224#define parse_bool(target,name,trueval,falseval) do { \
122 if (!strcmp (val, "yes")) target = trueval; \ 225 if (!strcmp (val, "yes")) target = trueval; \
123 else if (!strcmp (val, "no")) target = falseval; \ 226 else if (!strcmp (val, "no")) target = falseval; \
124 else if (!strcmp (val, "true")) target = trueval; \ 227 else if (!strcmp (val, "true")) target = trueval; \
125 else if (!strcmp (val, "false")) target = falseval; \ 228 else if (!strcmp (val, "false")) target = falseval; \
126 else if (!strcmp (val, "on")) target = trueval; \ 229 else if (!strcmp (val, "on")) target = trueval; \
127 else if (!strcmp (val, "off")) target = falseval; \ 230 else if (!strcmp (val, "off")) target = falseval; \
128 else \ 231 else \
129 slog (L_WARN, \
130 _("illegal value for '%s', only 'yes|true|on' or 'no|false|off' allowed, at '%s' line %d"), \ 232 return _("illegal boolean value, only 'yes|true|on' or 'no|false|off' allowed, ignored"); \
131 name, var, fname, lineno); 233} while (0)
132 234
133void configuration::read_config (bool need_keys) 235const char *
236configuration_parser::parse_line (char *line)
134{ 237{
135 char *fname; 238 {
136 FILE *f; 239 char *end = line + strlen (line);
137 240
138 clear_config (); 241 while (*end < ' ' && end >= line)
242 end--;
139 243
140 asprintf (&fname, "%s/vped.conf", confbase); 244 *++end = 0;
141 f = fopen (fname, "r"); 245 }
142 246
143 if (f) 247 char *tok = line;
248 const char *var = strtok (tok, "\t =");
249 tok = 0;
250
251 if (!var || !var[0])
252 return 0; /* no tokens on this line */
253
254 if (var[0] == '#')
255 return 0; /* comment: ignore */
256
257 if (!strcmp (var, "global"))
258 {
259 node = &conf.default_node;
260 return 0;
144 { 261 }
262
263 char *val = strtok (NULL, "\t\n\r =");
264
265 if (!val || val[0] == '#')
266 return _("no value given for variable, ignored");
267
268 else if (!strcmp (var, "on"))
269 {
270 if (::thisnode
271 && ((val[0] == '!' && strcmp (val + 1, ::thisnode))
272 || !strcmp (val, ::thisnode)))
273 return parse_line (strtok (NULL, "\n\r"));
274 }
275
276 else if (!strcmp (var, "include"))
277 {
278 char *fname = conf.config_filename (val);
279 parse_file (fname);
280 free (fname);
281 }
282
283 // truly global
284 else if (!strcmp (var, "loglevel"))
285 {
286 loglevel l = string_to_loglevel (val);
287
288 if (l == L_NONE)
289 return _("unknown loglevel, ignored");
290 }
291 else if (!strcmp (var, "serial"))
292 strncpy (conf.serial, val, sizeof (conf.serial));
293 else if (!strcmp (var, "ip-proto"))
294 conf.ip_proto = atoi (val);
295 else if (!strcmp (var, "icmp-type"))
296 {
297#if ENABLE_ICMP
298 conf.icmp_type = atoi (val);
299#endif
300 }
301 else if (!strcmp (var, "chuser"))
302 {
303 struct passwd *pw = getpwnam (val);
304 if (!pw)
305 return _("user specified for chuser not found");
306
307 conf.change_uid = pw->pw_uid;
308 conf.change_gid = pw->pw_gid;
309 }
310 else if (!strcmp (var, "chuid"))
311 conf.change_uid = atoi (val);
312 else if (!strcmp (var, "chgid"))
313 conf.change_gid = atoi (val);
314 else if (!strcmp (var, "chroot"))
315 free (conf.change_root), conf.change_root = strdup (val);
316
317 // per node
318 else if (!strcmp (var, "node"))
319 {
320 node = conf.find_node (val);
321
322 if (!node)
323 {
324 conf.default_node.id++;
325 node = new conf_node (conf.default_node);
326 conf.nodes.push_back (node);
327 node->nodename = strdup (val);
328 }
329 }
330 else if (!strcmp (var, "private-key"))
331 free (conf.prikeyfile), conf.prikeyfile = strdup (val);
332 else if (!strcmp (var, "ifpersist"))
333 parse_bool (conf.ifpersist, "ifpersist", true, false);
334 else if (!strcmp (var, "ifname"))
335 free (conf.ifname), conf.ifname = strdup (val);
336 else if (!strcmp (var, "rekey"))
337 conf.rekey = atoi (val);
338 else if (!strcmp (var, "keepalive"))
339 conf.keepalive = atoi (val);
340 else if (!strcmp (var, "mtu"))
341 conf.mtu = atoi (val);
342 else if (!strcmp (var, "nfmark"))
343 conf.nfmark = atoi (val);
344 else if (!strcmp (var, "seed-device"))
345 free (conf.seed_dev), conf.seed_dev = strdup (val);
346 else if (!strcmp (var, "seed-interval"))
347 conf.reseed = atoi (val);
348 else if (!strcmp (var, "if-up"))
349 free (conf.script_if_up), conf.script_if_up = strdup (val);
350 else if (!strcmp (var, "node-up"))
351 free (conf.script_node_up), conf.script_node_up = strdup (val);
352 else if (!strcmp (var, "node-change"))
353 free (conf.script_node_change), conf.script_node_change = strdup (val);
354 else if (!strcmp (var, "node-down"))
355 free (conf.script_node_down), conf.script_node_down = strdup (val);
356 else if (!strcmp (var, "pid-file"))
357 free (conf.pidfilename), conf.pidfilename = strdup (val);
358 else if (!strcmp (var, "dns-forw-host"))
359 {
360#if ENABLE_DNS
361 free (conf.dns_forw_host), conf.dns_forw_host = strdup (val);
362#endif
363 }
364 else if (!strcmp (var, "dns-forw-port"))
365 {
366#if ENABLE_DNS
367 conf.dns_forw_port = atoi (val);
368#endif
369 }
370 else if (!strcmp (var, "dns-timeout-factor"))
371 {
372#if ENABLE_DNS
373 conf.dns_timeout_factor = atof (val);
374#endif
375 }
376 else if (!strcmp (var, "dns-send-interval"))
377 {
378#if ENABLE_DNS
379 conf.dns_send_interval = atoi (val);
380#endif
381 }
382 else if (!strcmp (var, "dns-overlap-factor"))
383 {
384#if ENABLE_DNS
385 conf.dns_overlap_factor = atof (val);
386#endif
387 }
388 else if (!strcmp (var, "dns-max-outstanding"))
389 {
390#if ENABLE_DNS
391 conf.dns_max_outstanding = atoi (val);
392#endif
393 }
394 else if (!strcmp (var, "dns-case-preserving"))
395 {
396#if ENABLE_DNS
397 parse_bool (conf.dns_case_preserving, "dns-case-preserving", true, false);
398#endif
399 }
400 else if (!strcmp (var, "http-proxy-host"))
401 {
402#if ENABLE_HTTP_PROXY
403 free (conf.proxy_host), conf.proxy_host = strdup (val);
404#endif
405 }
406 else if (!strcmp (var, "http-proxy-port"))
407 {
408#if ENABLE_HTTP_PROXY
409 conf.proxy_port = atoi (val);
410#endif
411 }
412 else if (!strcmp (var, "http-proxy-auth"))
413 {
414#if ENABLE_HTTP_PROXY
415 conf.proxy_auth = (char *)base64_encode ((const u8 *)val, strlen (val));
416#endif
417 }
418
419 /* node-specific, non-defaultable */
420 else if (node != &conf.default_node && !strcmp (var, "hostname"))
421 free (node->hostname), node->hostname = strdup (val);
422
423 /* node-specific, defaultable */
424 else if (!strcmp (var, "udp-port"))
425 node->udp_port = atoi (val);
426 else if (!strcmp (var, "tcp-port"))
427 node->tcp_port = atoi (val);
428 else if (!strcmp (var, "dns-hostname"))
429 {
430#if ENABLE_DNS
431 free (node->dns_hostname), node->dns_hostname = strdup (val);
432#endif
433 }
434 else if (!strcmp (var, "dns-port"))
435 {
436#if ENABLE_DNS
437 node->dns_port = atoi (val);
438#endif
439 }
440 else if (!strcmp (var, "dns-domain"))
441 {
442#if ENABLE_DNS
443 free (node->domain), node->domain = strdup (val);
444#endif
445 }
446 else if (!strcmp (var, "if-up-data"))
447 free (node->if_up_data), node->if_up_data = strdup (val);
448 else if (!strcmp (var, "router-priority"))
449 node->routerprio = atoi (val);
450 else if (!strcmp (var, "max-retry"))
451 node->max_retry = atoi (val);
452 else if (!strcmp (var, "connect"))
453 {
454 if (!strcmp (val, "ondemand"))
455 node->connectmode = conf_node::C_ONDEMAND;
456 else if (!strcmp (val, "never"))
457 node->connectmode = conf_node::C_NEVER;
458 else if (!strcmp (val, "always"))
459 node->connectmode = conf_node::C_ALWAYS;
460 else if (!strcmp (val, "disabled"))
461 node->connectmode = conf_node::C_DISABLED;
462 else
463 return _("illegal value for 'connectmode', use one of 'ondemand', 'never', 'always' or 'disabled', ignored");
464 }
465 else if (!strcmp (var, "inherit-tos"))
466 parse_bool (node->inherit_tos, "inherit-tos", true, false);
467 else if (!strcmp (var, "compress"))
468 parse_bool (node->compress, "compress", true, false);
469 else if (!strcmp (var, "low-power"))
470 parse_bool (node->low_power, "low-power", true, false);
471 // all these bool options really really cost a lot of executable size!
472 else if (!strcmp (var, "enable-tcp"))
473 {
474#if ENABLE_TCP
475 u8 v; parse_bool (v, "enable-tcp" , PROT_TCPv4, 0); node->protocols = (node->protocols & ~PROT_TCPv4) | v;
476#endif
477 }
478 else if (!strcmp (var, "enable-icmp"))
479 {
480#if ENABLE_ICMP
481 u8 v; parse_bool (v, "enable-icmp" , PROT_ICMPv4, 0); node->protocols = (node->protocols & ~PROT_ICMPv4) | v;
482#endif
483 }
484 else if (!strcmp (var, "enable-dns"))
485 {
486#if ENABLE_DNS
487 u8 v; parse_bool (v, "enable-dns" , PROT_DNSv4, 0); node->protocols = (node->protocols & ~PROT_DNSv4) | v;
488#endif
489 }
490 else if (!strcmp (var, "enable-udp"))
491 {
492 u8 v; parse_bool (v, "enable-udp" , PROT_UDPv4, 0); node->protocols = (node->protocols & ~PROT_UDPv4) | v;
493 }
494 else if (!strcmp (var, "enable-rawip"))
495 {
496 u8 v; parse_bool (v, "enable-rawip", PROT_IPv4, 0); node->protocols = (node->protocols & ~PROT_IPv4 ) | v;
497 }
498 else if (!strcmp (var, "allow-direct"))
499 node->allow_direct.push_back (strdup (val));
500 else if (!strcmp (var, "deny-direct"))
501 node->deny_direct.push_back (strdup (val));
502 else if (!strcmp (var, "max-ttl"))
503 node->max_ttl = atof (val);
504 else if (!strcmp (var, "max-queue"))
505 node->max_queue = atoi (val);
506
507 // unknown or misplaced
508 else
509 return _("unknown configuration directive - ignored");
510
511 return 0;
512}
513
514void
515conf_node::finalise ()
516{
517 if (max_queue < 1)
518 {
519 slog (L_WARN, _("%s: max-queue value invalid, setting it to 1."), nodename);
520 max_queue = 1;
521 }
522
523 if (routerprio > 1 && (connectmode != C_ALWAYS && connectmode != C_DISABLED))
524 {
525 //slog (L_WARN, _("%s: has non-zero router-priority but either 'never' or 'ondemand' as connectmode, setting it to 'always'."), nodename);
526 connectmode = C_ALWAYS;
527 }
528}
529
530void
531configuration_parser::parse_file (const char *fname)
532{
533 if (FILE *f = fopen (fname, "r"))
534 {
145 char line[16384]; 535 char line [2048];
146 int lineno = 0; 536 int lineno = 0;
147 char *var, *val;
148 conf_node *node = &default_node;
149 537
150 while (fgets (line, sizeof (line), f)) 538 while (fgets (line, sizeof (line), f))
151 { 539 {
152 lineno++; 540 lineno++;
153 541
154 { 542 const char *warn = parse_line (line);
155 char *end = line + strlen (line);
156 543
157 while (*end < ' ' && end >= line) 544 if (warn)
158 end--; 545 slog (L_WARN, _("%s, at '%s', line %d."), warn, fname, lineno);
159
160 *++end = 0;
161 }
162
163 char *tok = line;
164
165retry:
166 var = strtok (tok, "\t =");
167 tok = 0;
168
169 if (!var || !var[0])
170 continue; /* no tokens on this line */
171
172 if (var[0] == '#')
173 continue; /* comment: ignore */
174
175 val = strtok (NULL, "\t\n\r =");
176
177 if (!val || val[0] == '#')
178 {
179 slog (L_WARN,
180 _("no value for variable `%s', at '%s' line %d"),
181 var, fname, lineno);
182 break;
183 }
184
185 if (!strcmp (var, "on"))
186 {
187 if (!::thisnode
188 || (val[0] == '!' && strcmp (val + 1, ::thisnode))
189 || !strcmp (val, ::thisnode))
190 goto retry;
191
192 continue;
193 }
194
195 // truly global
196 if (!strcmp (var, "loglevel"))
197 {
198 loglevel l = string_to_loglevel (val);
199
200 if (l != L_NONE)
201 llevel = l;
202 else
203 slog (L_WARN, "'%s': %s, at '%s' line %d", val, UNKNOWN_LOGLEVEL, fname, line);
204 }
205 else if (!strcmp (var, "ip-proto"))
206 ip_proto = atoi (val);
207
208 // per config
209 else if (!strcmp (var, "node"))
210 {
211 default_node.id++;
212
213 node = new conf_node (default_node);
214
215 nodes.push_back (node);
216
217 node->nodename = strdup (val);
218
219 {
220 char *fname;
221 FILE *f;
222
223 asprintf (&fname, "%s/pubkey/%s", confbase, node->nodename);
224
225 f = fopen (fname, "r");
226 if (f)
227 {
228 node->rsa_key = RSA_new ();
229
230 if (!PEM_read_RSAPublicKey(f, &node->rsa_key, NULL, NULL))
231 {
232 ERR_load_RSA_strings (); ERR_load_PEM_strings ();
233 slog (L_ERR, _("unable to open public rsa key file '%s': %s"), fname, ERR_error_string (ERR_get_error (), 0));
234 exit (1);
235 }
236
237 RSA_blinding_on (node->rsa_key, 0);
238
239 fclose (f);
240 }
241 else
242 {
243 slog (need_keys ? L_ERR : L_NOTICE, _("unable to read public rsa key file '%s': %s"), fname, strerror (errno));
244
245 if (need_keys)
246 exit (1);
247 }
248
249 free (fname);
250 }
251
252 if (!::thisnode || !strcmp (node->nodename, ::thisnode))
253 thisnode = node;
254 }
255 else if (!strcmp (var, "private-key"))
256 prikeyfile = strdup (val);
257 else if (!strcmp (var, "ifpersist"))
258 {
259 parse_bool (ifpersist, "ifpersist", true, false);
260 }
261 else if (!strcmp (var, "ifname"))
262 ifname = strdup (val);
263 else if (!strcmp (var, "rekey"))
264 rekey = atoi (val);
265 else if (!strcmp (var, "keepalive"))
266 keepalive = atoi (val);
267 else if (!strcmp (var, "mtu"))
268 mtu = atoi (val);
269 else if (!strcmp (var, "if-up"))
270 script_if_up = strdup (val);
271 else if (!strcmp (var, "node-up"))
272 script_node_up = strdup (val);
273 else if (!strcmp (var, "node-down"))
274 script_node_down = strdup (val);
275
276 /* node-specific, non-defaultable */
277 else if (node != &default_node && !strcmp (var, "hostname"))
278 {
279 free (node->hostname);
280 node->hostname = strdup (val);
281 }
282
283 /* node-specific, defaultable */
284 else if (!strcmp (var, "udp-port"))
285 node->udp_port = atoi (val);
286 else if (!strcmp (var, "tcp-port"))
287 node->tcp_port = atoi (val);
288 else if (!strcmp (var, "router-priority"))
289 node->routerprio = atoi (val);
290 else if (!strcmp (var, "connect"))
291 {
292 if (!strcmp (val, "ondemand"))
293 node->connectmode = conf_node::C_ONDEMAND;
294 else if (!strcmp (val, "never"))
295 node->connectmode = conf_node::C_NEVER;
296 else if (!strcmp (val, "always"))
297 node->connectmode = conf_node::C_ALWAYS;
298 else if (!strcmp (val, "disabled"))
299 node->connectmode = conf_node::C_DISABLED;
300 else
301 slog (L_WARN,
302 _("illegal value for 'connectmode', use one of 'ondemand', 'never', 'always' or 'disabled', at '%s' line %d"),
303 var, fname, lineno);
304 }
305 else if (!strcmp (var, "inherit-tos"))
306 {
307 parse_bool (node->inherit_tos, "inherit-tos", true, false);
308 }
309 else if (!strcmp (var, "compress"))
310 {
311 parse_bool (node->compress, "compress", true, false);
312 }
313 // all these bool options really really cost a lot of executable size!
314 else if (!strcmp (var, "enable-tcp"))
315 {
316 u8 v; parse_bool (v, "enable-tcp" , PROT_TCPv4, 0); node->protocols = (node->protocols & ~PROT_TCPv4) | v;
317 }
318 else if (!strcmp (var, "enable-udp"))
319 {
320 u8 v; parse_bool (v, "enable-udp" , PROT_UDPv4, 0); node->protocols = (node->protocols & ~PROT_UDPv4) | v;
321 }
322 else if (!strcmp (var, "enable-rawip"))
323 {
324 u8 v; parse_bool (v, "enable-rawip", PROT_IPv4, 0); node->protocols = (node->protocols & ~PROT_IPv4 ) | v;
325 }
326
327 // unknown or misplaced
328 else
329 {
330 slog (L_WARN,
331 _("unknown or misplaced variable `%s', at '%s' line %d"),
332 var, fname, lineno);
333 }
334 } 546 }
335 547
336 fclose (f); 548 fclose (f);
337 } 549 }
338 else 550 else
339 { 551 {
340 slog (L_ERR, _("unable to read config file '%s': %s"), fname, strerror (errno)); 552 slog (L_ERR, _("unable to read config file '%s': %s"), fname, strerror (errno));
341 exit (1); 553 exit (EXIT_FAILURE);
342 } 554 }
555}
343 556
557configuration_parser::configuration_parser (configuration &conf,
558 bool need_keys,
559 int argc,
560 char **argv)
561: conf (conf), need_keys (need_keys), argc (argc), argv (argv)
562{
563 char *fname;
564
565 conf.clear ();
566 node = &conf.default_node;
567
568 asprintf (&fname, "%s/gvpe.conf", confbase);
569 parse_file (fname);
344 free (fname); 570 free (fname);
345 571
346 fname = config_filename (prikeyfile, "hostkey"); 572 fname = conf.config_filename (conf.prikeyfile, "hostkey");
347 573
348 f = fopen (fname, "r"); 574 if (FILE *f = fopen (fname, "r"))
349 if (f)
350 { 575 {
351 rsa_key = RSA_new (); 576 conf.rsa_key = RSA_new ();
352 577
353 if (!PEM_read_RSAPrivateKey (f, &rsa_key, NULL, NULL)) 578 if (!PEM_read_RSAPrivateKey (f, &conf.rsa_key, NULL, NULL))
354 { 579 {
355 ERR_load_RSA_strings (); ERR_load_PEM_strings (); 580 ERR_load_RSA_strings (); ERR_load_PEM_strings ();
356 slog (L_ERR, _("unable to read private rsa key file '%s': %s"), fname, ERR_error_string (ERR_get_error (), 0)); 581 slog (L_ERR, _("unable to read private rsa key file '%s': %s"), fname, ERR_error_string (ERR_get_error (), 0));
357 exit (1); 582 exit (EXIT_FAILURE);
358 } 583 }
359 584
360 RSA_blinding_on (rsa_key, 0); 585 require (RSA_blinding_on (conf.rsa_key, 0));
361 586
362 fclose (f); 587 fclose (f);
363 } 588 }
364 else 589 else
365 { 590 {
366 slog (need_keys ? L_ERR : L_NOTICE, _("unable to open private rsa key file '%s': %s"), fname, strerror (errno));
367
368 if (need_keys) 591 if (need_keys)
369 exit (1); 592 {
593 slog (need_keys ? L_ERR : L_NOTICE, _("unable to open private rsa key file '%s': %s"), fname, strerror (errno));
594 exit (EXIT_FAILURE);
595 }
370 } 596 }
371 597
372 free (fname); 598 free (fname);
373}
374 599
600 fname = conf.config_filename (conf.pidfilename);
601 free (conf.pidfilename); conf.pidfilename = fname;
602
603 for (configuration::node_vector::iterator i = conf.nodes.begin(); i != conf.nodes.end(); ++i)
604 {
605 conf_node *node = *i;
606 char *fname;
607 FILE *f;
608
609 asprintf (&fname, "%s/pubkey/%s", confbase, node->nodename);
610
611 f = fopen (fname, "r");
612 if (f)
613 {
614 node->rsa_key = RSA_new ();
615
616 if (!PEM_read_RSAPublicKey (f, &node->rsa_key, NULL, NULL))
617 {
618 ERR_load_RSA_strings (); ERR_load_PEM_strings ();
619 slog (L_ERR, _("unable to open public rsa key file '%s': %s"), fname, ERR_error_string (ERR_get_error (), 0));
620 exit (EXIT_FAILURE);
621 }
622
623 require (RSA_blinding_on (node->rsa_key, 0));
624
625 fclose (f);
626 }
627 else
628 {
629 slog (need_keys ? L_ERR : L_NOTICE, _("unable to read public rsa key file '%s': %s"), fname, strerror (errno));
630
631 if (need_keys)
632 exit (EXIT_FAILURE);
633 }
634
635 free (fname);
636
637 (*i)->finalise ();
638 }
639
640 if (::thisnode)
641 {
642 conf.thisnode = conf.find_node (::thisnode);
643
644 if (need_keys)
645 {
646 if (!conf.thisnode)
647 {
648 slog (L_NOTICE, _("local node ('%s') not found in config file, aborting."), ::thisnode);
649 exit (EXIT_FAILURE);
650 }
651
652 if (conf.rsa_key && conf.thisnode->rsa_key)
653 if (BN_cmp (conf.rsa_key->n, conf.thisnode->rsa_key->n) != 0
654 || BN_cmp (conf.rsa_key->e, conf.thisnode->rsa_key->e) != 0)
655 {
656 slog (L_NOTICE, _("private hostkey and public node key mismatch: is '%s' the correct node?"), ::thisnode);
657 exit (EXIT_FAILURE);
658 }
659 }
660 }
661
662 parse_argv ();
663}
664
665void
666configuration_parser::parse_argv ()
667{
668 for (int i = 0; i < argc; ++i)
669 {
670 char *v = argv [i];
671
672 if (!*v)
673 continue;
674
675 char *enode = v;
676
677 while (*enode != '.' && *enode > ' ' && *enode != '=' && *enode)
678 enode++;
679
680 if (*enode != '.')
681 enode = 0;
682
683 if (enode)
684 {
685 char *val = strdup (v);
686 val [enode - v] = 0;
687 node = conf.find_node (val);
688 free (val);
689
690 if (!node)
691 {
692 slog (L_WARN, _("command line option '%s' refers to unknown node, ignoring."), v);
693 continue;
694 }
695 }
696 else
697 node = &conf.default_node;
698
699 const char *warn = parse_line (enode ? enode + 1 : v);
700
701 if (warn)
702 slog (L_WARN, _("%s, while parsing command line option '%s'."), warn, v);
703 }
704}
705
706char *
375char *configuration::config_filename (const char *name, const char *dflt) 707configuration::config_filename (const char *name, const char *dflt)
376{ 708{
377 char *fname; 709 char *fname;
378 710
379 asprintf (&fname, name ? name : dflt, ::thisnode); 711 asprintf (&fname, name ? name : dflt, ::thisnode ? ::thisnode : "<unset>");
380 712
381 if (!ABSOLUTE_PATH (fname)) 713 if (!ABSOLUTE_PATH (fname))
382 { 714 {
383 char *rname = fname; 715 char *rname = fname;
384 asprintf (&fname, "%s/%s", confbase, rname); 716 asprintf (&fname, "%s/%s", confbase, rname);
385 free (rname); 717 free (rname);
386 } 718 }
387 719
388 return fname; 720 return fname;
721}
722
723void
724conf_node::print ()
725{
726 printf ("%4d fe:fd:80:00:0%1x:%02x %c %-8.8s %-10.10s %02x %s%s%d\n",
727 id,
728 id >> 8, id & 0xff,
729 compress ? 'Y' : 'N',
730 connectmode == C_ONDEMAND ? "ondemand"
731 : connectmode == C_NEVER ? "never"
732 : connectmode == C_ALWAYS ? "always"
733 : connectmode == C_DISABLED ? "disabled"
734 : "",
735 nodename,
736 protocols,
737 hostname ? hostname : "",
738 hostname ? ":" : "",
739 hostname ? udp_port : 0
740 );
389} 741}
390 742
391void 743void
392configuration::print () 744configuration::print ()
393{ 745{
397 printf (_("MTU: %d\n"), mtu); 749 printf (_("MTU: %d\n"), mtu);
398 printf (_("rekeying interval: %d\n"), rekey); 750 printf (_("rekeying interval: %d\n"), rekey);
399 printf (_("keepalive interval: %d\n"), keepalive); 751 printf (_("keepalive interval: %d\n"), keepalive);
400 printf (_("interface: %s\n"), ifname); 752 printf (_("interface: %s\n"), ifname);
401 printf (_("primary rsa key: %s\n"), prikeyfile ? prikeyfile : "<default>"); 753 printf (_("primary rsa key: %s\n"), prikeyfile ? prikeyfile : "<default>");
402 printf (_("rsa key size: %d\n"), rsa_key ? RSA_size (rsa_key) : -1); 754 printf (_("rsa key size: %d\n"), rsa_key ? RSA_size (rsa_key) * 8 : -1);
403 printf ("\n"); 755 printf ("\n");
404 756
405 printf ("%4s %-17s %s %-8.8s %-10.10s %s\n", 757 printf ("%4s %-17s %s %-8.8s %-10.10s %04s %s\n",
406 _("ID#"), _("MAC"), _("Com"), _("Conmode"), _("Node"), _("Host:Port")); 758 _("ID#"), _("MAC"), _("Com"), _("Conmode"), _("Node"), _("Prot"), _("Host:Port"));
407 759
408 for (node_vector::iterator i = nodes.begin (); i != nodes.end (); ++i) 760 for (node_vector::iterator i = nodes.begin (); i != nodes.end (); ++i)
409 (*i)->print (); 761 (*i)->print ();
410 762
411 printf ("\n"); 763 printf ("\n");
412} 764}
413 765
414void 766configuration::configuration ()
415conf_node::print ()
416{ 767{
417 printf ("%4d fe:fd:80:00:0%1x:%02x %c %-8.8s %-10.10s %s%s%d\n", 768 asprintf (&confbase, "%s/gvpe", CONFDIR);
418 id,
419 id >> 8, id & 0xff,
420 compress ? 'Y' : 'N',
421 connectmode == C_ONDEMAND ? "ondemand" :
422 connectmode == C_NEVER ? "never" :
423 connectmode == C_ALWAYS ? "always" : "",
424 nodename,
425 hostname ? hostname : "",
426 hostname ? ":" : "",
427 hostname ? udp_port : 0
428 );
429}
430 769
770 init ();
771}
772
773configuration::~configuration ()
774{
775 cleanup ();
776}
777

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines