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

Comparing gvpe/src/gvpe.C (file contents):
Revision 1.3 by pcg, Wed Mar 23 20:07:56 2005 UTC vs.
Revision 1.24 by root, Sat Jul 13 04:10:29 2013 UTC

1/* 1/*
2 vped.C -- the main file for gvpe 2 gvpe.C -- the main file for gvpe
3 Copyright (C) 1998-2002 Ivo Timmermans <ivo@o2w.nl> 3 Copyright (C) 1998-2002 Ivo Timmermans <ivo@o2w.nl>
4 2000-2002 Guus Sliepen <guus@sliepen.eu.org> 4 2000-2002 Guus Sliepen <guus@sliepen.eu.org>
5 2003-2005 Marc Lehmann <gvpe@schmorp.de> 5 2003-2013 Marc Lehmann <gvpe@schmorp.de>
6 6
7 This file is part of GVPE. 7 This file is part of GVPE.
8 8
9 GVPE is free software; you can redistribute it and/or modify 9 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 10 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 11 Free Software Foundation; either version 3 of the License, or (at your
12 (at your option) any later version. 12 option) any later version.
13 13
14 This program is distributed in the hope that it will be useful, 14 This program is distributed in the hope that it will be useful, but
15 but WITHOUT ANY WARRANTY; without even the implied warranty of 15 WITHOUT ANY WARRANTY; without even the implied warranty of
16 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 16 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General
17 GNU General Public License for more details. 17 Public License for more details.
18 18
19 You should have received a copy of the GNU General Public License 19 You should have received a copy of the GNU General Public License along
20 along with gvpe; if not, write to the Free Software 20 with this program; if not, see <http://www.gnu.org/licenses/>.
21 Foundation, Inc. 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA 21
22 Additional permission under GNU GPL version 3 section 7
23
24 If you modify this Program, or any covered work, by linking or
25 combining it with the OpenSSL project's OpenSSL library (or a modified
26 version of that library), containing parts covered by the terms of the
27 OpenSSL or SSLeay licenses, the licensors of this Program grant you
28 additional permission to convey the resulting work. Corresponding
29 Source for a non-source form of such a combination shall include the
30 source code for the parts of OpenSSL used as well as that of the
31 covered work.
22*/ 32*/
23 33
24#include "config.h" 34#include "config.h"
25 35
26#include <cstdio> 36#include <cstdio>
… …
30#include <errno.h> 40#include <errno.h>
31#include <fcntl.h> 41#include <fcntl.h>
32#include <getopt.h> 42#include <getopt.h>
33#include <signal.h> 43#include <signal.h>
34#include <sys/types.h> 44#include <sys/types.h>
45#include <sys/stat.h>
35#include <unistd.h> 46#include <unistd.h>
36#include <signal.h> 47#include <signal.h>
37#include <termios.h> 48#include <termios.h>
38 49
39#if HAVE_SYS_MMAN_H 50#if HAVE_SYS_MMAN_H
… …
48 59
49#include "conf.h" 60#include "conf.h"
50#include "slog.h" 61#include "slog.h"
51#include "util.h" 62#include "util.h"
52#include "vpn.h" 63#include "vpn.h"
53#include "iom.h" 64#include "ev_cpp.h"
54 65
55static loglevel llevel = L_NONE; 66static loglevel llevel = L_NONE;
56 67
57/* If nonzero, display usage information and exit. */ 68/* If nonzero, display usage information and exit. */
58static int show_help; 69static int show_help;
… …
65 76
66/* If zero, don't detach from the terminal. */ 77/* If zero, don't detach from the terminal. */
67static int do_detach = 1; 78static int do_detach = 1;
68 79
69static struct option const long_options[] = 80static struct option const long_options[] =
70 { 81{
71 {"config", required_argument, NULL, 'c'}, 82 {"config", required_argument, NULL, 'c'},
72 {"help", no_argument, &show_help, 1}, 83 {"help", no_argument, &show_help, 1},
73 {"version", no_argument, &show_version, 1}, 84 {"version", no_argument, &show_version, 1},
74 {"no-detach", no_argument, &do_detach, 0}, 85 {"no-detach", no_argument, &do_detach, 0},
75 {"log-level", required_argument, NULL, 'l'}, 86 {"log-level", required_argument, NULL, 'l'},
76 {"mlock", no_argument, &do_mlock, 1}, 87 {"mlock", no_argument, &do_mlock, 1},
77 {NULL, 0, NULL, 0} 88 {NULL, 0, NULL, 0}
78 }; 89};
79 90
80static void 91static void
81usage (int status) 92usage (int status)
82{ 93{
83 if (status != 0) 94 if (status != 0)
… …
87 printf (_("Usage: %s [option]... NODENAME\n\n"), get_identity ()); 98 printf (_("Usage: %s [option]... NODENAME\n\n"), get_identity ());
88 printf (_ 99 printf (_
89 (" -c, --config=DIR Read configuration options from DIR.\n" 100 (" -c, --config=DIR Read configuration options from DIR.\n"
90 " -D, --no-detach Don't fork and detach.\n" 101 " -D, --no-detach Don't fork and detach.\n"
91 " -l, --log-level=LEVEL Set logging level (info, notice, warn are common).\n" 102 " -l, --log-level=LEVEL Set logging level (info, notice, warn are common).\n"
92 " -L, --mlock Lock tinc into main memory.\n" 103 " -L, --mlock Lock gvpe into main memory.\n"
93 " --help Display this help and exit.\n" 104 " --help Display this help and exit.\n"
94 " --version Output version information and exit.\n\n")); 105 " --version Output version information and exit.\n\n"));
95 printf (_("Report bugs to <vpe@plan9.de>.\n")); 106 printf (_("Report bugs to <gvpe@schmorp.de>.\n"));
96 } 107 }
97 108
98 exit (status); 109 exit (status);
99} 110}
100 111
101void 112static void
102parse_options (int argc, char **argv, char **envp) 113parse_options (int argc, char **argv, char **envp)
103{ 114{
104 int r; 115 int r;
105 int option_index = 0; 116 int option_index = 0;
106 117
107 while ((r = getopt_long (argc, argv, "-c:DLl:", long_options, &option_index)) != EOF) 118 while ((r = getopt_long (argc, argv, "c:DLl:", long_options, &option_index)) != EOF)
108 { 119 {
109 switch (r) 120 switch (r)
110 { 121 {
111 case 0: /* long option */ 122 case 0: /* long option */
112 break; 123 break;
113 124
114 case 1: /* this node name */
115 thisnode = strdup (optarg);
116 break;
117
118 case 'c': /* config file */ 125 case 'c': /* config file */
119 confbase = strdup (optarg); 126 confbase = strdup (optarg);
120 break; 127 break;
121 128
122 case 'D': /* no detach */ 129 case 'D': /* no detach */
… …
143 break; 150 break;
144 } 151 }
145 } 152 }
146} 153}
147 154
148/*
149 Close network connections, and terminate neatly 155// close network connections, and terminate neatly
150*/ 156static void
151void cleanup_and_exit(int c) 157cleanup_and_exit (int c)
152{ 158{
153 network.shutdown_all (); 159 network.shutdown_all ();
154 160
155 if (conf.pidfilename) 161 if (conf.pidfilename)
156 remove_pid (conf.pidfilename); 162 remove_pid (conf.pidfilename);
… …
158 slog (L_INFO, _("terminating with exit code %d"), c); 164 slog (L_INFO, _("terminating with exit code %d"), c);
159 165
160 exit (c); 166 exit (c);
161} 167}
162 168
163/*
164 Signal handlers. 169// signal handlers
165*/ 170static RETSIGTYPE
166RETSIGTYPE
167sigterm_handler (int a) 171sigterm_handler (int a)
168{ 172{
169 network.events |= vpn::EVENT_SHUTDOWN; 173 network.events |= vpn::EVENT_SHUTDOWN;
170 network.event.start (0); 174 network.event.start ();
171} 175}
172 176
173RETSIGTYPE 177static RETSIGTYPE
174sighup_handler (int a) 178sighup_handler (int a)
175{ 179{
176 network.events |= vpn::EVENT_RECONNECT; 180 network.events |= vpn::EVENT_RECONNECT;
177 network.event.start (0); 181 network.event.start ();
178} 182}
179 183
180RETSIGTYPE 184static RETSIGTYPE
181sigusr1_handler (int a) 185sigusr1_handler (int a)
182{ 186{
183 network.dump_status (); 187 network.dump_status ();
184} 188}
185 189
186RETSIGTYPE 190static RETSIGTYPE
187sigusr2_handler (int a) 191sigusr2_handler (int a)
188{ 192{
189} 193}
190 194
191void 195static void
192setup_signals (void) 196setup_signals (void)
193{ 197{
194 struct sigaction act; 198 struct sigaction act;
195 199
196 sigfillset (&act.sa_mask); 200 sigfillset (&act.sa_mask);
197 act.sa_flags = 0; 201 act.sa_flags = 0;
198 202
199 act.sa_handler = sighup_handler; sigaction (SIGHUP , &act, NULL); 203 act.sa_handler = sighup_handler; sigaction (SIGHUP , &act, NULL);
200 act.sa_handler = sigusr1_handler; sigaction (SIGUSR1, &act, NULL); 204 act.sa_handler = sigusr1_handler; sigaction (SIGUSR1, &act, NULL);
201 act.sa_handler = sigusr2_handler; sigaction (SIGUSR2, &act, NULL); 205 act.sa_handler = sigusr2_handler; sigaction (SIGUSR2, &act, NULL);
202 act.sa_handler = SIG_IGN; sigaction (SIGCHLD, &act, NULL);
203 act.sa_handler = SIG_IGN; sigaction (SIGPIPE, &act, NULL); 206 act.sa_handler = SIG_IGN; sigaction (SIGPIPE, &act, NULL);
204 act.sa_flags = SA_RESETHAND; 207 act.sa_flags = SA_RESETHAND;
205 act.sa_handler = sigterm_handler; sigaction (SIGINT , &act, NULL); 208 act.sa_handler = sigterm_handler; sigaction (SIGINT , &act, NULL);
206 act.sa_handler = sigterm_handler; sigaction (SIGTERM, &act, NULL); 209 act.sa_handler = sigterm_handler; sigaction (SIGTERM, &act, NULL);
207} 210}
208 211
212static int rand_fd;
213
214// antique C++ requires external linkage :/
215void
216reseed_rng (ev::timer &w, int revents)
217{
218 char buf [SEED_SIZE];
219 int n = read (rand_fd, buf, sizeof (buf));
220
221 if (n > 0)
222 RAND_seed (buf, n);
223}
224
225static void
226setup_rng (void)
227{
228 if (!*conf.seed_dev)
229 return;
230
231#ifndef O_BINARY
232# define O_BINARY 0
233#endif
234#ifndef O_NONBLOCK
235# define O_NONBLOCK 0
236#endif
237
238 rand_fd = open (conf.seed_dev, O_RDONLY | O_NONBLOCK | O_BINARY);
239
240 if (rand_fd < 0)
241 {
242 slog (L_ERR, _("unable to open seed device '%s': %s, exiting."), conf.seed_dev, strerror (errno));
243 exit (EXIT_FAILURE);
244 }
245
246 static ev::timer reseed_timer;
247
248 if (conf.reseed)
249 {
250 reseed_timer.set<reseed_rng> ();
251 reseed_timer.set (conf.reseed, conf.reseed);
252 reseed_timer.start (EV_DEFAULT);
253 }
254
255 reseed_rng (reseed_timer, 0);
256}
257
209int 258int
210main (int argc, char **argv, char **envp) 259main (int argc, char **argv, char **envp)
211{ 260{
212 ERR_load_crypto_strings (); // we have the RAM 261 ERR_load_crypto_strings (); // we have the RAM
213 262
… …
219 bindtextdomain (PACKAGE, LOCALEDIR); 268 bindtextdomain (PACKAGE, LOCALEDIR);
220 textdomain (PACKAGE); 269 textdomain (PACKAGE);
221 270
222 parse_options (argc, argv, envp); 271 parse_options (argc, argv, envp);
223 272
273 argc -= optind;
274 argv += optind;
275
224 if (show_version) 276 if (show_version)
225 { 277 {
226 printf (_("%s version %s (built %s %s, protocol %d.%d)\n"), get_identity (), 278 printf (_("%s version %s (built %s %s, protocol version %d.%d)\n"), get_identity (),
227 VERSION, __DATE__, __TIME__, PROTOCOL_MAJOR, PROTOCOL_MINOR); 279 VERSION, __DATE__, __TIME__, PROTOCOL_MAJOR, PROTOCOL_MINOR);
228 printf (_("Built with kernel interface %s/%s.\n"), IFTYPE, IFSUBTYPE); 280 printf (_("Built with kernel interface %s/%s.\n"), IFTYPE, IFSUBTYPE);
229 printf (_ 281 printf (_
230 ("Copyright (C) 2003 Marc Lehmann <vpe@plan9.de> and others.\n" 282 ("Copyright (C) 2003-2011 Marc Lehmann <gvpe@schmorp.de> and others.\n"
231 "See the AUTHORS file for a complete list.\n\n" 283 "See the AUTHORS file for a complete list.\n\n"
232 "tinc comes with ABSOLUTELY NO WARRANTY. This is free software,\n" 284 "GVPE comes with ABSOLUTELY NO WARRANTY. This is free software,\n"
233 "and you are welcome to redistribute it under certain conditions;\n" 285 "and you are welcome to redistribute it under certain conditions;\n"
234 "see the file COPYING for details.\n")); 286 "see the file COPYING for details.\n"));
235 287
236 return 0; 288 return 0;
237 } 289 }
… …
247 if (do_mlock) 299 if (do_mlock)
248 if (mlockall (MCL_CURRENT | MCL_FUTURE)) 300 if (mlockall (MCL_CURRENT | MCL_FUTURE))
249 slog (L_ERR, _("system call `%s' failed: %s"), "mlockall", strerror (errno)); 301 slog (L_ERR, _("system call `%s' failed: %s"), "mlockall", strerror (errno));
250#endif 302#endif
251 303
252 conf.read_config (true); 304 if (argc >= 1)
305 {
306 thisnode = *argv++;
307 argc--;
308 }
309
310 if (!ev_default_loop (0))
311 {
312 slog (L_ERR, _("unable to initialise the event loop (bad $LIBEV_METHODS?)"));
313 exit (EXIT_FAILURE);
314 }
315
316 {
317 configuration_parser (conf, true, argc, argv);
318 }
253 319
254 set_loglevel (llevel != L_NONE ? llevel : conf.llevel); 320 set_loglevel (llevel != L_NONE ? llevel : conf.llevel);
255 321
256 RAND_load_file ("/dev/urandom", 1024); 322 setup_rng ();
257 323
258 if (!THISNODE) 324 if (!THISNODE)
259 { 325 {
260 slog (L_ERR, _("current node not set, or node '%s' not found in configfile, specify the nodename when starting gvpe."), 326 slog (L_ERR, _("current node not set, or node '%s' not found in configfile, specify the nodename when starting gvpe."),
261 thisnode ? thisnode : "<unset>"); 327 thisnode ? thisnode : "<unset>");
… …
266 exit (EXIT_SUCCESS); 332 exit (EXIT_SUCCESS);
267 333
268 setup_signals (); 334 setup_signals ();
269 335
270 if (!network.setup ()) 336 if (!network.setup ())
337 if (network.drop_privileges ())
271 { 338 {
272 io_manager::loop (); 339 ev_run (EV_DEFAULT_ 0);
273 cleanup_and_exit (EXIT_FAILURE); 340 cleanup_and_exit (EXIT_FAILURE);
274 } 341 }
275 342
276 slog (L_ERR, _("unable to setup network, unrecoverable error, exiting.")); 343 slog (L_CRIT, _("unrecoverable error while setting up network, exiting."));
277 cleanup_and_exit (EXIT_FAILURE); 344 cleanup_and_exit (EXIT_FAILURE);
278} 345}
279 346

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines