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

Comparing gvpe/src/util.C (file contents):
Revision 1.2 by pcg, Fri Mar 21 23:17:01 2003 UTC vs.
Revision 1.17 by pcg, Fri Mar 18 01:53:05 2005 UTC

1/* 1/*
2 util.C -- process management and other utility functions 2 util.C -- process management and other utility functions
3 Copyright (C) 2003-2005 Marc Lehmann <gvpe@schmorp.de>
3 4
4 Most of these are taken from tinc, see the AUTHORS file. 5 Some of these are taken from tinc, see the AUTHORS file.
5 6
7 This file is part of GVPE.
8
6 This program is free software; you can redistribute it and/or modify 9 GVPE is free software; you can redistribute it and/or modify
7 it under the terms of the GNU General Public License as published by 10 it under the terms of the GNU General Public License as published by
8 the Free Software Foundation; either version 2 of the License, or 11 the Free Software Foundation; either version 2 of the License, or
9 (at your option) any later version. 12 (at your option) any later version.
10 13
11 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,
12 but WITHOUT ANY WARRANTY; without even the implied warranty of 15 but WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 16 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 GNU General Public License for more details. 17 GNU General Public License for more details.
15 18
16 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
17 along with this program; if not, write to the Free Software 20 along with gvpe; if not, write to the Free Software
18 Foundation, Inc. 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA 21 Foundation, Inc. 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
19*/ 22*/
20 23
21#include "config.h" 24#include "config.h"
22 25
23#include <cstdio> 26#include <cstdio>
27#include <cstdlib>
24#include <cstring> 28#include <cstring>
25 29
26#include <errno.h> 30#include <errno.h>
27#include <signal.h> 31#include <signal.h>
28#include <sys/types.h> 32#include <sys/types.h>
33#include <sys/wait.h>
29#include <unistd.h> 34#include <unistd.h>
30#include <time.h> 35#include <time.h>
31#include <sys/socket.h>
32#include <netinet/in.h>
33#include <arpa/inet.h>
34 36
35#include <sys/mman.h>
36
37#include <openssl/rand.h>
38#include <openssl/rsa.h>
39#include <openssl/pem.h>
40#include <openssl/evp.h>
41
42#include "gettext.h" 37#include "netcompat.h"
38
43#include "pidfile.h" 39#include "pidfile.h"
44#include "dropin.h" 40#include "dropin.h"
45 41
46#include "global.h" 42#include "global.h"
47#include "conf.h" 43#include "conf.h"
44#include "util.h"
48#include "slog.h" 45#include "slog.h"
49#include "protocol.h"
50 46
51int 47int
52write_pidfile (void) 48write_pidfile (void)
53{ 49{
54 int pid; 50 int pid;
55 51
56 pid = check_pid (pidfilename); 52 pid = check_pid (conf.pidfilename);
57 53
58 if (pid) 54 if (pid)
59 { 55 {
60 fprintf (stderr, _("A vped is already running with pid %d.\n"), pid); 56 fprintf (stderr, _("A gvpe daemon is already running with pid %d.\n"), pid);
61 return 1; 57 return 1;
62 } 58 }
63 59
64 /* if it's locked, write-protected, or whatever */ 60 /* if it's locked, write-protected, or whatever */
65 if (!write_pid (pidfilename)) 61 if (!write_pid (conf.pidfilename))
66 return 1; 62 return 1;
67 63
68 return 0; 64 return 0;
69} 65}
70 66
71int 67int
72kill_other (int signal) 68kill_other (int signal)
73{ 69{
74 int pid; 70 int pid;
75 71
76 pid = read_pid (pidfilename); 72 pid = read_pid (conf.pidfilename);
77 73
78 if (!pid) 74 if (!pid)
79 { 75 {
80 fprintf (stderr, _("No other vped is running.\n")); 76 fprintf (stderr, _("No other gvpe daemon is running.\n"));
81 return 1; 77 return 1;
82 } 78 }
83 79
84 errno = 0; /* No error, sometimes errno is only changed on error */ 80 errno = 0; /* No error, sometimes errno is only changed on error */
85 81
86 /* ESRCH is returned when no process with that pid is found */ 82 /* ESRCH is returned when no process with that pid is found */
87 if (kill (pid, signal) && errno == ESRCH) 83 if (kill (pid, signal) && errno == ESRCH)
88 { 84 {
89 fprintf (stderr, _("The vped is no longer running. ")); 85 fprintf (stderr, _("The gvpe daemon is no longer running. "));
90 86
91 fprintf (stderr, _("Removing stale lock file.\n")); 87 fprintf (stderr, _("Removing stale lock file.\n"));
92 remove_pid (pidfilename); 88 remove_pid (conf.pidfilename);
93 } 89 }
94 90
95 return 0; 91 return 0;
96} 92}
97 93
… …
117 return -1; 113 return -1;
118 } 114 }
119 115
120 /* Now UPDATE the pid in the pidfile, because we changed it... */ 116 /* Now UPDATE the pid in the pidfile, because we changed it... */
121 117
122 if (!write_pid (pidfilename)) 118 if (!write_pid (conf.pidfilename))
123 return -1; 119 return -1;
124 120
125 log_to (LOGTO_SYSLOG); 121 log_to (LOGTO_SYSLOG);
126 } 122 }
127 else 123 else
128 log_to (LOGTO_SYSLOG | LOGTO_STDERR); 124 log_to (LOGTO_SYSLOG | LOGTO_STDERR);
129 125
130 slog (L_INFO, _("vped %s (%s %s) starting"), VERSION, __DATE__, __TIME__); 126 slog (L_INFO, _("gvpe daemon %s (%s %s) starting"), VERSION, __DATE__, __TIME__);
131 127
132 return 0; 128 return 0;
133} 129}
134 130
131void run_script (const run_script_cb &cb, bool wait)
132{
133 int pid;
134
135 if ((pid = fork ()) == 0)
136 {
137 char *filename;
138 asprintf (&filename, "%s/%s", confbase, cb());
139 execl (filename, filename, (char *) 0);
140 exit (126);
141 }
142 else if (pid > 0)
143 {
144 if (wait)
145 {
146 waitpid (pid, 0, 0);
147 /* TODO: check status */
148 }
149 }
150}
151
152#if ENABLE_HTTP_PROXY
153// works like strdup
154u8 *
155base64_encode (const u8 *data, unsigned int len)
156{
157 const static char base64[65] = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
158
159 unsigned int t, i;
160 const u8 *end = data + len;
161 u8 *res = new u8 [4 * ((len + 2) / 3) + 1];
162 u8 *out = res;
163
164 while (data <= end - 3)
165 {
166 t = (((data[0] << 8) | data[1]) << 8) | data[2];
167 data += 3;
168
169 *out++ = base64[(t >> 18) & 0x3f];
170 *out++ = base64[(t >> 12) & 0x3f];
171 *out++ = base64[(t >> 6) & 0x3f];
172 *out++ = base64[(t ) & 0x3f];
173 }
174
175 for (t = 0, i = 0; data < end; i++)
176 t = (t << 8) | *data++;
177
178 switch (i)
179 {
180 case 2:
181 *out++ = base64[(t >> 10) & 0x3f];
182 *out++ = base64[(t >> 4) & 0x3f];
183 *out++ = base64[(t << 2) & 0x3f];
184 *out++ = '=';
185 break;
186 case 1:
187 *out++ = base64[(t >> 2) & 0x3f];
188 *out++ = base64[(t << 4) & 0x3f];
189 *out++ = '=';
190 *out++ = '=';
191 break;
192 }
193
194 *out++ = 0;
195
196 return res;
197}
198#endif
199
135void 200void
136make_names (void) 201id2mac (unsigned int id, void *m)
137{ 202{
138 if (!pidfilename) 203 mac &p = *(mac *)m;
139 pidfilename = LOCALSTATEDIR "/run/vped.pid";
140 204
141 if (!confbase) 205 if (id)
142 asprintf (&confbase, "%s/vpe", CONFDIR); 206 {
207 p[0] = 0xfe;
208 p[1] = 0xfd;
209 p[2] = 0x80;
210 p[3] = 0x00;
211 p[4] = id >> 8;
212 p[5] = id;
213 }
214 else
215 {
216 p[0] = 0xff;
217 p[1] = 0xff;
218 p[2] = 0xff;
219 p[3] = 0xff;
220 p[4] = 0xff;
221 p[5] = 0xff;
222 }
143} 223}
144 224
145sockinfo::operator const char *()
146{
147 static char hostport[15 + 1 + 5 + 1];
148 in_addr ia = { host };
149
150 sprintf (hostport, "%.15s:%d", inet_ntoa (ia), ntohs (port) & 0xffff);
151
152 return hostport;
153}
154

Diff Legend

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