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

Comparing gvpe/src/util.h (file contents):
Revision 1.3 by pcg, Fri Mar 21 23:17:01 2003 UTC vs.
Revision 1.26 by pcg, Thu Aug 7 19:07:03 2008 UTC

1/* 1/*
2 util.h -- process management and other utility functions 2 util.h -- process management and other utility functions
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 Marc Lehmannn <pcg@goof.com> 5 2003-2008 Marc Lehmann <gvpe@schmorp.de>
6 6
7 This file is part of GVPE.
8
7 This program is free software; you can redistribute it and/or modify 9 GVPE is free software; you can redistribute it and/or modify it
8 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
9 the Free Software Foundation; either version 2 of the License, or 11 Free Software Foundation; either version 3 of the License, or (at your
10 (at your option) any later version. 12 option) any later version.
11 13
12 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
13 but WITHOUT ANY WARRANTY; without even the implied warranty of 15 WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 16 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General
15 GNU General Public License for more details. 17 Public License for more details.
16 18
17 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
18 along with this program; if not, write to the Free Software 20 with this program; if not, see <http://www.gnu.org/licenses/>.
19 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.
20*/ 32*/
21 33
22#ifndef UTIL_H__ 34#ifndef UTIL_H__
23#define UTIL_H__ 35#define UTIL_H__
24 36
37#include <cstring>
25#include <sys/socket.h> 38#include <sys/types.h>
26#include <netinet/in.h>
27 39
28#include <map> 40#include <openssl/rsa.h>
29 41
30#include "iom.h"
31#include "device.h" 42#include "gettext.h"
32 43
33#define SOCKADDR sockaddr_in // this is lame, I know 44#include "slog.h"
45#include "ev_cpp.h"
46#include "callback.h"
47
48typedef ev_tstamp tstamp;
34 49
35/* 50/*
36 * check for an existing vped for this net, and write pid to pidfile 51 * check for an existing gvpe for this net, and write pid to pidfile
37 */ 52 */
38extern int write_pidfile (void); 53extern int write_pidfile (void);
39 54
40/* 55/*
41 * kill older vped 56 * kill older gvpe
42 */ 57 */
43extern int kill_other (int signal); 58extern int kill_other (int signal);
44 59
45/* 60/*
46 * Detach from current terminal, write pidfile, kill parent 61 * Detach from current terminal, write pidfile, kill parent
47 */ 62 */
48extern int detach (int do_detach); 63extern int detach (int do_detach);
49 64
50/* 65/*
51 * Set all files and paths according to netname
52 */
53extern void make_names (void);
54
55/*
56 * check wether the given path is an absolute pathname 66 * check wether the given path is an absolute pathname
57 */ 67 */
58#define ABSOLUTE_PATH(c) ((c)[0] == '/') 68#define ABSOLUTE_PATH(c) ((c)[0] == '/')
59 69
60static inline void 70/*****************************************************************************/
71
72typedef u8 mac[6];
73
61id2mac (unsigned int id, void *m) 74extern void id2mac (unsigned int id, void *m);
75
76#define mac2id(p) ((p)[0] & 0x01 ? 0 : ((p)[4] << 8) | (p)[5])
77
78struct sliding_window
62{ 79{
63 mac &p = *(mac *)m;
64
65 p[0] = 0xfe;
66 p[1] = 0xfd;
67 p[2] = 0x80;
68 p[3] = 0x00;
69 p[4] = id >> 8;
70 p[5] = id;
71}
72
73#define mac2id(p) (p[0] & 0x01 ? 0 : (p[4] << 8) | p[5])
74
75struct sockinfo
76 {
77 u32 host;
78 u16 port;
79
80 void set (const SOCKADDR *sa)
81 {
82 host = sa->sin_addr.s_addr;
83 port = sa->sin_port;
84 }
85
86 sockinfo()
87 {
88 host = port = 0;
89 }
90
91 sockinfo(const SOCKADDR &sa)
92 {
93 set (&sa);
94 }
95
96 sockinfo(const SOCKADDR *sa)
97 {
98 set (sa);
99 }
100
101 SOCKADDR *sa()
102 {
103 static SOCKADDR sa;
104
105 sa.sin_family = AF_INET;
106 sa.sin_port = port;
107 sa.sin_addr.s_addr = host;
108
109 return &sa;
110 }
111
112 operator const char *();
113 };
114
115inline bool
116operator == (const sockinfo &a, const sockinfo &b)
117{
118 return a.host == b.host && a.port == b.port;
119}
120
121inline bool
122operator < (const sockinfo &a, const sockinfo &b)
123{
124 return a.host < b.host
125 || (a.host == b.host && a.port < b.port);
126}
127
128struct sliding_window {
129 u32 v[(WINDOWSIZE + 31) / 32]; 80 u32 v[(WINDOWSIZE + 31) / 32];
130 u32 seq; 81 u32 seq;
131 82
132 void reset (u32 seqno) 83 void reset (u32 seqno)
133 { 84 {
… …
137 88
138 bool recv_ok (u32 seqno) 89 bool recv_ok (u32 seqno)
139 { 90 {
140 if (seqno <= seq - WINDOWSIZE) 91 if (seqno <= seq - WINDOWSIZE)
141 slog (L_ERR, _("received duplicate or outdated packet (received %08lx, expected %08lx)\n" 92 slog (L_ERR, _("received duplicate or outdated packet (received %08lx, expected %08lx)\n"
142 "possible replay attack, or just massive packet reordering"), seqno, seq + 1);//D 93 "possible replay attack, or just massive packet reordering"), seqno, seq + 1);
143 else if (seqno > seq + WINDOWSIZE) 94 else if (seqno > seq + WINDOWSIZE * 4)
144 slog (L_ERR, _("received duplicate or out-of-sync packet (received %08lx, expected %08lx)\n" 95 slog (L_ERR, _("received duplicate or out-of-sync packet (received %08lx, expected %08lx)\n"
145 "possible replay attack, or just massive packet loss"), seqno, seq + 1);//D 96 "possible replay attack, or just massive packet loss"), seqno, seq + 1);
146 else 97 else
147 { 98 {
148 while (seqno > seq) 99 while (seqno > seq)
149 { 100 {
150 seq++; 101 seq++;
… …
158 109
159 u32 s = seqno % WINDOWSIZE; 110 u32 s = seqno % WINDOWSIZE;
160 u32 *cell = v + (s >> 5); 111 u32 *cell = v + (s >> 5);
161 u32 mask = 1 << (s & 31); 112 u32 mask = 1 << (s & 31);
162 113
163 //printf ("received seqno %08lx, seq %08lx, mask %08lx is %08lx\n", seqno, seq, mask, ismask);
164 if (*cell & mask) 114 if (*cell & mask)
165 {
166 slog (L_ERR, _("received duplicate packet (received %08lx, expected %08lx)\n" 115 slog (L_ERR, _("received duplicate packet (received %08lx, expected %08lx)\n"
167 "possible replay attack, or just packet duplication"), seqno, seq + 1);//D 116 "possible replay attack, or just packet duplication"), seqno, seq + 1);
168 return false;
169 }
170 else 117 else
171 { 118 {
172 *cell |= mask; 119 *cell |= mask;
173 return true; 120 return true;
174 } 121 }
175 } 122 }
123
124 return false;
176 } 125 }
177}; 126};
178 127
128typedef callback<const char * ()> run_script_cb;
129
130// run a shell script (or actually an external program).
131pid_t run_script (const run_script_cb &cb, bool wait);
132
133#if ENABLE_HTTP_PROXY
134u8 *base64_encode (const u8 *data, unsigned int len);
179#endif 135#endif
180 136
137/*****************************************************************************/
138
139typedef u8 rsaclear[RSA_KEYLEN - RSA_OVERHEAD]; // challenge data;
140typedef u8 rsacrypt[RSA_KEYLEN]; // encrypted challenge
141
142static inline void
143rsa_encrypt (RSA *key, const rsaclear &chg, rsacrypt &encr)
144{
145 if (RSA_public_encrypt (sizeof chg,
146 (unsigned char *)&chg, (unsigned char *)&encr,
147 key, RSA_PKCS1_OAEP_PADDING) < 0)
148 fatal ("RSA_public_encrypt error");
149}
150
151static inline bool
152rsa_decrypt (RSA *key, const rsacrypt &encr, rsaclear &chg)
153{
154 return RSA_private_decrypt (sizeof encr,
155 (unsigned char *)&encr, (unsigned char *)&chg,
156 key, RSA_PKCS1_OAEP_PADDING) > 0;
157}
158
159#endif
160

Diff Legend

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