To get this branch, use:
bzr branch
http://bzr.recompile.se/loggerhead/mandos/trunk
« back to all changes in this revision
Viewing changes to plugins.d/mandos-client.c
- browse files at revision 833
- compare with another revision
- download diff
- download tarball
- view history from revision 833
- Committer: Teddy Hogeborn
- Date: 2016-03-17 20:40:55 UTC
- Revision ID: teddy@recompile.se-20160317204055-bhsh5xsidq7w5cxu
Client: Fix plymouth agent; broken since 1.7.2.
Fix an very old memory bug in the plymouth agent (which has been
present since its apperance in version 1.2), but which was only
recently detected at run time due to the new -fsanitize=address
compile- time flag, which has been used since version 1.7.2. This
detection of a memory access violation causes the program to abort,
making the Plymouth graphical boot system unable to accept interactive
input of passwords when using the Mandos client.
* plugins.d/plymouth.c (exec_and_wait): Fix memory allocation bug when
allocating new_argv. Also tolerate a zero-length argv.
Fix an very old memory bug in the plymouth agent (which has been
present since its apperance in version 1.2), but which was only
recently detected at run time due to the new -fsanitize=address
compile- time flag, which has been used since version 1.7.2. This
detection of a memory access violation causes the program to abort,
making the Plymouth graphical boot system unable to accept interactive
input of passwords when using the Mandos client.
* plugins.d/plymouth.c (exec_and_wait): Fix memory allocation bug when
allocating new_argv. Also tolerate a zero-length argv.
- files added:
- bugs.xml
- debian/upstream
- network-hooks.d
- plugin-helpers
- files modified:
- .bzrignore
added
removed
plugins.d/mandos-client.c
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 © 2008-2016 Teddy Hogeborn
13
* Copyright © 2008-2016 Björn Påhlsson
14
14
*
15
15
* This program is free software: you can redistribute it and/or
16
16
* modify it under the terms of the GNU General Public License as
32
32
/* Needed by GPGME, specifically gpgme_data_seek() */
33
33
#ifndef _LARGEFILE_SOURCE
34
34
#define _LARGEFILE_SOURCE
35
#endif
35
#endif /* not _LARGEFILE_SOURCE */
36
36
#ifndef _FILE_OFFSET_BITS
37
37
#define _FILE_OFFSET_BITS 64
38
#endif
38
#endif /* not _FILE_OFFSET_BITS */
39
39
40
40
#define _GNU_SOURCE /* TEMP_FAILURE_RETRY(), asprintf() */
41
41
42
42
#include <stdio.h> /* fprintf(), stderr, fwrite(),
43
stdout, ferror(), remove() */
44
#include <stdint.h> /* uint16_t, uint32_t */
43
stdout, ferror() */
44
#include <stdint.h> /* uint16_t, uint32_t, intptr_t */
45
45
#include <stddef.h> /* NULL, size_t, ssize_t */
46
46
#include <stdlib.h> /* free(), EXIT_SUCCESS, srand(),
47
47
strtof(), abort() */
48
48
#include <stdbool.h> /* bool, false, true */
49
#include <string.h> /* memset(), strcmp(), strlen(),
50
strerror(), asprintf(), strcpy() */
49
#include <string.h> /* strcmp(), strlen(), strerror(),
50
asprintf(), strncpy() */
51
51
#include <sys/ioctl.h> /* ioctl */
52
52
#include <sys/types.h> /* socket(), inet_pton(), sockaddr,
53
53
sockaddr_in6, PF_INET6,
55
55
opendir(), DIR */
56
56
#include <sys/stat.h> /* open(), S_ISREG */
57
57
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
58
inet_pton(), connect() */
59
#include <fcntl.h> /* open() */
58
inet_pton(), connect(),
59
getnameinfo() */
60
#include <fcntl.h> /* open(), unlinkat(), AT_REMOVEDIR */
60
61
#include <dirent.h> /* opendir(), struct dirent, readdir()
61
62
*/
62
63
#include <inttypes.h> /* PRIu16, PRIdMAX, intmax_t,
63
64
strtoimax() */
64
#include <assert.h> /* assert() */
65
#include <errno.h> /* perror(), errno,
65
#include <errno.h> /* perror(), errno, EINTR, EINVAL,
66
EAI_SYSTEM, ENETUNREACH,
67
EHOSTUNREACH, ECONNREFUSED, EPROTO,
68
EIO, ENOENT, ENXIO, ENOMEM, EISDIR,
69
ENOTEMPTY,
66
70
program_invocation_short_name */
67
71
#include <time.h> /* nanosleep(), time(), sleep() */
68
72
#include <net/if.h> /* ioctl, ifreq, SIOCGIFFLAGS, IFF_UP,
73
77
*/
74
78
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
75
79
getuid(), getgid(), seteuid(),
76
setgid(), pause() */
77
#include <arpa/inet.h> /* inet_pton(), htons, inet_ntop() */
80
setgid(), pause(), _exit(),
81
unlinkat() */
82
#include <arpa/inet.h> /* inet_pton(), htons() */
78
83
#include <iso646.h> /* not, or, and */
79
84
#include <argp.h> /* struct argp_option, error_t, struct
80
85
argp_state, struct argp,
87
92
EX_NOHOST, EX_IOERR, EX_PROTOCOL */
88
93
#include <sys/wait.h> /* waitpid(), WIFEXITED(),
89
94
WEXITSTATUS(), WTERMSIG() */
95
#include <grp.h> /* setgroups() */
96
#include <argz.h> /* argz_add_sep(), argz_next(),
97
argz_delete(), argz_append(),
98
argz_stringify(), argz_add(),
99
argz_count() */
100
#include <netdb.h> /* getnameinfo(), NI_NUMERICHOST,
101
EAI_SYSTEM, gai_strerror() */
90
102
91
103
#ifdef __linux__
92
104
#include <sys/klog.h> /* klogctl() */
134
146
static const char sys_class_net[] = "/sys/class/net";
135
147
char *connect_to = NULL;
136
148
const char *hookdir = HOOKDIR;
149
int hookdir_fd = -1;
150
uid_t uid = 65534;
151
gid_t gid = 65534;
137
152
138
153
/* Doubly linked list that need to be circularly linked when used */
139
154
typedef struct server{
140
155
const char *ip;
141
uint16_t port;
156
in_port_t port;
142
157
AvahiIfIndex if_index;
143
158
int af;
144
159
struct timespec last_seen;
148
163
149
164
/* Used for passing in values through the Avahi callback functions */
150
165
typedef struct {
151
AvahiSimplePoll *simple_poll;
152
166
AvahiServer *server;
153
167
gnutls_certificate_credentials_t cred;
154
168
unsigned int dh_bits;
156
170
const char *priority;
157
171
gpgme_ctx_t ctx;
158
172
server *current_server;
173
char *interfaces;
174
size_t interfaces_size;
159
175
} mandos_context;
160
176
161
/* global context so signal handler can reach it*/
162
mandos_context mc = { .simple_poll = NULL, .server = NULL,
163
.dh_bits = 1024, .priority = "SECURE256"
164
":!CTYPE-X.509:+CTYPE-OPENPGP",
165
.current_server = NULL };
177
/* global so signal handler can reach it*/
178
AvahiSimplePoll *simple_poll;
166
179
167
180
sig_atomic_t quit_now = 0;
168
181
int signal_received = 0;
169
182
170
183
/* Function to use when printing errors */
171
184
void perror_plus(const char *print_text){
185
int e = errno;
172
186
fprintf(stderr, "Mandos plugin %s: ",
173
187
program_invocation_short_name);
188
errno = e;
174
189
perror(print_text);
175
190
}
176
191
192
__attribute__((format (gnu_printf, 2, 3), nonnull))
177
193
int fprintf_plus(FILE *stream, const char *format, ...){
178
194
va_list ap;
179
195
va_start (ap, format);
180
196
181
TEMP_FAILURE_RETRY(fprintf(stream, "Mandos plugin %s: ", program_invocation_short_name));
182
return TEMP_FAILURE_RETRY(vfprintf(stream, format, ap));
197
TEMP_FAILURE_RETRY(fprintf(stream, "Mandos plugin %s: ",
198
program_invocation_short_name));
199
return (int)TEMP_FAILURE_RETRY(vfprintf(stream, format, ap));
183
200
}
184
201
185
202
/*
187
204
* bytes. "buffer_capacity" is how much is currently allocated,
188
205
* "buffer_length" is how much is already used.
189
206
*/
207
__attribute__((nonnull, warn_unused_result))
190
208
size_t incbuffer(char **buffer, size_t buffer_length,
191
209
size_t buffer_capacity){
192
210
if(buffer_length + BUFFER_SIZE > buffer_capacity){
193
*buffer = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
194
if(buffer == NULL){
211
char *new_buf = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
212
if(new_buf == NULL){
213
int old_errno = errno;
214
free(*buffer);
215
errno = old_errno;
216
*buffer = NULL;
195
217
return 0;
196
218
}
219
*buffer = new_buf;
197
220
buffer_capacity += BUFFER_SIZE;
198
221
}
199
222
return buffer_capacity;
200
223
}
201
224
202
225
/* Add server to set of servers to retry periodically */
203
int add_server(const char *ip, uint16_t port, AvahiIfIndex if_index,
204
int af){
226
__attribute__((nonnull, warn_unused_result))
227
bool add_server(const char *ip, in_port_t port, AvahiIfIndex if_index,
228
int af, server **current_server){
205
229
int ret;
206
230
server *new_server = malloc(sizeof(server));
207
231
if(new_server == NULL){
208
232
perror_plus("malloc");
209
return -1;
233
return false;
210
234
}
211
235
*new_server = (server){ .ip = strdup(ip),
212
236
.port = port,
214
238
.af = af };
215
239
if(new_server->ip == NULL){
216
240
perror_plus("strdup");
217
return -1;
241
free(new_server);
242
return false;
243
}
244
ret = clock_gettime(CLOCK_MONOTONIC, &(new_server->last_seen));
245
if(ret == -1){
246
perror_plus("clock_gettime");
247
#ifdef __GNUC__
248
#pragma GCC diagnostic push
249
#pragma GCC diagnostic ignored "-Wcast-qual"
250
#endif
251
free((char *)(new_server->ip));
252
#ifdef __GNUC__
253
#pragma GCC diagnostic pop
254
#endif
255
free(new_server);
256
return false;
218
257
}
219
258
/* Special case of first server */
220
if (mc.current_server == NULL){
259
if(*current_server == NULL){
221
260
new_server->next = new_server;
222
261
new_server->prev = new_server;
223
mc.current_server = new_server;
224
/* Place the new server last in the list */
262
*current_server = new_server;
225
263
} else {
226
new_server->next = mc.current_server;
227
new_server->prev = mc.current_server->prev;
264
/* Place the new server last in the list */
265
new_server->next = *current_server;
266
new_server->prev = (*current_server)->prev;
228
267
new_server->prev->next = new_server;
229
mc.current_server->prev = new_server;
230
}
231
ret = clock_gettime(CLOCK_MONOTONIC, &mc.current_server->last_seen);
232
if(ret == -1){
233
perror_plus("clock_gettime");
234
return -1;
235
}
236
return 0;
268
(*current_server)->prev = new_server;
269
}
270
return true;
237
271
}
238
272
239
273
/*
240
274
* Initialize GPGME.
241
275
*/
242
static bool init_gpgme(const char *seckey, const char *pubkey,
243
const char *tempdir){
276
__attribute__((nonnull, warn_unused_result))
277
static bool init_gpgme(const char * const seckey,
278
const char * const pubkey,
279
const char * const tempdir,
280
mandos_context *mc){
244
281
gpgme_error_t rc;
245
282
gpgme_engine_info_t engine_info;
246
283
247
248
284
/*
249
285
* Helper function to insert pub and seckey to the engine keyring.
250
286
*/
251
bool import_key(const char *filename){
287
bool import_key(const char * const filename){
252
288
int ret;
253
289
int fd;
254
290
gpgme_data_t pgp_data;
261
297
262
298
rc = gpgme_data_new_from_fd(&pgp_data, fd);
263
299
if(rc != GPG_ERR_NO_ERROR){
264
fprintf(stderr, "Mandos plugin mandos-client: "
265
"bad gpgme_data_new_from_fd: %s: %s\n",
266
gpgme_strsource(rc), gpgme_strerror(rc));
300
fprintf_plus(stderr, "bad gpgme_data_new_from_fd: %s: %s\n",
301
gpgme_strsource(rc), gpgme_strerror(rc));
267
302
return false;
268
303
}
269
304
270
rc = gpgme_op_import(mc.ctx, pgp_data);
305
rc = gpgme_op_import(mc->ctx, pgp_data);
271
306
if(rc != GPG_ERR_NO_ERROR){
272
fprintf(stderr, "Mandos plugin mandos-client: "
273
"bad gpgme_op_import: %s: %s\n",
274
gpgme_strsource(rc), gpgme_strerror(rc));
307
fprintf_plus(stderr, "bad gpgme_op_import: %s: %s\n",
308
gpgme_strsource(rc), gpgme_strerror(rc));
275
309
return false;
276
310
}
277
311
278
ret = (int)TEMP_FAILURE_RETRY(close(fd));
312
ret = close(fd);
279
313
if(ret == -1){
280
314
perror_plus("close");
281
315
}
284
318
}
285
319
286
320
if(debug){
287
fprintf(stderr, "Mandos plugin mandos-client: "
288
"Initializing GPGME\n");
321
fprintf_plus(stderr, "Initializing GPGME\n");
289
322
}
290
323
291
324
/* Init GPGME */
292
325
gpgme_check_version(NULL);
293
326
rc = gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP);
294
327
if(rc != GPG_ERR_NO_ERROR){
295
fprintf(stderr, "Mandos plugin mandos-client: "
296
"bad gpgme_engine_check_version: %s: %s\n",
297
gpgme_strsource(rc), gpgme_strerror(rc));
328
fprintf_plus(stderr, "bad gpgme_engine_check_version: %s: %s\n",
329
gpgme_strsource(rc), gpgme_strerror(rc));
298
330
return false;
299
331
}
300
332
301
333
/* Set GPGME home directory for the OpenPGP engine only */
302
334
rc = gpgme_get_engine_info(&engine_info);
303
335
if(rc != GPG_ERR_NO_ERROR){
304
fprintf(stderr, "Mandos plugin mandos-client: "
305
"bad gpgme_get_engine_info: %s: %s\n",
306
gpgme_strsource(rc), gpgme_strerror(rc));
336
fprintf_plus(stderr, "bad gpgme_get_engine_info: %s: %s\n",
337
gpgme_strsource(rc), gpgme_strerror(rc));
307
338
return false;
308
339
}
309
340
while(engine_info != NULL){
315
346
engine_info = engine_info->next;
316
347
}
317
348
if(engine_info == NULL){
318
fprintf(stderr, "Mandos plugin mandos-client: "
319
"Could not set GPGME home dir to %s\n", tempdir);
349
fprintf_plus(stderr, "Could not set GPGME home dir to %s\n",
350
tempdir);
320
351
return false;
321
352
}
322
353
323
354
/* Create new GPGME "context" */
324
rc = gpgme_new(&(mc.ctx));
355
rc = gpgme_new(&(mc->ctx));
325
356
if(rc != GPG_ERR_NO_ERROR){
326
fprintf(stderr, "Mandos plugin mandos-client: "
327
"bad gpgme_new: %s: %s\n", gpgme_strsource(rc),
328
gpgme_strerror(rc));
357
fprintf_plus(stderr, "Mandos plugin mandos-client: "
358
"bad gpgme_new: %s: %s\n", gpgme_strsource(rc),
359
gpgme_strerror(rc));
329
360
return false;
330
361
}
331
362
340
371
* Decrypt OpenPGP data.
341
372
* Returns -1 on error
342
373
*/
374
__attribute__((nonnull, warn_unused_result))
343
375
static ssize_t pgp_packet_decrypt(const char *cryptotext,
344
376
size_t crypto_size,
345
char **plaintext){
377
char **plaintext,
378
mandos_context *mc){
346
379
gpgme_data_t dh_crypto, dh_plain;
347
380
gpgme_error_t rc;
348
381
ssize_t ret;
350
383
ssize_t plaintext_length = 0;
351
384
352
385
if(debug){
353
fprintf(stderr, "Mandos plugin mandos-client: "
354
"Trying to decrypt OpenPGP data\n");
386
fprintf_plus(stderr, "Trying to decrypt OpenPGP data\n");
355
387
}
356
388
357
389
/* Create new GPGME data buffer from memory cryptotext */
358
390
rc = gpgme_data_new_from_mem(&dh_crypto, cryptotext, crypto_size,
359
391
0);
360
392
if(rc != GPG_ERR_NO_ERROR){
361
fprintf(stderr, "Mandos plugin mandos-client: "
362
"bad gpgme_data_new_from_mem: %s: %s\n",
363
gpgme_strsource(rc), gpgme_strerror(rc));
393
fprintf_plus(stderr, "bad gpgme_data_new_from_mem: %s: %s\n",
394
gpgme_strsource(rc), gpgme_strerror(rc));
364
395
return -1;
365
396
}
366
397
367
398
/* Create new empty GPGME data buffer for the plaintext */
368
399
rc = gpgme_data_new(&dh_plain);
369
400
if(rc != GPG_ERR_NO_ERROR){
370
fprintf(stderr, "Mandos plugin mandos-client: "
371
"bad gpgme_data_new: %s: %s\n",
372
gpgme_strsource(rc), gpgme_strerror(rc));
401
fprintf_plus(stderr, "Mandos plugin mandos-client: "
402
"bad gpgme_data_new: %s: %s\n",
403
gpgme_strsource(rc), gpgme_strerror(rc));
373
404
gpgme_data_release(dh_crypto);
374
405
return -1;
375
406
}
376
407
377
408
/* Decrypt data from the cryptotext data buffer to the plaintext
378
409
data buffer */
379
rc = gpgme_op_decrypt(mc.ctx, dh_crypto, dh_plain);
410
rc = gpgme_op_decrypt(mc->ctx, dh_crypto, dh_plain);
380
411
if(rc != GPG_ERR_NO_ERROR){
381
fprintf(stderr, "Mandos plugin mandos-client: "
382
"bad gpgme_op_decrypt: %s: %s\n",
383
gpgme_strsource(rc), gpgme_strerror(rc));
412
fprintf_plus(stderr, "bad gpgme_op_decrypt: %s: %s\n",
413
gpgme_strsource(rc), gpgme_strerror(rc));
384
414
plaintext_length = -1;
385
415
if(debug){
386
416
gpgme_decrypt_result_t result;
387
result = gpgme_op_decrypt_result(mc.ctx);
417
result = gpgme_op_decrypt_result(mc->ctx);
388
418
if(result == NULL){
389
fprintf(stderr, "Mandos plugin mandos-client: "
390
"gpgme_op_decrypt_result failed\n");
419
fprintf_plus(stderr, "gpgme_op_decrypt_result failed\n");
391
420
} else {
392
fprintf(stderr, "Mandos plugin mandos-client: "
393
"Unsupported algorithm: %s\n",
394
result->unsupported_algorithm);
395
fprintf(stderr, "Mandos plugin mandos-client: "
396
"Wrong key usage: %u\n",
397
result->wrong_key_usage);
421
fprintf_plus(stderr, "Unsupported algorithm: %s\n",
422
result->unsupported_algorithm);
423
fprintf_plus(stderr, "Wrong key usage: %u\n",
424
result->wrong_key_usage);
398
425
if(result->file_name != NULL){
399
fprintf(stderr, "Mandos plugin mandos-client: "
400
"File name: %s\n", result->file_name);
426
fprintf_plus(stderr, "File name: %s\n", result->file_name);
401
427
}
402
428
gpgme_recipient_t recipient;
403
429
recipient = result->recipients;
404
430
while(recipient != NULL){
405
fprintf(stderr, "Mandos plugin mandos-client: "
406
"Public key algorithm: %s\n",
407
gpgme_pubkey_algo_name(recipient->pubkey_algo));
408
fprintf(stderr, "Mandos plugin mandos-client: "
409
"Key ID: %s\n", recipient->keyid);
410
fprintf(stderr, "Mandos plugin mandos-client: "
411
"Secret key available: %s\n",
412
recipient->status == GPG_ERR_NO_SECKEY
413
? "No" : "Yes");
431
fprintf_plus(stderr, "Public key algorithm: %s\n",
432
gpgme_pubkey_algo_name
433
(recipient->pubkey_algo));
434
fprintf_plus(stderr, "Key ID: %s\n", recipient->keyid);
435
fprintf_plus(stderr, "Secret key available: %s\n",
436
recipient->status == GPG_ERR_NO_SECKEY
437
? "No" : "Yes");
414
438
recipient = recipient->next;
415
439
}
416
440
}
419
443
}
420
444
421
445
if(debug){
422
fprintf(stderr, "Mandos plugin mandos-client: "
423
"Decryption of OpenPGP data succeeded\n");
446
fprintf_plus(stderr, "Decryption of OpenPGP data succeeded\n");
424
447
}
425
448
426
449
/* Seek back to the beginning of the GPGME plaintext data buffer */
457
480
}
458
481
459
482
if(debug){
460
fprintf(stderr, "Mandos plugin mandos-client: "
461
"Decrypted password is: ");
483
fprintf_plus(stderr, "Decrypted password is: ");
462
484
for(ssize_t i = 0; i < plaintext_length; i++){
463
485
fprintf(stderr, "%02hhX ", (*plaintext)[i]);
464
486
}
475
497
return plaintext_length;
476
498
}
477
499
478
static const char * safer_gnutls_strerror(int value){
479
const char *ret = gnutls_strerror(value); /* Spurious warning from
480
-Wunreachable-code */
481
if(ret == NULL)
482
ret = "(unknown)";
483
return ret;
500
__attribute__((warn_unused_result, const))
501
static const char *safe_string(const char *str){
502
if(str == NULL)
503
return "(unknown)";
504
return str;
505
}
506
507
__attribute__((warn_unused_result))
508
static const char *safer_gnutls_strerror(int value){
509
const char *ret = gnutls_strerror(value);
510
return safe_string(ret);
484
511
}
485
512
486
513
/* GnuTLS log function callback */
514
__attribute__((nonnull))
487
515
static void debuggnutls(__attribute__((unused)) int level,
488
516
const char* string){
489
fprintf(stderr, "Mandos plugin mandos-client: GnuTLS: %s", string);
517
fprintf_plus(stderr, "GnuTLS: %s", string);
490
518
}
491
519
520
__attribute__((nonnull(1, 2, 4), warn_unused_result))
492
521
static int init_gnutls_global(const char *pubkeyfilename,
493
const char *seckeyfilename){
522
const char *seckeyfilename,
523
const char *dhparamsfilename,
524
mandos_context *mc){
494
525
int ret;
526
unsigned int uret;
495
527
496
528
if(debug){
497
fprintf(stderr, "Mandos plugin mandos-client: "
498
"Initializing GnuTLS\n");
499
}
500
501
ret = gnutls_global_init();
502
if(ret != GNUTLS_E_SUCCESS){
503
fprintf(stderr, "Mandos plugin mandos-client: "
504
"GnuTLS global_init: %s\n", safer_gnutls_strerror(ret));
505
return -1;
529
fprintf_plus(stderr, "Initializing GnuTLS\n");
506
530
}
507
531
508
532
if(debug){
514
538
}
515
539
516
540
/* OpenPGP credentials */
517
ret = gnutls_certificate_allocate_credentials(&mc.cred);
541
ret = gnutls_certificate_allocate_credentials(&mc->cred);
518
542
if(ret != GNUTLS_E_SUCCESS){
519
fprintf(stderr, "Mandos plugin mandos-client: "
520
"GnuTLS memory error: %s\n", safer_gnutls_strerror(ret));
521
gnutls_global_deinit();
543
fprintf_plus(stderr, "GnuTLS memory error: %s\n",
544
safer_gnutls_strerror(ret));
522
545
return -1;
523
546
}
524
547
525
548
if(debug){
526
fprintf(stderr, "Mandos plugin mandos-client: "
527
"Attempting to use OpenPGP public key %s and"
528
" secret key %s as GnuTLS credentials\n", pubkeyfilename,
529
seckeyfilename);
549
fprintf_plus(stderr, "Attempting to use OpenPGP public key %s and"
550
" secret key %s as GnuTLS credentials\n",
551
pubkeyfilename,
552
seckeyfilename);
530
553
}
531
554
532
555
ret = gnutls_certificate_set_openpgp_key_file
533
(mc.cred, pubkeyfilename, seckeyfilename,
556
(mc->cred, pubkeyfilename, seckeyfilename,
534
557
GNUTLS_OPENPGP_FMT_BASE64);
535
558
if(ret != GNUTLS_E_SUCCESS){
536
fprintf(stderr,
537
"Mandos plugin mandos-client: "
538
"Error[%d] while reading the OpenPGP key pair ('%s',"
539
" '%s')\n", ret, pubkeyfilename, seckeyfilename);
540
fprintf(stderr, "Mandos plugin mandos-client: "
541
"The GnuTLS error is: %s\n", safer_gnutls_strerror(ret));
559
fprintf_plus(stderr,
560
"Error[%d] while reading the OpenPGP key pair ('%s',"
561
" '%s')\n", ret, pubkeyfilename, seckeyfilename);
562
fprintf_plus(stderr, "The GnuTLS error is: %s\n",
563
safer_gnutls_strerror(ret));
542
564
goto globalfail;
543
565
}
544
566
545
567
/* GnuTLS server initialization */
546
ret = gnutls_dh_params_init(&mc.dh_params);
547
if(ret != GNUTLS_E_SUCCESS){
548
fprintf(stderr, "Mandos plugin mandos-client: "
549
"Error in GnuTLS DH parameter initialization:"
550
" %s\n", safer_gnutls_strerror(ret));
551
goto globalfail;
552
}
553
ret = gnutls_dh_params_generate2(mc.dh_params, mc.dh_bits);
554
if(ret != GNUTLS_E_SUCCESS){
555
fprintf(stderr, "Mandos plugin mandos-client: "
556
"Error in GnuTLS prime generation: %s\n",
557
safer_gnutls_strerror(ret));
558
goto globalfail;
559
}
560
561
gnutls_certificate_set_dh_params(mc.cred, mc.dh_params);
568
ret = gnutls_dh_params_init(&mc->dh_params);
569
if(ret != GNUTLS_E_SUCCESS){
570
fprintf_plus(stderr, "Error in GnuTLS DH parameter"
571
" initialization: %s\n",
572
safer_gnutls_strerror(ret));
573
goto globalfail;
574
}
575
/* If a Diffie-Hellman parameters file was given, try to use it */
576
if(dhparamsfilename != NULL){
577
gnutls_datum_t params = { .data = NULL, .size = 0 };
578
do {
579
int dhpfile = open(dhparamsfilename, O_RDONLY);
580
if(dhpfile == -1){
581
perror_plus("open");
582
dhparamsfilename = NULL;
583
break;
584
}
585
size_t params_capacity = 0;
586
while(true){
587
params_capacity = incbuffer((char **)¶ms.data,
588
(size_t)params.size,
589
(size_t)params_capacity);
590
if(params_capacity == 0){
591
perror_plus("incbuffer");
592
free(params.data);
593
params.data = NULL;
594
dhparamsfilename = NULL;
595
break;
596
}
597
ssize_t bytes_read = read(dhpfile,
598
params.data + params.size,
599
BUFFER_SIZE);
600
/* EOF */
601
if(bytes_read == 0){
602
break;
603
}
604
/* check bytes_read for failure */
605
if(bytes_read < 0){
606
perror_plus("read");
607
free(params.data);
608
params.data = NULL;
609
dhparamsfilename = NULL;
610
break;
611
}
612
params.size += (unsigned int)bytes_read;
613
}
614
if(params.data == NULL){
615
dhparamsfilename = NULL;
616
}
617
if(dhparamsfilename == NULL){
618
break;
619
}
620
ret = gnutls_dh_params_import_pkcs3(mc->dh_params, ¶ms,
621
GNUTLS_X509_FMT_PEM);
622
if(ret != GNUTLS_E_SUCCESS){
623
fprintf_plus(stderr, "Failed to parse DH parameters in file"
624
" \"%s\": %s\n", dhparamsfilename,
625
safer_gnutls_strerror(ret));
626
dhparamsfilename = NULL;
627
}
628
} while(false);
629
}
630
if(dhparamsfilename == NULL){
631
if(mc->dh_bits == 0){
632
/* Find out the optimal number of DH bits */
633
/* Try to read the private key file */
634
gnutls_datum_t buffer = { .data = NULL, .size = 0 };
635
do {
636
int secfile = open(seckeyfilename, O_RDONLY);
637
if(secfile == -1){
638
perror_plus("open");
639
break;
640
}
641
size_t buffer_capacity = 0;
642
while(true){
643
buffer_capacity = incbuffer((char **)&buffer.data,
644
(size_t)buffer.size,
645
(size_t)buffer_capacity);
646
if(buffer_capacity == 0){
647
perror_plus("incbuffer");
648
free(buffer.data);
649
buffer.data = NULL;
650
break;
651
}
652
ssize_t bytes_read = read(secfile,
653
buffer.data + buffer.size,
654
BUFFER_SIZE);
655
/* EOF */
656
if(bytes_read == 0){
657
break;
658
}
659
/* check bytes_read for failure */
660
if(bytes_read < 0){
661
perror_plus("read");
662
free(buffer.data);
663
buffer.data = NULL;
664
break;
665
}
666
buffer.size += (unsigned int)bytes_read;
667
}
668
close(secfile);
669
} while(false);
670
/* If successful, use buffer to parse private key */
671
gnutls_sec_param_t sec_param = GNUTLS_SEC_PARAM_ULTRA;
672
if(buffer.data != NULL){
673
{
674
gnutls_openpgp_privkey_t privkey = NULL;
675
ret = gnutls_openpgp_privkey_init(&privkey);
676
if(ret != GNUTLS_E_SUCCESS){
677
fprintf_plus(stderr, "Error initializing OpenPGP key"
678
" structure: %s",
679
safer_gnutls_strerror(ret));
680
free(buffer.data);
681
buffer.data = NULL;
682
} else {
683
ret = gnutls_openpgp_privkey_import
684
(privkey, &buffer, GNUTLS_OPENPGP_FMT_BASE64, "", 0);
685
if(ret != GNUTLS_E_SUCCESS){
686
fprintf_plus(stderr, "Error importing OpenPGP key : %s",
687
safer_gnutls_strerror(ret));
688
privkey = NULL;
689
}
690
free(buffer.data);
691
buffer.data = NULL;
692
if(privkey != NULL){
693
/* Use private key to suggest an appropriate
694
sec_param */
695
sec_param = gnutls_openpgp_privkey_sec_param(privkey);
696
gnutls_openpgp_privkey_deinit(privkey);
697
if(debug){
698
fprintf_plus(stderr, "This OpenPGP key implies using"
699
" a GnuTLS security parameter \"%s\".\n",
700
safe_string(gnutls_sec_param_get_name
701
(sec_param)));
702
}
703
}
704
}
705
}
706
if(sec_param == GNUTLS_SEC_PARAM_UNKNOWN){
707
/* Err on the side of caution */
708
sec_param = GNUTLS_SEC_PARAM_ULTRA;
709
if(debug){
710
fprintf_plus(stderr, "Falling back to security parameter"
711
" \"%s\"\n",
712
safe_string(gnutls_sec_param_get_name
713
(sec_param)));
714
}
715
}
716
}
717
uret = gnutls_sec_param_to_pk_bits(GNUTLS_PK_DH, sec_param);
718
if(uret != 0){
719
mc->dh_bits = uret;
720
if(debug){
721
fprintf_plus(stderr, "A \"%s\" GnuTLS security parameter"
722
" implies %u DH bits; using that.\n",
723
safe_string(gnutls_sec_param_get_name
724
(sec_param)),
725
mc->dh_bits);
726
}
727
} else {
728
fprintf_plus(stderr, "Failed to get implied number of DH"
729
" bits for security parameter \"%s\"): %s\n",
730
safe_string(gnutls_sec_param_get_name
731
(sec_param)),
732
safer_gnutls_strerror(ret));
733
goto globalfail;
734
}
735
} else if(debug){
736
fprintf_plus(stderr, "DH bits explicitly set to %u\n",
737
mc->dh_bits);
738
}
739
ret = gnutls_dh_params_generate2(mc->dh_params, mc->dh_bits);
740
if(ret != GNUTLS_E_SUCCESS){
741
fprintf_plus(stderr, "Error in GnuTLS prime generation (%u"
742
" bits): %s\n", mc->dh_bits,
743
safer_gnutls_strerror(ret));
744
goto globalfail;
745
}
746
}
747
gnutls_certificate_set_dh_params(mc->cred, mc->dh_params);
562
748
563
749
return 0;
564
750
565
751
globalfail:
566
752
567
gnutls_certificate_free_credentials(mc.cred);
568
gnutls_global_deinit();
569
gnutls_dh_params_deinit(mc.dh_params);
753
gnutls_certificate_free_credentials(mc->cred);
754
gnutls_dh_params_deinit(mc->dh_params);
570
755
return -1;
571
756
}
572
757
573
static int init_gnutls_session(gnutls_session_t *session){
758
__attribute__((nonnull, warn_unused_result))
759
static int init_gnutls_session(gnutls_session_t *session,
760
mandos_context *mc){
574
761
int ret;
575
762
/* GnuTLS session creation */
576
763
do {
580
767
}
581
768
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
582
769
if(ret != GNUTLS_E_SUCCESS){
583
fprintf(stderr, "Mandos plugin mandos-client: "
584
"Error in GnuTLS session initialization: %s\n",
585
safer_gnutls_strerror(ret));
770
fprintf_plus(stderr,
771
"Error in GnuTLS session initialization: %s\n",
772
safer_gnutls_strerror(ret));
586
773
}
587
774
588
775
{
589
776
const char *err;
590
777
do {
591
ret = gnutls_priority_set_direct(*session, mc.priority, &err);
778
ret = gnutls_priority_set_direct(*session, mc->priority, &err);
592
779
if(quit_now){
593
780
gnutls_deinit(*session);
594
781
return -1;
595
782
}
596
783
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
597
784
if(ret != GNUTLS_E_SUCCESS){
598
fprintf(stderr, "Mandos plugin mandos-client: "
599
"Syntax error at: %s\n", err);
600
fprintf(stderr, "Mandos plugin mandos-client: "
601
"GnuTLS error: %s\n", safer_gnutls_strerror(ret));
785
fprintf_plus(stderr, "Syntax error at: %s\n", err);
786
fprintf_plus(stderr, "GnuTLS error: %s\n",
787
safer_gnutls_strerror(ret));
602
788
gnutls_deinit(*session);
603
789
return -1;
604
790
}
606
792
607
793
do {
608
794
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
609
mc.cred);
795
mc->cred);
610
796
if(quit_now){
611
797
gnutls_deinit(*session);
612
798
return -1;
613
799
}
614
800
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
615
801
if(ret != GNUTLS_E_SUCCESS){
616
fprintf(stderr, "Mandos plugin mandos-client: "
617
"Error setting GnuTLS credentials: %s\n",
618
safer_gnutls_strerror(ret));
802
fprintf_plus(stderr, "Error setting GnuTLS credentials: %s\n",
803
safer_gnutls_strerror(ret));
619
804
gnutls_deinit(*session);
620
805
return -1;
621
806
}
623
808
/* ignore client certificate if any. */
624
809
gnutls_certificate_server_set_request(*session, GNUTLS_CERT_IGNORE);
625
810
626
gnutls_dh_set_prime_bits(*session, mc.dh_bits);
627
628
811
return 0;
629
812
}
630
813
632
815
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
633
816
__attribute__((unused)) const char *txt){}
634
817
818
/* Set effective uid to 0, return errno */
819
__attribute__((warn_unused_result))
820
int raise_privileges(void){
821
int old_errno = errno;
822
int ret = 0;
823
if(seteuid(0) == -1){
824
ret = errno;
825
}
826
errno = old_errno;
827
return ret;
828
}
829
830
/* Set effective and real user ID to 0. Return errno. */
831
__attribute__((warn_unused_result))
832
int raise_privileges_permanently(void){
833
int old_errno = errno;
834
int ret = raise_privileges();
835
if(ret != 0){
836
errno = old_errno;
837
return ret;
838
}
839
if(setuid(0) == -1){
840
ret = errno;
841
}
842
errno = old_errno;
843
return ret;
844
}
845
846
/* Set effective user ID to unprivileged saved user ID */
847
__attribute__((warn_unused_result))
848
int lower_privileges(void){
849
int old_errno = errno;
850
int ret = 0;
851
if(seteuid(uid) == -1){
852
ret = errno;
853
}
854
errno = old_errno;
855
return ret;
856
}
857
858
/* Lower privileges permanently */
859
__attribute__((warn_unused_result))
860
int lower_privileges_permanently(void){
861
int old_errno = errno;
862
int ret = 0;
863
if(setuid(uid) == -1){
864
ret = errno;
865
}
866
errno = old_errno;
867
return ret;
868
}
869
870
/* Helper function to add_local_route() and delete_local_route() */
871
__attribute__((nonnull, warn_unused_result))
872
static bool add_delete_local_route(const bool add,
873
const char *address,
874
AvahiIfIndex if_index){
875
int ret;
876
char helper[] = "mandos-client-iprouteadddel";
877
char add_arg[] = "add";
878
char delete_arg[] = "delete";
879
char debug_flag[] = "--debug";
880
char *pluginhelperdir = getenv("MANDOSPLUGINHELPERDIR");
881
if(pluginhelperdir == NULL){
882
if(debug){
883
fprintf_plus(stderr, "MANDOSPLUGINHELPERDIR environment"
884
" variable not set; cannot run helper\n");
885
}
886
return false;
887
}
888
889
char interface[IF_NAMESIZE];
890
if(if_indextoname((unsigned int)if_index, interface) == NULL){
891
perror_plus("if_indextoname");
892
return false;
893
}
894
895
int devnull = (int)TEMP_FAILURE_RETRY(open("/dev/null", O_RDONLY));
896
if(devnull == -1){
897
perror_plus("open(\"/dev/null\", O_RDONLY)");
898
return false;
899
}
900
pid_t pid = fork();
901
if(pid == 0){
902
/* Child */
903
/* Raise privileges */
904
errno = raise_privileges_permanently();
905
if(errno != 0){
906
perror_plus("Failed to raise privileges");
907
/* _exit(EX_NOPERM); */
908
} else {
909
/* Set group */
910
errno = 0;
911
ret = setgid(0);
912
if(ret == -1){
913
perror_plus("setgid");
914
_exit(EX_NOPERM);
915
}
916
/* Reset supplementary groups */
917
errno = 0;
918
ret = setgroups(0, NULL);
919
if(ret == -1){
920
perror_plus("setgroups");
921
_exit(EX_NOPERM);
922
}
923
}
924
ret = dup2(devnull, STDIN_FILENO);
925
if(ret == -1){
926
perror_plus("dup2(devnull, STDIN_FILENO)");
927
_exit(EX_OSERR);
928
}
929
ret = close(devnull);
930
if(ret == -1){
931
perror_plus("close");
932
_exit(EX_OSERR);
933
}
934
ret = dup2(STDERR_FILENO, STDOUT_FILENO);
935
if(ret == -1){
936
perror_plus("dup2(STDERR_FILENO, STDOUT_FILENO)");
937
_exit(EX_OSERR);
938
}
939
int helperdir_fd = (int)TEMP_FAILURE_RETRY(open(pluginhelperdir,
940
O_RDONLY
941
| O_DIRECTORY
942
| O_PATH
943
| O_CLOEXEC));
944
if(helperdir_fd == -1){
945
perror_plus("open");
946
_exit(EX_UNAVAILABLE);
947
}
948
int helper_fd = (int)TEMP_FAILURE_RETRY(openat(helperdir_fd,
949
helper, O_RDONLY));
950
if(helper_fd == -1){
951
perror_plus("openat");
952
close(helperdir_fd);
953
_exit(EX_UNAVAILABLE);
954
}
955
close(helperdir_fd);
956
#ifdef __GNUC__
957
#pragma GCC diagnostic push
958
#pragma GCC diagnostic ignored "-Wcast-qual"
959
#endif
960
if(fexecve(helper_fd, (char *const [])
961
{ helper, add ? add_arg : delete_arg, (char *)address,
962
interface, debug ? debug_flag : NULL, NULL },
963
environ) == -1){
964
#ifdef __GNUC__
965
#pragma GCC diagnostic pop
966
#endif
967
perror_plus("fexecve");
968
_exit(EXIT_FAILURE);
969
}
970
}
971
if(pid == -1){
972
perror_plus("fork");
973
return false;
974
}
975
int status;
976
pid_t pret = -1;
977
errno = 0;
978
do {
979
pret = waitpid(pid, &status, 0);
980
if(pret == -1 and errno == EINTR and quit_now){
981
int errno_raising = 0;
982
if((errno = raise_privileges()) != 0){
983
errno_raising = errno;
984
perror_plus("Failed to raise privileges in order to"
985
" kill helper program");
986
}
987
if(kill(pid, SIGTERM) == -1){
988
perror_plus("kill");
989
}
990
if((errno_raising == 0) and (errno = lower_privileges()) != 0){
991
perror_plus("Failed to lower privileges after killing"
992
" helper program");
993
}
994
return false;
995
}
996
} while(pret == -1 and errno == EINTR);
997
if(pret == -1){
998
perror_plus("waitpid");
999
return false;
1000
}
1001
if(WIFEXITED(status)){
1002
if(WEXITSTATUS(status) != 0){
1003
fprintf_plus(stderr, "Error: iprouteadddel exited"
1004
" with status %d\n", WEXITSTATUS(status));
1005
return false;
1006
}
1007
return true;
1008
}
1009
if(WIFSIGNALED(status)){
1010
fprintf_plus(stderr, "Error: iprouteadddel died by"
1011
" signal %d\n", WTERMSIG(status));
1012
return false;
1013
}
1014
fprintf_plus(stderr, "Error: iprouteadddel crashed\n");
1015
return false;
1016
}
1017
1018
__attribute__((nonnull, warn_unused_result))
1019
static bool add_local_route(const char *address,
1020
AvahiIfIndex if_index){
1021
if(debug){
1022
fprintf_plus(stderr, "Adding route to %s\n", address);
1023
}
1024
return add_delete_local_route(true, address, if_index);
1025
}
1026
1027
__attribute__((nonnull, warn_unused_result))
1028
static bool delete_local_route(const char *address,
1029
AvahiIfIndex if_index){
1030
if(debug){
1031
fprintf_plus(stderr, "Removing route to %s\n", address);
1032
}
1033
return add_delete_local_route(false, address, if_index);
1034
}
1035
635
1036
/* Called when a Mandos server is found */
636
static int start_mandos_communication(const char *ip, uint16_t port,
1037
__attribute__((nonnull, warn_unused_result))
1038
static int start_mandos_communication(const char *ip, in_port_t port,
637
1039
AvahiIfIndex if_index,
638
int af){
1040
int af, mandos_context *mc){
639
1041
int ret, tcp_sd = -1;
640
1042
ssize_t sret;
641
union {
642
struct sockaddr_in in;
643
struct sockaddr_in6 in6;
644
} to;
1043
struct sockaddr_storage to;
645
1044
char *buffer = NULL;
646
1045
char *decrypted_buffer = NULL;
647
1046
size_t buffer_length = 0;
650
1049
int retval = -1;
651
1050
gnutls_session_t session;
652
1051
int pf; /* Protocol family */
1052
bool route_added = false;
653
1053
654
1054
errno = 0;
655
1055
666
1066
pf = PF_INET;
667
1067
break;
668
1068
default:
669
fprintf(stderr, "Mandos plugin mandos-client: "
670
"Bad address family: %d\n", af);
1069
fprintf_plus(stderr, "Bad address family: %d\n", af);
671
1070
errno = EINVAL;
672
1071
return -1;
673
1072
}
674
1073
675
ret = init_gnutls_session(&session);
1074
/* If the interface is specified and we have a list of interfaces */
1075
if(if_index != AVAHI_IF_UNSPEC and mc->interfaces != NULL){
1076
/* Check if the interface is one of the interfaces we are using */
1077
bool match = false;
1078
{
1079
char *interface = NULL;
1080
while((interface=argz_next(mc->interfaces, mc->interfaces_size,
1081
interface))){
1082
if(if_nametoindex(interface) == (unsigned int)if_index){
1083
match = true;
1084
break;
1085
}
1086
}
1087
}
1088
if(not match){
1089
/* This interface does not match any in the list, so we don't
1090
connect to the server */
1091
if(debug){
1092
char interface[IF_NAMESIZE];
1093
if(if_indextoname((unsigned int)if_index, interface) == NULL){
1094
perror_plus("if_indextoname");
1095
} else {
1096
fprintf_plus(stderr, "Skipping server on non-used interface"
1097
" \"%s\"\n",
1098
if_indextoname((unsigned int)if_index,
1099
interface));
1100
}
1101
}
1102
return -1;
1103
}
1104
}
1105
1106
ret = init_gnutls_session(&session, mc);
676
1107
if(ret != 0){
677
1108
return -1;
678
1109
}
679
1110
680
1111
if(debug){
681
fprintf(stderr, "Mandos plugin mandos-client: "
682
"Setting up a TCP connection to %s, port %" PRIu16
683
"\n", ip, port);
1112
fprintf_plus(stderr, "Setting up a TCP connection to %s, port %"
1113
PRIuMAX "\n", ip, (uintmax_t)port);
684
1114
}
685
1115
686
tcp_sd = socket(pf, SOCK_STREAM, 0);
1116
tcp_sd = socket(pf, SOCK_STREAM | SOCK_CLOEXEC, 0);
687
1117
if(tcp_sd < 0){
688
1118
int e = errno;
689
1119
perror_plus("socket");
696
1126
goto mandos_end;
697
1127
}
698
1128
699
memset(&to, 0, sizeof(to));
700
1129
if(af == AF_INET6){
701
to.in6.sin6_family = (sa_family_t)af;
702
ret = inet_pton(af, ip, &to.in6.sin6_addr);
1130
struct sockaddr_in6 *to6 = (struct sockaddr_in6 *)&to;
1131
*to6 = (struct sockaddr_in6){ .sin6_family = (sa_family_t)af };
1132
ret = inet_pton(af, ip, &to6->sin6_addr);
703
1133
} else { /* IPv4 */
704
to.in.sin_family = (sa_family_t)af;
705
ret = inet_pton(af, ip, &to.in.sin_addr);
1134
struct sockaddr_in *to4 = (struct sockaddr_in *)&to;
1135
*to4 = (struct sockaddr_in){ .sin_family = (sa_family_t)af };
1136
ret = inet_pton(af, ip, &to4->sin_addr);
706
1137
}
707
1138
if(ret < 0 ){
708
1139
int e = errno;
712
1143
}
713
1144
if(ret == 0){
714
1145
int e = errno;
715
fprintf(stderr, "Mandos plugin mandos-client: "
716
"Bad address: %s\n", ip);
1146
fprintf_plus(stderr, "Bad address: %s\n", ip);
717
1147
errno = e;
718
1148
goto mandos_end;
719
1149
}
720
1150
if(af == AF_INET6){
721
to.in6.sin6_port = htons(port); /* Spurious warnings from
722
-Wconversion and
723
-Wunreachable-code */
724
725
if(IN6_IS_ADDR_LINKLOCAL /* Spurious warnings from */
726
(&to.in6.sin6_addr)){ /* -Wstrict-aliasing=2 or lower and
727
-Wunreachable-code*/
1151
((struct sockaddr_in6 *)&to)->sin6_port = htons(port);
1152
if(IN6_IS_ADDR_LINKLOCAL
1153
(&((struct sockaddr_in6 *)&to)->sin6_addr)){
728
1154
if(if_index == AVAHI_IF_UNSPEC){
729
fprintf(stderr, "Mandos plugin mandos-client: "
730
"An IPv6 link-local address is incomplete"
731
" without a network interface\n");
1155
fprintf_plus(stderr, "An IPv6 link-local address is"
1156
" incomplete without a network interface\n");
732
1157
errno = EINVAL;
733
1158
goto mandos_end;
734
1159
}
735
1160
/* Set the network interface number as scope */
736
to.in6.sin6_scope_id = (uint32_t)if_index;
1161
((struct sockaddr_in6 *)&to)->sin6_scope_id = (uint32_t)if_index;
737
1162
}
738
1163
} else {
739
to.in.sin_port = htons(port); /* Spurious warnings from
740
-Wconversion and
741
-Wunreachable-code */
1164
((struct sockaddr_in *)&to)->sin_port = htons(port);
742
1165
}
743
1166
744
1167
if(quit_now){
752
1175
if(if_indextoname((unsigned int)if_index, interface) == NULL){
753
1176
perror_plus("if_indextoname");
754
1177
} else {
755
fprintf(stderr, "Mandos plugin mandos-client: "
756
"Connection to: %s%%%s, port %" PRIu16 "\n",
757
ip, interface, port);
1178
fprintf_plus(stderr, "Connection to: %s%%%s, port %" PRIuMAX
1179
"\n", ip, interface, (uintmax_t)port);
758
1180
}
759
1181
} else {
760
fprintf(stderr, "Mandos plugin mandos-client: "
761
"Connection to: %s, port %" PRIu16 "\n", ip, port);
1182
fprintf_plus(stderr, "Connection to: %s, port %" PRIuMAX "\n",
1183
ip, (uintmax_t)port);
762
1184
}
763
1185
char addrstr[(INET_ADDRSTRLEN > INET6_ADDRSTRLEN) ?
764
1186
INET_ADDRSTRLEN : INET6_ADDRSTRLEN] = "";
765
const char *pcret;
766
if(af == AF_INET6){
767
pcret = inet_ntop(af, &(to.in6.sin6_addr), addrstr,
768
sizeof(addrstr));
769
} else {
770
pcret = inet_ntop(af, &(to.in.sin_addr), addrstr,
771
sizeof(addrstr));
772
}
773
if(pcret == NULL){
774
perror_plus("inet_ntop");
775
} else {
776
if(strcmp(addrstr, ip) != 0){
777
fprintf(stderr, "Mandos plugin mandos-client: "
778
"Canonical address form: %s\n", addrstr);
779
}
780
}
781
}
782
783
if(quit_now){
784
errno = EINTR;
785
goto mandos_end;
786
}
787
788
if(af == AF_INET6){
789
ret = connect(tcp_sd, &to.in6, sizeof(to));
790
} else {
791
ret = connect(tcp_sd, &to.in, sizeof(to)); /* IPv4 */
792
}
793
if(ret < 0){
794
if ((errno != ECONNREFUSED and errno != ENETUNREACH) or debug){
795
int e = errno;
796
perror_plus("connect");
797
errno = e;
798
}
799
goto mandos_end;
800
}
801
802
if(quit_now){
803
errno = EINTR;
804
goto mandos_end;
1187
if(af == AF_INET6){
1188
ret = getnameinfo((struct sockaddr *)&to,
1189
sizeof(struct sockaddr_in6),
1190
addrstr, sizeof(addrstr), NULL, 0,
1191
NI_NUMERICHOST);
1192
} else {
1193
ret = getnameinfo((struct sockaddr *)&to,
1194
sizeof(struct sockaddr_in),
1195
addrstr, sizeof(addrstr), NULL, 0,
1196
NI_NUMERICHOST);
1197
}
1198
if(ret == EAI_SYSTEM){
1199
perror_plus("getnameinfo");
1200
} else if(ret != 0) {
1201
fprintf_plus(stderr, "getnameinfo: %s", gai_strerror(ret));
1202
} else if(strcmp(addrstr, ip) != 0){
1203
fprintf_plus(stderr, "Canonical address form: %s\n", addrstr);
1204
}
1205
}
1206
1207
if(quit_now){
1208
errno = EINTR;
1209
goto mandos_end;
1210
}
1211
1212
while(true){
1213
if(af == AF_INET6){
1214
ret = connect(tcp_sd, (struct sockaddr *)&to,
1215
sizeof(struct sockaddr_in6));
1216
} else {
1217
ret = connect(tcp_sd, (struct sockaddr *)&to, /* IPv4 */
1218
sizeof(struct sockaddr_in));
1219
}
1220
if(ret < 0){
1221
if(((errno == ENETUNREACH) or (errno == EHOSTUNREACH))
1222
and if_index != AVAHI_IF_UNSPEC
1223
and connect_to == NULL
1224
and not route_added and
1225
((af == AF_INET6 and not
1226
IN6_IS_ADDR_LINKLOCAL(&(((struct sockaddr_in6 *)
1227
&to)->sin6_addr)))
1228
or (af == AF_INET and
1229
/* Not a a IPv4LL address */
1230
(ntohl(((struct sockaddr_in *)&to)->sin_addr.s_addr)
1231
& 0xFFFF0000L) != 0xA9FE0000L))){
1232
/* Work around Avahi bug - Avahi does not announce link-local
1233
addresses if it has a global address, so local hosts with
1234
*only* a link-local address (e.g. Mandos clients) cannot
1235
connect to a Mandos server announced by Avahi on a server
1236
host with a global address. Work around this by retrying
1237
with an explicit route added with the server's address.
1238
1239
Avahi bug reference:
1240
http://lists.freedesktop.org/archives/avahi/2010-February/001833.html
1241
https://bugs.debian.org/587961
1242
*/
1243
if(debug){
1244
fprintf_plus(stderr, "Mandos server unreachable, trying"
1245
" direct route\n");
1246
}
1247
int e = errno;
1248
route_added = add_local_route(ip, if_index);
1249
if(route_added){
1250
continue;
1251
}
1252
errno = e;
1253
}
1254
if(errno != ECONNREFUSED or debug){
1255
int e = errno;
1256
perror_plus("connect");
1257
errno = e;
1258
}
1259
goto mandos_end;
1260
}
1261
1262
if(quit_now){
1263
errno = EINTR;
1264
goto mandos_end;
1265
}
1266
break;
805
1267
}
806
1268
807
1269
const char *out = mandos_protocol_version;
835
1297
}
836
1298
837
1299
if(debug){
838
fprintf(stderr, "Mandos plugin mandos-client: "
839
"Establishing TLS session with %s\n", ip);
1300
fprintf_plus(stderr, "Establishing TLS session with %s\n", ip);
840
1301
}
841
1302
842
1303
if(quit_now){
844
1305
goto mandos_end;
845
1306
}
846
1307
847
/* Spurious warning from -Wint-to-pointer-cast */
848
gnutls_transport_set_ptr(session, (gnutls_transport_ptr_t) tcp_sd);
1308
/* This casting via intptr_t is to eliminate warning about casting
1309
an int to a pointer type. This is exactly how the GnuTLS Guile
1310
function "set-session-transport-fd!" does it. */
1311
gnutls_transport_set_ptr(session,
1312
(gnutls_transport_ptr_t)(intptr_t)tcp_sd);
849
1313
850
1314
if(quit_now){
851
1315
errno = EINTR;
862
1326
863
1327
if(ret != GNUTLS_E_SUCCESS){
864
1328
if(debug){
865
fprintf(stderr, "Mandos plugin mandos-client: "
866
"*** GnuTLS Handshake failed ***\n");
1329
fprintf_plus(stderr, "*** GnuTLS Handshake failed ***\n");
867
1330
gnutls_perror(ret);
868
1331
}
869
1332
errno = EPROTO;
873
1336
/* Read OpenPGP packet that contains the wanted password */
874
1337
875
1338
if(debug){
876
fprintf(stderr, "Mandos plugin mandos-client: "
877
"Retrieving OpenPGP encrypted password from %s\n", ip);
1339
fprintf_plus(stderr, "Retrieving OpenPGP encrypted password from"
1340
" %s\n", ip);
878
1341
}
879
1342
880
1343
while(true){
918
1381
}
919
1382
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
920
1383
if(ret < 0){
921
fprintf(stderr, "Mandos plugin mandos-client: "
922
"*** GnuTLS Re-handshake failed ***\n");
1384
fprintf_plus(stderr, "*** GnuTLS Re-handshake failed "
1385
"***\n");
923
1386
gnutls_perror(ret);
924
1387
errno = EPROTO;
925
1388
goto mandos_end;
926
1389
}
927
1390
break;
928
1391
default:
929
fprintf(stderr, "Mandos plugin mandos-client: "
930
"Unknown error while reading data from"
931
" encrypted session with Mandos server\n");
1392
fprintf_plus(stderr, "Unknown error while reading data from"
1393
" encrypted session with Mandos server\n");
932
1394
gnutls_bye(session, GNUTLS_SHUT_RDWR);
933
1395
errno = EIO;
934
1396
goto mandos_end;
939
1401
}
940
1402
941
1403
if(debug){
942
fprintf(stderr, "Mandos plugin mandos-client: "
943
"Closing TLS session\n");
1404
fprintf_plus(stderr, "Closing TLS session\n");
944
1405
}
945
1406
946
1407
if(quit_now){
959
1420
if(buffer_length > 0){
960
1421
ssize_t decrypted_buffer_size;
961
1422
decrypted_buffer_size = pgp_packet_decrypt(buffer, buffer_length,
962
&decrypted_buffer);
1423
&decrypted_buffer, mc);
963
1424
if(decrypted_buffer_size >= 0){
964
1425
965
1426
written = 0;
975
1436
if(ret == 0 and ferror(stdout)){
976
1437
int e = errno;
977
1438
if(debug){
978
fprintf(stderr, "Mandos plugin mandos-client: "
979
"Error writing encrypted data: %s\n",
980
strerror(errno));
1439
fprintf_plus(stderr, "Error writing encrypted data: %s\n",
1440
strerror(errno));
981
1441
}
982
1442
errno = e;
983
1443
goto mandos_end;
992
1452
993
1453
mandos_end:
994
1454
{
1455
if(route_added){
1456
if(not delete_local_route(ip, if_index)){
1457
fprintf_plus(stderr, "Failed to delete local route to %s on"
1458
" interface %d", ip, if_index);
1459
}
1460
}
995
1461
int e = errno;
996
1462
free(decrypted_buffer);
997
1463
free(buffer);
998
1464
if(tcp_sd >= 0){
999
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
1465
ret = close(tcp_sd);
1000
1466
}
1001
1467
if(ret == -1){
1002
1468
if(e == 0){
1014
1480
return retval;
1015
1481
}
1016
1482
1483
__attribute__((nonnull))
1017
1484
static void resolve_callback(AvahiSServiceResolver *r,
1018
1485
AvahiIfIndex interface,
1019
1486
AvahiProtocol proto,
1027
1494
AVAHI_GCC_UNUSED AvahiStringList *txt,
1028
1495
AVAHI_GCC_UNUSED AvahiLookupResultFlags
1029
1496
flags,
1030
AVAHI_GCC_UNUSED void* userdata){
1031
assert(r);
1497
void *mc){
1498
if(r == NULL){
1499
return;
1500
}
1032
1501
1033
1502
/* Called whenever a service has been resolved successfully or
1034
1503
timed out */
1035
1504
1036
1505
if(quit_now){
1506
avahi_s_service_resolver_free(r);
1037
1507
return;
1038
1508
}
1039
1509
1040
1510
switch(event){
1041
1511
default:
1042
1512
case AVAHI_RESOLVER_FAILURE:
1043
fprintf(stderr, "Mandos plugin mandos-client: "
1044
"(Avahi Resolver) Failed to resolve service '%s'"
1045
" of type '%s' in domain '%s': %s\n", name, type, domain,
1046
avahi_strerror(avahi_server_errno(mc.server)));
1513
fprintf_plus(stderr, "(Avahi Resolver) Failed to resolve service "
1514
"'%s' of type '%s' in domain '%s': %s\n", name, type,
1515
domain,
1516
avahi_strerror(avahi_server_errno
1517
(((mandos_context*)mc)->server)));
1047
1518
break;
1048
1519
1049
1520
case AVAHI_RESOLVER_FOUND:
1051
1522
char ip[AVAHI_ADDRESS_STR_MAX];
1052
1523
avahi_address_snprint(ip, sizeof(ip), address);
1053
1524
if(debug){
1054
fprintf(stderr, "Mandos plugin mandos-client: "
1055
"Mandos server \"%s\" found on %s (%s, %"
1056
PRIdMAX ") on port %" PRIu16 "\n", name, host_name,
1057
ip, (intmax_t)interface, port);
1525
fprintf_plus(stderr, "Mandos server \"%s\" found on %s (%s, %"
1526
PRIdMAX ") on port %" PRIu16 "\n", name,
1527
host_name, ip, (intmax_t)interface, port);
1058
1528
}
1059
int ret = start_mandos_communication(ip, port, interface,
1060
avahi_proto_to_af(proto));
1529
int ret = start_mandos_communication(ip, (in_port_t)port,
1530
interface,
1531
avahi_proto_to_af(proto),
1532
mc);
1061
1533
if(ret == 0){
1062
avahi_simple_poll_quit(mc.simple_poll);
1534
avahi_simple_poll_quit(simple_poll);
1063
1535
} else {
1064
ret = add_server(ip, port, interface,
1065
avahi_proto_to_af(proto));
1536
if(not add_server(ip, (in_port_t)port, interface,
1537
avahi_proto_to_af(proto),
1538
&((mandos_context*)mc)->current_server)){
1539
fprintf_plus(stderr, "Failed to add server \"%s\" to server"
1540
" list\n", name);
1541
}
1066
1542
}
1067
1543
}
1068
1544
}
1078
1554
const char *domain,
1079
1555
AVAHI_GCC_UNUSED AvahiLookupResultFlags
1080
1556
flags,
1081
AVAHI_GCC_UNUSED void* userdata){
1082
assert(b);
1557
void *mc){
1558
if(b == NULL){
1559
return;
1560
}
1083
1561
1084
1562
/* Called whenever a new services becomes available on the LAN or
1085
1563
is removed from the LAN */
1092
1570
default:
1093
1571
case AVAHI_BROWSER_FAILURE:
1094
1572
1095
fprintf(stderr, "Mandos plugin mandos-client: "
1096
"(Avahi browser) %s\n",
1097
avahi_strerror(avahi_server_errno(mc.server)));
1098
avahi_simple_poll_quit(mc.simple_poll);
1573
fprintf_plus(stderr, "(Avahi browser) %s\n",
1574
avahi_strerror(avahi_server_errno
1575
(((mandos_context*)mc)->server)));
1576
avahi_simple_poll_quit(simple_poll);
1099
1577
return;
1100
1578
1101
1579
case AVAHI_BROWSER_NEW:
1104
1582
the callback function is called the Avahi server will free the
1105
1583
resolver for us. */
1106
1584
1107
if(avahi_s_service_resolver_new(mc.server, interface, protocol,
1108
name, type, domain, protocol, 0,
1109
resolve_callback, NULL) == NULL)
1110
fprintf(stderr, "Mandos plugin mandos-client: "
1111
"Avahi: Failed to resolve service '%s': %s\n",
1112
name, avahi_strerror(avahi_server_errno(mc.server)));
1585
if(avahi_s_service_resolver_new(((mandos_context*)mc)->server,
1586
interface, protocol, name, type,
1587
domain, protocol, 0,
1588
resolve_callback, mc) == NULL)
1589
fprintf_plus(stderr, "Avahi: Failed to resolve service '%s':"
1590
" %s\n", name,
1591
avahi_strerror(avahi_server_errno
1592
(((mandos_context*)mc)->server)));
1113
1593
break;
1114
1594
1115
1595
case AVAHI_BROWSER_REMOVE:
1118
1598
case AVAHI_BROWSER_ALL_FOR_NOW:
1119
1599
case AVAHI_BROWSER_CACHE_EXHAUSTED:
1120
1600
if(debug){
1121
fprintf(stderr, "Mandos plugin mandos-client: "
1122
"No Mandos server found, still searching...\n");
1601
fprintf_plus(stderr, "No Mandos server found, still"
1602
" searching...\n");
1123
1603
}
1124
1604
break;
1125
1605
}
1134
1614
signal_received = sig;
1135
1615
int old_errno = errno;
1136
1616
/* set main loop to exit */
1137
if(mc.simple_poll != NULL){
1138
avahi_simple_poll_quit(mc.simple_poll);
1617
if(simple_poll != NULL){
1618
avahi_simple_poll_quit(simple_poll);
1139
1619
}
1140
1620
errno = old_errno;
1141
1621
}
1142
1622
1623
__attribute__((nonnull, warn_unused_result))
1143
1624
bool get_flags(const char *ifname, struct ifreq *ifr){
1144
1625
int ret;
1626
int old_errno;
1145
1627
1146
1628
int s = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1147
1629
if(s < 0){
1630
old_errno = errno;
1148
1631
perror_plus("socket");
1632
errno = old_errno;
1149
1633
return false;
1150
1634
}
1151
strcpy(ifr->ifr_name, ifname);
1635
strncpy(ifr->ifr_name, ifname, IF_NAMESIZE);
1636
ifr->ifr_name[IF_NAMESIZE-1] = '\0'; /* NUL terminate */
1152
1637
ret = ioctl(s, SIOCGIFFLAGS, ifr);
1153
1638
if(ret == -1){
1154
1639
if(debug){
1640
old_errno = errno;
1155
1641
perror_plus("ioctl SIOCGIFFLAGS");
1642
errno = old_errno;
1156
1643
}
1157
1644
return false;
1158
1645
}
1159
1646
return true;
1160
1647
}
1161
1648
1649
__attribute__((nonnull, warn_unused_result))
1162
1650
bool good_flags(const char *ifname, const struct ifreq *ifr){
1163
1651
1164
1652
/* Reject the loopback device */
1165
1653
if(ifr->ifr_flags & IFF_LOOPBACK){
1166
1654
if(debug){
1167
fprintf(stderr, "Mandos plugin mandos-client: "
1168
"Rejecting loopback interface \"%s\"\n", ifname);
1655
fprintf_plus(stderr, "Rejecting loopback interface \"%s\"\n",
1656
ifname);
1169
1657
}
1170
1658
return false;
1171
1659
}
1172
1660
/* Accept point-to-point devices only if connect_to is specified */
1173
1661
if(connect_to != NULL and (ifr->ifr_flags & IFF_POINTOPOINT)){
1174
1662
if(debug){
1175
fprintf(stderr, "Mandos plugin mandos-client: "
1176
"Accepting point-to-point interface \"%s\"\n", ifname);
1663
fprintf_plus(stderr, "Accepting point-to-point interface"
1664
" \"%s\"\n", ifname);
1177
1665
}
1178
1666
return true;
1179
1667
}
1180
1668
/* Otherwise, reject non-broadcast-capable devices */
1181
1669
if(not (ifr->ifr_flags & IFF_BROADCAST)){
1182
1670
if(debug){
1183
fprintf(stderr, "Mandos plugin mandos-client: "
1184
"Rejecting non-broadcast interface \"%s\"\n", ifname);
1671
fprintf_plus(stderr, "Rejecting non-broadcast interface"
1672
" \"%s\"\n", ifname);
1185
1673
}
1186
1674
return false;
1187
1675
}
1188
1676
/* Reject non-ARP interfaces (including dummy interfaces) */
1189
1677
if(ifr->ifr_flags & IFF_NOARP){
1190
1678
if(debug){
1191
fprintf(stderr, "Mandos plugin mandos-client: "
1192
"Rejecting non-ARP interface \"%s\"\n", ifname);
1679
fprintf_plus(stderr, "Rejecting non-ARP interface \"%s\"\n",
1680
ifname);
1193
1681
}
1194
1682
return false;
1195
1683
}
1196
1684
1197
1685
/* Accept this device */
1198
1686
if(debug){
1199
fprintf(stderr, "Mandos plugin mandos-client: "
1200
"Interface \"%s\" is good\n", ifname);
1687
fprintf_plus(stderr, "Interface \"%s\" is good\n", ifname);
1201
1688
}
1202
1689
return true;
1203
1690
}
1207
1694
* corresponds to an acceptable network device.
1208
1695
* (This function is passed to scandir(3) as a filter function.)
1209
1696
*/
1697
__attribute__((nonnull, warn_unused_result))
1210
1698
int good_interface(const struct dirent *if_entry){
1211
1699
if(if_entry->d_name[0] == '.'){
1212
1700
return 0;
1215
1703
struct ifreq ifr;
1216
1704
if(not get_flags(if_entry->d_name, &ifr)){
1217
1705
if(debug){
1218
fprintf(stderr, "Mandos plugin mandos-client: "
1219
"Failed to get flags for interface \"%s\"\n",
1220
if_entry->d_name);
1221
}
1222
return 0;
1223
}
1224
1225
if(not good_flags(if_entry->d_name, &ifr)){
1226
return 0;
1227
}
1228
return 1;
1229
}
1230
1231
/*
1232
* This function determines if a directory entry in /sys/class/net
1233
* corresponds to an acceptable network device which is up.
1234
* (This function is passed to scandir(3) as a filter function.)
1235
*/
1236
int up_interface(const struct dirent *if_entry){
1237
if(if_entry->d_name[0] == '.'){
1238
return 0;
1239
}
1240
1241
struct ifreq ifr;
1242
if(not get_flags(if_entry->d_name, &ifr)){
1243
if(debug){
1244
fprintf(stderr, "Mandos plugin mandos-client: "
1245
"Failed to get flags for interface \"%s\"\n",
1246
if_entry->d_name);
1247
}
1248
return 0;
1249
}
1250
1251
/* Reject down interfaces */
1252
if(not (ifr.ifr_flags & IFF_UP)){
1253
if(debug){
1254
fprintf(stderr, "Mandos plugin mandos-client: "
1255
"Rejecting down interface \"%s\"\n",
1256
if_entry->d_name);
1257
}
1258
return 0;
1259
}
1260
1261
/* Reject non-running interfaces */
1262
if(not (ifr.ifr_flags & IFF_RUNNING)){
1263
if(debug){
1264
fprintf(stderr, "Mandos plugin mandos-client: "
1265
"Rejecting non-running interface \"%s\"\n",
1266
if_entry->d_name);
1267
}
1268
return 0;
1269
}
1270
1271
if(not good_flags(if_entry->d_name, &ifr)){
1272
return 0;
1273
}
1274
return 1;
1275
}
1276
1706
fprintf_plus(stderr, "Failed to get flags for interface "
1707
"\"%s\"\n", if_entry->d_name);
1708
}
1709
return 0;
1710
}
1711
1712
if(not good_flags(if_entry->d_name, &ifr)){
1713
return 0;
1714
}
1715
return 1;
1716
}
1717
1718
/*
1719
* This function determines if a network interface is up.
1720
*/
1721
__attribute__((nonnull, warn_unused_result))
1722
bool interface_is_up(const char *interface){
1723
struct ifreq ifr;
1724
if(not get_flags(interface, &ifr)){
1725
if(debug){
1726
fprintf_plus(stderr, "Failed to get flags for interface "
1727
"\"%s\"\n", interface);
1728
}
1729
return false;
1730
}
1731
1732
return (bool)(ifr.ifr_flags & IFF_UP);
1733
}
1734
1735
/*
1736
* This function determines if a network interface is running
1737
*/
1738
__attribute__((nonnull, warn_unused_result))
1739
bool interface_is_running(const char *interface){
1740
struct ifreq ifr;
1741
if(not get_flags(interface, &ifr)){
1742
if(debug){
1743
fprintf_plus(stderr, "Failed to get flags for interface "
1744
"\"%s\"\n", interface);
1745
}
1746
return false;
1747
}
1748
1749
return (bool)(ifr.ifr_flags & IFF_RUNNING);
1750
}
1751
1752
__attribute__((nonnull, pure, warn_unused_result))
1277
1753
int notdotentries(const struct dirent *direntry){
1278
1754
/* Skip "." and ".." */
1279
1755
if(direntry->d_name[0] == '.'
1286
1762
}
1287
1763
1288
1764
/* Is this directory entry a runnable program? */
1765
__attribute__((nonnull, warn_unused_result))
1289
1766
int runnable_hook(const struct dirent *direntry){
1290
1767
int ret;
1291
1768
size_t sret;
1299
1776
sret = strspn(direntry->d_name, "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
1300
1777
"abcdefghijklmnopqrstuvwxyz"
1301
1778
"0123456789"
1302
"_-");
1779
"_.-");
1303
1780
if((direntry->d_name)[sret] != '\0'){
1304
1781
/* Contains non-allowed characters */
1305
1782
if(debug){
1306
fprintf(stderr, "Mandos plugin mandos-client: "
1307
"Ignoring hook \"%s\" with bad name\n",
1308
direntry->d_name);
1783
fprintf_plus(stderr, "Ignoring hook \"%s\" with bad name\n",
1784
direntry->d_name);
1309
1785
}
1310
1786
return 0;
1311
1787
}
1312
1788
1313
char *fullname = NULL;
1314
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1315
if(ret < 0){
1316
perror_plus("asprintf");
1317
return 0;
1318
}
1319
1320
ret = stat(fullname, &st);
1789
ret = fstatat(hookdir_fd, direntry->d_name, &st, 0);
1321
1790
if(ret == -1){
1322
1791
if(debug){
1323
1792
perror_plus("Could not stat hook");
1327
1796
if(not (S_ISREG(st.st_mode))){
1328
1797
/* Not a regular file */
1329
1798
if(debug){
1330
fprintf(stderr, "Mandos plugin mandos-client: "
1331
"Ignoring hook \"%s\" - not a file\n",
1332
direntry->d_name);
1799
fprintf_plus(stderr, "Ignoring hook \"%s\" - not a file\n",
1800
direntry->d_name);
1333
1801
}
1334
1802
return 0;
1335
1803
}
1336
1804
if(not (st.st_mode & (S_IXUSR | S_IXGRP | S_IXOTH))){
1337
1805
/* Not executable */
1338
1806
if(debug){
1339
fprintf(stderr, "Mandos plugin mandos-client: "
1340
"Ignoring hook \"%s\" - not executable\n",
1341
direntry->d_name);
1807
fprintf_plus(stderr, "Ignoring hook \"%s\" - not executable\n",
1808
direntry->d_name);
1342
1809
}
1343
1810
return 0;
1344
1811
}
1812
if(debug){
1813
fprintf_plus(stderr, "Hook \"%s\" is acceptable\n",
1814
direntry->d_name);
1815
}
1345
1816
return 1;
1346
1817
}
1347
1818
1348
int avahi_loop_with_timeout(AvahiSimplePoll *s, int retry_interval){
1819
__attribute__((nonnull, warn_unused_result))
1820
int avahi_loop_with_timeout(AvahiSimplePoll *s, int retry_interval,
1821
mandos_context *mc){
1349
1822
int ret;
1350
1823
struct timespec now;
1351
1824
struct timespec waited_time;
1352
1825
intmax_t block_time;
1353
1826
1354
1827
while(true){
1355
if(mc.current_server == NULL){
1356
if (debug){
1357
fprintf(stderr, "Mandos plugin mandos-client: "
1358
"Wait until first server is found. No timeout!\n");
1828
if(mc->current_server == NULL){
1829
if(debug){
1830
fprintf_plus(stderr, "Wait until first server is found."
1831
" No timeout!\n");
1359
1832
}
1360
1833
ret = avahi_simple_poll_iterate(s, -1);
1361
1834
} else {
1362
if (debug){
1363
fprintf(stderr, "Mandos plugin mandos-client: "
1364
"Check current_server if we should run it,"
1365
" or wait\n");
1835
if(debug){
1836
fprintf_plus(stderr, "Check current_server if we should run"
1837
" it, or wait\n");
1366
1838
}
1367
1839
/* the current time */
1368
1840
ret = clock_gettime(CLOCK_MONOTONIC, &now);
1373
1845
/* Calculating in ms how long time between now and server
1374
1846
who we visted longest time ago. Now - last seen. */
1375
1847
waited_time.tv_sec = (now.tv_sec
1376
- mc.current_server->last_seen.tv_sec);
1848
- mc->current_server->last_seen.tv_sec);
1377
1849
waited_time.tv_nsec = (now.tv_nsec
1378
- mc.current_server->last_seen.tv_nsec);
1850
- mc->current_server->last_seen.tv_nsec);
1379
1851
/* total time is 10s/10,000ms.
1380
1852
Converting to s from ms by dividing by 1,000,
1381
1853
and ns to ms by dividing by 1,000,000. */
1383
1855
- ((intmax_t)waited_time.tv_sec * 1000))
1384
1856
- ((intmax_t)waited_time.tv_nsec / 1000000));
1385
1857
1386
if (debug){
1387
fprintf(stderr, "Mandos plugin mandos-client: "
1388
"Blocking for %" PRIdMAX " ms\n", block_time);
1858
if(debug){
1859
fprintf_plus(stderr, "Blocking for %" PRIdMAX " ms\n",
1860
block_time);
1389
1861
}
1390
1862
1391
1863
if(block_time <= 0){
1392
ret = start_mandos_communication(mc.current_server->ip,
1393
mc.current_server->port,
1394
mc.current_server->if_index,
1395
mc.current_server->af);
1864
ret = start_mandos_communication(mc->current_server->ip,
1865
mc->current_server->port,
1866
mc->current_server->if_index,
1867
mc->current_server->af, mc);
1396
1868
if(ret == 0){
1397
avahi_simple_poll_quit(mc.simple_poll);
1869
avahi_simple_poll_quit(s);
1398
1870
return 0;
1399
1871
}
1400
1872
ret = clock_gettime(CLOCK_MONOTONIC,
1401
&mc.current_server->last_seen);
1873
&mc->current_server->last_seen);
1402
1874
if(ret == -1){
1403
1875
perror_plus("clock_gettime");
1404
1876
return -1;
1405
1877
}
1406
mc.current_server = mc.current_server->next;
1878
mc->current_server = mc->current_server->next;
1407
1879
block_time = 0; /* Call avahi to find new Mandos
1408
1880
servers, but don't block */
1409
1881
}
1411
1883
ret = avahi_simple_poll_iterate(s, (int)block_time);
1412
1884
}
1413
1885
if(ret != 0){
1414
if (ret > 0 or errno != EINTR){
1886
if(ret > 0 or errno != EINTR){
1415
1887
return (ret != 1) ? ret : 0;
1416
1888
}
1417
1889
}
1418
1890
}
1419
1891
}
1420
1892
1893
__attribute__((nonnull))
1894
void run_network_hooks(const char *mode, const char *interface,
1895
const float delay){
1896
struct dirent **direntries = NULL;
1897
if(hookdir_fd == -1){
1898
hookdir_fd = open(hookdir, O_RDONLY | O_DIRECTORY | O_PATH
1899
| O_CLOEXEC);
1900
if(hookdir_fd == -1){
1901
if(errno == ENOENT){
1902
if(debug){
1903
fprintf_plus(stderr, "Network hook directory \"%s\" not"
1904
" found\n", hookdir);
1905
}
1906
} else {
1907
perror_plus("open");
1908
}
1909
return;
1910
}
1911
}
1912
int numhooks = scandirat(hookdir_fd, ".", &direntries,
1913
runnable_hook, alphasort);
1914
if(numhooks == -1){
1915
perror_plus("scandir");
1916
return;
1917
}
1918
struct dirent *direntry;
1919
int ret;
1920
int devnull = (int)TEMP_FAILURE_RETRY(open("/dev/null", O_RDONLY));
1921
if(devnull == -1){
1922
perror_plus("open(\"/dev/null\", O_RDONLY)");
1923
return;
1924
}
1925
for(int i = 0; i < numhooks; i++){
1926
direntry = direntries[i];
1927
if(debug){
1928
fprintf_plus(stderr, "Running network hook \"%s\"\n",
1929
direntry->d_name);
1930
}
1931
pid_t hook_pid = fork();
1932
if(hook_pid == 0){
1933
/* Child */
1934
/* Raise privileges */
1935
errno = raise_privileges_permanently();
1936
if(errno != 0){
1937
perror_plus("Failed to raise privileges");
1938
_exit(EX_NOPERM);
1939
}
1940
/* Set group */
1941
errno = 0;
1942
ret = setgid(0);
1943
if(ret == -1){
1944
perror_plus("setgid");
1945
_exit(EX_NOPERM);
1946
}
1947
/* Reset supplementary groups */
1948
errno = 0;
1949
ret = setgroups(0, NULL);
1950
if(ret == -1){
1951
perror_plus("setgroups");
1952
_exit(EX_NOPERM);
1953
}
1954
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1955
if(ret == -1){
1956
perror_plus("setenv");
1957
_exit(EX_OSERR);
1958
}
1959
ret = setenv("DEVICE", interface, 1);
1960
if(ret == -1){
1961
perror_plus("setenv");
1962
_exit(EX_OSERR);
1963
}
1964
ret = setenv("VERBOSITY", debug ? "1" : "0", 1);
1965
if(ret == -1){
1966
perror_plus("setenv");
1967
_exit(EX_OSERR);
1968
}
1969
ret = setenv("MODE", mode, 1);
1970
if(ret == -1){
1971
perror_plus("setenv");
1972
_exit(EX_OSERR);
1973
}
1974
char *delaystring;
1975
ret = asprintf(&delaystring, "%f", (double)delay);
1976
if(ret == -1){
1977
perror_plus("asprintf");
1978
_exit(EX_OSERR);
1979
}
1980
ret = setenv("DELAY", delaystring, 1);
1981
if(ret == -1){
1982
free(delaystring);
1983
perror_plus("setenv");
1984
_exit(EX_OSERR);
1985
}
1986
free(delaystring);
1987
if(connect_to != NULL){
1988
ret = setenv("CONNECT", connect_to, 1);
1989
if(ret == -1){
1990
perror_plus("setenv");
1991
_exit(EX_OSERR);
1992
}
1993
}
1994
int hook_fd = (int)TEMP_FAILURE_RETRY(openat(hookdir_fd,
1995
direntry->d_name,
1996
O_RDONLY));
1997
if(hook_fd == -1){
1998
perror_plus("openat");
1999
_exit(EXIT_FAILURE);
2000
}
2001
if(close(hookdir_fd) == -1){
2002
perror_plus("close");
2003
_exit(EXIT_FAILURE);
2004
}
2005
ret = dup2(devnull, STDIN_FILENO);
2006
if(ret == -1){
2007
perror_plus("dup2(devnull, STDIN_FILENO)");
2008
_exit(EX_OSERR);
2009
}
2010
ret = close(devnull);
2011
if(ret == -1){
2012
perror_plus("close");
2013
_exit(EX_OSERR);
2014
}
2015
ret = dup2(STDERR_FILENO, STDOUT_FILENO);
2016
if(ret == -1){
2017
perror_plus("dup2(STDERR_FILENO, STDOUT_FILENO)");
2018
_exit(EX_OSERR);
2019
}
2020
if(fexecve(hook_fd, (char *const []){ direntry->d_name, NULL },
2021
environ) == -1){
2022
perror_plus("fexecve");
2023
_exit(EXIT_FAILURE);
2024
}
2025
} else {
2026
if(hook_pid == -1){
2027
perror_plus("fork");
2028
free(direntry);
2029
continue;
2030
}
2031
int status;
2032
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
2033
perror_plus("waitpid");
2034
free(direntry);
2035
continue;
2036
}
2037
if(WIFEXITED(status)){
2038
if(WEXITSTATUS(status) != 0){
2039
fprintf_plus(stderr, "Warning: network hook \"%s\" exited"
2040
" with status %d\n", direntry->d_name,
2041
WEXITSTATUS(status));
2042
free(direntry);
2043
continue;
2044
}
2045
} else if(WIFSIGNALED(status)){
2046
fprintf_plus(stderr, "Warning: network hook \"%s\" died by"
2047
" signal %d\n", direntry->d_name,
2048
WTERMSIG(status));
2049
free(direntry);
2050
continue;
2051
} else {
2052
fprintf_plus(stderr, "Warning: network hook \"%s\""
2053
" crashed\n", direntry->d_name);
2054
free(direntry);
2055
continue;
2056
}
2057
}
2058
if(debug){
2059
fprintf_plus(stderr, "Network hook \"%s\" ran successfully\n",
2060
direntry->d_name);
2061
}
2062
free(direntry);
2063
}
2064
free(direntries);
2065
if(close(hookdir_fd) == -1){
2066
perror_plus("close");
2067
} else {
2068
hookdir_fd = -1;
2069
}
2070
close(devnull);
2071
}
2072
2073
__attribute__((nonnull, warn_unused_result))
2074
int bring_up_interface(const char *const interface,
2075
const float delay){
2076
int old_errno = errno;
2077
int ret;
2078
struct ifreq network;
2079
unsigned int if_index = if_nametoindex(interface);
2080
if(if_index == 0){
2081
fprintf_plus(stderr, "No such interface: \"%s\"\n", interface);
2082
errno = old_errno;
2083
return ENXIO;
2084
}
2085
2086
if(quit_now){
2087
errno = old_errno;
2088
return EINTR;
2089
}
2090
2091
if(not interface_is_up(interface)){
2092
int ret_errno = 0;
2093
int ioctl_errno = 0;
2094
if(not get_flags(interface, &network)){
2095
ret_errno = errno;
2096
fprintf_plus(stderr, "Failed to get flags for interface "
2097
"\"%s\"\n", interface);
2098
errno = old_errno;
2099
return ret_errno;
2100
}
2101
network.ifr_flags |= IFF_UP; /* set flag */
2102
2103
int sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
2104
if(sd == -1){
2105
ret_errno = errno;
2106
perror_plus("socket");
2107
errno = old_errno;
2108
return ret_errno;
2109
}
2110
2111
if(quit_now){
2112
ret = close(sd);
2113
if(ret == -1){
2114
perror_plus("close");
2115
}
2116
errno = old_errno;
2117
return EINTR;
2118
}
2119
2120
if(debug){
2121
fprintf_plus(stderr, "Bringing up interface \"%s\"\n",
2122
interface);
2123
}
2124
2125
/* Raise privileges */
2126
ret_errno = raise_privileges();
2127
if(ret_errno != 0){
2128
errno = ret_errno;
2129
perror_plus("Failed to raise privileges");
2130
}
2131
2132
#ifdef __linux__
2133
int ret_linux;
2134
bool restore_loglevel = false;
2135
if(ret_errno == 0){
2136
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
2137
messages about the network interface to mess up the prompt */
2138
ret_linux = klogctl(8, NULL, 5);
2139
if(ret_linux == -1){
2140
perror_plus("klogctl");
2141
} else {
2142
restore_loglevel = true;
2143
}
2144
}
2145
#endif /* __linux__ */
2146
int ret_setflags = ioctl(sd, SIOCSIFFLAGS, &network);
2147
ioctl_errno = errno;
2148
#ifdef __linux__
2149
if(restore_loglevel){
2150
ret_linux = klogctl(7, NULL, 0);
2151
if(ret_linux == -1){
2152
perror_plus("klogctl");
2153
}
2154
}
2155
#endif /* __linux__ */
2156
2157
/* If raise_privileges() succeeded above */
2158
if(ret_errno == 0){
2159
/* Lower privileges */
2160
ret_errno = lower_privileges();
2161
if(ret_errno != 0){
2162
errno = ret_errno;
2163
perror_plus("Failed to lower privileges");
2164
}
2165
}
2166
2167
/* Close the socket */
2168
ret = close(sd);
2169
if(ret == -1){
2170
perror_plus("close");
2171
}
2172
2173
if(ret_setflags == -1){
2174
errno = ioctl_errno;
2175
perror_plus("ioctl SIOCSIFFLAGS +IFF_UP");
2176
errno = old_errno;
2177
return ioctl_errno;
2178
}
2179
} else if(debug){
2180
fprintf_plus(stderr, "Interface \"%s\" is already up; good\n",
2181
interface);
2182
}
2183
2184
/* Sleep checking until interface is running.
2185
Check every 0.25s, up to total time of delay */
2186
for(int i=0; i < delay * 4; i++){
2187
if(interface_is_running(interface)){
2188
break;
2189
}
2190
struct timespec sleeptime = { .tv_nsec = 250000000 };
2191
ret = nanosleep(&sleeptime, NULL);
2192
if(ret == -1 and errno != EINTR){
2193
perror_plus("nanosleep");
2194
}
2195
}
2196
2197
errno = old_errno;
2198
return 0;
2199
}
2200
2201
__attribute__((nonnull, warn_unused_result))
2202
int take_down_interface(const char *const interface){
2203
int old_errno = errno;
2204
struct ifreq network;
2205
unsigned int if_index = if_nametoindex(interface);
2206
if(if_index == 0){
2207
fprintf_plus(stderr, "No such interface: \"%s\"\n", interface);
2208
errno = old_errno;
2209
return ENXIO;
2210
}
2211
if(interface_is_up(interface)){
2212
int ret_errno = 0;
2213
int ioctl_errno = 0;
2214
if(not get_flags(interface, &network) and debug){
2215
ret_errno = errno;
2216
fprintf_plus(stderr, "Failed to get flags for interface "
2217
"\"%s\"\n", interface);
2218
errno = old_errno;
2219
return ret_errno;
2220
}
2221
network.ifr_flags &= ~(short)IFF_UP; /* clear flag */
2222
2223
int sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
2224
if(sd == -1){
2225
ret_errno = errno;
2226
perror_plus("socket");
2227
errno = old_errno;
2228
return ret_errno;
2229
}
2230
2231
if(debug){
2232
fprintf_plus(stderr, "Taking down interface \"%s\"\n",
2233
interface);
2234
}
2235
2236
/* Raise privileges */
2237
ret_errno = raise_privileges();
2238
if(ret_errno != 0){
2239
errno = ret_errno;
2240
perror_plus("Failed to raise privileges");
2241
}
2242
2243
int ret_setflags = ioctl(sd, SIOCSIFFLAGS, &network);
2244
ioctl_errno = errno;
2245
2246
/* If raise_privileges() succeeded above */
2247
if(ret_errno == 0){
2248
/* Lower privileges */
2249
ret_errno = lower_privileges();
2250
if(ret_errno != 0){
2251
errno = ret_errno;
2252
perror_plus("Failed to lower privileges");
2253
}
2254
}
2255
2256
/* Close the socket */
2257
int ret = close(sd);
2258
if(ret == -1){
2259
perror_plus("close");
2260
}
2261
2262
if(ret_setflags == -1){
2263
errno = ioctl_errno;
2264
perror_plus("ioctl SIOCSIFFLAGS -IFF_UP");
2265
errno = old_errno;
2266
return ioctl_errno;
2267
}
2268
} else if(debug){
2269
fprintf_plus(stderr, "Interface \"%s\" is already down; odd\n",
2270
interface);
2271
}
2272
2273
errno = old_errno;
2274
return 0;
2275
}
2276
1421
2277
int main(int argc, char *argv[]){
2278
mandos_context mc = { .server = NULL, .dh_bits = 0,
2279
.priority = "SECURE256:!CTYPE-X.509"
2280
":+CTYPE-OPENPGP:!RSA:+SIGN-DSA-SHA256",
2281
.current_server = NULL, .interfaces = NULL,
2282
.interfaces_size = 0 };
1422
2283
AvahiSServiceBrowser *sb = NULL;
1423
int error;
2284
error_t ret_errno;
1424
2285
int ret;
1425
2286
intmax_t tmpmax;
1426
2287
char *tmp;
1427
2288
int exitcode = EXIT_SUCCESS;
1428
const char *interface = "";
1429
struct ifreq network;
1430
int sd = -1;
1431
bool take_down_interface = false;
1432
uid_t uid;
1433
gid_t gid;
1434
char tempdir[] = "/tmp/mandosXXXXXX";
1435
bool tempdir_created = false;
2289
char *interfaces_to_take_down = NULL;
2290
size_t interfaces_to_take_down_size = 0;
2291
char run_tempdir[] = "/run/tmp/mandosXXXXXX";
2292
char old_tempdir[] = "/tmp/mandosXXXXXX";
2293
char *tempdir = NULL;
1436
2294
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
1437
2295
const char *seckey = PATHDIR "/" SECKEY;
1438
2296
const char *pubkey = PATHDIR "/" PUBKEY;
2297
const char *dh_params_file = NULL;
2298
char *interfaces_hooks = NULL;
1439
2299
1440
2300
bool gnutls_initialized = false;
1441
2301
bool gpgme_initialized = false;
1493
2353
.doc = "Bit length of the prime number used in the"
1494
2354
" Diffie-Hellman key exchange",
1495
2355
.group = 2 },
2356
{ .name = "dh-params", .key = 134,
2357
.arg = "FILE",
2358
.doc = "PEM-encoded PKCS#3 file with pre-generated parameters"
2359
" for the Diffie-Hellman key exchange",
2360
.group = 2 },
1496
2361
{ .name = "priority", .key = 130,
1497
2362
.arg = "STRING",
1498
2363
.doc = "GnuTLS priority string for the TLS handshake",
1503
2368
.group = 2 },
1504
2369
{ .name = "retry", .key = 132,
1505
2370
.arg = "SECONDS",
1506
.doc = "Retry interval used when denied by the mandos server",
2371
.doc = "Retry interval used when denied by the Mandos server",
1507
2372
.group = 2 },
1508
2373
{ .name = "network-hook-dir", .key = 133,
1509
2374
.arg = "DIR",
1532
2397
connect_to = arg;
1533
2398
break;
1534
2399
case 'i': /* --interface */
1535
interface = arg;
2400
ret_errno = argz_add_sep(&mc.interfaces, &mc.interfaces_size,
2401
arg, (int)',');
2402
if(ret_errno != 0){
2403
argp_error(state, "%s", strerror(ret_errno));
2404
}
1536
2405
break;
1537
2406
case 's': /* --seckey */
1538
2407
seckey = arg;
1549
2418
}
1550
2419
mc.dh_bits = (typeof(mc.dh_bits))tmpmax;
1551
2420
break;
2421
case 134: /* --dh-params */
2422
dh_params_file = arg;
2423
break;
1552
2424
case 130: /* --priority */
1553
2425
mc.priority = arg;
1554
2426
break;
1581
2453
argp_state_help(state, state->out_stream,
1582
2454
ARGP_HELP_USAGE | ARGP_HELP_EXIT_ERR);
1583
2455
case 'V': /* --version */
1584
fprintf(state->out_stream, "Mandos plugin mandos-client: ");
1585
fprintf(state->out_stream, "%s\n", argp_program_version);
2456
fprintf_plus(state->out_stream, "%s\n", argp_program_version);
1586
2457
exit(argp_err_exit_status);
1587
2458
break;
1588
2459
default:
1595
2466
.args_doc = "",
1596
2467
.doc = "Mandos client -- Get and decrypt"
1597
2468
" passwords from a Mandos server" };
1598
ret = argp_parse(&argp, argc, argv,
1599
ARGP_IN_ORDER | ARGP_NO_HELP, 0, NULL);
1600
switch(ret){
2469
ret_errno = argp_parse(&argp, argc, argv,
2470
ARGP_IN_ORDER | ARGP_NO_HELP, 0, NULL);
2471
switch(ret_errno){
1601
2472
case 0:
1602
2473
break;
1603
2474
case ENOMEM:
1604
2475
default:
1605
errno = ret;
2476
errno = ret_errno;
1606
2477
perror_plus("argp_parse");
1607
2478
exitcode = EX_OSERR;
1608
2479
goto end;
1611
2482
goto end;
1612
2483
}
1613
2484
}
1614
2485
1615
2486
{
1616
2487
/* Work around Debian bug #633582:
1617
2488
<http://bugs.debian.org/633582> */
1618
struct stat st;
1619
1620
/* Re-raise priviliges */
1621
errno = 0;
1622
ret = seteuid(0);
1623
if(ret == -1){
1624
perror_plus("seteuid");
1625
}
1626
1627
if(strcmp(seckey, PATHDIR "/" SECKEY) == 0){
1628
int seckey_fd = open(seckey, O_RDONLY);
1629
if(seckey_fd == -1){
1630
perror_plus("open");
1631
} else {
1632
ret = (int)TEMP_FAILURE_RETRY(fstat(seckey_fd, &st));
1633
if(ret == -1){
1634
perror_plus("fstat");
1635
} else {
1636
if(S_ISREG(st.st_mode) and st.st_uid == 0 and st.st_gid == 0){
1637
ret = fchown(seckey_fd, uid, gid);
1638
if(ret == -1){
1639
perror_plus("fchown");
1640
}
1641
}
1642
}
1643
TEMP_FAILURE_RETRY(close(seckey_fd));
1644
}
1645
}
1646
1647
if(strcmp(pubkey, PATHDIR "/" PUBKEY) == 0){
1648
int pubkey_fd = open(pubkey, O_RDONLY);
1649
if(pubkey_fd == -1){
1650
perror_plus("open");
1651
} else {
1652
ret = (int)TEMP_FAILURE_RETRY(fstat(pubkey_fd, &st));
1653
if(ret == -1){
1654
perror_plus("fstat");
1655
} else {
1656
if(S_ISREG(st.st_mode) and st.st_uid == 0 and st.st_gid == 0){
1657
ret = fchown(pubkey_fd, uid, gid);
1658
if(ret == -1){
1659
perror_plus("fchown");
1660
}
1661
}
1662
}
1663
TEMP_FAILURE_RETRY(close(pubkey_fd));
1664
}
1665
}
1666
1667
/* Lower privileges */
1668
errno = 0;
1669
ret = seteuid(uid);
1670
if(ret == -1){
1671
perror_plus("seteuid");
1672
}
1673
}
1674
1675
/* Find network hooks and run them */
1676
{
1677
struct dirent **direntries;
1678
struct dirent *direntry;
1679
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1680
alphasort);
1681
if(numhooks == -1){
1682
perror_plus("scandir");
2489
2490
/* Re-raise privileges */
2491
ret = raise_privileges();
2492
if(ret != 0){
2493
errno = ret;
2494
perror_plus("Failed to raise privileges");
1683
2495
} else {
1684
int devnull = open("/dev/null", O_RDONLY);
1685
for(int i = 0; i < numhooks; i++){
1686
direntry = direntries[0];
1687
char *fullname = NULL;
1688
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1689
if(ret < 0){
1690
perror_plus("asprintf");
1691
continue;
1692
}
1693
pid_t hook_pid = fork();
1694
if(hook_pid == 0){
1695
/* Child */
1696
dup2(devnull, STDIN_FILENO);
1697
close(devnull);
1698
dup2(STDERR_FILENO, STDOUT_FILENO);
1699
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1700
if(ret == -1){
1701
perror_plus("setenv");
1702
exit(1);
1703
}
1704
ret = setenv("DEVICE", interface, 1);
1705
if(ret == -1){
1706
perror_plus("setenv");
1707
exit(1);
1708
}
1709
ret = setenv("VERBOSE", debug ? "1" : "0", 1);
1710
if(ret == -1){
1711
perror_plus("setenv");
1712
exit(1);
1713
}
1714
ret = setenv("MODE", "start", 1);
1715
if(ret == -1){
1716
perror_plus("setenv");
1717
exit(1);
1718
}
1719
char *delaystring;
1720
ret = asprintf(&delaystring, "%f", delay);
1721
if(ret == -1){
1722
perror_plus("asprintf");
1723
exit(1);
1724
}
1725
ret = setenv("DELAY", delaystring, 1);
1726
if(ret == -1){
1727
free(delaystring);
1728
perror_plus("setenv");
1729
exit(1);
1730
}
1731
free(delaystring);
1732
ret = execl(fullname, direntry->d_name, "start", NULL);
1733
perror_plus("execl");
1734
} else {
1735
int status;
1736
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
1737
perror_plus("waitpid");
1738
free(fullname);
1739
continue;
1740
}
1741
if(WIFEXITED(status)){
1742
if(WEXITSTATUS(status) != 0){
1743
fprintf(stderr, "Mandos plugin mandos-client: "
1744
"Warning: network hook \"%s\" exited"
1745
" with status %d\n", direntry->d_name,
1746
WEXITSTATUS(status));
1747
free(fullname);
1748
continue;
1749
}
1750
} else if(WIFSIGNALED(status)){
1751
fprintf(stderr, "Mandos plugin mandos-client: "
1752
"Warning: network hook \"%s\" died by"
1753
" signal %d\n", direntry->d_name,
1754
WTERMSIG(status));
1755
free(fullname);
1756
continue;
1757
} else {
1758
fprintf(stderr, "Mandos plugin mandos-client: "
1759
"Warning: network hook \"%s\" crashed\n",
1760
direntry->d_name);
1761
free(fullname);
1762
continue;
1763
}
1764
}
1765
free(fullname);
1766
if(quit_now){
1767
goto end;
1768
}
1769
}
1770
close(devnull);
1771
}
2496
struct stat st;
2497
2498
if(strcmp(seckey, PATHDIR "/" SECKEY) == 0){
2499
int seckey_fd = open(seckey, O_RDONLY);
2500
if(seckey_fd == -1){
2501
perror_plus("open");
2502
} else {
2503
ret = (int)TEMP_FAILURE_RETRY(fstat(seckey_fd, &st));
2504
if(ret == -1){
2505
perror_plus("fstat");
2506
} else {
2507
if(S_ISREG(st.st_mode)
2508
and st.st_uid == 0 and st.st_gid == 0){
2509
ret = fchown(seckey_fd, uid, gid);
2510
if(ret == -1){
2511
perror_plus("fchown");
2512
}
2513
}
2514
}
2515
close(seckey_fd);
2516
}
2517
}
2518
2519
if(strcmp(pubkey, PATHDIR "/" PUBKEY) == 0){
2520
int pubkey_fd = open(pubkey, O_RDONLY);
2521
if(pubkey_fd == -1){
2522
perror_plus("open");
2523
} else {
2524
ret = (int)TEMP_FAILURE_RETRY(fstat(pubkey_fd, &st));
2525
if(ret == -1){
2526
perror_plus("fstat");
2527
} else {
2528
if(S_ISREG(st.st_mode)
2529
and st.st_uid == 0 and st.st_gid == 0){
2530
ret = fchown(pubkey_fd, uid, gid);
2531
if(ret == -1){
2532
perror_plus("fchown");
2533
}
2534
}
2535
}
2536
close(pubkey_fd);
2537
}
2538
}
2539
2540
if(dh_params_file != NULL
2541
and strcmp(dh_params_file, PATHDIR "/dhparams.pem" ) == 0){
2542
int dhparams_fd = open(dh_params_file, O_RDONLY);
2543
if(dhparams_fd == -1){
2544
perror_plus("open");
2545
} else {
2546
ret = (int)TEMP_FAILURE_RETRY(fstat(dhparams_fd, &st));
2547
if(ret == -1){
2548
perror_plus("fstat");
2549
} else {
2550
if(S_ISREG(st.st_mode)
2551
and st.st_uid == 0 and st.st_gid == 0){
2552
ret = fchown(dhparams_fd, uid, gid);
2553
if(ret == -1){
2554
perror_plus("fchown");
2555
}
2556
}
2557
}
2558
close(dhparams_fd);
2559
}
2560
}
2561
2562
/* Lower privileges */
2563
ret = lower_privileges();
2564
if(ret != 0){
2565
errno = ret;
2566
perror_plus("Failed to lower privileges");
2567
}
2568
}
2569
}
2570
2571
/* Remove invalid interface names (except "none") */
2572
{
2573
char *interface = NULL;
2574
while((interface = argz_next(mc.interfaces, mc.interfaces_size,
2575
interface))){
2576
if(strcmp(interface, "none") != 0
2577
and if_nametoindex(interface) == 0){
2578
if(interface[0] != '\0'){
2579
fprintf_plus(stderr, "Not using nonexisting interface"
2580
" \"%s\"\n", interface);
2581
}
2582
argz_delete(&mc.interfaces, &mc.interfaces_size, interface);
2583
interface = NULL;
2584
}
2585
}
2586
}
2587
2588
/* Run network hooks */
2589
{
2590
if(mc.interfaces != NULL){
2591
interfaces_hooks = malloc(mc.interfaces_size);
2592
if(interfaces_hooks == NULL){
2593
perror_plus("malloc");
2594
goto end;
2595
}
2596
memcpy(interfaces_hooks, mc.interfaces, mc.interfaces_size);
2597
argz_stringify(interfaces_hooks, mc.interfaces_size, (int)',');
2598
}
2599
run_network_hooks("start", interfaces_hooks != NULL ?
2600
interfaces_hooks : "", delay);
1772
2601
}
1773
2602
1774
2603
if(not debug){
1775
2604
avahi_set_log_function(empty_log);
1776
2605
}
1777
2606
1778
if(interface[0] == '\0'){
1779
struct dirent **direntries;
1780
/* First look for interfaces that are up */
1781
ret = scandir(sys_class_net, &direntries, up_interface,
1782
alphasort);
1783
if(ret == 0){
1784
/* No up interfaces, look for any good interfaces */
1785
free(direntries);
1786
ret = scandir(sys_class_net, &direntries, good_interface,
1787
alphasort);
1788
}
1789
if(ret >= 1){
1790
/* Pick the first interface returned */
1791
interface = strdup(direntries[0]->d_name);
1792
if(debug){
1793
fprintf(stderr, "Mandos plugin mandos-client: "
1794
"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(stderr, "Mandos plugin mandos-client: "
1806
"Could not find a network interface\n");
1807
exitcode = EXIT_FAILURE;
1808
goto end;
1809
}
1810
}
1811
1812
2607
/* Initialize Avahi early so avahi_simple_poll_quit() can be called
1813
2608
from the signal handler */
1814
2609
/* Initialize the pseudo-RNG for Avahi */
1815
2610
srand((unsigned int) time(NULL));
1816
mc.simple_poll = avahi_simple_poll_new();
1817
if(mc.simple_poll == NULL){
1818
fprintf(stderr, "Mandos plugin mandos-client: "
1819
"Avahi: Failed to create simple poll object.\n");
2611
simple_poll = avahi_simple_poll_new();
2612
if(simple_poll == NULL){
2613
fprintf_plus(stderr,
2614
"Avahi: Failed to create simple poll object.\n");
1820
2615
exitcode = EX_UNAVAILABLE;
1821
2616
goto end;
1822
2617
}
1884
2679
}
1885
2680
}
1886
2681
1887
/* If the interface is down, bring it up */
1888
if(strcmp(interface, "none") != 0){
1889
if_index = (AvahiIfIndex) if_nametoindex(interface);
1890
if(if_index == 0){
1891
fprintf(stderr, "Mandos plugin mandos-client: "
1892
"No such interface: \"%s\"\n", interface);
1893
exitcode = EX_UNAVAILABLE;
1894
goto end;
1895
}
1896
1897
if(quit_now){
1898
goto end;
1899
}
1900
1901
/* Re-raise priviliges */
1902
errno = 0;
1903
ret = seteuid(0);
1904
if(ret == -1){
1905
perror_plus("seteuid");
1906
}
1907
1908
#ifdef __linux__
1909
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1910
messages about the network interface to mess up the prompt */
1911
ret = klogctl(8, NULL, 5);
1912
bool restore_loglevel = true;
1913
if(ret == -1){
1914
restore_loglevel = false;
1915
perror_plus("klogctl");
1916
}
1917
#endif /* __linux__ */
1918
1919
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1920
if(sd < 0){
1921
perror_plus("socket");
1922
exitcode = EX_OSERR;
1923
#ifdef __linux__
1924
if(restore_loglevel){
1925
ret = klogctl(7, NULL, 0);
1926
if(ret == -1){
1927
perror_plus("klogctl");
1928
}
1929
}
1930
#endif /* __linux__ */
1931
/* Lower privileges */
1932
errno = 0;
1933
ret = seteuid(uid);
1934
if(ret == -1){
1935
perror_plus("seteuid");
1936
}
1937
goto end;
1938
}
1939
strcpy(network.ifr_name, interface);
1940
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1941
if(ret == -1){
1942
perror_plus("ioctl SIOCGIFFLAGS");
1943
#ifdef __linux__
1944
if(restore_loglevel){
1945
ret = klogctl(7, NULL, 0);
1946
if(ret == -1){
1947
perror_plus("klogctl");
1948
}
1949
}
1950
#endif /* __linux__ */
1951
exitcode = EX_OSERR;
1952
/* Lower privileges */
1953
errno = 0;
1954
ret = seteuid(uid);
1955
if(ret == -1){
1956
perror_plus("seteuid");
1957
}
1958
goto end;
1959
}
1960
if((network.ifr_flags & IFF_UP) == 0){
1961
network.ifr_flags |= IFF_UP;
1962
take_down_interface = true;
1963
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1964
if(ret == -1){
1965
take_down_interface = false;
1966
perror_plus("ioctl SIOCSIFFLAGS +IFF_UP");
1967
exitcode = EX_OSERR;
1968
#ifdef __linux__
1969
if(restore_loglevel){
1970
ret = klogctl(7, NULL, 0);
1971
if(ret == -1){
1972
perror_plus("klogctl");
2682
/* If no interfaces were specified, make a list */
2683
if(mc.interfaces == NULL){
2684
struct dirent **direntries = NULL;
2685
/* Look for any good interfaces */
2686
ret = scandir(sys_class_net, &direntries, good_interface,
2687
alphasort);
2688
if(ret >= 1){
2689
/* Add all found interfaces to interfaces list */
2690
for(int i = 0; i < ret; ++i){
2691
ret_errno = argz_add(&mc.interfaces, &mc.interfaces_size,
2692
direntries[i]->d_name);
2693
if(ret_errno != 0){
2694
errno = ret_errno;
2695
perror_plus("argz_add");
2696
free(direntries[i]);
2697
continue;
2698
}
2699
if(debug){
2700
fprintf_plus(stderr, "Will use interface \"%s\"\n",
2701
direntries[i]->d_name);
2702
}
2703
free(direntries[i]);
2704
}
2705
free(direntries);
2706
} else {
2707
if(ret == 0){
2708
free(direntries);
2709
}
2710
fprintf_plus(stderr, "Could not find a network interface\n");
2711
exitcode = EXIT_FAILURE;
2712
goto end;
2713
}
2714
}
2715
2716
/* Bring up interfaces which are down, and remove any "none"s */
2717
{
2718
char *interface = NULL;
2719
while((interface = argz_next(mc.interfaces, mc.interfaces_size,
2720
interface))){
2721
/* If interface name is "none", stop bringing up interfaces.
2722
Also remove all instances of "none" from the list */
2723
if(strcmp(interface, "none") == 0){
2724
argz_delete(&mc.interfaces, &mc.interfaces_size,
2725
interface);
2726
interface = NULL;
2727
while((interface = argz_next(mc.interfaces,
2728
mc.interfaces_size, interface))){
2729
if(strcmp(interface, "none") == 0){
2730
argz_delete(&mc.interfaces, &mc.interfaces_size,
2731
interface);
2732
interface = NULL;
1973
2733
}
1974
2734
}
1975
#endif /* __linux__ */
1976
/* Lower privileges */
1977
errno = 0;
1978
ret = seteuid(uid);
1979
if(ret == -1){
1980
perror_plus("seteuid");
1981
}
1982
goto end;
1983
}
1984
}
1985
/* Sleep checking until interface is running.
1986
Check every 0.25s, up to total time of delay */
1987
for(int i=0; i < delay * 4; i++){
1988
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1989
if(ret == -1){
1990
perror_plus("ioctl SIOCGIFFLAGS");
1991
} else if(network.ifr_flags & IFF_RUNNING){
1992
2735
break;
1993
2736
}
1994
struct timespec sleeptime = { .tv_nsec = 250000000 };
1995
ret = nanosleep(&sleeptime, NULL);
1996
if(ret == -1 and errno != EINTR){
1997
perror_plus("nanosleep");
1998
}
1999
}
2000
if(not take_down_interface){
2001
/* We won't need the socket anymore */
2002
ret = (int)TEMP_FAILURE_RETRY(close(sd));
2003
if(ret == -1){
2004
perror_plus("close");
2005
}
2006
}
2007
#ifdef __linux__
2008
if(restore_loglevel){
2009
/* Restores kernel loglevel to default */
2010
ret = klogctl(7, NULL, 0);
2011
if(ret == -1){
2012
perror_plus("klogctl");
2013
}
2014
}
2015
#endif /* __linux__ */
2016
/* Lower privileges */
2017
errno = 0;
2018
if(take_down_interface){
2019
/* Lower privileges */
2020
ret = seteuid(uid);
2021
if(ret == -1){
2022
perror_plus("seteuid");
2023
}
2024
} else {
2025
/* Lower privileges permanently */
2026
ret = setuid(uid);
2027
if(ret == -1){
2028
perror_plus("setuid");
2029
}
2030
}
2737
bool interface_was_up = interface_is_up(interface);
2738
errno = bring_up_interface(interface, delay);
2739
if(not interface_was_up){
2740
if(errno != 0){
2741
fprintf_plus(stderr, "Failed to bring up interface \"%s\":"
2742
" %s\n", interface, strerror(errno));
2743
} else {
2744
errno = argz_add(&interfaces_to_take_down,
2745
&interfaces_to_take_down_size,
2746
interface);
2747
if(errno != 0){
2748
perror_plus("argz_add");
2749
}
2750
}
2751
}
2752
}
2753
if(debug and (interfaces_to_take_down == NULL)){
2754
fprintf_plus(stderr, "No interfaces were brought up\n");
2755
}
2756
}
2757
2758
/* If we only got one interface, explicitly use only that one */
2759
if(argz_count(mc.interfaces, mc.interfaces_size) == 1){
2760
if(debug){
2761
fprintf_plus(stderr, "Using only interface \"%s\"\n",
2762
mc.interfaces);
2763
}
2764
if_index = (AvahiIfIndex)if_nametoindex(mc.interfaces);
2031
2765
}
2032
2766
2033
2767
if(quit_now){
2034
2768
goto end;
2035
2769
}
2036
2770
2037
ret = init_gnutls_global(pubkey, seckey);
2771
ret = init_gnutls_global(pubkey, seckey, dh_params_file, &mc);
2038
2772
if(ret == -1){
2039
fprintf(stderr, "Mandos plugin mandos-client: "
2040
"init_gnutls_global failed\n");
2773
fprintf_plus(stderr, "init_gnutls_global failed\n");
2041
2774
exitcode = EX_UNAVAILABLE;
2042
2775
goto end;
2043
2776
} else {
2048
2781
goto end;
2049
2782
}
2050
2783
2051
if(mkdtemp(tempdir) == NULL){
2784
/* Try /run/tmp before /tmp */
2785
tempdir = mkdtemp(run_tempdir);
2786
if(tempdir == NULL and errno == ENOENT){
2787
if(debug){
2788
fprintf_plus(stderr, "Tempdir %s did not work, trying %s\n",
2789
run_tempdir, old_tempdir);
2790
}
2791
tempdir = mkdtemp(old_tempdir);
2792
}
2793
if(tempdir == NULL){
2052
2794
perror_plus("mkdtemp");
2053
2795
goto end;
2054
2796
}
2055
tempdir_created = true;
2056
2797
2057
2798
if(quit_now){
2058
2799
goto end;
2059
2800
}
2060
2801
2061
if(not init_gpgme(pubkey, seckey, tempdir)){
2062
fprintf(stderr, "Mandos plugin mandos-client: "
2063
"init_gpgme failed\n");
2802
if(not init_gpgme(pubkey, seckey, tempdir, &mc)){
2803
fprintf_plus(stderr, "init_gpgme failed\n");
2064
2804
exitcode = EX_UNAVAILABLE;
2065
2805
goto end;
2066
2806
} else {
2075
2815
/* Connect directly, do not use Zeroconf */
2076
2816
/* (Mainly meant for debugging) */
2077
2817
char *address = strrchr(connect_to, ':');
2818
2078
2819
if(address == NULL){
2079
fprintf(stderr, "Mandos plugin mandos-client: "
2080
"No colon in address\n");
2820
fprintf_plus(stderr, "No colon in address\n");
2081
2821
exitcode = EX_USAGE;
2082
2822
goto end;
2083
2823
}
2086
2826
goto end;
2087
2827
}
2088
2828
2089
uint16_t port;
2829
in_port_t port;
2090
2830
errno = 0;
2091
2831
tmpmax = strtoimax(address+1, &tmp, 10);
2092
2832
if(errno != 0 or tmp == address+1 or *tmp != '\0'
2093
or tmpmax != (uint16_t)tmpmax){
2094
fprintf(stderr, "Mandos plugin mandos-client: "
2095
"Bad port number\n");
2833
or tmpmax != (in_port_t)tmpmax){
2834
fprintf_plus(stderr, "Bad port number\n");
2096
2835
exitcode = EX_USAGE;
2097
2836
goto end;
2098
2837
}
2099
2838
2100
2839
if(quit_now){
2101
2840
goto end;
2102
2841
}
2103
2842
2104
port = (uint16_t)tmpmax;
2843
port = (in_port_t)tmpmax;
2105
2844
*address = '\0';
2106
2845
/* Colon in address indicates IPv6 */
2107
2846
int af;
2123
2862
}
2124
2863
2125
2864
while(not quit_now){
2126
ret = start_mandos_communication(address, port, if_index, af);
2865
ret = start_mandos_communication(address, port, if_index, af,
2866
&mc);
2127
2867
if(quit_now or ret == 0){
2128
2868
break;
2129
2869
}
2130
2870
if(debug){
2131
fprintf(stderr, "Mandos plugin mandos-client: "
2132
"Retrying in %d seconds\n", (int)retry_interval);
2871
fprintf_plus(stderr, "Retrying in %d seconds\n",
2872
(int)retry_interval);
2133
2873
}
2134
sleep((int)retry_interval);
2874
sleep((unsigned int)retry_interval);
2135
2875
}
2136
2876
2137
if (not quit_now){
2877
if(not quit_now){
2138
2878
exitcode = EXIT_SUCCESS;
2139
2879
}
2140
2880
2155
2895
config.publish_domain = 0;
2156
2896
2157
2897
/* Allocate a new server */
2158
mc.server = avahi_server_new(avahi_simple_poll_get
2159
(mc.simple_poll), &config, NULL,
2160
NULL, &error);
2898
mc.server = avahi_server_new(avahi_simple_poll_get(simple_poll),
2899
&config, NULL, NULL, &ret);
2161
2900
2162
2901
/* Free the Avahi configuration data */
2163
2902
avahi_server_config_free(&config);
2165
2904
2166
2905
/* Check if creating the Avahi server object succeeded */
2167
2906
if(mc.server == NULL){
2168
fprintf(stderr, "Mandos plugin mandos-client: "
2169
"Failed to create Avahi server: %s\n",
2170
avahi_strerror(error));
2907
fprintf_plus(stderr, "Failed to create Avahi server: %s\n",
2908
avahi_strerror(ret));
2171
2909
exitcode = EX_UNAVAILABLE;
2172
2910
goto end;
2173
2911
}
2179
2917
/* Create the Avahi service browser */
2180
2918
sb = avahi_s_service_browser_new(mc.server, if_index,
2181
2919
AVAHI_PROTO_UNSPEC, "_mandos._tcp",
2182
NULL, 0, browse_callback, NULL);
2920
NULL, 0, browse_callback,
2921
(void *)&mc);
2183
2922
if(sb == NULL){
2184
fprintf(stderr, "Mandos plugin mandos-client: "
2185
"Failed to create service browser: %s\n",
2186
avahi_strerror(avahi_server_errno(mc.server)));
2923
fprintf_plus(stderr, "Failed to create service browser: %s\n",
2924
avahi_strerror(avahi_server_errno(mc.server)));
2187
2925
exitcode = EX_UNAVAILABLE;
2188
2926
goto end;
2189
2927
}
2195
2933
/* Run the main loop */
2196
2934
2197
2935
if(debug){
2198
fprintf(stderr, "Mandos plugin mandos-client: "
2199
"Starting Avahi loop search\n");
2936
fprintf_plus(stderr, "Starting Avahi loop search\n");
2200
2937
}
2201
2202
ret = avahi_loop_with_timeout(mc.simple_poll,
2203
(int)(retry_interval * 1000));
2938
2939
ret = avahi_loop_with_timeout(simple_poll,
2940
(int)(retry_interval * 1000), &mc);
2204
2941
if(debug){
2205
fprintf(stderr, "Mandos plugin mandos-client: "
2206
"avahi_loop_with_timeout exited %s\n",
2207
(ret == 0) ? "successfully" : "with error");
2942
fprintf_plus(stderr, "avahi_loop_with_timeout exited %s\n",
2943
(ret == 0) ? "successfully" : "with error");
2208
2944
}
2209
2945
2210
2946
end:
2211
2947
2212
2948
if(debug){
2213
fprintf(stderr, "Mandos plugin mandos-client: "
2214
"%s exiting\n", argv[0]);
2949
fprintf_plus(stderr, "%s exiting\n", argv[0]);
2215
2950
}
2216
2951
2217
2952
/* Cleanup things */
2953
free(mc.interfaces);
2954
2218
2955
if(sb != NULL)
2219
2956
avahi_s_service_browser_free(sb);
2220
2957
2221
2958
if(mc.server != NULL)
2222
2959
avahi_server_free(mc.server);
2223
2960
2224
if(mc.simple_poll != NULL)
2225
avahi_simple_poll_free(mc.simple_poll);
2961
if(simple_poll != NULL)
2962
avahi_simple_poll_free(simple_poll);
2226
2963
2227
2964
if(gnutls_initialized){
2228
2965
gnutls_certificate_free_credentials(mc.cred);
2229
gnutls_global_deinit();
2230
2966
gnutls_dh_params_deinit(mc.dh_params);
2231
2967
}
2232
2968
2233
2969
if(gpgme_initialized){
2234
2970
gpgme_release(mc.ctx);
2235
2971
}
2236
2972
2237
2973
/* Cleans up the circular linked list of Mandos servers the client
2238
2974
has seen */
2239
2975
if(mc.current_server != NULL){
2240
2976
mc.current_server->prev->next = NULL;
2241
2977
while(mc.current_server != NULL){
2242
2978
server *next = mc.current_server->next;
2979
#ifdef __GNUC__
2980
#pragma GCC diagnostic push
2981
#pragma GCC diagnostic ignored "-Wcast-qual"
2982
#endif
2983
free((char *)(mc.current_server->ip));
2984
#ifdef __GNUC__
2985
#pragma GCC diagnostic pop
2986
#endif
2243
2987
free(mc.current_server);
2244
2988
mc.current_server = next;
2245
2989
}
2246
2990
}
2247
2991
2248
/* XXX run network hooks "stop" here */
2249
2250
/* Take down the network interface */
2251
if(take_down_interface){
2252
/* Re-raise priviliges */
2253
errno = 0;
2254
ret = seteuid(0);
2255
if(ret == -1){
2256
perror_plus("seteuid");
2257
}
2258
if(geteuid() == 0){
2259
ret = ioctl(sd, SIOCGIFFLAGS, &network);
2260
if(ret == -1){
2261
perror_plus("ioctl SIOCGIFFLAGS");
2262
} else if(network.ifr_flags & IFF_UP){
2263
network.ifr_flags &= ~(short)IFF_UP; /* clear flag */
2264
ret = ioctl(sd, SIOCSIFFLAGS, &network);
2265
if(ret == -1){
2266
perror_plus("ioctl SIOCSIFFLAGS -IFF_UP");
2267
}
2268
}
2269
ret = (int)TEMP_FAILURE_RETRY(close(sd));
2270
if(ret == -1){
2271
perror_plus("close");
2272
}
2273
/* Lower privileges permanently */
2274
errno = 0;
2275
ret = setuid(uid);
2276
if(ret == -1){
2277
perror_plus("setuid");
2278
}
2279
}
2992
/* Re-raise privileges */
2993
{
2994
ret = raise_privileges();
2995
if(ret != 0){
2996
errno = ret;
2997
perror_plus("Failed to raise privileges");
2998
} else {
2999
3000
/* Run network hooks */
3001
run_network_hooks("stop", interfaces_hooks != NULL ?
3002
interfaces_hooks : "", delay);
3003
3004
/* Take down the network interfaces which were brought up */
3005
{
3006
char *interface = NULL;
3007
while((interface=argz_next(interfaces_to_take_down,
3008
interfaces_to_take_down_size,
3009
interface))){
3010
ret = take_down_interface(interface);
3011
if(ret != 0){
3012
errno = ret;
3013
perror_plus("Failed to take down interface");
3014
}
3015
}
3016
if(debug and (interfaces_to_take_down == NULL)){
3017
fprintf_plus(stderr, "No interfaces needed to be taken"
3018
" down\n");
3019
}
3020
}
3021
}
3022
3023
ret = lower_privileges_permanently();
3024
if(ret != 0){
3025
errno = ret;
3026
perror_plus("Failed to lower privileges permanently");
3027
}
3028
}
3029
3030
free(interfaces_to_take_down);
3031
free(interfaces_hooks);
3032
3033
void clean_dir_at(int base, const char * const dirname,
3034
uintmax_t level){
3035
struct dirent **direntries = NULL;
3036
int dret;
3037
int dir_fd = (int)TEMP_FAILURE_RETRY(openat(base, dirname,
3038
O_RDONLY
3039
| O_NOFOLLOW
3040
| O_DIRECTORY
3041
| O_PATH));
3042
if(dir_fd == -1){
3043
perror_plus("open");
3044
}
3045
int numentries = scandirat(dir_fd, ".", &direntries,
3046
notdotentries, alphasort);
3047
if(numentries >= 0){
3048
for(int i = 0; i < numentries; i++){
3049
if(debug){
3050
fprintf_plus(stderr, "Unlinking \"%s/%s\"\n",
3051
dirname, direntries[i]->d_name);
3052
}
3053
dret = unlinkat(dir_fd, direntries[i]->d_name, 0);
3054
if(dret == -1){
3055
if(errno == EISDIR){
3056
dret = unlinkat(dir_fd, direntries[i]->d_name,
3057
AT_REMOVEDIR);
3058
}
3059
if((dret == -1) and (errno == ENOTEMPTY)
3060
and (strcmp(direntries[i]->d_name, "private-keys-v1.d")
3061
== 0) and (level == 0)){
3062
/* Recurse only in this special case */
3063
clean_dir_at(dir_fd, direntries[i]->d_name, level+1);
3064
dret = 0;
3065
}
3066
if(dret == -1){
3067
fprintf_plus(stderr, "unlink(\"%s/%s\"): %s\n", dirname,
3068
direntries[i]->d_name, strerror(errno));
3069
}
3070
}
3071
free(direntries[i]);
3072
}
3073
3074
/* need to clean even if 0 because man page doesn't specify */
3075
free(direntries);
3076
if(numentries == -1){
3077
perror_plus("scandirat");
3078
}
3079
dret = unlinkat(base, dirname, AT_REMOVEDIR);
3080
if(dret == -1 and errno != ENOENT){
3081
perror_plus("rmdir");
3082
}
3083
} else {
3084
perror_plus("scandirat");
3085
}
3086
close(dir_fd);
2280
3087
}
2281
3088
2282
3089
/* Removes the GPGME temp directory and all files inside */
2283
if(tempdir_created){
2284
struct dirent **direntries = NULL;
2285
struct dirent *direntry = NULL;
2286
int numentries = scandir(tempdir, &direntries, notdotentries,
2287
alphasort);
2288
if (numentries > 0){
2289
for(int i = 0; i < numentries; i++){
2290
direntry = direntries[i];
2291
char *fullname = NULL;
2292
ret = asprintf(&fullname, "%s/%s", tempdir,
2293
direntry->d_name);
2294
if(ret < 0){
2295
perror_plus("asprintf");
2296
continue;
2297
}
2298
ret = remove(fullname);
2299
if(ret == -1){
2300
fprintf(stderr, "Mandos plugin mandos-client: "
2301
"remove(\"%s\"): %s\n", fullname, strerror(errno));
2302
}
2303
free(fullname);
2304
}
2305
}
2306
2307
/* need to clean even if 0 because man page doesn't specify */
2308
free(direntries);
2309
if (numentries == -1){
2310
perror_plus("scandir");
2311
}
2312
ret = rmdir(tempdir);
2313
if(ret == -1 and errno != ENOENT){
2314
perror_plus("rmdir");
2315
}
3090
if(tempdir != NULL){
3091
clean_dir_at(-1, tempdir, 0);
2316
3092
}
2317
3093
2318
3094
if(quit_now){
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0