To get this branch, use:
bzr branch
http://bzr.recompile.se/loggerhead/mandos/release
« back to all changes in this revision
Viewing changes to plugins.d/mandosclient.c
- browse files at revision 38
- compare with another revision
- download diff
- download tarball
- view history from revision 38
- Committer: Teddy Hogeborn
- Date: 2008-08-03 01:09:36 UTC
- mfrom: (24.1.9 mandos)
- Revision ID: teddy@fukt.bsnet.se-20080803010936-ujme8tgxceszfbi1
* plugbasedclient.c (main): New "--userid" and "--groupid" options.
Take an additional non-option argument and
parse it as a plus-separated and -prefixed
list of additional options.
* plugins.d/mandosclient.c (DH_BITS): Replaced with
"mandos_context.dh_bits". All
users changed.
(certdir): Renamed to "keydir". All users changed.
(certfile): Renamed to "pubkeyfile". All users changed.
(certkey): Renamed to "seckeyfile". All users changed.
(encrypted_session): Replaced with "mandos_context". All users
changed.
(initgnutls): Take additional "session" and "dh_params" arguments.
All callers changed.
(start_mandos_communication): Take additional "mc" argument. All
callers changed. Print target IPv6
address if different than supplied
string.
(simple_poll) Replaced with "mandos_context.simple_poll". All users
changed.
(server): Replaced with "mandos_context.server". All users changed.
(main): Default interface to "eth0". Rename "--certdir" to
"--keydir", "--certkey" to "--seckey", and "--certfile" to
"--pubkey". New options "--dh-bits" and "--priority". If
the interface is not up, bring it up.
Take an additional non-option argument and
parse it as a plus-separated and -prefixed
list of additional options.
* plugins.d/mandosclient.c (DH_BITS): Replaced with
"mandos_context.dh_bits". All
users changed.
(certdir): Renamed to "keydir". All users changed.
(certfile): Renamed to "pubkeyfile". All users changed.
(certkey): Renamed to "seckeyfile". All users changed.
(encrypted_session): Replaced with "mandos_context". All users
changed.
(initgnutls): Take additional "session" and "dh_params" arguments.
All callers changed.
(start_mandos_communication): Take additional "mc" argument. All
callers changed. Print target IPv6
address if different than supplied
string.
(simple_poll) Replaced with "mandos_context.simple_poll". All users
changed.
(server): Replaced with "mandos_context.server". All users changed.
(main): Default interface to "eth0". Rename "--certdir" to
"--keydir", "--certkey" to "--seckey", and "--certfile" to
"--pubkey". New options "--dh-bits" and "--priority". If
the interface is not up, bring it up.
- files added:
- ca.pem
- files removed:
- .bzr-builddeb
- debian
- debian/po
- debian/source
- network-hooks.d
- files renamed:
- plugin-runner.c => plugbasedclient.c
- plugins.d/mandos-client.c => plugins.d/mandosclient.c
- plugins.d/password-prompt.c => plugins.d/passprompt.c
- mandos.conf => server.conf
- mandos => server.py
- files modified:
- Makefile
added
removed
plugins.d/mandosclient.c
1
1
/* -*- coding: utf-8 -*- */
2
2
/*
3
* Mandos-client - get and decrypt data from a Mandos server
3
* Mandos client - get and decrypt data from a Mandos server
4
4
*
5
5
* This program is partly derived from an example program for an Avahi
6
6
* service browser, downloaded from
9
9
* "browse_callback", and parts of "main".
10
10
*
11
11
* Everything else is
12
* Copyright © 2008-2011 Teddy Hogeborn
13
* Copyright © 2008-2011 Björn Påhlsson
12
* Copyright © 2007-2008 Teddy Hogeborn & Björn Påhlsson
14
13
*
15
14
* This program is free software: you can redistribute it and/or
16
15
* modify it under the terms of the GNU General Public License as
26
25
* along with this program. If not, see
27
26
* <http://www.gnu.org/licenses/>.
28
27
*
29
* Contact the authors at <mandos@recompile.se>.
28
* Contact the authors at <mandos@fukt.bsnet.se>.
30
29
*/
31
30
32
31
/* Needed by GPGME, specifically gpgme_data_seek() */
33
#ifndef _LARGEFILE_SOURCE
34
32
#define _LARGEFILE_SOURCE
35
#endif
36
#ifndef _FILE_OFFSET_BITS
37
33
#define _FILE_OFFSET_BITS 64
38
#endif
39
40
#define _GNU_SOURCE /* TEMP_FAILURE_RETRY(), asprintf() */
41
42
#include <stdio.h> /* fprintf(), stderr, fwrite(),
43
stdout, ferror(), remove() */
44
#include <stdint.h> /* uint16_t, uint32_t */
45
#include <stddef.h> /* NULL, size_t, ssize_t */
46
#include <stdlib.h> /* free(), EXIT_SUCCESS, srand(),
47
strtof(), abort() */
48
#include <stdbool.h> /* bool, false, true */
49
#include <string.h> /* memset(), strcmp(), strlen(),
50
strerror(), asprintf(), strcpy() */
51
#include <sys/ioctl.h> /* ioctl */
52
#include <sys/types.h> /* socket(), inet_pton(), sockaddr,
53
sockaddr_in6, PF_INET6,
54
SOCK_STREAM, uid_t, gid_t, open(),
55
opendir(), DIR */
56
#include <sys/stat.h> /* open(), S_ISREG */
57
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
58
inet_pton(), connect() */
59
#include <fcntl.h> /* open() */
60
#include <dirent.h> /* opendir(), struct dirent, readdir()
61
*/
62
#include <inttypes.h> /* PRIu16, PRIdMAX, intmax_t,
63
strtoimax() */
64
#include <assert.h> /* assert() */
65
#include <errno.h> /* perror(), errno,
66
program_invocation_short_name */
67
#include <time.h> /* nanosleep(), time(), sleep() */
68
#include <net/if.h> /* ioctl, ifreq, SIOCGIFFLAGS, IFF_UP,
69
SIOCSIFFLAGS, if_indextoname(),
70
if_nametoindex(), IF_NAMESIZE */
71
#include <netinet/in.h> /* IN6_IS_ADDR_LINKLOCAL,
72
INET_ADDRSTRLEN, INET6_ADDRSTRLEN
73
*/
74
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
75
getuid(), getgid(), seteuid(),
76
setgid(), pause(), _exit() */
77
#include <arpa/inet.h> /* inet_pton(), htons, inet_ntop() */
78
#include <iso646.h> /* not, or, and */
79
#include <argp.h> /* struct argp_option, error_t, struct
80
argp_state, struct argp,
81
argp_parse(), ARGP_KEY_ARG,
82
ARGP_KEY_END, ARGP_ERR_UNKNOWN */
83
#include <signal.h> /* sigemptyset(), sigaddset(),
84
sigaction(), SIGTERM, sig_atomic_t,
85
raise() */
86
#include <sysexits.h> /* EX_OSERR, EX_USAGE, EX_UNAVAILABLE,
87
EX_NOHOST, EX_IOERR, EX_PROTOCOL */
88
#include <sys/wait.h> /* waitpid(), WIFEXITED(),
89
WEXITSTATUS(), WTERMSIG() */
90
#include <grp.h> /* setgroups() */
91
92
#ifdef __linux__
93
#include <sys/klog.h> /* klogctl() */
94
#endif /* __linux__ */
95
96
/* Avahi */
97
/* All Avahi types, constants and functions
98
Avahi*, avahi_*,
99
AVAHI_* */
34
35
#include <stdio.h>
36
#include <assert.h>
37
#include <stdlib.h>
38
#include <time.h>
39
#include <net/if.h> /* if_nametoindex */
40
#include <sys/ioctl.h> // ioctl, ifreq, SIOCGIFFLAGS, IFF_UP, SIOCSIFFLAGS
41
#include <net/if.h> // ioctl, ifreq, SIOCGIFFLAGS, IFF_UP, SIOCSIFFLAGS
42
100
43
#include <avahi-core/core.h>
101
44
#include <avahi-core/lookup.h>
102
45
#include <avahi-core/log.h>
104
47
#include <avahi-common/malloc.h>
105
48
#include <avahi-common/error.h>
106
49
107
/* GnuTLS */
108
#include <gnutls/gnutls.h> /* All GnuTLS types, constants and
109
functions:
110
gnutls_*
111
init_gnutls_session(),
112
GNUTLS_* */
113
#include <gnutls/openpgp.h>
114
/* gnutls_certificate_set_openpgp_key_file(),
115
GNUTLS_OPENPGP_FMT_BASE64 */
116
117
/* GPGME */
118
#include <gpgme.h> /* All GPGME types, constants and
119
functions:
120
gpgme_*
121
GPGME_PROTOCOL_OpenPGP,
122
GPG_ERR_NO_* */
50
//mandos client part
51
#include <sys/types.h> /* socket(), inet_pton() */
52
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
53
struct in6_addr, inet_pton() */
54
#include <gnutls/gnutls.h> /* All GnuTLS stuff */
55
#include <gnutls/openpgp.h> /* GnuTLS with openpgp stuff */
56
57
#include <unistd.h> /* close() */
58
#include <netinet/in.h>
59
#include <stdbool.h> /* true */
60
#include <string.h> /* memset */
61
#include <arpa/inet.h> /* inet_pton() */
62
#include <iso646.h> /* not */
63
64
// gpgme
65
#include <errno.h> /* perror() */
66
#include <gpgme.h>
67
68
// getopt_long
69
#include <getopt.h>
123
70
124
71
#define BUFFER_SIZE 256
125
72
126
#define PATHDIR "/conf/conf.d/mandos"
127
#define SECKEY "seckey.txt"
128
#define PUBKEY "pubkey.txt"
129
#define HOOKDIR "/lib/mandos/network-hooks.d"
73
static const char *keydir = "/conf/conf.d/mandos";
74
static const char *pubkeyfile = "pubkey.txt";
75
static const char *seckeyfile = "seckey.txt";
130
76
131
77
bool debug = false;
132
static const char mandos_protocol_version[] = "1";
133
const char *argp_program_version = "mandos-client " VERSION;
134
const char *argp_program_bug_address = "<mandos@recompile.se>";
135
static const char sys_class_net[] = "/sys/class/net";
136
char *connect_to = NULL;
137
const char *hookdir = HOOKDIR;
138
139
/* Doubly linked list that need to be circularly linked when used */
140
typedef struct server{
141
const char *ip;
142
uint16_t port;
143
AvahiIfIndex if_index;
144
int af;
145
struct timespec last_seen;
146
struct server *next;
147
struct server *prev;
148
} server;
149
150
/* Used for passing in values through the Avahi callback functions */
78
79
/* Used for passing in values through all the callback functions */
151
80
typedef struct {
152
81
AvahiSimplePoll *simple_poll;
153
82
AvahiServer *server;
154
83
gnutls_certificate_credentials_t cred;
155
84
unsigned int dh_bits;
156
gnutls_dh_params_t dh_params;
157
85
const char *priority;
86
} mandos_context;
87
88
static ssize_t pgp_packet_decrypt (char *packet, size_t packet_size,
89
char **new_packet,
90
const char *homedir){
91
gpgme_data_t dh_crypto, dh_plain;
158
92
gpgme_ctx_t ctx;
159
server *current_server;
160
} mandos_context;
161
162
/* global context so signal handler can reach it*/
163
mandos_context mc = { .simple_poll = NULL, .server = NULL,
164
.dh_bits = 1024, .priority = "SECURE256"
165
":!CTYPE-X.509:+CTYPE-OPENPGP",
166
.current_server = NULL };
167
168
sig_atomic_t quit_now = 0;
169
int signal_received = 0;
170
171
/* Function to use when printing errors */
172
void perror_plus(const char *print_text){
173
fprintf(stderr, "Mandos plugin %s: ",
174
program_invocation_short_name);
175
perror(print_text);
176
}
177
178
int fprintf_plus(FILE *stream, const char *format, ...){
179
va_list ap;
180
va_start (ap, format);
181
182
TEMP_FAILURE_RETRY(fprintf(stream, "Mandos plugin %s: ",
183
program_invocation_short_name));
184
return TEMP_FAILURE_RETRY(vfprintf(stream, format, ap));
185
}
186
187
/*
188
* Make additional room in "buffer" for at least BUFFER_SIZE more
189
* bytes. "buffer_capacity" is how much is currently allocated,
190
* "buffer_length" is how much is already used.
191
*/
192
size_t incbuffer(char **buffer, size_t buffer_length,
193
size_t buffer_capacity){
194
if(buffer_length + BUFFER_SIZE > buffer_capacity){
195
*buffer = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
196
if(buffer == NULL){
197
return 0;
198
}
199
buffer_capacity += BUFFER_SIZE;
200
}
201
return buffer_capacity;
202
}
203
204
/* Add server to set of servers to retry periodically */
205
bool add_server(const char *ip, uint16_t port, AvahiIfIndex if_index,
206
int af){
207
int ret;
208
server *new_server = malloc(sizeof(server));
209
if(new_server == NULL){
210
perror_plus("malloc");
211
return false;
212
}
213
*new_server = (server){ .ip = strdup(ip),
214
.port = port,
215
.if_index = if_index,
216
.af = af };
217
if(new_server->ip == NULL){
218
perror_plus("strdup");
219
return false;
220
}
221
/* Special case of first server */
222
if (mc.current_server == NULL){
223
new_server->next = new_server;
224
new_server->prev = new_server;
225
mc.current_server = new_server;
226
/* Place the new server last in the list */
227
} else {
228
new_server->next = mc.current_server;
229
new_server->prev = mc.current_server->prev;
230
new_server->prev->next = new_server;
231
mc.current_server->prev = new_server;
232
}
233
ret = clock_gettime(CLOCK_MONOTONIC, &mc.current_server->last_seen);
234
if(ret == -1){
235
perror_plus("clock_gettime");
236
return false;
237
}
238
return true;
239
}
240
241
/*
242
* Initialize GPGME.
243
*/
244
static bool init_gpgme(const char *seckey, const char *pubkey,
245
const char *tempdir){
246
93
gpgme_error_t rc;
94
ssize_t ret;
95
ssize_t new_packet_capacity = 0;
96
ssize_t new_packet_length = 0;
247
97
gpgme_engine_info_t engine_info;
248
249
250
/*
251
* Helper function to insert pub and seckey to the engine keyring.
252
*/
253
bool import_key(const char *filename){
254
int ret;
255
int fd;
256
gpgme_data_t pgp_data;
257
258
fd = (int)TEMP_FAILURE_RETRY(open(filename, O_RDONLY));
259
if(fd == -1){
260
perror_plus("open");
261
return false;
262
}
263
264
rc = gpgme_data_new_from_fd(&pgp_data, fd);
265
if(rc != GPG_ERR_NO_ERROR){
266
fprintf_plus(stderr, "bad gpgme_data_new_from_fd: %s: %s\n",
267
gpgme_strsource(rc), gpgme_strerror(rc));
268
return false;
269
}
270
271
rc = gpgme_op_import(mc.ctx, pgp_data);
272
if(rc != GPG_ERR_NO_ERROR){
273
fprintf_plus(stderr, "bad gpgme_op_import: %s: %s\n",
274
gpgme_strsource(rc), gpgme_strerror(rc));
275
return false;
276
}
277
278
ret = (int)TEMP_FAILURE_RETRY(close(fd));
279
if(ret == -1){
280
perror_plus("close");
281
}
282
gpgme_data_release(pgp_data);
283
return true;
284
}
285
286
if(debug){
287
fprintf_plus(stderr, "Initializing GPGME\n");
98
99
if (debug){
100
fprintf(stderr, "Trying to decrypt OpenPGP packet\n");
288
101
}
289
102
290
103
/* Init GPGME */
291
104
gpgme_check_version(NULL);
292
105
rc = gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP);
293
if(rc != GPG_ERR_NO_ERROR){
294
fprintf_plus(stderr, "bad gpgme_engine_check_version: %s: %s\n",
295
gpgme_strsource(rc), gpgme_strerror(rc));
296
return false;
106
if (rc != GPG_ERR_NO_ERROR){
107
fprintf(stderr, "bad gpgme_engine_check_version: %s: %s\n",
108
gpgme_strsource(rc), gpgme_strerror(rc));
109
return -1;
297
110
}
298
111
299
/* Set GPGME home directory for the OpenPGP engine only */
300
rc = gpgme_get_engine_info(&engine_info);
301
if(rc != GPG_ERR_NO_ERROR){
302
fprintf_plus(stderr, "bad gpgme_get_engine_info: %s: %s\n",
303
gpgme_strsource(rc), gpgme_strerror(rc));
304
return false;
112
/* Set GPGME home directory */
113
rc = gpgme_get_engine_info (&engine_info);
114
if (rc != GPG_ERR_NO_ERROR){
115
fprintf(stderr, "bad gpgme_get_engine_info: %s: %s\n",
116
gpgme_strsource(rc), gpgme_strerror(rc));
117
return -1;
305
118
}
306
119
while(engine_info != NULL){
307
120
if(engine_info->protocol == GPGME_PROTOCOL_OpenPGP){
308
121
gpgme_set_engine_info(GPGME_PROTOCOL_OpenPGP,
309
engine_info->file_name, tempdir);
122
engine_info->file_name, homedir);
310
123
break;
311
124
}
312
125
engine_info = engine_info->next;
313
126
}
314
127
if(engine_info == NULL){
315
fprintf_plus(stderr, "Could not set GPGME home dir to %s\n",
316
tempdir);
317
return false;
318
}
319
320
/* Create new GPGME "context" */
321
rc = gpgme_new(&(mc.ctx));
322
if(rc != GPG_ERR_NO_ERROR){
323
fprintf_plus(stderr, "Mandos plugin mandos-client: "
324
"bad gpgme_new: %s: %s\n", gpgme_strsource(rc),
325
gpgme_strerror(rc));
326
return false;
327
}
328
329
if(not import_key(pubkey) or not import_key(seckey)){
330
return false;
331
}
332
333
return true;
334
}
335
336
/*
337
* Decrypt OpenPGP data.
338
* Returns -1 on error
339
*/
340
static ssize_t pgp_packet_decrypt(const char *cryptotext,
341
size_t crypto_size,
342
char **plaintext){
343
gpgme_data_t dh_crypto, dh_plain;
344
gpgme_error_t rc;
345
ssize_t ret;
346
size_t plaintext_capacity = 0;
347
ssize_t plaintext_length = 0;
348
349
if(debug){
350
fprintf_plus(stderr, "Trying to decrypt OpenPGP data\n");
351
}
352
353
/* Create new GPGME data buffer from memory cryptotext */
354
rc = gpgme_data_new_from_mem(&dh_crypto, cryptotext, crypto_size,
355
0);
356
if(rc != GPG_ERR_NO_ERROR){
357
fprintf_plus(stderr, "bad gpgme_data_new_from_mem: %s: %s\n",
358
gpgme_strsource(rc), gpgme_strerror(rc));
128
fprintf(stderr, "Could not set home dir to %s\n", homedir);
129
return -1;
130
}
131
132
/* Create new GPGME data buffer from packet buffer */
133
rc = gpgme_data_new_from_mem(&dh_crypto, packet, packet_size, 0);
134
if (rc != GPG_ERR_NO_ERROR){
135
fprintf(stderr, "bad gpgme_data_new_from_mem: %s: %s\n",
136
gpgme_strsource(rc), gpgme_strerror(rc));
359
137
return -1;
360
138
}
361
139
362
140
/* Create new empty GPGME data buffer for the plaintext */
363
141
rc = gpgme_data_new(&dh_plain);
364
if(rc != GPG_ERR_NO_ERROR){
365
fprintf_plus(stderr, "Mandos plugin mandos-client: "
366
"bad gpgme_data_new: %s: %s\n",
367
gpgme_strsource(rc), gpgme_strerror(rc));
368
gpgme_data_release(dh_crypto);
369
return -1;
370
}
371
372
/* Decrypt data from the cryptotext data buffer to the plaintext
373
data buffer */
374
rc = gpgme_op_decrypt(mc.ctx, dh_crypto, dh_plain);
375
if(rc != GPG_ERR_NO_ERROR){
376
fprintf_plus(stderr, "bad gpgme_op_decrypt: %s: %s\n",
377
gpgme_strsource(rc), gpgme_strerror(rc));
378
plaintext_length = -1;
379
if(debug){
380
gpgme_decrypt_result_t result;
381
result = gpgme_op_decrypt_result(mc.ctx);
382
if(result == NULL){
383
fprintf_plus(stderr, "gpgme_op_decrypt_result failed\n");
384
} else {
385
fprintf_plus(stderr, "Unsupported algorithm: %s\n",
386
result->unsupported_algorithm);
387
fprintf_plus(stderr, "Wrong key usage: %u\n",
388
result->wrong_key_usage);
389
if(result->file_name != NULL){
390
fprintf_plus(stderr, "File name: %s\n", result->file_name);
391
}
392
gpgme_recipient_t recipient;
393
recipient = result->recipients;
142
if (rc != GPG_ERR_NO_ERROR){
143
fprintf(stderr, "bad gpgme_data_new: %s: %s\n",
144
gpgme_strsource(rc), gpgme_strerror(rc));
145
return -1;
146
}
147
148
/* Create new GPGME "context" */
149
rc = gpgme_new(&ctx);
150
if (rc != GPG_ERR_NO_ERROR){
151
fprintf(stderr, "bad gpgme_new: %s: %s\n",
152
gpgme_strsource(rc), gpgme_strerror(rc));
153
return -1;
154
}
155
156
/* Decrypt data from the FILE pointer to the plaintext data
157
buffer */
158
rc = gpgme_op_decrypt(ctx, dh_crypto, dh_plain);
159
if (rc != GPG_ERR_NO_ERROR){
160
fprintf(stderr, "bad gpgme_op_decrypt: %s: %s\n",
161
gpgme_strsource(rc), gpgme_strerror(rc));
162
return -1;
163
}
164
165
if(debug){
166
fprintf(stderr, "Decryption of OpenPGP packet succeeded\n");
167
}
168
169
if (debug){
170
gpgme_decrypt_result_t result;
171
result = gpgme_op_decrypt_result(ctx);
172
if (result == NULL){
173
fprintf(stderr, "gpgme_op_decrypt_result failed\n");
174
} else {
175
fprintf(stderr, "Unsupported algorithm: %s\n",
176
result->unsupported_algorithm);
177
fprintf(stderr, "Wrong key usage: %d\n",
178
result->wrong_key_usage);
179
if(result->file_name != NULL){
180
fprintf(stderr, "File name: %s\n", result->file_name);
181
}
182
gpgme_recipient_t recipient;
183
recipient = result->recipients;
184
if(recipient){
394
185
while(recipient != NULL){
395
fprintf_plus(stderr, "Public key algorithm: %s\n",
396
gpgme_pubkey_algo_name
397
(recipient->pubkey_algo));
398
fprintf_plus(stderr, "Key ID: %s\n", recipient->keyid);
399
fprintf_plus(stderr, "Secret key available: %s\n",
400
recipient->status == GPG_ERR_NO_SECKEY
401
? "No" : "Yes");
186
fprintf(stderr, "Public key algorithm: %s\n",
187
gpgme_pubkey_algo_name(recipient->pubkey_algo));
188
fprintf(stderr, "Key ID: %s\n", recipient->keyid);
189
fprintf(stderr, "Secret key available: %s\n",
190
recipient->status == GPG_ERR_NO_SECKEY
191
? "No" : "Yes");
402
192
recipient = recipient->next;
403
193
}
404
194
}
405
195
}
406
goto decrypt_end;
407
196
}
408
197
409
if(debug){
410
fprintf_plus(stderr, "Decryption of OpenPGP data succeeded\n");
411
}
198
/* Delete the GPGME FILE pointer cryptotext data buffer */
199
gpgme_data_release(dh_crypto);
412
200
413
201
/* Seek back to the beginning of the GPGME plaintext data buffer */
414
if(gpgme_data_seek(dh_plain, (off_t)0, SEEK_SET) == -1){
415
perror_plus("gpgme_data_seek");
416
plaintext_length = -1;
417
goto decrypt_end;
202
if (gpgme_data_seek(dh_plain, (off_t) 0, SEEK_SET) == -1){
203
perror("pgpme_data_seek");
418
204
}
419
205
420
*plaintext = NULL;
206
*new_packet = 0;
421
207
while(true){
422
plaintext_capacity = incbuffer(plaintext,
423
(size_t)plaintext_length,
424
plaintext_capacity);
425
if(plaintext_capacity == 0){
426
perror_plus("incbuffer");
427
plaintext_length = -1;
428
goto decrypt_end;
208
if (new_packet_length + BUFFER_SIZE > new_packet_capacity){
209
*new_packet = realloc(*new_packet,
210
(unsigned int)new_packet_capacity
211
+ BUFFER_SIZE);
212
if (*new_packet == NULL){
213
perror("realloc");
214
return -1;
215
}
216
new_packet_capacity += BUFFER_SIZE;
429
217
}
430
218
431
ret = gpgme_data_read(dh_plain, *plaintext + plaintext_length,
219
ret = gpgme_data_read(dh_plain, *new_packet + new_packet_length,
432
220
BUFFER_SIZE);
433
221
/* Print the data, if any */
434
if(ret == 0){
435
/* EOF */
222
if (ret == 0){
436
223
break;
437
224
}
438
225
if(ret < 0){
439
perror_plus("gpgme_data_read");
440
plaintext_length = -1;
441
goto decrypt_end;
442
}
443
plaintext_length += ret;
444
}
445
446
if(debug){
447
fprintf_plus(stderr, "Decrypted password is: ");
448
for(ssize_t i = 0; i < plaintext_length; i++){
449
fprintf(stderr, "%02hhX ", (*plaintext)[i]);
450
}
451
fprintf(stderr, "\n");
452
}
453
454
decrypt_end:
455
456
/* Delete the GPGME cryptotext data buffer */
457
gpgme_data_release(dh_crypto);
226
perror("gpgme_data_read");
227
return -1;
228
}
229
new_packet_length += ret;
230
}
231
232
/* FIXME: check characters before printing to screen so to not print
233
terminal control characters */
234
/* if(debug){ */
235
/* fprintf(stderr, "decrypted password is: "); */
236
/* fwrite(*new_packet, 1, new_packet_length, stderr); */
237
/* fprintf(stderr, "\n"); */
238
/* } */
458
239
459
240
/* Delete the GPGME plaintext data buffer */
460
241
gpgme_data_release(dh_plain);
461
return plaintext_length;
242
return new_packet_length;
462
243
}
463
244
464
static const char * safer_gnutls_strerror(int value){
465
const char *ret = gnutls_strerror(value); /* Spurious warning from
466
-Wunreachable-code */
467
if(ret == NULL)
245
static const char * safer_gnutls_strerror (int value) {
246
const char *ret = gnutls_strerror (value);
247
if (ret == NULL)
468
248
ret = "(unknown)";
469
249
return ret;
470
250
}
471
251
472
/* GnuTLS log function callback */
473
252
static void debuggnutls(__attribute__((unused)) int level,
474
253
const char* string){
475
fprintf_plus(stderr, "GnuTLS: %s", string);
254
fprintf(stderr, "%s", string);
476
255
}
477
256
478
static int init_gnutls_global(const char *pubkeyfilename,
479
const char *seckeyfilename){
257
static int initgnutls(mandos_context *mc, gnutls_session_t *session,
258
gnutls_dh_params_t *dh_params){
259
const char *err;
480
260
int ret;
481
261
482
262
if(debug){
483
fprintf_plus(stderr, "Initializing GnuTLS\n");
263
fprintf(stderr, "Initializing GnuTLS\n");
484
264
}
485
486
ret = gnutls_global_init();
487
if(ret != GNUTLS_E_SUCCESS){
488
fprintf_plus(stderr, "GnuTLS global_init: %s\n",
489
safer_gnutls_strerror(ret));
265
266
if ((ret = gnutls_global_init ())
267
!= GNUTLS_E_SUCCESS) {
268
fprintf (stderr, "global_init: %s\n", safer_gnutls_strerror(ret));
490
269
return -1;
491
270
}
492
271
493
if(debug){
494
/* "Use a log level over 10 to enable all debugging options."
495
* - GnuTLS manual
496
*/
272
if (debug){
497
273
gnutls_global_set_log_level(11);
498
274
gnutls_global_set_log_function(debuggnutls);
499
275
}
500
276
501
/* OpenPGP credentials */
502
ret = gnutls_certificate_allocate_credentials(&mc.cred);
503
if(ret != GNUTLS_E_SUCCESS){
504
fprintf_plus(stderr, "GnuTLS memory error: %s\n",
505
safer_gnutls_strerror(ret));
506
gnutls_global_deinit();
277
/* openpgp credentials */
278
if ((ret = gnutls_certificate_allocate_credentials (&mc->cred))
279
!= GNUTLS_E_SUCCESS) {
280
fprintf (stderr, "memory error: %s\n",
281
safer_gnutls_strerror(ret));
507
282
return -1;
508
283
}
509
284
510
285
if(debug){
511
fprintf_plus(stderr, "Attempting to use OpenPGP public key %s and"
512
" secret key %s as GnuTLS credentials\n",
513
pubkeyfilename,
514
seckeyfilename);
286
fprintf(stderr, "Attempting to use OpenPGP certificate %s"
287
" and keyfile %s as GnuTLS credentials\n", pubkeyfile,
288
seckeyfile);
515
289
}
516
290
517
291
ret = gnutls_certificate_set_openpgp_key_file
518
(mc.cred, pubkeyfilename, seckeyfilename,
519
GNUTLS_OPENPGP_FMT_BASE64);
520
if(ret != GNUTLS_E_SUCCESS){
521
fprintf_plus(stderr,
522
"Error[%d] while reading the OpenPGP key pair ('%s',"
523
" '%s')\n", ret, pubkeyfilename, seckeyfilename);
524
fprintf_plus(stderr, "The GnuTLS error is: %s\n",
525
safer_gnutls_strerror(ret));
526
goto globalfail;
527
}
528
529
/* GnuTLS server initialization */
530
ret = gnutls_dh_params_init(&mc.dh_params);
531
if(ret != GNUTLS_E_SUCCESS){
532
fprintf_plus(stderr, "Error in GnuTLS DH parameter"
533
" initialization: %s\n",
534
safer_gnutls_strerror(ret));
535
goto globalfail;
536
}
537
ret = gnutls_dh_params_generate2(mc.dh_params, mc.dh_bits);
538
if(ret != GNUTLS_E_SUCCESS){
539
fprintf_plus(stderr, "Error in GnuTLS prime generation: %s\n",
540
safer_gnutls_strerror(ret));
541
goto globalfail;
542
}
543
544
gnutls_certificate_set_dh_params(mc.cred, mc.dh_params);
545
546
return 0;
547
548
globalfail:
549
550
gnutls_certificate_free_credentials(mc.cred);
551
gnutls_global_deinit();
552
gnutls_dh_params_deinit(mc.dh_params);
553
return -1;
554
}
555
556
static int init_gnutls_session(gnutls_session_t *session){
557
int ret;
558
/* GnuTLS session creation */
559
do {
560
ret = gnutls_init(session, GNUTLS_SERVER);
561
if(quit_now){
562
return -1;
563
}
564
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
565
if(ret != GNUTLS_E_SUCCESS){
566
fprintf_plus(stderr,
567
"Error in GnuTLS session initialization: %s\n",
568
safer_gnutls_strerror(ret));
569
}
570
571
{
572
const char *err;
573
do {
574
ret = gnutls_priority_set_direct(*session, mc.priority, &err);
575
if(quit_now){
576
gnutls_deinit(*session);
577
return -1;
578
}
579
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
580
if(ret != GNUTLS_E_SUCCESS){
581
fprintf_plus(stderr, "Syntax error at: %s\n", err);
582
fprintf_plus(stderr, "GnuTLS error: %s\n",
583
safer_gnutls_strerror(ret));
584
gnutls_deinit(*session);
585
return -1;
586
}
587
}
588
589
do {
590
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
591
mc.cred);
592
if(quit_now){
593
gnutls_deinit(*session);
594
return -1;
595
}
596
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
597
if(ret != GNUTLS_E_SUCCESS){
598
fprintf_plus(stderr, "Error setting GnuTLS credentials: %s\n",
599
safer_gnutls_strerror(ret));
600
gnutls_deinit(*session);
292
(mc->cred, pubkeyfile, seckeyfile, GNUTLS_OPENPGP_FMT_BASE64);
293
if (ret != GNUTLS_E_SUCCESS) {
294
fprintf
295
(stderr, "Error[%d] while reading the OpenPGP key pair ('%s',"
296
" '%s')\n",
297
ret, pubkeyfile, seckeyfile);
298
fprintf(stdout, "The Error is: %s\n",
299
safer_gnutls_strerror(ret));
300
return -1;
301
}
302
303
//GnuTLS server initialization
304
if ((ret = gnutls_dh_params_init(dh_params))
305
!= GNUTLS_E_SUCCESS) {
306
fprintf (stderr, "Error in dh parameter initialization: %s\n",
307
safer_gnutls_strerror(ret));
308
return -1;
309
}
310
311
if ((ret = gnutls_dh_params_generate2(*dh_params, mc->dh_bits))
312
!= GNUTLS_E_SUCCESS) {
313
fprintf (stderr, "Error in prime generation: %s\n",
314
safer_gnutls_strerror(ret));
315
return -1;
316
}
317
318
gnutls_certificate_set_dh_params(mc->cred, *dh_params);
319
320
// GnuTLS session creation
321
if ((ret = gnutls_init(session, GNUTLS_SERVER))
322
!= GNUTLS_E_SUCCESS){
323
fprintf(stderr, "Error in GnuTLS session initialization: %s\n",
324
safer_gnutls_strerror(ret));
325
}
326
327
if ((ret = gnutls_priority_set_direct(*session, mc->priority, &err))
328
!= GNUTLS_E_SUCCESS) {
329
fprintf(stderr, "Syntax error at: %s\n", err);
330
fprintf(stderr, "GnuTLS error: %s\n",
331
safer_gnutls_strerror(ret));
332
return -1;
333
}
334
335
if ((ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
336
mc->cred))
337
!= GNUTLS_E_SUCCESS) {
338
fprintf(stderr, "Error setting a credentials set: %s\n",
339
safer_gnutls_strerror(ret));
601
340
return -1;
602
341
}
603
342
604
343
/* ignore client certificate if any. */
605
gnutls_certificate_server_set_request(*session, GNUTLS_CERT_IGNORE);
344
gnutls_certificate_server_set_request (*session,
345
GNUTLS_CERT_IGNORE);
606
346
607
gnutls_dh_set_prime_bits(*session, mc.dh_bits);
347
gnutls_dh_set_prime_bits (*session, mc->dh_bits);
608
348
609
349
return 0;
610
350
}
611
351
612
/* Avahi log function callback */
613
352
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
614
353
__attribute__((unused)) const char *txt){}
615
354
616
/* Called when a Mandos server is found */
617
355
static int start_mandos_communication(const char *ip, uint16_t port,
618
356
AvahiIfIndex if_index,
619
int af){
620
int ret, tcp_sd = -1;
621
ssize_t sret;
622
union {
623
struct sockaddr_in in;
624
struct sockaddr_in6 in6;
625
} to;
357
mandos_context *mc){
358
int ret, tcp_sd;
359
struct sockaddr_in6 to;
626
360
char *buffer = NULL;
627
char *decrypted_buffer = NULL;
361
char *decrypted_buffer;
628
362
size_t buffer_length = 0;
629
363
size_t buffer_capacity = 0;
630
size_t written;
631
int retval = -1;
364
ssize_t decrypted_buffer_size;
365
size_t written = 0;
366
int retval = 0;
367
char interface[IF_NAMESIZE];
632
368
gnutls_session_t session;
633
int pf; /* Protocol family */
634
635
errno = 0;
636
637
if(quit_now){
638
errno = EINTR;
639
return -1;
640
}
641
642
switch(af){
643
case AF_INET6:
644
pf = PF_INET6;
645
break;
646
case AF_INET:
647
pf = PF_INET;
648
break;
649
default:
650
fprintf_plus(stderr, "Bad address family: %d\n", af);
651
errno = EINVAL;
652
return -1;
653
}
654
655
ret = init_gnutls_session(&session);
656
if(ret != 0){
657
return -1;
658
}
659
660
if(debug){
661
fprintf_plus(stderr, "Setting up a TCP connection to %s, port %"
662
PRIu16 "\n", ip, port);
663
}
664
665
tcp_sd = socket(pf, SOCK_STREAM, 0);
666
if(tcp_sd < 0){
667
int e = errno;
668
perror_plus("socket");
669
errno = e;
670
goto mandos_end;
671
}
672
673
if(quit_now){
674
errno = EINTR;
675
goto mandos_end;
676
}
677
678
memset(&to, 0, sizeof(to));
679
if(af == AF_INET6){
680
to.in6.sin6_family = (sa_family_t)af;
681
ret = inet_pton(af, ip, &to.in6.sin6_addr);
682
} else { /* IPv4 */
683
to.in.sin_family = (sa_family_t)af;
684
ret = inet_pton(af, ip, &to.in.sin_addr);
685
}
686
if(ret < 0 ){
687
int e = errno;
688
perror_plus("inet_pton");
689
errno = e;
690
goto mandos_end;
369
gnutls_dh_params_t dh_params;
370
371
if(debug){
372
fprintf(stderr, "Setting up a tcp connection to %s, port %d\n",
373
ip, port);
374
}
375
376
tcp_sd = socket(PF_INET6, SOCK_STREAM, 0);
377
if(tcp_sd < 0) {
378
perror("socket");
379
return -1;
380
}
381
382
if(debug){
383
if(if_indextoname((unsigned int)if_index, interface) == NULL){
384
perror("if_indextoname");
385
return -1;
386
}
387
fprintf(stderr, "Binding to interface %s\n", interface);
388
}
389
390
memset(&to,0,sizeof(to)); /* Spurious warning */
391
to.sin6_family = AF_INET6;
392
ret = inet_pton(AF_INET6, ip, &to.sin6_addr);
393
if (ret < 0 ){
394
perror("inet_pton");
395
return -1;
691
396
}
692
397
if(ret == 0){
693
int e = errno;
694
fprintf_plus(stderr, "Bad address: %s\n", ip);
695
errno = e;
696
goto mandos_end;
697
}
698
if(af == AF_INET6){
699
to.in6.sin6_port = htons(port); /* Spurious warnings from
700
-Wconversion and
701
-Wunreachable-code */
702
703
if(IN6_IS_ADDR_LINKLOCAL /* Spurious warnings from */
704
(&to.in6.sin6_addr)){ /* -Wstrict-aliasing=2 or lower and
705
-Wunreachable-code*/
706
if(if_index == AVAHI_IF_UNSPEC){
707
fprintf_plus(stderr, "An IPv6 link-local address is"
708
" incomplete without a network interface\n");
709
errno = EINVAL;
710
goto mandos_end;
711
}
712
/* Set the network interface number as scope */
713
to.in6.sin6_scope_id = (uint32_t)if_index;
714
}
715
} else {
716
to.in.sin_port = htons(port); /* Spurious warnings from
717
-Wconversion and
718
-Wunreachable-code */
719
}
398
fprintf(stderr, "Bad address: %s\n", ip);
399
return -1;
400
}
401
to.sin6_port = htons(port); /* Spurious warning */
720
402
721
if(quit_now){
722
errno = EINTR;
723
goto mandos_end;
724
}
403
to.sin6_scope_id = (uint32_t)if_index;
725
404
726
405
if(debug){
727
if(af == AF_INET6 and if_index != AVAHI_IF_UNSPEC){
728
char interface[IF_NAMESIZE];
729
if(if_indextoname((unsigned int)if_index, interface) == NULL){
730
perror_plus("if_indextoname");
731
} else {
732
fprintf_plus(stderr, "Connection to: %s%%%s, port %" PRIu16
733
"\n", ip, interface, port);
734
}
735
} else {
736
fprintf_plus(stderr, "Connection to: %s, port %" PRIu16 "\n",
737
ip, port);
738
}
739
char addrstr[(INET_ADDRSTRLEN > INET6_ADDRSTRLEN) ?
740
INET_ADDRSTRLEN : INET6_ADDRSTRLEN] = "";
741
const char *pcret;
742
if(af == AF_INET6){
743
pcret = inet_ntop(af, &(to.in6.sin6_addr), addrstr,
744
sizeof(addrstr));
745
} else {
746
pcret = inet_ntop(af, &(to.in.sin_addr), addrstr,
747
sizeof(addrstr));
748
}
749
if(pcret == NULL){
750
perror_plus("inet_ntop");
406
fprintf(stderr, "Connection to: %s, port %d\n", ip, port);
407
char addrstr[INET6_ADDRSTRLEN] = "";
408
if(inet_ntop(to.sin6_family, &(to.sin6_addr), addrstr,
409
sizeof(addrstr)) == NULL){
410
perror("inet_ntop");
751
411
} else {
752
412
if(strcmp(addrstr, ip) != 0){
753
fprintf_plus(stderr, "Canonical address form: %s\n", addrstr);
754
}
755
}
756
}
757
758
if(quit_now){
759
errno = EINTR;
760
goto mandos_end;
761
}
762
763
if(af == AF_INET6){
764
ret = connect(tcp_sd, &to.in6, sizeof(to));
765
} else {
766
ret = connect(tcp_sd, &to.in, sizeof(to)); /* IPv4 */
767
}
768
if(ret < 0){
769
if ((errno != ECONNREFUSED and errno != ENETUNREACH) or debug){
770
int e = errno;
771
perror_plus("connect");
772
errno = e;
773
}
774
goto mandos_end;
775
}
776
777
if(quit_now){
778
errno = EINTR;
779
goto mandos_end;
780
}
781
782
const char *out = mandos_protocol_version;
783
written = 0;
784
while(true){
785
size_t out_size = strlen(out);
786
ret = (int)TEMP_FAILURE_RETRY(write(tcp_sd, out + written,
787
out_size - written));
788
if(ret == -1){
789
int e = errno;
790
perror_plus("write");
791
errno = e;
792
goto mandos_end;
793
}
794
written += (size_t)ret;
795
if(written < out_size){
796
continue;
797
} else {
798
if(out == mandos_protocol_version){
799
written = 0;
800
out = "\r\n";
801
} else {
802
break;
803
}
804
}
805
806
if(quit_now){
807
errno = EINTR;
808
goto mandos_end;
809
}
810
}
413
fprintf(stderr, "Canonical address form: %s\n", addrstr);
414
}
415
}
416
}
417
418
ret = connect(tcp_sd, (struct sockaddr *) &to, sizeof(to));
419
if (ret < 0){
420
perror("connect");
421
return -1;
422
}
423
424
ret = initgnutls (mc, &session, &dh_params);
425
if (ret != 0){
426
retval = -1;
427
return -1;
428
}
429
430
gnutls_transport_set_ptr (session, (gnutls_transport_ptr_t) tcp_sd);
811
431
812
432
if(debug){
813
fprintf_plus(stderr, "Establishing TLS session with %s\n", ip);
814
}
815
816
if(quit_now){
817
errno = EINTR;
818
goto mandos_end;
819
}
820
821
/* Spurious warning from -Wint-to-pointer-cast */
822
gnutls_transport_set_ptr(session, (gnutls_transport_ptr_t) tcp_sd);
823
824
if(quit_now){
825
errno = EINTR;
826
goto mandos_end;
827
}
828
829
do {
830
ret = gnutls_handshake(session);
831
if(quit_now){
832
errno = EINTR;
833
goto mandos_end;
834
}
835
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
836
837
if(ret != GNUTLS_E_SUCCESS){
433
fprintf(stderr, "Establishing TLS session with %s\n", ip);
434
}
435
436
ret = gnutls_handshake (session);
437
438
if (ret != GNUTLS_E_SUCCESS){
838
439
if(debug){
839
fprintf_plus(stderr, "*** GnuTLS Handshake failed ***\n");
840
gnutls_perror(ret);
440
fprintf(stderr, "\n*** Handshake failed ***\n");
441
gnutls_perror (ret);
841
442
}
842
errno = EPROTO;
843
goto mandos_end;
443
retval = -1;
444
goto exit;
844
445
}
845
446
846
/* Read OpenPGP packet that contains the wanted password */
447
//Retrieve OpenPGP packet that contains the wanted password
847
448
848
449
if(debug){
849
fprintf_plus(stderr, "Retrieving OpenPGP encrypted password from"
850
" %s\n", ip);
450
fprintf(stderr, "Retrieving pgp encrypted password from %s\n",
451
ip);
851
452
}
852
453
853
454
while(true){
854
855
if(quit_now){
856
errno = EINTR;
857
goto mandos_end;
858
}
859
860
buffer_capacity = incbuffer(&buffer, buffer_length,
861
buffer_capacity);
862
if(buffer_capacity == 0){
863
int e = errno;
864
perror_plus("incbuffer");
865
errno = e;
866
goto mandos_end;
867
}
868
869
if(quit_now){
870
errno = EINTR;
871
goto mandos_end;
872
}
873
874
sret = gnutls_record_recv(session, buffer+buffer_length,
875
BUFFER_SIZE);
876
if(sret == 0){
455
if (buffer_length + BUFFER_SIZE > buffer_capacity){
456
buffer = realloc(buffer, buffer_capacity + BUFFER_SIZE);
457
if (buffer == NULL){
458
perror("realloc");
459
goto exit;
460
}
461
buffer_capacity += BUFFER_SIZE;
462
}
463
464
ret = gnutls_record_recv(session, buffer+buffer_length,
465
BUFFER_SIZE);
466
if (ret == 0){
877
467
break;
878
468
}
879
if(sret < 0){
880
switch(sret){
469
if (ret < 0){
470
switch(ret){
881
471
case GNUTLS_E_INTERRUPTED:
882
472
case GNUTLS_E_AGAIN:
883
473
break;
884
474
case GNUTLS_E_REHANDSHAKE:
885
do {
886
ret = gnutls_handshake(session);
887
888
if(quit_now){
889
errno = EINTR;
890
goto mandos_end;
891
}
892
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
893
if(ret < 0){
894
fprintf_plus(stderr, "*** GnuTLS Re-handshake failed "
895
"***\n");
896
gnutls_perror(ret);
897
errno = EPROTO;
898
goto mandos_end;
475
ret = gnutls_handshake (session);
476
if (ret < 0){
477
fprintf(stderr, "\n*** Handshake failed ***\n");
478
gnutls_perror (ret);
479
retval = -1;
480
goto exit;
899
481
}
900
482
break;
901
483
default:
902
fprintf_plus(stderr, "Unknown error while reading data from"
903
" encrypted session with Mandos server\n");
904
gnutls_bye(session, GNUTLS_SHUT_RDWR);
905
errno = EIO;
906
goto mandos_end;
484
fprintf(stderr, "Unknown error while reading data from"
485
" encrypted session with mandos server\n");
486
retval = -1;
487
gnutls_bye (session, GNUTLS_SHUT_RDWR);
488
goto exit;
907
489
}
908
490
} else {
909
buffer_length += (size_t) sret;
910
}
911
}
912
913
if(debug){
914
fprintf_plus(stderr, "Closing TLS session\n");
915
}
916
917
if(quit_now){
918
errno = EINTR;
919
goto mandos_end;
920
}
921
922
do {
923
ret = gnutls_bye(session, GNUTLS_SHUT_RDWR);
924
if(quit_now){
925
errno = EINTR;
926
goto mandos_end;
927
}
928
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
929
930
if(buffer_length > 0){
931
ssize_t decrypted_buffer_size;
932
decrypted_buffer_size = pgp_packet_decrypt(buffer, buffer_length,
933
&decrypted_buffer);
934
if(decrypted_buffer_size >= 0){
935
936
written = 0;
491
buffer_length += (size_t) ret;
492
}
493
}
494
495
if (buffer_length > 0){
496
decrypted_buffer_size = pgp_packet_decrypt(buffer,
497
buffer_length,
498
&decrypted_buffer,
499
keydir);
500
if (decrypted_buffer_size >= 0){
937
501
while(written < (size_t) decrypted_buffer_size){
938
if(quit_now){
939
errno = EINTR;
940
goto mandos_end;
941
}
942
943
ret = (int)fwrite(decrypted_buffer + written, 1,
944
(size_t)decrypted_buffer_size - written,
945
stdout);
502
ret = (int)fwrite (decrypted_buffer + written, 1,
503
(size_t)decrypted_buffer_size - written,
504
stdout);
946
505
if(ret == 0 and ferror(stdout)){
947
int e = errno;
948
506
if(debug){
949
fprintf_plus(stderr, "Error writing encrypted data: %s\n",
950
strerror(errno));
507
fprintf(stderr, "Error writing encrypted data: %s\n",
508
strerror(errno));
951
509
}
952
errno = e;
953
goto mandos_end;
510
retval = -1;
511
break;
954
512
}
955
513
written += (size_t)ret;
956
514
}
957
retval = 0;
958
}
959
}
960
961
/* Shutdown procedure */
962
963
mandos_end:
964
{
965
int e = errno;
966
free(decrypted_buffer);
967
free(buffer);
968
if(tcp_sd >= 0){
969
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
970
}
971
if(ret == -1){
972
if(e == 0){
973
e = errno;
974
}
975
perror_plus("close");
976
}
977
gnutls_deinit(session);
978
errno = e;
979
if(quit_now){
980
errno = EINTR;
515
free(decrypted_buffer);
516
} else {
981
517
retval = -1;
982
518
}
983
519
}
520
521
//shutdown procedure
522
523
if(debug){
524
fprintf(stderr, "Closing TLS session\n");
525
}
526
527
free(buffer);
528
gnutls_bye (session, GNUTLS_SHUT_RDWR);
529
exit:
530
close(tcp_sd);
531
gnutls_deinit (session);
532
gnutls_certificate_free_credentials (mc->cred);
533
gnutls_global_deinit ();
984
534
return retval;
985
535
}
986
536
987
static void resolve_callback(AvahiSServiceResolver *r,
988
AvahiIfIndex interface,
989
AvahiProtocol proto,
990
AvahiResolverEvent event,
991
const char *name,
992
const char *type,
993
const char *domain,
994
const char *host_name,
995
const AvahiAddress *address,
996
uint16_t port,
997
AVAHI_GCC_UNUSED AvahiStringList *txt,
998
AVAHI_GCC_UNUSED AvahiLookupResultFlags
999
flags,
1000
AVAHI_GCC_UNUSED void* userdata){
1001
assert(r);
537
static void resolve_callback( AvahiSServiceResolver *r,
538
AvahiIfIndex interface,
539
AVAHI_GCC_UNUSED AvahiProtocol protocol,
540
AvahiResolverEvent event,
541
const char *name,
542
const char *type,
543
const char *domain,
544
const char *host_name,
545
const AvahiAddress *address,
546
uint16_t port,
547
AVAHI_GCC_UNUSED AvahiStringList *txt,
548
AVAHI_GCC_UNUSED AvahiLookupResultFlags flags,
549
void* userdata) {
550
mandos_context *mc = userdata;
551
assert(r); /* Spurious warning */
1002
552
1003
553
/* Called whenever a service has been resolved successfully or
1004
554
timed out */
1005
555
1006
if(quit_now){
1007
return;
1008
}
1009
1010
switch(event){
556
switch (event) {
1011
557
default:
1012
558
case AVAHI_RESOLVER_FAILURE:
1013
fprintf_plus(stderr, "(Avahi Resolver) Failed to resolve service "
1014
"'%s' of type '%s' in domain '%s': %s\n", name, type,
1015
domain,
1016
avahi_strerror(avahi_server_errno(mc.server)));
559
fprintf(stderr, "(Resolver) Failed to resolve service '%s' of"
560
" type '%s' in domain '%s': %s\n", name, type, domain,
561
avahi_strerror(avahi_server_errno(mc->server)));
1017
562
break;
1018
563
1019
564
case AVAHI_RESOLVER_FOUND:
1021
566
char ip[AVAHI_ADDRESS_STR_MAX];
1022
567
avahi_address_snprint(ip, sizeof(ip), address);
1023
568
if(debug){
1024
fprintf_plus(stderr, "Mandos server \"%s\" found on %s (%s, %"
1025
PRIdMAX ") on port %" PRIu16 "\n", name,
1026
host_name, ip, (intmax_t)interface, port);
569
fprintf(stderr, "Mandos server \"%s\" found on %s (%s) on"
570
" port %d\n", name, host_name, ip, port);
1027
571
}
1028
int ret = start_mandos_communication(ip, port, interface,
1029
avahi_proto_to_af(proto));
1030
if(ret == 0){
1031
avahi_simple_poll_quit(mc.simple_poll);
1032
} else {
1033
if(not add_server(ip, port, interface,
1034
avahi_proto_to_af(proto))){
1035
fprintf_plus(stderr, "Failed to add server \"%s\" to server"
1036
" list\n", name);
1037
}
572
int ret = start_mandos_communication(ip, port, interface, mc);
573
if (ret == 0){
574
exit(EXIT_SUCCESS);
1038
575
}
1039
576
}
1040
577
}
1041
578
avahi_s_service_resolver_free(r);
1042
579
}
1043
580
1044
static void browse_callback(AvahiSServiceBrowser *b,
1045
AvahiIfIndex interface,
1046
AvahiProtocol protocol,
1047
AvahiBrowserEvent event,
1048
const char *name,
1049
const char *type,
1050
const char *domain,
1051
AVAHI_GCC_UNUSED AvahiLookupResultFlags
1052
flags,
1053
AVAHI_GCC_UNUSED void* userdata){
1054
assert(b);
581
static void browse_callback( AvahiSServiceBrowser *b,
582
AvahiIfIndex interface,
583
AvahiProtocol protocol,
584
AvahiBrowserEvent event,
585
const char *name,
586
const char *type,
587
const char *domain,
588
AVAHI_GCC_UNUSED AvahiLookupResultFlags flags,
589
void* userdata) {
590
mandos_context *mc = userdata;
591
assert(b); /* Spurious warning */
1055
592
1056
593
/* Called whenever a new services becomes available on the LAN or
1057
594
is removed from the LAN */
1058
595
1059
if(quit_now){
1060
return;
1061
}
1062
1063
switch(event){
596
switch (event) {
1064
597
default:
1065
598
case AVAHI_BROWSER_FAILURE:
1066
599
1067
fprintf_plus(stderr, "(Avahi browser) %s\n",
1068
avahi_strerror(avahi_server_errno(mc.server)));
1069
avahi_simple_poll_quit(mc.simple_poll);
600
fprintf(stderr, "(Browser) %s\n",
601
avahi_strerror(avahi_server_errno(mc->server)));
602
avahi_simple_poll_quit(mc->simple_poll);
1070
603
return;
1071
604
1072
605
case AVAHI_BROWSER_NEW:
1073
/* We ignore the returned Avahi resolver object. In the callback
1074
function we free it. If the Avahi server is terminated before
1075
the callback function is called the Avahi server will free the
1076
resolver for us. */
606
/* We ignore the returned resolver object. In the callback
607
function we free it. If the server is terminated before
608
the callback function is called the server will free
609
the resolver for us. */
1077
610
1078
if(avahi_s_service_resolver_new(mc.server, interface, protocol,
1079
name, type, domain, protocol, 0,
1080
resolve_callback, NULL) == NULL)
1081
fprintf_plus(stderr, "Avahi: Failed to resolve service '%s':"
1082
" %s\n", name,
1083
avahi_strerror(avahi_server_errno(mc.server)));
611
if (!(avahi_s_service_resolver_new(mc->server, interface, protocol, name,
612
type, domain,
613
AVAHI_PROTO_INET6, 0,
614
resolve_callback, mc)))
615
fprintf(stderr, "Failed to resolve service '%s': %s\n", name,
616
avahi_strerror(avahi_server_errno(mc->server)));
1084
617
break;
1085
618
1086
619
case AVAHI_BROWSER_REMOVE:
1088
621
1089
622
case AVAHI_BROWSER_ALL_FOR_NOW:
1090
623
case AVAHI_BROWSER_CACHE_EXHAUSTED:
1091
if(debug){
1092
fprintf_plus(stderr, "No Mandos server found, still"
1093
" searching...\n");
1094
}
1095
624
break;
1096
625
}
1097
626
}
1098
627
1099
/* Signal handler that stops main loop after SIGTERM */
1100
static void handle_sigterm(int sig){
1101
if(quit_now){
1102
return;
1103
}
1104
quit_now = 1;
1105
signal_received = sig;
1106
int old_errno = errno;
1107
/* set main loop to exit */
1108
if(mc.simple_poll != NULL){
1109
avahi_simple_poll_quit(mc.simple_poll);
1110
}
1111
errno = old_errno;
1112
}
1113
1114
bool get_flags(const char *ifname, struct ifreq *ifr){
1115
int ret;
1116
1117
int s = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1118
if(s < 0){
1119
perror_plus("socket");
1120
return false;
1121
}
1122
strcpy(ifr->ifr_name, ifname);
1123
ret = ioctl(s, SIOCGIFFLAGS, ifr);
1124
if(ret == -1){
1125
if(debug){
1126
perror_plus("ioctl SIOCGIFFLAGS");
1127
}
1128
return false;
1129
}
1130
return true;
1131
}
1132
1133
bool good_flags(const char *ifname, const struct ifreq *ifr){
1134
1135
/* Reject the loopback device */
1136
if(ifr->ifr_flags & IFF_LOOPBACK){
1137
if(debug){
1138
fprintf_plus(stderr, "Rejecting loopback interface \"%s\"\n",
1139
ifname);
1140
}
1141
return false;
1142
}
1143
/* Accept point-to-point devices only if connect_to is specified */
1144
if(connect_to != NULL and (ifr->ifr_flags & IFF_POINTOPOINT)){
1145
if(debug){
1146
fprintf_plus(stderr, "Accepting point-to-point interface"
1147
" \"%s\"\n", ifname);
1148
}
1149
return true;
1150
}
1151
/* Otherwise, reject non-broadcast-capable devices */
1152
if(not (ifr->ifr_flags & IFF_BROADCAST)){
1153
if(debug){
1154
fprintf_plus(stderr, "Rejecting non-broadcast interface"
1155
" \"%s\"\n", ifname);
1156
}
1157
return false;
1158
}
1159
/* Reject non-ARP interfaces (including dummy interfaces) */
1160
if(ifr->ifr_flags & IFF_NOARP){
1161
if(debug){
1162
fprintf_plus(stderr, "Rejecting non-ARP interface \"%s\"\n",
1163
ifname);
1164
}
1165
return false;
1166
}
1167
1168
/* Accept this device */
1169
if(debug){
1170
fprintf_plus(stderr, "Interface \"%s\" is good\n", ifname);
1171
}
1172
return true;
1173
}
1174
1175
/*
1176
* This function determines if a directory entry in /sys/class/net
1177
* corresponds to an acceptable network device.
1178
* (This function is passed to scandir(3) as a filter function.)
1179
*/
1180
int good_interface(const struct dirent *if_entry){
1181
if(if_entry->d_name[0] == '.'){
1182
return 0;
1183
}
1184
1185
struct ifreq ifr;
1186
if(not get_flags(if_entry->d_name, &ifr)){
1187
if(debug){
1188
fprintf_plus(stderr, "Failed to get flags for interface "
1189
"\"%s\"\n", if_entry->d_name);
1190
}
1191
return 0;
1192
}
1193
1194
if(not good_flags(if_entry->d_name, &ifr)){
1195
return 0;
1196
}
1197
return 1;
1198
}
1199
1200
/*
1201
* This function determines if a directory entry in /sys/class/net
1202
* corresponds to an acceptable network device which is up.
1203
* (This function is passed to scandir(3) as a filter function.)
1204
*/
1205
int up_interface(const struct dirent *if_entry){
1206
if(if_entry->d_name[0] == '.'){
1207
return 0;
1208
}
1209
1210
struct ifreq ifr;
1211
if(not get_flags(if_entry->d_name, &ifr)){
1212
if(debug){
1213
fprintf_plus(stderr, "Failed to get flags for interface "
1214
"\"%s\"\n", if_entry->d_name);
1215
}
1216
return 0;
1217
}
1218
1219
/* Reject down interfaces */
1220
if(not (ifr.ifr_flags & IFF_UP)){
1221
if(debug){
1222
fprintf_plus(stderr, "Rejecting down interface \"%s\"\n",
1223
if_entry->d_name);
1224
}
1225
return 0;
1226
}
1227
1228
/* Reject non-running interfaces */
1229
if(not (ifr.ifr_flags & IFF_RUNNING)){
1230
if(debug){
1231
fprintf_plus(stderr, "Rejecting non-running interface \"%s\"\n",
1232
if_entry->d_name);
1233
}
1234
return 0;
1235
}
1236
1237
if(not good_flags(if_entry->d_name, &ifr)){
1238
return 0;
1239
}
1240
return 1;
1241
}
1242
1243
int notdotentries(const struct dirent *direntry){
1244
/* Skip "." and ".." */
1245
if(direntry->d_name[0] == '.'
1246
and (direntry->d_name[1] == '\0'
1247
or (direntry->d_name[1] == '.'
1248
and direntry->d_name[2] == '\0'))){
1249
return 0;
1250
}
1251
return 1;
1252
}
1253
1254
/* Is this directory entry a runnable program? */
1255
int runnable_hook(const struct dirent *direntry){
1256
int ret;
1257
size_t sret;
1258
struct stat st;
1259
1260
if((direntry->d_name)[0] == '\0'){
1261
/* Empty name? */
1262
return 0;
1263
}
1264
1265
sret = strspn(direntry->d_name, "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
1266
"abcdefghijklmnopqrstuvwxyz"
1267
"0123456789"
1268
"_-");
1269
if((direntry->d_name)[sret] != '\0'){
1270
/* Contains non-allowed characters */
1271
if(debug){
1272
fprintf_plus(stderr, "Ignoring hook \"%s\" with bad name\n",
1273
direntry->d_name);
1274
}
1275
return 0;
1276
}
1277
1278
char *fullname = NULL;
1279
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1280
if(ret < 0){
1281
perror_plus("asprintf");
1282
return 0;
1283
}
1284
1285
ret = stat(fullname, &st);
1286
if(ret == -1){
1287
if(debug){
1288
perror_plus("Could not stat hook");
1289
}
1290
return 0;
1291
}
1292
if(not (S_ISREG(st.st_mode))){
1293
/* Not a regular file */
1294
if(debug){
1295
fprintf_plus(stderr, "Ignoring hook \"%s\" - not a file\n",
1296
direntry->d_name);
1297
}
1298
return 0;
1299
}
1300
if(not (st.st_mode & (S_IXUSR | S_IXGRP | S_IXOTH))){
1301
/* Not executable */
1302
if(debug){
1303
fprintf_plus(stderr, "Ignoring hook \"%s\" - not executable\n",
1304
direntry->d_name);
1305
}
1306
return 0;
1307
}
1308
if(debug){
1309
fprintf_plus(stderr, "Hook \"%s\" is acceptable\n",
1310
direntry->d_name);
1311
}
1312
return 1;
1313
}
1314
1315
int avahi_loop_with_timeout(AvahiSimplePoll *s, int retry_interval){
1316
int ret;
1317
struct timespec now;
1318
struct timespec waited_time;
1319
intmax_t block_time;
1320
1321
while(true){
1322
if(mc.current_server == NULL){
1323
if (debug){
1324
fprintf_plus(stderr, "Wait until first server is found."
1325
" No timeout!\n");
1326
}
1327
ret = avahi_simple_poll_iterate(s, -1);
1328
} else {
1329
if (debug){
1330
fprintf_plus(stderr, "Check current_server if we should run"
1331
" it, or wait\n");
1332
}
1333
/* the current time */
1334
ret = clock_gettime(CLOCK_MONOTONIC, &now);
1335
if(ret == -1){
1336
perror_plus("clock_gettime");
1337
return -1;
1338
}
1339
/* Calculating in ms how long time between now and server
1340
who we visted longest time ago. Now - last seen. */
1341
waited_time.tv_sec = (now.tv_sec
1342
- mc.current_server->last_seen.tv_sec);
1343
waited_time.tv_nsec = (now.tv_nsec
1344
- mc.current_server->last_seen.tv_nsec);
1345
/* total time is 10s/10,000ms.
1346
Converting to s from ms by dividing by 1,000,
1347
and ns to ms by dividing by 1,000,000. */
1348
block_time = ((retry_interval
1349
- ((intmax_t)waited_time.tv_sec * 1000))
1350
- ((intmax_t)waited_time.tv_nsec / 1000000));
1351
1352
if (debug){
1353
fprintf_plus(stderr, "Blocking for %" PRIdMAX " ms\n",
1354
block_time);
1355
}
1356
1357
if(block_time <= 0){
1358
ret = start_mandos_communication(mc.current_server->ip,
1359
mc.current_server->port,
1360
mc.current_server->if_index,
1361
mc.current_server->af);
1362
if(ret == 0){
1363
avahi_simple_poll_quit(mc.simple_poll);
1364
return 0;
1365
}
1366
ret = clock_gettime(CLOCK_MONOTONIC,
1367
&mc.current_server->last_seen);
1368
if(ret == -1){
1369
perror_plus("clock_gettime");
1370
return -1;
1371
}
1372
mc.current_server = mc.current_server->next;
1373
block_time = 0; /* Call avahi to find new Mandos
1374
servers, but don't block */
1375
}
1376
1377
ret = avahi_simple_poll_iterate(s, (int)block_time);
1378
}
1379
if(ret != 0){
1380
if (ret > 0 or errno != EINTR){
1381
return (ret != 1) ? ret : 0;
1382
}
1383
}
1384
}
1385
}
1386
1387
bool run_network_hooks(const char *mode, const char *interface,
1388
const float delay){
1389
struct dirent **direntries;
1390
struct dirent *direntry;
1391
int ret;
1392
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1393
alphasort);
1394
if(numhooks == -1){
1395
perror_plus("scandir");
1396
} else {
1397
int devnull = open("/dev/null", O_RDONLY);
1398
for(int i = 0; i < numhooks; i++){
1399
direntry = direntries[i];
1400
char *fullname = NULL;
1401
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1402
if(ret < 0){
1403
perror_plus("asprintf");
1404
continue;
1405
}
1406
if(debug){
1407
fprintf_plus(stderr, "Running network hook \"%s\"\n",
1408
direntry->d_name);
1409
}
1410
pid_t hook_pid = fork();
1411
if(hook_pid == 0){
1412
/* Child */
1413
/* Raise privileges */
1414
errno = 0;
1415
ret = seteuid(0);
1416
if(ret == -1){
1417
perror_plus("seteuid");
1418
}
1419
/* Raise privileges even more */
1420
errno = 0;
1421
ret = setuid(0);
1422
if(ret == -1){
1423
perror_plus("setuid");
1424
}
1425
/* Set group */
1426
errno = 0;
1427
ret = setgid(0);
1428
if(ret == -1){
1429
perror_plus("setgid");
1430
}
1431
/* Reset supplementary groups */
1432
errno = 0;
1433
ret = setgroups(0, NULL);
1434
if(ret == -1){
1435
perror_plus("setgroups");
1436
}
1437
dup2(devnull, STDIN_FILENO);
1438
close(devnull);
1439
dup2(STDERR_FILENO, STDOUT_FILENO);
1440
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1441
if(ret == -1){
1442
perror_plus("setenv");
1443
_exit(EX_OSERR);
1444
}
1445
ret = setenv("DEVICE", interface, 1);
1446
if(ret == -1){
1447
perror_plus("setenv");
1448
_exit(EX_OSERR);
1449
}
1450
ret = setenv("VERBOSE", debug ? "1" : "0", 1);
1451
if(ret == -1){
1452
perror_plus("setenv");
1453
_exit(EX_OSERR);
1454
}
1455
ret = setenv("MODE", mode, 1);
1456
if(ret == -1){
1457
perror_plus("setenv");
1458
_exit(EX_OSERR);
1459
}
1460
char *delaystring;
1461
ret = asprintf(&delaystring, "%f", delay);
1462
if(ret == -1){
1463
perror_plus("asprintf");
1464
_exit(EX_OSERR);
1465
}
1466
ret = setenv("DELAY", delaystring, 1);
1467
if(ret == -1){
1468
free(delaystring);
1469
perror_plus("setenv");
1470
_exit(EX_OSERR);
1471
}
1472
free(delaystring);
1473
ret = execl(fullname, direntry->d_name, mode, NULL);
1474
perror_plus("execl");
1475
} else {
1476
int status;
1477
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
1478
perror_plus("waitpid");
1479
free(fullname);
1480
continue;
1481
}
1482
if(WIFEXITED(status)){
1483
if(WEXITSTATUS(status) != 0){
1484
fprintf_plus(stderr, "Warning: network hook \"%s\" exited"
1485
" with status %d\n", direntry->d_name,
1486
WEXITSTATUS(status));
1487
free(fullname);
1488
continue;
1489
}
1490
} else if(WIFSIGNALED(status)){
1491
fprintf_plus(stderr, "Warning: network hook \"%s\" died by"
1492
" signal %d\n", direntry->d_name,
1493
WTERMSIG(status));
1494
free(fullname);
1495
continue;
1496
} else {
1497
fprintf_plus(stderr, "Warning: network hook \"%s\""
1498
" crashed\n", direntry->d_name);
1499
free(fullname);
1500
continue;
1501
}
1502
}
1503
free(fullname);
1504
if(debug){
1505
fprintf_plus(stderr, "Network hook \"%s\" ran successfully\n",
1506
direntry->d_name);
1507
}
1508
}
1509
close(devnull);
1510
}
1511
return true;
1512
}
1513
1514
int main(int argc, char *argv[]){
1515
AvahiSServiceBrowser *sb = NULL;
1516
int error;
1517
int ret;
1518
intmax_t tmpmax;
1519
char *tmp;
1520
int exitcode = EXIT_SUCCESS;
1521
const char *interface = "";
1522
struct ifreq network;
1523
int sd = -1;
1524
bool take_down_interface = false;
1525
uid_t uid;
1526
gid_t gid;
1527
char tempdir[] = "/tmp/mandosXXXXXX";
1528
bool tempdir_created = false;
1529
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
1530
const char *seckey = PATHDIR "/" SECKEY;
1531
const char *pubkey = PATHDIR "/" PUBKEY;
1532
1533
bool gnutls_initialized = false;
1534
bool gpgme_initialized = false;
1535
float delay = 2.5f;
1536
double retry_interval = 10; /* 10s between trying a server and
1537
retrying the same server again */
1538
1539
struct sigaction old_sigterm_action = { .sa_handler = SIG_DFL };
1540
struct sigaction sigterm_action = { .sa_handler = handle_sigterm };
1541
1542
uid = getuid();
1543
gid = getgid();
1544
1545
/* Lower any group privileges we might have, just to be safe */
1546
errno = 0;
1547
ret = setgid(gid);
1548
if(ret == -1){
1549
perror_plus("setgid");
1550
}
1551
1552
/* Lower user privileges (temporarily) */
1553
errno = 0;
1554
ret = seteuid(uid);
1555
if(ret == -1){
1556
perror_plus("seteuid");
1557
}
1558
1559
if(quit_now){
1560
goto end;
1561
}
1562
1563
{
1564
struct argp_option options[] = {
1565
{ .name = "debug", .key = 128,
1566
.doc = "Debug mode", .group = 3 },
1567
{ .name = "connect", .key = 'c',
1568
.arg = "ADDRESS:PORT",
1569
.doc = "Connect directly to a specific Mandos server",
1570
.group = 1 },
1571
{ .name = "interface", .key = 'i',
1572
.arg = "NAME",
1573
.doc = "Network interface that will be used to search for"
1574
" Mandos servers",
1575
.group = 1 },
1576
{ .name = "seckey", .key = 's',
1577
.arg = "FILE",
1578
.doc = "OpenPGP secret key file base name",
1579
.group = 1 },
1580
{ .name = "pubkey", .key = 'p',
1581
.arg = "FILE",
1582
.doc = "OpenPGP public key file base name",
1583
.group = 2 },
1584
{ .name = "dh-bits", .key = 129,
1585
.arg = "BITS",
1586
.doc = "Bit length of the prime number used in the"
1587
" Diffie-Hellman key exchange",
1588
.group = 2 },
1589
{ .name = "priority", .key = 130,
1590
.arg = "STRING",
1591
.doc = "GnuTLS priority string for the TLS handshake",
1592
.group = 1 },
1593
{ .name = "delay", .key = 131,
1594
.arg = "SECONDS",
1595
.doc = "Maximum delay to wait for interface startup",
1596
.group = 2 },
1597
{ .name = "retry", .key = 132,
1598
.arg = "SECONDS",
1599
.doc = "Retry interval used when denied by the mandos server",
1600
.group = 2 },
1601
{ .name = "network-hook-dir", .key = 133,
1602
.arg = "DIR",
1603
.doc = "Directory where network hooks are located",
1604
.group = 2 },
1605
/*
1606
* These reproduce what we would get without ARGP_NO_HELP
1607
*/
1608
{ .name = "help", .key = '?',
1609
.doc = "Give this help list", .group = -1 },
1610
{ .name = "usage", .key = -3,
1611
.doc = "Give a short usage message", .group = -1 },
1612
{ .name = "version", .key = 'V',
1613
.doc = "Print program version", .group = -1 },
1614
{ .name = NULL }
1615
};
628
/* Combines file name and path and returns the malloced new
629
string. some sane checks could/should be added */
630
static const char *combinepath(const char *first, const char *second){
631
size_t f_len = strlen(first);
632
size_t s_len = strlen(second);
633
char *tmp = malloc(f_len + s_len + 2);
634
if (tmp == NULL){
635
return NULL;
636
}
637
if(f_len > 0){
638
memcpy(tmp, first, f_len); /* Spurious warning */
639
}
640
tmp[f_len] = '/';
641
if(s_len > 0){
642
memcpy(tmp + f_len + 1, second, s_len); /* Spurious warning */
643
}
644
tmp[f_len + 1 + s_len] = '\0';
645
return tmp;
646
}
647
648
649
int main(AVAHI_GCC_UNUSED int argc, AVAHI_GCC_UNUSED char*argv[]) {
650
AvahiServerConfig config;
651
AvahiSServiceBrowser *sb = NULL;
652
int error;
653
int ret;
654
int debug_int;
655
int returncode = EXIT_SUCCESS;
656
const char *interface = "eth0";
657
struct ifreq network;
658
int sd;
659
char *connect_to = NULL;
660
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
661
mandos_context mc = { .simple_poll = NULL, .server = NULL,
662
.dh_bits = 1024, .priority = "SECURE256"};
1616
663
1617
error_t parse_opt(int key, char *arg,
1618
struct argp_state *state){
1619
errno = 0;
1620
switch(key){
1621
case 128: /* --debug */
1622
debug = true;
1623
break;
1624
case 'c': /* --connect */
1625
connect_to = arg;
1626
break;
1627
case 'i': /* --interface */
1628
interface = arg;
1629
break;
1630
case 's': /* --seckey */
1631
seckey = arg;
1632
break;
1633
case 'p': /* --pubkey */
1634
pubkey = arg;
1635
break;
1636
case 129: /* --dh-bits */
1637
errno = 0;
1638
tmpmax = strtoimax(arg, &tmp, 10);
1639
if(errno != 0 or tmp == arg or *tmp != '\0'
1640
or tmpmax != (typeof(mc.dh_bits))tmpmax){
1641
argp_error(state, "Bad number of DH bits");
1642
}
1643
mc.dh_bits = (typeof(mc.dh_bits))tmpmax;
1644
break;
1645
case 130: /* --priority */
1646
mc.priority = arg;
1647
break;
1648
case 131: /* --delay */
1649
errno = 0;
1650
delay = strtof(arg, &tmp);
1651
if(errno != 0 or tmp == arg or *tmp != '\0'){
1652
argp_error(state, "Bad delay");
1653
}
1654
case 132: /* --retry */
1655
errno = 0;
1656
retry_interval = strtod(arg, &tmp);
1657
if(errno != 0 or tmp == arg or *tmp != '\0'
1658
or (retry_interval * 1000) > INT_MAX
1659
or retry_interval < 0){
1660
argp_error(state, "Bad retry interval");
1661
}
1662
break;
1663
case 133: /* --network-hook-dir */
1664
hookdir = arg;
1665
break;
1666
/*
1667
* These reproduce what we would get without ARGP_NO_HELP
1668
*/
1669
case '?': /* --help */
1670
argp_state_help(state, state->out_stream,
1671
(ARGP_HELP_STD_HELP | ARGP_HELP_EXIT_ERR)
1672
& ~(unsigned int)ARGP_HELP_EXIT_OK);
1673
case -3: /* --usage */
1674
argp_state_help(state, state->out_stream,
1675
ARGP_HELP_USAGE | ARGP_HELP_EXIT_ERR);
1676
case 'V': /* --version */
1677
fprintf_plus(state->out_stream, "%s\n", argp_program_version);
1678
exit(argp_err_exit_status);
1679
break;
664
debug_int = debug ? 1 : 0;
665
while (true){
666
struct option long_options[] = {
667
{"debug", no_argument, &debug_int, 1},
668
{"connect", required_argument, NULL, 'c'},
669
{"interface", required_argument, NULL, 'i'},
670
{"keydir", required_argument, NULL, 'd'},
671
{"seckey", required_argument, NULL, 's'},
672
{"pubkey", required_argument, NULL, 'p'},
673
{"dh-bits", required_argument, NULL, 'D'},
674
{"priority", required_argument, NULL, 'P'},
675
{0, 0, 0, 0} };
676
677
int option_index = 0;
678
ret = getopt_long (argc, argv, "i:", long_options,
679
&option_index);
680
681
if (ret == -1){
682
break;
683
}
684
685
switch(ret){
686
case 0:
687
break;
688
case 'i':
689
interface = optarg;
690
break;
691
case 'c':
692
connect_to = optarg;
693
break;
694
case 'd':
695
keydir = optarg;
696
break;
697
case 'p':
698
pubkeyfile = optarg;
699
break;
700
case 's':
701
seckeyfile = optarg;
702
break;
703
case 'D':
704
errno = 0;
705
mc.dh_bits = (unsigned int) strtol(optarg, NULL, 10);
706
if (errno){
707
perror("strtol");
708
exit(EXIT_FAILURE);
709
}
710
break;
711
case 'P':
712
mc.priority = optarg;
713
break;
714
case '?':
1680
715
default:
1681
return ARGP_ERR_UNKNOWN;
1682
}
1683
return errno;
1684
}
1685
1686
struct argp argp = { .options = options, .parser = parse_opt,
1687
.args_doc = "",
1688
.doc = "Mandos client -- Get and decrypt"
1689
" passwords from a Mandos server" };
1690
ret = argp_parse(&argp, argc, argv,
1691
ARGP_IN_ORDER | ARGP_NO_HELP, 0, NULL);
1692
switch(ret){
1693
case 0:
1694
break;
1695
case ENOMEM:
1696
default:
1697
errno = ret;
1698
perror_plus("argp_parse");
1699
exitcode = EX_OSERR;
1700
goto end;
1701
case EINVAL:
1702
exitcode = EX_USAGE;
1703
goto end;
1704
}
1705
}
1706
1707
{
1708
/* Work around Debian bug #633582:
1709
<http://bugs.debian.org/633582> */
1710
1711
/* Re-raise priviliges */
1712
errno = 0;
1713
ret = seteuid(0);
1714
if(ret == -1){
1715
perror_plus("seteuid");
1716
} else {
1717
struct stat st;
1718
1719
if(strcmp(seckey, PATHDIR "/" SECKEY) == 0){
1720
int seckey_fd = open(seckey, O_RDONLY);
1721
if(seckey_fd == -1){
1722
perror_plus("open");
1723
} else {
1724
ret = (int)TEMP_FAILURE_RETRY(fstat(seckey_fd, &st));
1725
if(ret == -1){
1726
perror_plus("fstat");
1727
} else {
1728
if(S_ISREG(st.st_mode)
1729
and st.st_uid == 0 and st.st_gid == 0){
1730
ret = fchown(seckey_fd, uid, gid);
1731
if(ret == -1){
1732
perror_plus("fchown");
1733
}
1734
}
1735
}
1736
TEMP_FAILURE_RETRY(close(seckey_fd));
1737
}
1738
}
1739
1740
if(strcmp(pubkey, PATHDIR "/" PUBKEY) == 0){
1741
int pubkey_fd = open(pubkey, O_RDONLY);
1742
if(pubkey_fd == -1){
1743
perror_plus("open");
1744
} else {
1745
ret = (int)TEMP_FAILURE_RETRY(fstat(pubkey_fd, &st));
1746
if(ret == -1){
1747
perror_plus("fstat");
1748
} else {
1749
if(S_ISREG(st.st_mode)
1750
and st.st_uid == 0 and st.st_gid == 0){
1751
ret = fchown(pubkey_fd, uid, gid);
1752
if(ret == -1){
1753
perror_plus("fchown");
1754
}
1755
}
1756
}
1757
TEMP_FAILURE_RETRY(close(pubkey_fd));
1758
}
1759
}
1760
1761
/* Lower privileges */
1762
errno = 0;
1763
ret = seteuid(uid);
1764
if(ret == -1){
1765
perror_plus("seteuid");
1766
}
1767
}
1768
}
1769
1770
/* Run network hooks */
1771
if(not run_network_hooks("start", interface, delay)){
1772
goto end;
1773
}
1774
1775
if(not debug){
1776
avahi_set_log_function(empty_log);
1777
}
1778
1779
if(interface[0] == '\0'){
1780
struct dirent **direntries;
1781
/* First look for interfaces that are up */
1782
ret = scandir(sys_class_net, &direntries, up_interface,
1783
alphasort);
1784
if(ret == 0){
1785
/* No up interfaces, look for any good interfaces */
1786
free(direntries);
1787
ret = scandir(sys_class_net, &direntries, good_interface,
1788
alphasort);
1789
}
1790
if(ret >= 1){
1791
/* Pick the first interface returned */
1792
interface = strdup(direntries[0]->d_name);
1793
if(debug){
1794
fprintf_plus(stderr, "Using interface \"%s\"\n", interface);
1795
}
1796
if(interface == NULL){
1797
perror_plus("malloc");
1798
free(direntries);
1799
exitcode = EXIT_FAILURE;
1800
goto end;
1801
}
1802
free(direntries);
1803
} else {
1804
free(direntries);
1805
fprintf_plus(stderr, "Could not find a network interface\n");
1806
exitcode = EXIT_FAILURE;
1807
goto end;
1808
}
1809
}
1810
1811
/* Initialize Avahi early so avahi_simple_poll_quit() can be called
1812
from the signal handler */
1813
/* Initialize the pseudo-RNG for Avahi */
1814
srand((unsigned int) time(NULL));
1815
mc.simple_poll = avahi_simple_poll_new();
1816
if(mc.simple_poll == NULL){
1817
fprintf_plus(stderr,
1818
"Avahi: Failed to create simple poll object.\n");
1819
exitcode = EX_UNAVAILABLE;
1820
goto end;
1821
}
1822
1823
sigemptyset(&sigterm_action.sa_mask);
1824
ret = sigaddset(&sigterm_action.sa_mask, SIGINT);
1825
if(ret == -1){
1826
perror_plus("sigaddset");
1827
exitcode = EX_OSERR;
1828
goto end;
1829
}
1830
ret = sigaddset(&sigterm_action.sa_mask, SIGHUP);
1831
if(ret == -1){
1832
perror_plus("sigaddset");
1833
exitcode = EX_OSERR;
1834
goto end;
1835
}
1836
ret = sigaddset(&sigterm_action.sa_mask, SIGTERM);
1837
if(ret == -1){
1838
perror_plus("sigaddset");
1839
exitcode = EX_OSERR;
1840
goto end;
1841
}
1842
/* Need to check if the handler is SIG_IGN before handling:
1843
| [[info:libc:Initial Signal Actions]] |
1844
| [[info:libc:Basic Signal Handling]] |
1845
*/
1846
ret = sigaction(SIGINT, NULL, &old_sigterm_action);
1847
if(ret == -1){
1848
perror_plus("sigaction");
1849
return EX_OSERR;
1850
}
1851
if(old_sigterm_action.sa_handler != SIG_IGN){
1852
ret = sigaction(SIGINT, &sigterm_action, NULL);
1853
if(ret == -1){
1854
perror_plus("sigaction");
1855
exitcode = EX_OSERR;
1856
goto end;
1857
}
1858
}
1859
ret = sigaction(SIGHUP, NULL, &old_sigterm_action);
1860
if(ret == -1){
1861
perror_plus("sigaction");
1862
return EX_OSERR;
1863
}
1864
if(old_sigterm_action.sa_handler != SIG_IGN){
1865
ret = sigaction(SIGHUP, &sigterm_action, NULL);
1866
if(ret == -1){
1867
perror_plus("sigaction");
1868
exitcode = EX_OSERR;
1869
goto end;
1870
}
1871
}
1872
ret = sigaction(SIGTERM, NULL, &old_sigterm_action);
1873
if(ret == -1){
1874
perror_plus("sigaction");
1875
return EX_OSERR;
1876
}
1877
if(old_sigterm_action.sa_handler != SIG_IGN){
1878
ret = sigaction(SIGTERM, &sigterm_action, NULL);
1879
if(ret == -1){
1880
perror_plus("sigaction");
1881
exitcode = EX_OSERR;
1882
goto end;
1883
}
1884
}
1885
1886
/* If the interface is down, bring it up */
1887
if(strcmp(interface, "none") != 0){
716
exit(EXIT_FAILURE);
717
}
718
}
719
debug = debug_int ? true : false;
720
721
pubkeyfile = combinepath(keydir, pubkeyfile);
722
if (pubkeyfile == NULL){
723
perror("combinepath");
724
returncode = EXIT_FAILURE;
725
goto exit;
726
}
727
728
seckeyfile = combinepath(keydir, seckeyfile);
729
if (seckeyfile == NULL){
730
perror("combinepath");
731
goto exit;
732
}
733
1888
734
if_index = (AvahiIfIndex) if_nametoindex(interface);
1889
735
if(if_index == 0){
1890
fprintf_plus(stderr, "No such interface: \"%s\"\n", interface);
1891
exitcode = EX_UNAVAILABLE;
1892
goto end;
1893
}
1894
1895
if(quit_now){
1896
goto end;
1897
}
1898
1899
/* Re-raise priviliges */
1900
errno = 0;
1901
ret = seteuid(0);
1902
if(ret == -1){
1903
perror_plus("seteuid");
1904
}
1905
1906
#ifdef __linux__
1907
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1908
messages about the network interface to mess up the prompt */
1909
ret = klogctl(8, NULL, 5);
1910
bool restore_loglevel = true;
1911
if(ret == -1){
1912
restore_loglevel = false;
1913
perror_plus("klogctl");
1914
}
1915
#endif /* __linux__ */
736
fprintf(stderr, "No such interface: \"%s\"\n", interface);
737
exit(EXIT_FAILURE);
738
}
739
740
if(connect_to != NULL){
741
/* Connect directly, do not use Zeroconf */
742
/* (Mainly meant for debugging) */
743
char *address = strrchr(connect_to, ':');
744
if(address == NULL){
745
fprintf(stderr, "No colon in address\n");
746
exit(EXIT_FAILURE);
747
}
748
errno = 0;
749
uint16_t port = (uint16_t) strtol(address+1, NULL, 10);
750
if(errno){
751
perror("Bad port number");
752
exit(EXIT_FAILURE);
753
}
754
*address = '\0';
755
address = connect_to;
756
ret = start_mandos_communication(address, port, if_index, &mc);
757
if(ret < 0){
758
exit(EXIT_FAILURE);
759
} else {
760
exit(EXIT_SUCCESS);
761
}
762
}
1916
763
1917
764
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1918
if(sd < 0){
1919
perror_plus("socket");
1920
exitcode = EX_OSERR;
1921
#ifdef __linux__
1922
if(restore_loglevel){
1923
ret = klogctl(7, NULL, 0);
1924
if(ret == -1){
1925
perror_plus("klogctl");
1926
}
1927
}
1928
#endif /* __linux__ */
1929
/* Lower privileges */
1930
errno = 0;
1931
ret = seteuid(uid);
1932
if(ret == -1){
1933
perror_plus("seteuid");
1934
}
1935
goto end;
765
if(sd < 0) {
766
perror("socket");
767
returncode = EXIT_FAILURE;
768
goto exit;
1936
769
}
1937
strcpy(network.ifr_name, interface);
770
strcpy(network.ifr_name, interface); /* Spurious warning */
1938
771
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1939
772
if(ret == -1){
1940
perror_plus("ioctl SIOCGIFFLAGS");
1941
#ifdef __linux__
1942
if(restore_loglevel){
1943
ret = klogctl(7, NULL, 0);
1944
if(ret == -1){
1945
perror_plus("klogctl");
1946
}
1947
}
1948
#endif /* __linux__ */
1949
exitcode = EX_OSERR;
1950
/* Lower privileges */
1951
errno = 0;
1952
ret = seteuid(uid);
1953
if(ret == -1){
1954
perror_plus("seteuid");
1955
}
1956
goto end;
773
774
perror("ioctl SIOCGIFFLAGS");
775
returncode = EXIT_FAILURE;
776
goto exit;
1957
777
}
1958
778
if((network.ifr_flags & IFF_UP) == 0){
1959
779
network.ifr_flags |= IFF_UP;
1960
take_down_interface = true;
1961
780
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1962
781
if(ret == -1){
1963
take_down_interface = false;
1964
perror_plus("ioctl SIOCSIFFLAGS +IFF_UP");
1965
exitcode = EX_OSERR;
1966
#ifdef __linux__
1967
if(restore_loglevel){
1968
ret = klogctl(7, NULL, 0);
1969
if(ret == -1){
1970
perror_plus("klogctl");
1971
}
1972
}
1973
#endif /* __linux__ */
1974
/* Lower privileges */
1975
errno = 0;
1976
ret = seteuid(uid);
1977
if(ret == -1){
1978
perror_plus("seteuid");
1979
}
1980
goto end;
1981
}
1982
}
1983
/* Sleep checking until interface is running.
1984
Check every 0.25s, up to total time of delay */
1985
for(int i=0; i < delay * 4; i++){
1986
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1987
if(ret == -1){
1988
perror_plus("ioctl SIOCGIFFLAGS");
1989
} else if(network.ifr_flags & IFF_RUNNING){
1990
break;
1991
}
1992
struct timespec sleeptime = { .tv_nsec = 250000000 };
1993
ret = nanosleep(&sleeptime, NULL);
1994
if(ret == -1 and errno != EINTR){
1995
perror_plus("nanosleep");
1996
}
1997
}
1998
if(not take_down_interface){
1999
/* We won't need the socket anymore */
2000
ret = (int)TEMP_FAILURE_RETRY(close(sd));
2001
if(ret == -1){
2002
perror_plus("close");
2003
}
2004
}
2005
#ifdef __linux__
2006
if(restore_loglevel){
2007
/* Restores kernel loglevel to default */
2008
ret = klogctl(7, NULL, 0);
2009
if(ret == -1){
2010
perror_plus("klogctl");
2011
}
2012
}
2013
#endif /* __linux__ */
2014
/* Lower privileges */
2015
errno = 0;
2016
/* Lower privileges */
2017
ret = seteuid(uid);
2018
if(ret == -1){
2019
perror_plus("seteuid");
2020
}
2021
}
2022
2023
if(quit_now){
2024
goto end;
2025
}
2026
2027
ret = init_gnutls_global(pubkey, seckey);
2028
if(ret == -1){
2029
fprintf_plus(stderr, "init_gnutls_global failed\n");
2030
exitcode = EX_UNAVAILABLE;
2031
goto end;
2032
} else {
2033
gnutls_initialized = true;
2034
}
2035
2036
if(quit_now){
2037
goto end;
2038
}
2039
2040
if(mkdtemp(tempdir) == NULL){
2041
perror_plus("mkdtemp");
2042
goto end;
2043
}
2044
tempdir_created = true;
2045
2046
if(quit_now){
2047
goto end;
2048
}
2049
2050
if(not init_gpgme(pubkey, seckey, tempdir)){
2051
fprintf_plus(stderr, "init_gpgme failed\n");
2052
exitcode = EX_UNAVAILABLE;
2053
goto end;
2054
} else {
2055
gpgme_initialized = true;
2056
}
2057
2058
if(quit_now){
2059
goto end;
2060
}
2061
2062
if(connect_to != NULL){
2063
/* Connect directly, do not use Zeroconf */
2064
/* (Mainly meant for debugging) */
2065
char *address = strrchr(connect_to, ':');
2066
if(address == NULL){
2067
fprintf_plus(stderr, "No colon in address\n");
2068
exitcode = EX_USAGE;
2069
goto end;
2070
}
2071
2072
if(quit_now){
2073
goto end;
2074
}
2075
2076
uint16_t port;
2077
errno = 0;
2078
tmpmax = strtoimax(address+1, &tmp, 10);
2079
if(errno != 0 or tmp == address+1 or *tmp != '\0'
2080
or tmpmax != (uint16_t)tmpmax){
2081
fprintf_plus(stderr, "Bad port number\n");
2082
exitcode = EX_USAGE;
2083
goto end;
2084
}
2085
2086
if(quit_now){
2087
goto end;
2088
}
2089
2090
port = (uint16_t)tmpmax;
2091
*address = '\0';
2092
/* Colon in address indicates IPv6 */
2093
int af;
2094
if(strchr(connect_to, ':') != NULL){
2095
af = AF_INET6;
2096
/* Accept [] around IPv6 address - see RFC 5952 */
2097
if(connect_to[0] == '[' and address[-1] == ']')
2098
{
2099
connect_to++;
2100
address[-1] = '\0';
2101
}
2102
} else {
2103
af = AF_INET;
2104
}
2105
address = connect_to;
2106
2107
if(quit_now){
2108
goto end;
2109
}
2110
2111
while(not quit_now){
2112
ret = start_mandos_communication(address, port, if_index, af);
2113
if(quit_now or ret == 0){
2114
break;
2115
}
2116
if(debug){
2117
fprintf_plus(stderr, "Retrying in %d seconds\n",
2118
(int)retry_interval);
2119
}
2120
sleep((int)retry_interval);
2121
}
2122
2123
if (not quit_now){
2124
exitcode = EXIT_SUCCESS;
2125
}
2126
2127
goto end;
2128
}
2129
2130
if(quit_now){
2131
goto end;
2132
}
2133
2134
{
2135
AvahiServerConfig config;
2136
/* Do not publish any local Zeroconf records */
782
perror("ioctl SIOCSIFFLAGS");
783
returncode = EXIT_FAILURE;
784
goto exit;
785
}
786
}
787
close(sd);
788
789
if (not debug){
790
avahi_set_log_function(empty_log);
791
}
792
793
/* Initialize the psuedo-RNG */
794
srand((unsigned int) time(NULL));
795
796
/* Allocate main loop object */
797
if (!(mc.simple_poll = avahi_simple_poll_new())) {
798
fprintf(stderr, "Failed to create simple poll object.\n");
799
returncode = EXIT_FAILURE;
800
goto exit;
801
}
802
803
/* Do not publish any local records */
2137
804
avahi_server_config_init(&config);
2138
805
config.publish_hinfo = 0;
2139
806
config.publish_addresses = 0;
2140
807
config.publish_workstation = 0;
2141
808
config.publish_domain = 0;
2142
809
2143
810
/* Allocate a new server */
2144
mc.server = avahi_server_new(avahi_simple_poll_get
2145
(mc.simple_poll), &config, NULL,
2146
NULL, &error);
811
mc.server=avahi_server_new(avahi_simple_poll_get(mc.simple_poll),
812
&config, NULL, NULL, &error);
2147
813
2148
/* Free the Avahi configuration data */
814
/* Free the configuration data */
2149
815
avahi_server_config_free(&config);
2150
}
2151
2152
/* Check if creating the Avahi server object succeeded */
2153
if(mc.server == NULL){
2154
fprintf_plus(stderr, "Failed to create Avahi server: %s\n",
2155
avahi_strerror(error));
2156
exitcode = EX_UNAVAILABLE;
2157
goto end;
2158
}
2159
2160
if(quit_now){
2161
goto end;
2162
}
2163
2164
/* Create the Avahi service browser */
2165
sb = avahi_s_service_browser_new(mc.server, if_index,
2166
AVAHI_PROTO_UNSPEC, "_mandos._tcp",
2167
NULL, 0, browse_callback, NULL);
2168
if(sb == NULL){
2169
fprintf_plus(stderr, "Failed to create service browser: %s\n",
2170
avahi_strerror(avahi_server_errno(mc.server)));
2171
exitcode = EX_UNAVAILABLE;
2172
goto end;
2173
}
2174
2175
if(quit_now){
2176
goto end;
2177
}
2178
2179
/* Run the main loop */
2180
2181
if(debug){
2182
fprintf_plus(stderr, "Starting Avahi loop search\n");
2183
}
2184
2185
ret = avahi_loop_with_timeout(mc.simple_poll,
2186
(int)(retry_interval * 1000));
2187
if(debug){
2188
fprintf_plus(stderr, "avahi_loop_with_timeout exited %s\n",
2189
(ret == 0) ? "successfully" : "with error");
2190
}
2191
2192
end:
2193
2194
if(debug){
2195
fprintf_plus(stderr, "%s exiting\n", argv[0]);
2196
}
2197
2198
/* Cleanup things */
2199
if(sb != NULL)
2200
avahi_s_service_browser_free(sb);
2201
2202
if(mc.server != NULL)
2203
avahi_server_free(mc.server);
2204
2205
if(mc.simple_poll != NULL)
2206
avahi_simple_poll_free(mc.simple_poll);
2207
2208
if(gnutls_initialized){
2209
gnutls_certificate_free_credentials(mc.cred);
2210
gnutls_global_deinit();
2211
gnutls_dh_params_deinit(mc.dh_params);
2212
}
2213
2214
if(gpgme_initialized){
2215
gpgme_release(mc.ctx);
2216
}
2217
2218
/* Cleans up the circular linked list of Mandos servers the client
2219
has seen */
2220
if(mc.current_server != NULL){
2221
mc.current_server->prev->next = NULL;
2222
while(mc.current_server != NULL){
2223
server *next = mc.current_server->next;
2224
free(mc.current_server);
2225
mc.current_server = next;
2226
}
2227
}
2228
2229
/* Run network hooks */
2230
run_network_hooks("stop", interface, delay);
2231
2232
/* Re-raise priviliges */
2233
{
2234
errno = 0;
2235
ret = seteuid(0);
2236
if(ret == -1){
2237
perror_plus("seteuid");
2238
}
2239
2240
/* Take down the network interface */
2241
if(take_down_interface and geteuid() == 0){
2242
ret = ioctl(sd, SIOCGIFFLAGS, &network);
2243
if(ret == -1){
2244
perror_plus("ioctl SIOCGIFFLAGS");
2245
} else if(network.ifr_flags & IFF_UP){
2246
network.ifr_flags &= ~(short)IFF_UP; /* clear flag */
2247
ret = ioctl(sd, SIOCSIFFLAGS, &network);
2248
if(ret == -1){
2249
perror_plus("ioctl SIOCSIFFLAGS -IFF_UP");
2250
}
2251
}
2252
ret = (int)TEMP_FAILURE_RETRY(close(sd));
2253
if(ret == -1){
2254
perror_plus("close");
2255
}
2256
}
2257
}
2258
/* Lower privileges permanently */
2259
errno = 0;
2260
ret = setuid(uid);
2261
if(ret == -1){
2262
perror_plus("setuid");
2263
}
2264
2265
/* Removes the GPGME temp directory and all files inside */
2266
if(tempdir_created){
2267
struct dirent **direntries = NULL;
2268
struct dirent *direntry = NULL;
2269
int numentries = scandir(tempdir, &direntries, notdotentries,
2270
alphasort);
2271
if (numentries > 0){
2272
for(int i = 0; i < numentries; i++){
2273
direntry = direntries[i];
2274
char *fullname = NULL;
2275
ret = asprintf(&fullname, "%s/%s", tempdir,
2276
direntry->d_name);
2277
if(ret < 0){
2278
perror_plus("asprintf");
2279
continue;
2280
}
2281
ret = remove(fullname);
2282
if(ret == -1){
2283
fprintf_plus(stderr, "remove(\"%s\"): %s\n", fullname,
2284
strerror(errno));
2285
}
2286
free(fullname);
2287
}
2288
}
2289
2290
/* need to clean even if 0 because man page doesn't specify */
2291
free(direntries);
2292
if (numentries == -1){
2293
perror_plus("scandir");
2294
}
2295
ret = rmdir(tempdir);
2296
if(ret == -1 and errno != ENOENT){
2297
perror_plus("rmdir");
2298
}
2299
}
2300
2301
if(quit_now){
2302
sigemptyset(&old_sigterm_action.sa_mask);
2303
old_sigterm_action.sa_handler = SIG_DFL;
2304
ret = (int)TEMP_FAILURE_RETRY(sigaction(signal_received,
2305
&old_sigterm_action,
2306
NULL));
2307
if(ret == -1){
2308
perror_plus("sigaction");
2309
}
2310
do {
2311
ret = raise(signal_received);
2312
} while(ret != 0 and errno == EINTR);
2313
if(ret != 0){
2314
perror_plus("raise");
2315
abort();
2316
}
2317
TEMP_FAILURE_RETRY(pause());
2318
}
2319
2320
return exitcode;
816
817
/* Check if creating the server object succeeded */
818
if (!mc.server) {
819
fprintf(stderr, "Failed to create server: %s\n",
820
avahi_strerror(error));
821
returncode = EXIT_FAILURE;
822
goto exit;
823
}
824
825
/* Create the service browser */
826
sb = avahi_s_service_browser_new(mc.server, if_index,
827
AVAHI_PROTO_INET6,
828
"_mandos._tcp", NULL, 0,
829
browse_callback, &mc);
830
if (!sb) {
831
fprintf(stderr, "Failed to create service browser: %s\n",
832
avahi_strerror(avahi_server_errno(mc.server)));
833
returncode = EXIT_FAILURE;
834
goto exit;
835
}
836
837
/* Run the main loop */
838
839
if (debug){
840
fprintf(stderr, "Starting avahi loop search\n");
841
}
842
843
avahi_simple_poll_loop(mc.simple_poll);
844
845
exit:
846
847
if (debug){
848
fprintf(stderr, "%s exiting\n", argv[0]);
849
}
850
851
/* Cleanup things */
852
if (sb)
853
avahi_s_service_browser_free(sb);
854
855
if (mc.server)
856
avahi_server_free(mc.server);
857
858
if (mc.simple_poll)
859
avahi_simple_poll_free(mc.simple_poll);
860
free(pubkeyfile);
861
free(seckeyfile);
862
863
return returncode;
2321
864
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0