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 777
- compare with another revision
- download diff
- download tarball
- view history from revision 777
- Committer: Teddy Hogeborn
- Date: 2015-07-20 03:03:33 UTC
- Revision ID: teddy@recompile.se-20150720030333-203m2aeblypcsfte
Bug fix for GnuTLS 3: be compatible with old 2048-bit DSA keys.
The mandos-keygen program in Mandos version 1.6.0 and older generated
2048-bit DSA keys, and when GnuTLS uses these it has trouble
connecting using the Mandos default priority string. This was
previously fixed in Mandos 1.6.2, but the bug reappeared when using
GnuTLS 3, so the default priority string has to change again; this
time also the Mandos client has to change its default, so now the
server and the client should use the same default priority string:
SECURE256:!CTYPE-X.509:+CTYPE-OPENPGP:!RSA:+SIGN-DSA-SHA256
* mandos (main/server_defaults): Changed default priority string.
* mandos-options.xml (/section/para[id="priority_compat"]): Removed.
(/section/para[id="priority"]): Changed default priority string.
* mandos.conf ([DEFAULT]/priority): - '' -
* mandos.conf.xml (OPTIONS/priority): Refer to the id "priority"
instead of "priority_compat".
* mandos.xml (OPTIONS/--priority): - '' -
* plugins.d/mandos-client.c (main): Changed default priority string.
The mandos-keygen program in Mandos version 1.6.0 and older generated
2048-bit DSA keys, and when GnuTLS uses these it has trouble
connecting using the Mandos default priority string. This was
previously fixed in Mandos 1.6.2, but the bug reappeared when using
GnuTLS 3, so the default priority string has to change again; this
time also the Mandos client has to change its default, so now the
server and the client should use the same default priority string:
SECURE256:!CTYPE-X.509:+CTYPE-OPENPGP:!RSA:+SIGN-DSA-SHA256
* mandos (main/server_defaults): Changed default priority string.
* mandos-options.xml (/section/para[id="priority_compat"]): Removed.
(/section/para[id="priority"]): Changed default priority string.
* mandos.conf ([DEFAULT]/priority): - '' -
* mandos.conf.xml (OPTIONS/priority): Refer to the id "priority"
instead of "priority_compat".
* mandos.xml (OPTIONS/--priority): - '' -
* plugins.d/mandos-client.c (main): Changed default priority string.
- files added:
- debian/mandos-client.examples
- debian/upstream
- 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-2015 Teddy Hogeborn
13
* Copyright © 2008-2015 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(), strcpy() */
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() */
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
65
#include <errno.h> /* perror(), errno,
66
66
program_invocation_short_name */
67
67
#include <time.h> /* nanosleep(), time(), sleep() */
73
73
*/
74
74
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
75
75
getuid(), getgid(), seteuid(),
76
setgid(), pause(), _exit() */
77
#include <arpa/inet.h> /* inet_pton(), htons, inet_ntop() */
76
setgid(), pause(), _exit(),
77
unlinkat() */
78
#include <arpa/inet.h> /* inet_pton(), htons() */
78
79
#include <iso646.h> /* not, or, and */
79
80
#include <argp.h> /* struct argp_option, error_t, struct
80
81
argp_state, struct argp,
88
89
#include <sys/wait.h> /* waitpid(), WIFEXITED(),
89
90
WEXITSTATUS(), WTERMSIG() */
90
91
#include <grp.h> /* setgroups() */
92
#include <argz.h> /* argz_add_sep(), argz_next(),
93
argz_delete(), argz_append(),
94
argz_stringify(), argz_add(),
95
argz_count() */
96
#include <netdb.h> /* getnameinfo(), NI_NUMERICHOST,
97
EAI_SYSTEM, gai_strerror() */
91
98
92
99
#ifdef __linux__
93
100
#include <sys/klog.h> /* klogctl() */
135
142
static const char sys_class_net[] = "/sys/class/net";
136
143
char *connect_to = NULL;
137
144
const char *hookdir = HOOKDIR;
145
int hookdir_fd = -1;
146
uid_t uid = 65534;
147
gid_t gid = 65534;
138
148
139
149
/* Doubly linked list that need to be circularly linked when used */
140
150
typedef struct server{
141
151
const char *ip;
142
uint16_t port;
152
in_port_t port;
143
153
AvahiIfIndex if_index;
144
154
int af;
145
155
struct timespec last_seen;
149
159
150
160
/* Used for passing in values through the Avahi callback functions */
151
161
typedef struct {
152
AvahiSimplePoll *simple_poll;
153
162
AvahiServer *server;
154
163
gnutls_certificate_credentials_t cred;
155
164
unsigned int dh_bits;
157
166
const char *priority;
158
167
gpgme_ctx_t ctx;
159
168
server *current_server;
169
char *interfaces;
170
size_t interfaces_size;
160
171
} mandos_context;
161
172
162
/* global context so signal handler can reach it*/
163
mandos_context mc = { .simple_poll = NULL, .server = NULL,
164
.dh_bits = 1024, .priority = "SECURE256"
165
":!CTYPE-X.509:+CTYPE-OPENPGP",
166
.current_server = NULL };
173
/* global so signal handler can reach it*/
174
AvahiSimplePoll *simple_poll;
167
175
168
176
sig_atomic_t quit_now = 0;
169
177
int signal_received = 0;
170
178
171
179
/* Function to use when printing errors */
172
180
void perror_plus(const char *print_text){
181
int e = errno;
173
182
fprintf(stderr, "Mandos plugin %s: ",
174
183
program_invocation_short_name);
184
errno = e;
175
185
perror(print_text);
176
186
}
177
187
188
__attribute__((format (gnu_printf, 2, 3), nonnull))
178
189
int fprintf_plus(FILE *stream, const char *format, ...){
179
190
va_list ap;
180
191
va_start (ap, format);
181
192
182
193
TEMP_FAILURE_RETRY(fprintf(stream, "Mandos plugin %s: ",
183
194
program_invocation_short_name));
184
return TEMP_FAILURE_RETRY(vfprintf(stream, format, ap));
195
return (int)TEMP_FAILURE_RETRY(vfprintf(stream, format, ap));
185
196
}
186
197
187
198
/*
189
200
* bytes. "buffer_capacity" is how much is currently allocated,
190
201
* "buffer_length" is how much is already used.
191
202
*/
203
__attribute__((nonnull, warn_unused_result))
192
204
size_t incbuffer(char **buffer, size_t buffer_length,
193
205
size_t buffer_capacity){
194
206
if(buffer_length + BUFFER_SIZE > buffer_capacity){
195
*buffer = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
196
if(buffer == NULL){
207
char *new_buf = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
208
if(new_buf == NULL){
209
int old_errno = errno;
210
free(*buffer);
211
errno = old_errno;
212
*buffer = NULL;
197
213
return 0;
198
214
}
215
*buffer = new_buf;
199
216
buffer_capacity += BUFFER_SIZE;
200
217
}
201
218
return buffer_capacity;
202
219
}
203
220
204
221
/* Add server to set of servers to retry periodically */
205
int add_server(const char *ip, uint16_t port, AvahiIfIndex if_index,
206
int af){
222
__attribute__((nonnull, warn_unused_result))
223
bool add_server(const char *ip, in_port_t port, AvahiIfIndex if_index,
224
int af, server **current_server){
207
225
int ret;
208
226
server *new_server = malloc(sizeof(server));
209
227
if(new_server == NULL){
210
228
perror_plus("malloc");
211
return -1;
229
return false;
212
230
}
213
231
*new_server = (server){ .ip = strdup(ip),
214
232
.port = port,
216
234
.af = af };
217
235
if(new_server->ip == NULL){
218
236
perror_plus("strdup");
219
return -1;
237
free(new_server);
238
return false;
239
}
240
ret = clock_gettime(CLOCK_MONOTONIC, &(new_server->last_seen));
241
if(ret == -1){
242
perror_plus("clock_gettime");
243
#ifdef __GNUC__
244
#pragma GCC diagnostic push
245
#pragma GCC diagnostic ignored "-Wcast-qual"
246
#endif
247
free((char *)(new_server->ip));
248
#ifdef __GNUC__
249
#pragma GCC diagnostic pop
250
#endif
251
free(new_server);
252
return false;
220
253
}
221
254
/* Special case of first server */
222
if (mc.current_server == NULL){
255
if(*current_server == NULL){
223
256
new_server->next = new_server;
224
257
new_server->prev = new_server;
225
mc.current_server = new_server;
226
/* Place the new server last in the list */
258
*current_server = new_server;
227
259
} else {
228
new_server->next = mc.current_server;
229
new_server->prev = mc.current_server->prev;
260
/* Place the new server last in the list */
261
new_server->next = *current_server;
262
new_server->prev = (*current_server)->prev;
230
263
new_server->prev->next = new_server;
231
mc.current_server->prev = new_server;
232
}
233
ret = clock_gettime(CLOCK_MONOTONIC, &mc.current_server->last_seen);
234
if(ret == -1){
235
perror_plus("clock_gettime");
236
return -1;
237
}
238
return 0;
264
(*current_server)->prev = new_server;
265
}
266
return true;
239
267
}
240
268
241
269
/*
242
270
* Initialize GPGME.
243
271
*/
244
static bool init_gpgme(const char *seckey, const char *pubkey,
245
const char *tempdir){
272
__attribute__((nonnull, warn_unused_result))
273
static bool init_gpgme(const char * const seckey,
274
const char * const pubkey,
275
const char * const tempdir,
276
mandos_context *mc){
246
277
gpgme_error_t rc;
247
278
gpgme_engine_info_t engine_info;
248
279
249
250
280
/*
251
281
* Helper function to insert pub and seckey to the engine keyring.
252
282
*/
253
bool import_key(const char *filename){
283
bool import_key(const char * const filename){
254
284
int ret;
255
285
int fd;
256
286
gpgme_data_t pgp_data;
268
298
return false;
269
299
}
270
300
271
rc = gpgme_op_import(mc.ctx, pgp_data);
301
rc = gpgme_op_import(mc->ctx, pgp_data);
272
302
if(rc != GPG_ERR_NO_ERROR){
273
303
fprintf_plus(stderr, "bad gpgme_op_import: %s: %s\n",
274
304
gpgme_strsource(rc), gpgme_strerror(rc));
275
305
return false;
276
306
}
277
307
278
ret = (int)TEMP_FAILURE_RETRY(close(fd));
308
ret = close(fd);
279
309
if(ret == -1){
280
310
perror_plus("close");
281
311
}
318
348
}
319
349
320
350
/* Create new GPGME "context" */
321
rc = gpgme_new(&(mc.ctx));
351
rc = gpgme_new(&(mc->ctx));
322
352
if(rc != GPG_ERR_NO_ERROR){
323
353
fprintf_plus(stderr, "Mandos plugin mandos-client: "
324
354
"bad gpgme_new: %s: %s\n", gpgme_strsource(rc),
337
367
* Decrypt OpenPGP data.
338
368
* Returns -1 on error
339
369
*/
370
__attribute__((nonnull, warn_unused_result))
340
371
static ssize_t pgp_packet_decrypt(const char *cryptotext,
341
372
size_t crypto_size,
342
char **plaintext){
373
char **plaintext,
374
mandos_context *mc){
343
375
gpgme_data_t dh_crypto, dh_plain;
344
376
gpgme_error_t rc;
345
377
ssize_t ret;
371
403
372
404
/* Decrypt data from the cryptotext data buffer to the plaintext
373
405
data buffer */
374
rc = gpgme_op_decrypt(mc.ctx, dh_crypto, dh_plain);
406
rc = gpgme_op_decrypt(mc->ctx, dh_crypto, dh_plain);
375
407
if(rc != GPG_ERR_NO_ERROR){
376
408
fprintf_plus(stderr, "bad gpgme_op_decrypt: %s: %s\n",
377
409
gpgme_strsource(rc), gpgme_strerror(rc));
378
410
plaintext_length = -1;
379
411
if(debug){
380
412
gpgme_decrypt_result_t result;
381
result = gpgme_op_decrypt_result(mc.ctx);
413
result = gpgme_op_decrypt_result(mc->ctx);
382
414
if(result == NULL){
383
415
fprintf_plus(stderr, "gpgme_op_decrypt_result failed\n");
384
416
} else {
461
493
return plaintext_length;
462
494
}
463
495
464
static const char * safer_gnutls_strerror(int value){
465
const char *ret = gnutls_strerror(value); /* Spurious warning from
466
-Wunreachable-code */
467
if(ret == NULL)
468
ret = "(unknown)";
469
return ret;
496
__attribute__((warn_unused_result, const))
497
static const char *safe_string(const char *str){
498
if(str == NULL)
499
return "(unknown)";
500
return str;
501
}
502
503
__attribute__((warn_unused_result))
504
static const char *safer_gnutls_strerror(int value){
505
const char *ret = gnutls_strerror(value);
506
return safe_string(ret);
470
507
}
471
508
472
509
/* GnuTLS log function callback */
510
__attribute__((nonnull))
473
511
static void debuggnutls(__attribute__((unused)) int level,
474
512
const char* string){
475
513
fprintf_plus(stderr, "GnuTLS: %s", string);
476
514
}
477
515
516
__attribute__((nonnull, warn_unused_result))
478
517
static int init_gnutls_global(const char *pubkeyfilename,
479
const char *seckeyfilename){
518
const char *seckeyfilename,
519
const char *dhparamsfilename,
520
mandos_context *mc){
480
521
int ret;
522
unsigned int uret;
481
523
482
524
if(debug){
483
525
fprintf_plus(stderr, "Initializing GnuTLS\n");
499
541
}
500
542
501
543
/* OpenPGP credentials */
502
ret = gnutls_certificate_allocate_credentials(&mc.cred);
544
ret = gnutls_certificate_allocate_credentials(&mc->cred);
503
545
if(ret != GNUTLS_E_SUCCESS){
504
546
fprintf_plus(stderr, "GnuTLS memory error: %s\n",
505
547
safer_gnutls_strerror(ret));
515
557
}
516
558
517
559
ret = gnutls_certificate_set_openpgp_key_file
518
(mc.cred, pubkeyfilename, seckeyfilename,
560
(mc->cred, pubkeyfilename, seckeyfilename,
519
561
GNUTLS_OPENPGP_FMT_BASE64);
520
562
if(ret != GNUTLS_E_SUCCESS){
521
563
fprintf_plus(stderr,
527
569
}
528
570
529
571
/* GnuTLS server initialization */
530
ret = gnutls_dh_params_init(&mc.dh_params);
572
ret = gnutls_dh_params_init(&mc->dh_params);
531
573
if(ret != GNUTLS_E_SUCCESS){
532
574
fprintf_plus(stderr, "Error in GnuTLS DH parameter"
533
575
" initialization: %s\n",
534
576
safer_gnutls_strerror(ret));
535
577
goto globalfail;
536
578
}
537
ret = gnutls_dh_params_generate2(mc.dh_params, mc.dh_bits);
538
if(ret != GNUTLS_E_SUCCESS){
539
fprintf_plus(stderr, "Error in GnuTLS prime generation: %s\n",
540
safer_gnutls_strerror(ret));
541
goto globalfail;
542
}
543
544
gnutls_certificate_set_dh_params(mc.cred, mc.dh_params);
579
/* If a Diffie-Hellman parameters file was given, try to use it */
580
if(dhparamsfilename != NULL){
581
gnutls_datum_t params = { .data = NULL, .size = 0 };
582
do {
583
int dhpfile = open(dhparamsfilename, O_RDONLY);
584
if(dhpfile == -1){
585
perror_plus("open");
586
dhparamsfilename = NULL;
587
break;
588
}
589
size_t params_capacity = 0;
590
while(true){
591
params_capacity = incbuffer((char **)¶ms.data,
592
(size_t)params.size,
593
(size_t)params_capacity);
594
if(params_capacity == 0){
595
perror_plus("incbuffer");
596
free(params.data);
597
params.data = NULL;
598
dhparamsfilename = NULL;
599
break;
600
}
601
ssize_t bytes_read = read(dhpfile,
602
params.data + params.size,
603
BUFFER_SIZE);
604
/* EOF */
605
if(bytes_read == 0){
606
break;
607
}
608
/* check bytes_read for failure */
609
if(bytes_read < 0){
610
perror_plus("read");
611
free(params.data);
612
params.data = NULL;
613
dhparamsfilename = NULL;
614
break;
615
}
616
params.size += (unsigned int)bytes_read;
617
}
618
if(params.data == NULL){
619
dhparamsfilename = NULL;
620
}
621
if(dhparamsfilename == NULL){
622
break;
623
}
624
ret = gnutls_dh_params_import_pkcs3(mc->dh_params, ¶ms,
625
GNUTLS_X509_FMT_PEM);
626
if(ret != GNUTLS_E_SUCCESS){
627
fprintf_plus(stderr, "Failed to parse DH parameters in file"
628
" \"%s\": %s\n", dhparamsfilename,
629
safer_gnutls_strerror(ret));
630
dhparamsfilename = NULL;
631
}
632
} while(false);
633
}
634
if(dhparamsfilename == NULL){
635
if(mc->dh_bits == 0){
636
/* Find out the optimal number of DH bits */
637
/* Try to read the private key file */
638
gnutls_datum_t buffer = { .data = NULL, .size = 0 };
639
do {
640
int secfile = open(seckeyfilename, O_RDONLY);
641
if(secfile == -1){
642
perror_plus("open");
643
break;
644
}
645
size_t buffer_capacity = 0;
646
while(true){
647
buffer_capacity = incbuffer((char **)&buffer.data,
648
(size_t)buffer.size,
649
(size_t)buffer_capacity);
650
if(buffer_capacity == 0){
651
perror_plus("incbuffer");
652
free(buffer.data);
653
buffer.data = NULL;
654
break;
655
}
656
ssize_t bytes_read = read(secfile,
657
buffer.data + buffer.size,
658
BUFFER_SIZE);
659
/* EOF */
660
if(bytes_read == 0){
661
break;
662
}
663
/* check bytes_read for failure */
664
if(bytes_read < 0){
665
perror_plus("read");
666
free(buffer.data);
667
buffer.data = NULL;
668
break;
669
}
670
buffer.size += (unsigned int)bytes_read;
671
}
672
close(secfile);
673
} while(false);
674
/* If successful, use buffer to parse private key */
675
gnutls_sec_param_t sec_param = GNUTLS_SEC_PARAM_ULTRA;
676
if(buffer.data != NULL){
677
{
678
gnutls_openpgp_privkey_t privkey = NULL;
679
ret = gnutls_openpgp_privkey_init(&privkey);
680
if(ret != GNUTLS_E_SUCCESS){
681
fprintf_plus(stderr, "Error initializing OpenPGP key"
682
" structure: %s",
683
safer_gnutls_strerror(ret));
684
free(buffer.data);
685
buffer.data = NULL;
686
} else {
687
ret = gnutls_openpgp_privkey_import
688
(privkey, &buffer, GNUTLS_OPENPGP_FMT_BASE64, "", 0);
689
if(ret != GNUTLS_E_SUCCESS){
690
fprintf_plus(stderr, "Error importing OpenPGP key : %s",
691
safer_gnutls_strerror(ret));
692
privkey = NULL;
693
}
694
free(buffer.data);
695
buffer.data = NULL;
696
if(privkey != NULL){
697
/* Use private key to suggest an appropriate
698
sec_param */
699
sec_param = gnutls_openpgp_privkey_sec_param(privkey);
700
gnutls_openpgp_privkey_deinit(privkey);
701
if(debug){
702
fprintf_plus(stderr, "This OpenPGP key implies using"
703
" a GnuTLS security parameter \"%s\".\n",
704
safe_string(gnutls_sec_param_get_name
705
(sec_param)));
706
}
707
}
708
}
709
}
710
if(sec_param == GNUTLS_SEC_PARAM_UNKNOWN){
711
/* Err on the side of caution */
712
sec_param = GNUTLS_SEC_PARAM_ULTRA;
713
if(debug){
714
fprintf_plus(stderr, "Falling back to security parameter"
715
" \"%s\"\n",
716
safe_string(gnutls_sec_param_get_name
717
(sec_param)));
718
}
719
}
720
}
721
uret = gnutls_sec_param_to_pk_bits(GNUTLS_PK_DH, sec_param);
722
if(uret != 0){
723
mc->dh_bits = uret;
724
if(debug){
725
fprintf_plus(stderr, "A \"%s\" GnuTLS security parameter"
726
" implies %u DH bits; using that.\n",
727
safe_string(gnutls_sec_param_get_name
728
(sec_param)),
729
mc->dh_bits);
730
}
731
} else {
732
fprintf_plus(stderr, "Failed to get implied number of DH"
733
" bits for security parameter \"%s\"): %s\n",
734
safe_string(gnutls_sec_param_get_name
735
(sec_param)),
736
safer_gnutls_strerror(ret));
737
goto globalfail;
738
}
739
} else if(debug){
740
fprintf_plus(stderr, "DH bits explicitly set to %u\n",
741
mc->dh_bits);
742
}
743
ret = gnutls_dh_params_generate2(mc->dh_params, mc->dh_bits);
744
if(ret != GNUTLS_E_SUCCESS){
745
fprintf_plus(stderr, "Error in GnuTLS prime generation (%u"
746
" bits): %s\n", mc->dh_bits,
747
safer_gnutls_strerror(ret));
748
goto globalfail;
749
}
750
}
751
gnutls_certificate_set_dh_params(mc->cred, mc->dh_params);
545
752
546
753
return 0;
547
754
548
755
globalfail:
549
756
550
gnutls_certificate_free_credentials(mc.cred);
757
gnutls_certificate_free_credentials(mc->cred);
551
758
gnutls_global_deinit();
552
gnutls_dh_params_deinit(mc.dh_params);
759
gnutls_dh_params_deinit(mc->dh_params);
553
760
return -1;
554
761
}
555
762
556
static int init_gnutls_session(gnutls_session_t *session){
763
__attribute__((nonnull, warn_unused_result))
764
static int init_gnutls_session(gnutls_session_t *session,
765
mandos_context *mc){
557
766
int ret;
558
767
/* GnuTLS session creation */
559
768
do {
571
780
{
572
781
const char *err;
573
782
do {
574
ret = gnutls_priority_set_direct(*session, mc.priority, &err);
783
ret = gnutls_priority_set_direct(*session, mc->priority, &err);
575
784
if(quit_now){
576
785
gnutls_deinit(*session);
577
786
return -1;
588
797
589
798
do {
590
799
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
591
mc.cred);
800
mc->cred);
592
801
if(quit_now){
593
802
gnutls_deinit(*session);
594
803
return -1;
604
813
/* ignore client certificate if any. */
605
814
gnutls_certificate_server_set_request(*session, GNUTLS_CERT_IGNORE);
606
815
607
gnutls_dh_set_prime_bits(*session, mc.dh_bits);
608
609
816
return 0;
610
817
}
611
818
613
820
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
614
821
__attribute__((unused)) const char *txt){}
615
822
823
/* Set effective uid to 0, return errno */
824
__attribute__((warn_unused_result))
825
error_t raise_privileges(void){
826
error_t old_errno = errno;
827
error_t ret_errno = 0;
828
if(seteuid(0) == -1){
829
ret_errno = errno;
830
}
831
errno = old_errno;
832
return ret_errno;
833
}
834
835
/* Set effective and real user ID to 0. Return errno. */
836
__attribute__((warn_unused_result))
837
error_t raise_privileges_permanently(void){
838
error_t old_errno = errno;
839
error_t ret_errno = raise_privileges();
840
if(ret_errno != 0){
841
errno = old_errno;
842
return ret_errno;
843
}
844
if(setuid(0) == -1){
845
ret_errno = errno;
846
}
847
errno = old_errno;
848
return ret_errno;
849
}
850
851
/* Set effective user ID to unprivileged saved user ID */
852
__attribute__((warn_unused_result))
853
error_t lower_privileges(void){
854
error_t old_errno = errno;
855
error_t ret_errno = 0;
856
if(seteuid(uid) == -1){
857
ret_errno = errno;
858
}
859
errno = old_errno;
860
return ret_errno;
861
}
862
863
/* Lower privileges permanently */
864
__attribute__((warn_unused_result))
865
error_t lower_privileges_permanently(void){
866
error_t old_errno = errno;
867
error_t ret_errno = 0;
868
if(setuid(uid) == -1){
869
ret_errno = errno;
870
}
871
errno = old_errno;
872
return ret_errno;
873
}
874
875
/* Helper function to add_local_route() and delete_local_route() */
876
__attribute__((nonnull, warn_unused_result))
877
static bool add_delete_local_route(const bool add,
878
const char *address,
879
AvahiIfIndex if_index){
880
int ret;
881
char helper[] = "mandos-client-iprouteadddel";
882
char add_arg[] = "add";
883
char delete_arg[] = "delete";
884
char debug_flag[] = "--debug";
885
char *pluginhelperdir = getenv("MANDOSPLUGINHELPERDIR");
886
if(pluginhelperdir == NULL){
887
if(debug){
888
fprintf_plus(stderr, "MANDOSPLUGINHELPERDIR environment"
889
" variable not set; cannot run helper\n");
890
}
891
return false;
892
}
893
894
char interface[IF_NAMESIZE];
895
if(if_indextoname((unsigned int)if_index, interface) == NULL){
896
perror_plus("if_indextoname");
897
return false;
898
}
899
900
int devnull = (int)TEMP_FAILURE_RETRY(open("/dev/null", O_RDONLY));
901
if(devnull == -1){
902
perror_plus("open(\"/dev/null\", O_RDONLY)");
903
return false;
904
}
905
pid_t pid = fork();
906
if(pid == 0){
907
/* Child */
908
/* Raise privileges */
909
errno = raise_privileges_permanently();
910
if(errno != 0){
911
perror_plus("Failed to raise privileges");
912
/* _exit(EX_NOPERM); */
913
} else {
914
/* Set group */
915
errno = 0;
916
ret = setgid(0);
917
if(ret == -1){
918
perror_plus("setgid");
919
_exit(EX_NOPERM);
920
}
921
/* Reset supplementary groups */
922
errno = 0;
923
ret = setgroups(0, NULL);
924
if(ret == -1){
925
perror_plus("setgroups");
926
_exit(EX_NOPERM);
927
}
928
}
929
ret = dup2(devnull, STDIN_FILENO);
930
if(ret == -1){
931
perror_plus("dup2(devnull, STDIN_FILENO)");
932
_exit(EX_OSERR);
933
}
934
ret = close(devnull);
935
if(ret == -1){
936
perror_plus("close");
937
_exit(EX_OSERR);
938
}
939
ret = dup2(STDERR_FILENO, STDOUT_FILENO);
940
if(ret == -1){
941
perror_plus("dup2(STDERR_FILENO, STDOUT_FILENO)");
942
_exit(EX_OSERR);
943
}
944
int helperdir_fd = (int)TEMP_FAILURE_RETRY(open(pluginhelperdir,
945
O_RDONLY
946
| O_DIRECTORY
947
| O_PATH
948
| O_CLOEXEC));
949
if(helperdir_fd == -1){
950
perror_plus("open");
951
_exit(EX_UNAVAILABLE);
952
}
953
int helper_fd = (int)TEMP_FAILURE_RETRY(openat(helperdir_fd,
954
helper, O_RDONLY));
955
if(helper_fd == -1){
956
perror_plus("openat");
957
close(helperdir_fd);
958
_exit(EX_UNAVAILABLE);
959
}
960
close(helperdir_fd);
961
#ifdef __GNUC__
962
#pragma GCC diagnostic push
963
#pragma GCC diagnostic ignored "-Wcast-qual"
964
#endif
965
if(fexecve(helper_fd, (char *const [])
966
{ helper, add ? add_arg : delete_arg, (char *)address,
967
interface, debug ? debug_flag : NULL, NULL },
968
environ) == -1){
969
#ifdef __GNUC__
970
#pragma GCC diagnostic pop
971
#endif
972
perror_plus("fexecve");
973
_exit(EXIT_FAILURE);
974
}
975
}
976
if(pid == -1){
977
perror_plus("fork");
978
return false;
979
}
980
int status;
981
pid_t pret = -1;
982
errno = 0;
983
do {
984
pret = waitpid(pid, &status, 0);
985
if(pret == -1 and errno == EINTR and quit_now){
986
int errno_raising = 0;
987
if((errno = raise_privileges()) != 0){
988
errno_raising = errno;
989
perror_plus("Failed to raise privileges in order to"
990
" kill helper program");
991
}
992
if(kill(pid, SIGTERM) == -1){
993
perror_plus("kill");
994
}
995
if((errno_raising == 0) and (errno = lower_privileges()) != 0){
996
perror_plus("Failed to lower privileges after killing"
997
" helper program");
998
}
999
return false;
1000
}
1001
} while(pret == -1 and errno == EINTR);
1002
if(pret == -1){
1003
perror_plus("waitpid");
1004
return false;
1005
}
1006
if(WIFEXITED(status)){
1007
if(WEXITSTATUS(status) != 0){
1008
fprintf_plus(stderr, "Error: iprouteadddel exited"
1009
" with status %d\n", WEXITSTATUS(status));
1010
return false;
1011
}
1012
return true;
1013
}
1014
if(WIFSIGNALED(status)){
1015
fprintf_plus(stderr, "Error: iprouteadddel died by"
1016
" signal %d\n", WTERMSIG(status));
1017
return false;
1018
}
1019
fprintf_plus(stderr, "Error: iprouteadddel crashed\n");
1020
return false;
1021
}
1022
1023
__attribute__((nonnull, warn_unused_result))
1024
static bool add_local_route(const char *address,
1025
AvahiIfIndex if_index){
1026
if(debug){
1027
fprintf_plus(stderr, "Adding route to %s\n", address);
1028
}
1029
return add_delete_local_route(true, address, if_index);
1030
}
1031
1032
__attribute__((nonnull, warn_unused_result))
1033
static bool delete_local_route(const char *address,
1034
AvahiIfIndex if_index){
1035
if(debug){
1036
fprintf_plus(stderr, "Removing route to %s\n", address);
1037
}
1038
return add_delete_local_route(false, address, if_index);
1039
}
1040
616
1041
/* Called when a Mandos server is found */
617
static int start_mandos_communication(const char *ip, uint16_t port,
1042
__attribute__((nonnull, warn_unused_result))
1043
static int start_mandos_communication(const char *ip, in_port_t port,
618
1044
AvahiIfIndex if_index,
619
int af){
1045
int af, mandos_context *mc){
620
1046
int ret, tcp_sd = -1;
621
1047
ssize_t sret;
622
union {
623
struct sockaddr_in in;
624
struct sockaddr_in6 in6;
625
} to;
1048
struct sockaddr_storage to;
626
1049
char *buffer = NULL;
627
1050
char *decrypted_buffer = NULL;
628
1051
size_t buffer_length = 0;
631
1054
int retval = -1;
632
1055
gnutls_session_t session;
633
1056
int pf; /* Protocol family */
1057
bool route_added = false;
634
1058
635
1059
errno = 0;
636
1060
652
1076
return -1;
653
1077
}
654
1078
655
ret = init_gnutls_session(&session);
1079
/* If the interface is specified and we have a list of interfaces */
1080
if(if_index != AVAHI_IF_UNSPEC and mc->interfaces != NULL){
1081
/* Check if the interface is one of the interfaces we are using */
1082
bool match = false;
1083
{
1084
char *interface = NULL;
1085
while((interface=argz_next(mc->interfaces, mc->interfaces_size,
1086
interface))){
1087
if(if_nametoindex(interface) == (unsigned int)if_index){
1088
match = true;
1089
break;
1090
}
1091
}
1092
}
1093
if(not match){
1094
/* This interface does not match any in the list, so we don't
1095
connect to the server */
1096
if(debug){
1097
char interface[IF_NAMESIZE];
1098
if(if_indextoname((unsigned int)if_index, interface) == NULL){
1099
perror_plus("if_indextoname");
1100
} else {
1101
fprintf_plus(stderr, "Skipping server on non-used interface"
1102
" \"%s\"\n",
1103
if_indextoname((unsigned int)if_index,
1104
interface));
1105
}
1106
}
1107
return -1;
1108
}
1109
}
1110
1111
ret = init_gnutls_session(&session, mc);
656
1112
if(ret != 0){
657
1113
return -1;
658
1114
}
659
1115
660
1116
if(debug){
661
1117
fprintf_plus(stderr, "Setting up a TCP connection to %s, port %"
662
PRIu16 "\n", ip, port);
1118
PRIuMAX "\n", ip, (uintmax_t)port);
663
1119
}
664
1120
665
tcp_sd = socket(pf, SOCK_STREAM, 0);
1121
tcp_sd = socket(pf, SOCK_STREAM | SOCK_CLOEXEC, 0);
666
1122
if(tcp_sd < 0){
667
1123
int e = errno;
668
1124
perror_plus("socket");
675
1131
goto mandos_end;
676
1132
}
677
1133
678
memset(&to, 0, sizeof(to));
679
1134
if(af == AF_INET6){
680
to.in6.sin6_family = (sa_family_t)af;
681
ret = inet_pton(af, ip, &to.in6.sin6_addr);
1135
struct sockaddr_in6 *to6 = (struct sockaddr_in6 *)&to;
1136
*to6 = (struct sockaddr_in6){ .sin6_family = (sa_family_t)af };
1137
ret = inet_pton(af, ip, &to6->sin6_addr);
682
1138
} else { /* IPv4 */
683
to.in.sin_family = (sa_family_t)af;
684
ret = inet_pton(af, ip, &to.in.sin_addr);
1139
struct sockaddr_in *to4 = (struct sockaddr_in *)&to;
1140
*to4 = (struct sockaddr_in){ .sin_family = (sa_family_t)af };
1141
ret = inet_pton(af, ip, &to4->sin_addr);
685
1142
}
686
1143
if(ret < 0 ){
687
1144
int e = errno;
696
1153
goto mandos_end;
697
1154
}
698
1155
if(af == AF_INET6){
699
to.in6.sin6_port = htons(port); /* Spurious warnings from
700
-Wconversion and
701
-Wunreachable-code */
702
703
if(IN6_IS_ADDR_LINKLOCAL /* Spurious warnings from */
704
(&to.in6.sin6_addr)){ /* -Wstrict-aliasing=2 or lower and
705
-Wunreachable-code*/
1156
((struct sockaddr_in6 *)&to)->sin6_port = htons(port);
1157
if(IN6_IS_ADDR_LINKLOCAL
1158
(&((struct sockaddr_in6 *)&to)->sin6_addr)){
706
1159
if(if_index == AVAHI_IF_UNSPEC){
707
1160
fprintf_plus(stderr, "An IPv6 link-local address is"
708
1161
" incomplete without a network interface\n");
710
1163
goto mandos_end;
711
1164
}
712
1165
/* Set the network interface number as scope */
713
to.in6.sin6_scope_id = (uint32_t)if_index;
1166
((struct sockaddr_in6 *)&to)->sin6_scope_id = (uint32_t)if_index;
714
1167
}
715
1168
} else {
716
to.in.sin_port = htons(port); /* Spurious warnings from
717
-Wconversion and
718
-Wunreachable-code */
1169
((struct sockaddr_in *)&to)->sin_port = htons(port);
719
1170
}
720
1171
721
1172
if(quit_now){
729
1180
if(if_indextoname((unsigned int)if_index, interface) == NULL){
730
1181
perror_plus("if_indextoname");
731
1182
} else {
732
fprintf_plus(stderr, "Connection to: %s%%%s, port %" PRIu16
733
"\n", ip, interface, port);
1183
fprintf_plus(stderr, "Connection to: %s%%%s, port %" PRIuMAX
1184
"\n", ip, interface, (uintmax_t)port);
734
1185
}
735
1186
} else {
736
fprintf_plus(stderr, "Connection to: %s, port %" PRIu16 "\n",
737
ip, port);
1187
fprintf_plus(stderr, "Connection to: %s, port %" PRIuMAX "\n",
1188
ip, (uintmax_t)port);
738
1189
}
739
1190
char addrstr[(INET_ADDRSTRLEN > INET6_ADDRSTRLEN) ?
740
1191
INET_ADDRSTRLEN : INET6_ADDRSTRLEN] = "";
741
const char *pcret;
742
if(af == AF_INET6){
743
pcret = inet_ntop(af, &(to.in6.sin6_addr), addrstr,
744
sizeof(addrstr));
745
} else {
746
pcret = inet_ntop(af, &(to.in.sin_addr), addrstr,
747
sizeof(addrstr));
748
}
749
if(pcret == NULL){
750
perror_plus("inet_ntop");
751
} else {
752
if(strcmp(addrstr, ip) != 0){
753
fprintf_plus(stderr, "Canonical address form: %s\n", addrstr);
754
}
755
}
756
}
757
758
if(quit_now){
759
errno = EINTR;
760
goto mandos_end;
761
}
762
763
if(af == AF_INET6){
764
ret = connect(tcp_sd, &to.in6, sizeof(to));
765
} else {
766
ret = connect(tcp_sd, &to.in, sizeof(to)); /* IPv4 */
767
}
768
if(ret < 0){
769
if ((errno != ECONNREFUSED and errno != ENETUNREACH) or debug){
770
int e = errno;
771
perror_plus("connect");
772
errno = e;
773
}
774
goto mandos_end;
775
}
776
777
if(quit_now){
778
errno = EINTR;
779
goto mandos_end;
1192
if(af == AF_INET6){
1193
ret = getnameinfo((struct sockaddr *)&to,
1194
sizeof(struct sockaddr_in6),
1195
addrstr, sizeof(addrstr), NULL, 0,
1196
NI_NUMERICHOST);
1197
} else {
1198
ret = getnameinfo((struct sockaddr *)&to,
1199
sizeof(struct sockaddr_in),
1200
addrstr, sizeof(addrstr), NULL, 0,
1201
NI_NUMERICHOST);
1202
}
1203
if(ret == EAI_SYSTEM){
1204
perror_plus("getnameinfo");
1205
} else if(ret != 0) {
1206
fprintf_plus(stderr, "getnameinfo: %s", gai_strerror(ret));
1207
} else if(strcmp(addrstr, ip) != 0){
1208
fprintf_plus(stderr, "Canonical address form: %s\n", addrstr);
1209
}
1210
}
1211
1212
if(quit_now){
1213
errno = EINTR;
1214
goto mandos_end;
1215
}
1216
1217
while(true){
1218
if(af == AF_INET6){
1219
ret = connect(tcp_sd, (struct sockaddr *)&to,
1220
sizeof(struct sockaddr_in6));
1221
} else {
1222
ret = connect(tcp_sd, (struct sockaddr *)&to, /* IPv4 */
1223
sizeof(struct sockaddr_in));
1224
}
1225
if(ret < 0){
1226
if(errno == ENETUNREACH
1227
and if_index != AVAHI_IF_UNSPEC
1228
and connect_to == NULL
1229
and not route_added and
1230
((af == AF_INET6 and not
1231
IN6_IS_ADDR_LINKLOCAL(&(((struct sockaddr_in6 *)
1232
&to)->sin6_addr)))
1233
or (af == AF_INET and
1234
/* Not a a IPv4LL address */
1235
(ntohl(((struct sockaddr_in *)&to)->sin_addr.s_addr)
1236
& 0xFFFF0000L) != 0xA9FE0000L))){
1237
/* Work around Avahi bug - Avahi does not announce link-local
1238
addresses if it has a global address, so local hosts with
1239
*only* a link-local address (e.g. Mandos clients) cannot
1240
connect to a Mandos server announced by Avahi on a server
1241
host with a global address. Work around this by retrying
1242
with an explicit route added with the server's address.
1243
1244
Avahi bug reference:
1245
http://lists.freedesktop.org/archives/avahi/2010-February/001833.html
1246
https://bugs.debian.org/587961
1247
*/
1248
if(debug){
1249
fprintf_plus(stderr, "Mandos server unreachable, trying"
1250
" direct route\n");
1251
}
1252
int e = errno;
1253
route_added = add_local_route(ip, if_index);
1254
if(route_added){
1255
continue;
1256
}
1257
errno = e;
1258
}
1259
if(errno != ECONNREFUSED or debug){
1260
int e = errno;
1261
perror_plus("connect");
1262
errno = e;
1263
}
1264
goto mandos_end;
1265
}
1266
1267
if(quit_now){
1268
errno = EINTR;
1269
goto mandos_end;
1270
}
1271
break;
780
1272
}
781
1273
782
1274
const char *out = mandos_protocol_version;
818
1310
goto mandos_end;
819
1311
}
820
1312
821
/* Spurious warning from -Wint-to-pointer-cast */
822
gnutls_transport_set_ptr(session, (gnutls_transport_ptr_t) tcp_sd);
1313
/* This casting via intptr_t is to eliminate warning about casting
1314
an int to a pointer type. This is exactly how the GnuTLS Guile
1315
function "set-session-transport-fd!" does it. */
1316
gnutls_transport_set_ptr(session,
1317
(gnutls_transport_ptr_t)(intptr_t)tcp_sd);
823
1318
824
1319
if(quit_now){
825
1320
errno = EINTR;
930
1425
if(buffer_length > 0){
931
1426
ssize_t decrypted_buffer_size;
932
1427
decrypted_buffer_size = pgp_packet_decrypt(buffer, buffer_length,
933
&decrypted_buffer);
1428
&decrypted_buffer, mc);
934
1429
if(decrypted_buffer_size >= 0){
935
1430
936
1431
written = 0;
962
1457
963
1458
mandos_end:
964
1459
{
1460
if(route_added){
1461
if(not delete_local_route(ip, if_index)){
1462
fprintf_plus(stderr, "Failed to delete local route to %s on"
1463
" interface %d", ip, if_index);
1464
}
1465
}
965
1466
int e = errno;
966
1467
free(decrypted_buffer);
967
1468
free(buffer);
968
1469
if(tcp_sd >= 0){
969
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
1470
ret = close(tcp_sd);
970
1471
}
971
1472
if(ret == -1){
972
1473
if(e == 0){
984
1485
return retval;
985
1486
}
986
1487
1488
__attribute__((nonnull))
987
1489
static void resolve_callback(AvahiSServiceResolver *r,
988
1490
AvahiIfIndex interface,
989
1491
AvahiProtocol proto,
997
1499
AVAHI_GCC_UNUSED AvahiStringList *txt,
998
1500
AVAHI_GCC_UNUSED AvahiLookupResultFlags
999
1501
flags,
1000
AVAHI_GCC_UNUSED void* userdata){
1001
assert(r);
1502
void *mc){
1503
if(r == NULL){
1504
return;
1505
}
1002
1506
1003
1507
/* Called whenever a service has been resolved successfully or
1004
1508
timed out */
1005
1509
1006
1510
if(quit_now){
1511
avahi_s_service_resolver_free(r);
1007
1512
return;
1008
1513
}
1009
1514
1013
1518
fprintf_plus(stderr, "(Avahi Resolver) Failed to resolve service "
1014
1519
"'%s' of type '%s' in domain '%s': %s\n", name, type,
1015
1520
domain,
1016
avahi_strerror(avahi_server_errno(mc.server)));
1521
avahi_strerror(avahi_server_errno
1522
(((mandos_context*)mc)->server)));
1017
1523
break;
1018
1524
1019
1525
case AVAHI_RESOLVER_FOUND:
1025
1531
PRIdMAX ") on port %" PRIu16 "\n", name,
1026
1532
host_name, ip, (intmax_t)interface, port);
1027
1533
}
1028
int ret = start_mandos_communication(ip, port, interface,
1029
avahi_proto_to_af(proto));
1534
int ret = start_mandos_communication(ip, (in_port_t)port,
1535
interface,
1536
avahi_proto_to_af(proto),
1537
mc);
1030
1538
if(ret == 0){
1031
avahi_simple_poll_quit(mc.simple_poll);
1539
avahi_simple_poll_quit(simple_poll);
1032
1540
} else {
1033
ret = add_server(ip, port, interface,
1034
avahi_proto_to_af(proto));
1541
if(not add_server(ip, (in_port_t)port, interface,
1542
avahi_proto_to_af(proto),
1543
&((mandos_context*)mc)->current_server)){
1544
fprintf_plus(stderr, "Failed to add server \"%s\" to server"
1545
" list\n", name);
1546
}
1035
1547
}
1036
1548
}
1037
1549
}
1047
1559
const char *domain,
1048
1560
AVAHI_GCC_UNUSED AvahiLookupResultFlags
1049
1561
flags,
1050
AVAHI_GCC_UNUSED void* userdata){
1051
assert(b);
1562
void *mc){
1563
if(b == NULL){
1564
return;
1565
}
1052
1566
1053
1567
/* Called whenever a new services becomes available on the LAN or
1054
1568
is removed from the LAN */
1062
1576
case AVAHI_BROWSER_FAILURE:
1063
1577
1064
1578
fprintf_plus(stderr, "(Avahi browser) %s\n",
1065
avahi_strerror(avahi_server_errno(mc.server)));
1066
avahi_simple_poll_quit(mc.simple_poll);
1579
avahi_strerror(avahi_server_errno
1580
(((mandos_context*)mc)->server)));
1581
avahi_simple_poll_quit(simple_poll);
1067
1582
return;
1068
1583
1069
1584
case AVAHI_BROWSER_NEW:
1072
1587
the callback function is called the Avahi server will free the
1073
1588
resolver for us. */
1074
1589
1075
if(avahi_s_service_resolver_new(mc.server, interface, protocol,
1076
name, type, domain, protocol, 0,
1077
resolve_callback, NULL) == NULL)
1590
if(avahi_s_service_resolver_new(((mandos_context*)mc)->server,
1591
interface, protocol, name, type,
1592
domain, protocol, 0,
1593
resolve_callback, mc) == NULL)
1078
1594
fprintf_plus(stderr, "Avahi: Failed to resolve service '%s':"
1079
1595
" %s\n", name,
1080
avahi_strerror(avahi_server_errno(mc.server)));
1596
avahi_strerror(avahi_server_errno
1597
(((mandos_context*)mc)->server)));
1081
1598
break;
1082
1599
1083
1600
case AVAHI_BROWSER_REMOVE:
1102
1619
signal_received = sig;
1103
1620
int old_errno = errno;
1104
1621
/* set main loop to exit */
1105
if(mc.simple_poll != NULL){
1106
avahi_simple_poll_quit(mc.simple_poll);
1622
if(simple_poll != NULL){
1623
avahi_simple_poll_quit(simple_poll);
1107
1624
}
1108
1625
errno = old_errno;
1109
1626
}
1110
1627
1628
__attribute__((nonnull, warn_unused_result))
1111
1629
bool get_flags(const char *ifname, struct ifreq *ifr){
1112
1630
int ret;
1631
error_t ret_errno;
1113
1632
1114
1633
int s = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1115
1634
if(s < 0){
1635
ret_errno = errno;
1116
1636
perror_plus("socket");
1637
errno = ret_errno;
1117
1638
return false;
1118
1639
}
1119
1640
strcpy(ifr->ifr_name, ifname);
1120
1641
ret = ioctl(s, SIOCGIFFLAGS, ifr);
1121
1642
if(ret == -1){
1122
1643
if(debug){
1644
ret_errno = errno;
1123
1645
perror_plus("ioctl SIOCGIFFLAGS");
1646
errno = ret_errno;
1124
1647
}
1125
1648
return false;
1126
1649
}
1127
1650
return true;
1128
1651
}
1129
1652
1653
__attribute__((nonnull, warn_unused_result))
1130
1654
bool good_flags(const char *ifname, const struct ifreq *ifr){
1131
1655
1132
1656
/* Reject the loopback device */
1174
1698
* corresponds to an acceptable network device.
1175
1699
* (This function is passed to scandir(3) as a filter function.)
1176
1700
*/
1701
__attribute__((nonnull, warn_unused_result))
1177
1702
int good_interface(const struct dirent *if_entry){
1178
1703
if(if_entry->d_name[0] == '.'){
1179
1704
return 0;
1195
1720
}
1196
1721
1197
1722
/*
1198
* This function determines if a directory entry in /sys/class/net
1199
* corresponds to an acceptable network device which is up.
1200
* (This function is passed to scandir(3) as a filter function.)
1201
*/
1202
int up_interface(const struct dirent *if_entry){
1203
if(if_entry->d_name[0] == '.'){
1204
return 0;
1205
}
1206
1207
struct ifreq ifr;
1208
if(not get_flags(if_entry->d_name, &ifr)){
1209
if(debug){
1210
fprintf_plus(stderr, "Failed to get flags for interface "
1211
"\"%s\"\n", if_entry->d_name);
1212
}
1213
return 0;
1214
}
1215
1216
/* Reject down interfaces */
1217
if(not (ifr.ifr_flags & IFF_UP)){
1218
if(debug){
1219
fprintf_plus(stderr, "Rejecting down interface \"%s\"\n",
1220
if_entry->d_name);
1221
}
1222
return 0;
1223
}
1224
1225
/* Reject non-running interfaces */
1226
if(not (ifr.ifr_flags & IFF_RUNNING)){
1227
if(debug){
1228
fprintf_plus(stderr, "Rejecting non-running interface \"%s\"\n",
1229
if_entry->d_name);
1230
}
1231
return 0;
1232
}
1233
1234
if(not good_flags(if_entry->d_name, &ifr)){
1235
return 0;
1236
}
1237
return 1;
1238
}
1239
1723
* This function determines if a network interface is up.
1724
*/
1725
__attribute__((nonnull, warn_unused_result))
1726
bool interface_is_up(const char *interface){
1727
struct ifreq ifr;
1728
if(not get_flags(interface, &ifr)){
1729
if(debug){
1730
fprintf_plus(stderr, "Failed to get flags for interface "
1731
"\"%s\"\n", interface);
1732
}
1733
return false;
1734
}
1735
1736
return (bool)(ifr.ifr_flags & IFF_UP);
1737
}
1738
1739
/*
1740
* This function determines if a network interface is running
1741
*/
1742
__attribute__((nonnull, warn_unused_result))
1743
bool interface_is_running(const char *interface){
1744
struct ifreq ifr;
1745
if(not get_flags(interface, &ifr)){
1746
if(debug){
1747
fprintf_plus(stderr, "Failed to get flags for interface "
1748
"\"%s\"\n", interface);
1749
}
1750
return false;
1751
}
1752
1753
return (bool)(ifr.ifr_flags & IFF_RUNNING);
1754
}
1755
1756
__attribute__((nonnull, pure, warn_unused_result))
1240
1757
int notdotentries(const struct dirent *direntry){
1241
1758
/* Skip "." and ".." */
1242
1759
if(direntry->d_name[0] == '.'
1249
1766
}
1250
1767
1251
1768
/* Is this directory entry a runnable program? */
1769
__attribute__((nonnull, warn_unused_result))
1252
1770
int runnable_hook(const struct dirent *direntry){
1253
1771
int ret;
1254
1772
size_t sret;
1262
1780
sret = strspn(direntry->d_name, "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
1263
1781
"abcdefghijklmnopqrstuvwxyz"
1264
1782
"0123456789"
1265
"_-");
1783
"_.-");
1266
1784
if((direntry->d_name)[sret] != '\0'){
1267
1785
/* Contains non-allowed characters */
1268
1786
if(debug){
1272
1790
return 0;
1273
1791
}
1274
1792
1275
char *fullname = NULL;
1276
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1277
if(ret < 0){
1278
perror_plus("asprintf");
1279
return 0;
1280
}
1281
1282
ret = stat(fullname, &st);
1793
ret = fstatat(hookdir_fd, direntry->d_name, &st, 0);
1283
1794
if(ret == -1){
1284
1795
if(debug){
1285
1796
perror_plus("Could not stat hook");
1309
1820
return 1;
1310
1821
}
1311
1822
1312
int avahi_loop_with_timeout(AvahiSimplePoll *s, int retry_interval){
1823
__attribute__((nonnull, warn_unused_result))
1824
int avahi_loop_with_timeout(AvahiSimplePoll *s, int retry_interval,
1825
mandos_context *mc){
1313
1826
int ret;
1314
1827
struct timespec now;
1315
1828
struct timespec waited_time;
1316
1829
intmax_t block_time;
1317
1830
1318
1831
while(true){
1319
if(mc.current_server == NULL){
1320
if (debug){
1832
if(mc->current_server == NULL){
1833
if(debug){
1321
1834
fprintf_plus(stderr, "Wait until first server is found."
1322
1835
" No timeout!\n");
1323
1836
}
1324
1837
ret = avahi_simple_poll_iterate(s, -1);
1325
1838
} else {
1326
if (debug){
1839
if(debug){
1327
1840
fprintf_plus(stderr, "Check current_server if we should run"
1328
1841
" it, or wait\n");
1329
1842
}
1336
1849
/* Calculating in ms how long time between now and server
1337
1850
who we visted longest time ago. Now - last seen. */
1338
1851
waited_time.tv_sec = (now.tv_sec
1339
- mc.current_server->last_seen.tv_sec);
1852
- mc->current_server->last_seen.tv_sec);
1340
1853
waited_time.tv_nsec = (now.tv_nsec
1341
- mc.current_server->last_seen.tv_nsec);
1854
- mc->current_server->last_seen.tv_nsec);
1342
1855
/* total time is 10s/10,000ms.
1343
1856
Converting to s from ms by dividing by 1,000,
1344
1857
and ns to ms by dividing by 1,000,000. */
1346
1859
- ((intmax_t)waited_time.tv_sec * 1000))
1347
1860
- ((intmax_t)waited_time.tv_nsec / 1000000));
1348
1861
1349
if (debug){
1862
if(debug){
1350
1863
fprintf_plus(stderr, "Blocking for %" PRIdMAX " ms\n",
1351
1864
block_time);
1352
1865
}
1353
1866
1354
1867
if(block_time <= 0){
1355
ret = start_mandos_communication(mc.current_server->ip,
1356
mc.current_server->port,
1357
mc.current_server->if_index,
1358
mc.current_server->af);
1868
ret = start_mandos_communication(mc->current_server->ip,
1869
mc->current_server->port,
1870
mc->current_server->if_index,
1871
mc->current_server->af, mc);
1359
1872
if(ret == 0){
1360
avahi_simple_poll_quit(mc.simple_poll);
1873
avahi_simple_poll_quit(s);
1361
1874
return 0;
1362
1875
}
1363
1876
ret = clock_gettime(CLOCK_MONOTONIC,
1364
&mc.current_server->last_seen);
1877
&mc->current_server->last_seen);
1365
1878
if(ret == -1){
1366
1879
perror_plus("clock_gettime");
1367
1880
return -1;
1368
1881
}
1369
mc.current_server = mc.current_server->next;
1882
mc->current_server = mc->current_server->next;
1370
1883
block_time = 0; /* Call avahi to find new Mandos
1371
1884
servers, but don't block */
1372
1885
}
1374
1887
ret = avahi_simple_poll_iterate(s, (int)block_time);
1375
1888
}
1376
1889
if(ret != 0){
1377
if (ret > 0 or errno != EINTR){
1890
if(ret > 0 or errno != EINTR){
1378
1891
return (ret != 1) ? ret : 0;
1379
1892
}
1380
1893
}
1381
1894
}
1382
1895
}
1383
1896
1384
bool run_network_hooks(const char *mode, const char *interface,
1897
__attribute__((nonnull))
1898
void run_network_hooks(const char *mode, const char *interface,
1385
1899
const float delay){
1386
struct dirent **direntries;
1387
struct dirent *direntry;
1388
int ret;
1389
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1390
alphasort);
1900
struct dirent **direntries = NULL;
1901
if(hookdir_fd == -1){
1902
hookdir_fd = open(hookdir, O_RDONLY | O_DIRECTORY | O_PATH
1903
| O_CLOEXEC);
1904
if(hookdir_fd == -1){
1905
if(errno == ENOENT){
1906
if(debug){
1907
fprintf_plus(stderr, "Network hook directory \"%s\" not"
1908
" found\n", hookdir);
1909
}
1910
} else {
1911
perror_plus("open");
1912
}
1913
return;
1914
}
1915
}
1916
#ifdef __GLIBC__
1917
#if __GLIBC_PREREQ(2, 15)
1918
int numhooks = scandirat(hookdir_fd, ".", &direntries,
1919
runnable_hook, alphasort);
1920
#else /* not __GLIBC_PREREQ(2, 15) */
1921
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1922
alphasort);
1923
#endif /* not __GLIBC_PREREQ(2, 15) */
1924
#else /* not __GLIBC__ */
1925
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1926
alphasort);
1927
#endif /* not __GLIBC__ */
1391
1928
if(numhooks == -1){
1392
1929
perror_plus("scandir");
1393
} else {
1394
int devnull = open("/dev/null", O_RDONLY);
1395
for(int i = 0; i < numhooks; i++){
1396
direntry = direntries[i];
1397
char *fullname = NULL;
1398
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1399
if(ret < 0){
1930
return;
1931
}
1932
struct dirent *direntry;
1933
int ret;
1934
int devnull = (int)TEMP_FAILURE_RETRY(open("/dev/null", O_RDONLY));
1935
if(devnull == -1){
1936
perror_plus("open(\"/dev/null\", O_RDONLY)");
1937
return;
1938
}
1939
for(int i = 0; i < numhooks; i++){
1940
direntry = direntries[i];
1941
if(debug){
1942
fprintf_plus(stderr, "Running network hook \"%s\"\n",
1943
direntry->d_name);
1944
}
1945
pid_t hook_pid = fork();
1946
if(hook_pid == 0){
1947
/* Child */
1948
/* Raise privileges */
1949
errno = raise_privileges_permanently();
1950
if(errno != 0){
1951
perror_plus("Failed to raise privileges");
1952
_exit(EX_NOPERM);
1953
}
1954
/* Set group */
1955
errno = 0;
1956
ret = setgid(0);
1957
if(ret == -1){
1958
perror_plus("setgid");
1959
_exit(EX_NOPERM);
1960
}
1961
/* Reset supplementary groups */
1962
errno = 0;
1963
ret = setgroups(0, NULL);
1964
if(ret == -1){
1965
perror_plus("setgroups");
1966
_exit(EX_NOPERM);
1967
}
1968
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1969
if(ret == -1){
1970
perror_plus("setenv");
1971
_exit(EX_OSERR);
1972
}
1973
ret = setenv("DEVICE", interface, 1);
1974
if(ret == -1){
1975
perror_plus("setenv");
1976
_exit(EX_OSERR);
1977
}
1978
ret = setenv("VERBOSITY", debug ? "1" : "0", 1);
1979
if(ret == -1){
1980
perror_plus("setenv");
1981
_exit(EX_OSERR);
1982
}
1983
ret = setenv("MODE", mode, 1);
1984
if(ret == -1){
1985
perror_plus("setenv");
1986
_exit(EX_OSERR);
1987
}
1988
char *delaystring;
1989
ret = asprintf(&delaystring, "%f", (double)delay);
1990
if(ret == -1){
1400
1991
perror_plus("asprintf");
1401
continue;
1402
}
1403
if(debug){
1404
fprintf_plus(stderr, "Running network hook \"%s\"\n",
1405
direntry->d_name);
1406
}
1407
pid_t hook_pid = fork();
1408
if(hook_pid == 0){
1409
/* Child */
1410
/* Raise privileges */
1411
errno = 0;
1412
ret = seteuid(0);
1413
if(ret == -1){
1414
perror_plus("seteuid");
1415
}
1416
/* Raise privileges even more */
1417
errno = 0;
1418
ret = setuid(0);
1419
if(ret == -1){
1420
perror_plus("setuid");
1421
}
1422
/* Set group */
1423
errno = 0;
1424
ret = setgid(0);
1425
if(ret == -1){
1426
perror_plus("setgid");
1427
}
1428
/* Reset supplementary groups */
1429
errno = 0;
1430
ret = setgroups(0, NULL);
1431
if(ret == -1){
1432
perror_plus("setgroups");
1433
}
1434
dup2(devnull, STDIN_FILENO);
1435
close(devnull);
1436
dup2(STDERR_FILENO, STDOUT_FILENO);
1437
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1438
if(ret == -1){
1439
perror_plus("setenv");
1440
_exit(EX_OSERR);
1441
}
1442
ret = setenv("DEVICE", interface, 1);
1443
if(ret == -1){
1444
perror_plus("setenv");
1445
_exit(EX_OSERR);
1446
}
1447
ret = setenv("VERBOSE", debug ? "1" : "0", 1);
1448
if(ret == -1){
1449
perror_plus("setenv");
1450
_exit(EX_OSERR);
1451
}
1452
ret = setenv("MODE", mode, 1);
1453
if(ret == -1){
1454
perror_plus("setenv");
1455
_exit(EX_OSERR);
1456
}
1457
char *delaystring;
1458
ret = asprintf(&delaystring, "%f", delay);
1459
if(ret == -1){
1460
perror_plus("asprintf");
1461
_exit(EX_OSERR);
1462
}
1463
ret = setenv("DELAY", delaystring, 1);
1464
if(ret == -1){
1465
free(delaystring);
1466
perror_plus("setenv");
1467
_exit(EX_OSERR);
1468
}
1992
_exit(EX_OSERR);
1993
}
1994
ret = setenv("DELAY", delaystring, 1);
1995
if(ret == -1){
1469
1996
free(delaystring);
1470
ret = execl(fullname, direntry->d_name, mode, NULL);
1471
perror_plus("execl");
1472
} else {
1473
int status;
1474
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
1475
perror_plus("waitpid");
1476
free(fullname);
1477
continue;
1478
}
1479
if(WIFEXITED(status)){
1480
if(WEXITSTATUS(status) != 0){
1481
fprintf_plus(stderr, "Warning: network hook \"%s\" exited"
1482
" with status %d\n", direntry->d_name,
1483
WEXITSTATUS(status));
1484
free(fullname);
1485
continue;
1486
}
1487
} else if(WIFSIGNALED(status)){
1488
fprintf_plus(stderr, "Warning: network hook \"%s\" died by"
1489
" signal %d\n", direntry->d_name,
1490
WTERMSIG(status));
1491
free(fullname);
1492
continue;
1493
} else {
1494
fprintf_plus(stderr, "Warning: network hook \"%s\""
1495
" crashed\n", direntry->d_name);
1496
free(fullname);
1497
continue;
1498
}
1499
}
1500
free(fullname);
1501
if(debug){
1502
fprintf_plus(stderr, "Network hook \"%s\" ran successfully\n",
1503
direntry->d_name);
1504
}
1505
}
1506
close(devnull);
1507
}
1508
return true;
1997
perror_plus("setenv");
1998
_exit(EX_OSERR);
1999
}
2000
free(delaystring);
2001
if(connect_to != NULL){
2002
ret = setenv("CONNECT", connect_to, 1);
2003
if(ret == -1){
2004
perror_plus("setenv");
2005
_exit(EX_OSERR);
2006
}
2007
}
2008
int hook_fd = (int)TEMP_FAILURE_RETRY(openat(hookdir_fd,
2009
direntry->d_name,
2010
O_RDONLY));
2011
if(hook_fd == -1){
2012
perror_plus("openat");
2013
_exit(EXIT_FAILURE);
2014
}
2015
if(close(hookdir_fd) == -1){
2016
perror_plus("close");
2017
_exit(EXIT_FAILURE);
2018
}
2019
ret = dup2(devnull, STDIN_FILENO);
2020
if(ret == -1){
2021
perror_plus("dup2(devnull, STDIN_FILENO)");
2022
_exit(EX_OSERR);
2023
}
2024
ret = close(devnull);
2025
if(ret == -1){
2026
perror_plus("close");
2027
_exit(EX_OSERR);
2028
}
2029
ret = dup2(STDERR_FILENO, STDOUT_FILENO);
2030
if(ret == -1){
2031
perror_plus("dup2(STDERR_FILENO, STDOUT_FILENO)");
2032
_exit(EX_OSERR);
2033
}
2034
if(fexecve(hook_fd, (char *const []){ direntry->d_name, NULL },
2035
environ) == -1){
2036
perror_plus("fexecve");
2037
_exit(EXIT_FAILURE);
2038
}
2039
} else {
2040
if(hook_pid == -1){
2041
perror_plus("fork");
2042
free(direntry);
2043
continue;
2044
}
2045
int status;
2046
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
2047
perror_plus("waitpid");
2048
free(direntry);
2049
continue;
2050
}
2051
if(WIFEXITED(status)){
2052
if(WEXITSTATUS(status) != 0){
2053
fprintf_plus(stderr, "Warning: network hook \"%s\" exited"
2054
" with status %d\n", direntry->d_name,
2055
WEXITSTATUS(status));
2056
free(direntry);
2057
continue;
2058
}
2059
} else if(WIFSIGNALED(status)){
2060
fprintf_plus(stderr, "Warning: network hook \"%s\" died by"
2061
" signal %d\n", direntry->d_name,
2062
WTERMSIG(status));
2063
free(direntry);
2064
continue;
2065
} else {
2066
fprintf_plus(stderr, "Warning: network hook \"%s\""
2067
" crashed\n", direntry->d_name);
2068
free(direntry);
2069
continue;
2070
}
2071
}
2072
if(debug){
2073
fprintf_plus(stderr, "Network hook \"%s\" ran successfully\n",
2074
direntry->d_name);
2075
}
2076
free(direntry);
2077
}
2078
free(direntries);
2079
if(close(hookdir_fd) == -1){
2080
perror_plus("close");
2081
} else {
2082
hookdir_fd = -1;
2083
}
2084
close(devnull);
2085
}
2086
2087
__attribute__((nonnull, warn_unused_result))
2088
error_t bring_up_interface(const char *const interface,
2089
const float delay){
2090
error_t old_errno = errno;
2091
int ret;
2092
struct ifreq network;
2093
unsigned int if_index = if_nametoindex(interface);
2094
if(if_index == 0){
2095
fprintf_plus(stderr, "No such interface: \"%s\"\n", interface);
2096
errno = old_errno;
2097
return ENXIO;
2098
}
2099
2100
if(quit_now){
2101
errno = old_errno;
2102
return EINTR;
2103
}
2104
2105
if(not interface_is_up(interface)){
2106
error_t ret_errno = 0, ioctl_errno = 0;
2107
if(not get_flags(interface, &network)){
2108
ret_errno = errno;
2109
fprintf_plus(stderr, "Failed to get flags for interface "
2110
"\"%s\"\n", interface);
2111
errno = old_errno;
2112
return ret_errno;
2113
}
2114
network.ifr_flags |= IFF_UP; /* set flag */
2115
2116
int sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
2117
if(sd == -1){
2118
ret_errno = errno;
2119
perror_plus("socket");
2120
errno = old_errno;
2121
return ret_errno;
2122
}
2123
2124
if(quit_now){
2125
ret = close(sd);
2126
if(ret == -1){
2127
perror_plus("close");
2128
}
2129
errno = old_errno;
2130
return EINTR;
2131
}
2132
2133
if(debug){
2134
fprintf_plus(stderr, "Bringing up interface \"%s\"\n",
2135
interface);
2136
}
2137
2138
/* Raise privileges */
2139
ret_errno = raise_privileges();
2140
if(ret_errno != 0){
2141
errno = ret_errno;
2142
perror_plus("Failed to raise privileges");
2143
}
2144
2145
#ifdef __linux__
2146
int ret_linux;
2147
bool restore_loglevel = false;
2148
if(ret_errno == 0){
2149
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
2150
messages about the network interface to mess up the prompt */
2151
ret_linux = klogctl(8, NULL, 5);
2152
if(ret_linux == -1){
2153
perror_plus("klogctl");
2154
} else {
2155
restore_loglevel = true;
2156
}
2157
}
2158
#endif /* __linux__ */
2159
int ret_setflags = ioctl(sd, SIOCSIFFLAGS, &network);
2160
ioctl_errno = errno;
2161
#ifdef __linux__
2162
if(restore_loglevel){
2163
ret_linux = klogctl(7, NULL, 0);
2164
if(ret_linux == -1){
2165
perror_plus("klogctl");
2166
}
2167
}
2168
#endif /* __linux__ */
2169
2170
/* If raise_privileges() succeeded above */
2171
if(ret_errno == 0){
2172
/* Lower privileges */
2173
ret_errno = lower_privileges();
2174
if(ret_errno != 0){
2175
errno = ret_errno;
2176
perror_plus("Failed to lower privileges");
2177
}
2178
}
2179
2180
/* Close the socket */
2181
ret = close(sd);
2182
if(ret == -1){
2183
perror_plus("close");
2184
}
2185
2186
if(ret_setflags == -1){
2187
errno = ioctl_errno;
2188
perror_plus("ioctl SIOCSIFFLAGS +IFF_UP");
2189
errno = old_errno;
2190
return ioctl_errno;
2191
}
2192
} else if(debug){
2193
fprintf_plus(stderr, "Interface \"%s\" is already up; good\n",
2194
interface);
2195
}
2196
2197
/* Sleep checking until interface is running.
2198
Check every 0.25s, up to total time of delay */
2199
for(int i=0; i < delay * 4; i++){
2200
if(interface_is_running(interface)){
2201
break;
2202
}
2203
struct timespec sleeptime = { .tv_nsec = 250000000 };
2204
ret = nanosleep(&sleeptime, NULL);
2205
if(ret == -1 and errno != EINTR){
2206
perror_plus("nanosleep");
2207
}
2208
}
2209
2210
errno = old_errno;
2211
return 0;
2212
}
2213
2214
__attribute__((nonnull, warn_unused_result))
2215
error_t take_down_interface(const char *const interface){
2216
error_t old_errno = errno;
2217
struct ifreq network;
2218
unsigned int if_index = if_nametoindex(interface);
2219
if(if_index == 0){
2220
fprintf_plus(stderr, "No such interface: \"%s\"\n", interface);
2221
errno = old_errno;
2222
return ENXIO;
2223
}
2224
if(interface_is_up(interface)){
2225
error_t ret_errno = 0, ioctl_errno = 0;
2226
if(not get_flags(interface, &network) and debug){
2227
ret_errno = errno;
2228
fprintf_plus(stderr, "Failed to get flags for interface "
2229
"\"%s\"\n", interface);
2230
errno = old_errno;
2231
return ret_errno;
2232
}
2233
network.ifr_flags &= ~(short)IFF_UP; /* clear flag */
2234
2235
int sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
2236
if(sd == -1){
2237
ret_errno = errno;
2238
perror_plus("socket");
2239
errno = old_errno;
2240
return ret_errno;
2241
}
2242
2243
if(debug){
2244
fprintf_plus(stderr, "Taking down interface \"%s\"\n",
2245
interface);
2246
}
2247
2248
/* Raise privileges */
2249
ret_errno = raise_privileges();
2250
if(ret_errno != 0){
2251
errno = ret_errno;
2252
perror_plus("Failed to raise privileges");
2253
}
2254
2255
int ret_setflags = ioctl(sd, SIOCSIFFLAGS, &network);
2256
ioctl_errno = errno;
2257
2258
/* If raise_privileges() succeeded above */
2259
if(ret_errno == 0){
2260
/* Lower privileges */
2261
ret_errno = lower_privileges();
2262
if(ret_errno != 0){
2263
errno = ret_errno;
2264
perror_plus("Failed to lower privileges");
2265
}
2266
}
2267
2268
/* Close the socket */
2269
int ret = close(sd);
2270
if(ret == -1){
2271
perror_plus("close");
2272
}
2273
2274
if(ret_setflags == -1){
2275
errno = ioctl_errno;
2276
perror_plus("ioctl SIOCSIFFLAGS -IFF_UP");
2277
errno = old_errno;
2278
return ioctl_errno;
2279
}
2280
} else if(debug){
2281
fprintf_plus(stderr, "Interface \"%s\" is already down; odd\n",
2282
interface);
2283
}
2284
2285
errno = old_errno;
2286
return 0;
1509
2287
}
1510
2288
1511
2289
int main(int argc, char *argv[]){
2290
mandos_context mc = { .server = NULL, .dh_bits = 0,
2291
.priority = "SECURE256:!CTYPE-X.509"
2292
":+CTYPE-OPENPGP:!RSA:+SIGN-DSA-SHA256",
2293
.current_server = NULL, .interfaces = NULL,
2294
.interfaces_size = 0 };
1512
2295
AvahiSServiceBrowser *sb = NULL;
1513
int error;
2296
error_t ret_errno;
1514
2297
int ret;
1515
2298
intmax_t tmpmax;
1516
2299
char *tmp;
1517
2300
int exitcode = EXIT_SUCCESS;
1518
const char *interface = "";
1519
struct ifreq network;
1520
int sd = -1;
1521
bool take_down_interface = false;
1522
uid_t uid;
1523
gid_t gid;
1524
char tempdir[] = "/tmp/mandosXXXXXX";
1525
bool tempdir_created = false;
2301
char *interfaces_to_take_down = NULL;
2302
size_t interfaces_to_take_down_size = 0;
2303
char run_tempdir[] = "/run/tmp/mandosXXXXXX";
2304
char old_tempdir[] = "/tmp/mandosXXXXXX";
2305
char *tempdir = NULL;
1526
2306
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
1527
2307
const char *seckey = PATHDIR "/" SECKEY;
1528
2308
const char *pubkey = PATHDIR "/" PUBKEY;
2309
const char *dh_params_file = NULL;
2310
char *interfaces_hooks = NULL;
1529
2311
1530
2312
bool gnutls_initialized = false;
1531
2313
bool gpgme_initialized = false;
1583
2365
.doc = "Bit length of the prime number used in the"
1584
2366
" Diffie-Hellman key exchange",
1585
2367
.group = 2 },
2368
{ .name = "dh-params", .key = 134,
2369
.arg = "FILE",
2370
.doc = "PEM-encoded PKCS#3 file with pre-generated parameters"
2371
" for the Diffie-Hellman key exchange",
2372
.group = 2 },
1586
2373
{ .name = "priority", .key = 130,
1587
2374
.arg = "STRING",
1588
2375
.doc = "GnuTLS priority string for the TLS handshake",
1593
2380
.group = 2 },
1594
2381
{ .name = "retry", .key = 132,
1595
2382
.arg = "SECONDS",
1596
.doc = "Retry interval used when denied by the mandos server",
2383
.doc = "Retry interval used when denied by the Mandos server",
1597
2384
.group = 2 },
1598
2385
{ .name = "network-hook-dir", .key = 133,
1599
2386
.arg = "DIR",
1622
2409
connect_to = arg;
1623
2410
break;
1624
2411
case 'i': /* --interface */
1625
interface = arg;
2412
ret_errno = argz_add_sep(&mc.interfaces, &mc.interfaces_size,
2413
arg, (int)',');
2414
if(ret_errno != 0){
2415
argp_error(state, "%s", strerror(ret_errno));
2416
}
1626
2417
break;
1627
2418
case 's': /* --seckey */
1628
2419
seckey = arg;
1639
2430
}
1640
2431
mc.dh_bits = (typeof(mc.dh_bits))tmpmax;
1641
2432
break;
2433
case 134: /* --dh-params */
2434
dh_params_file = arg;
2435
break;
1642
2436
case 130: /* --priority */
1643
2437
mc.priority = arg;
1644
2438
break;
1671
2465
argp_state_help(state, state->out_stream,
1672
2466
ARGP_HELP_USAGE | ARGP_HELP_EXIT_ERR);
1673
2467
case 'V': /* --version */
1674
fprintf_plus(state->out_stream,
1675
"Mandos plugin mandos-client: ");
1676
2468
fprintf_plus(state->out_stream, "%s\n", argp_program_version);
1677
2469
exit(argp_err_exit_status);
1678
2470
break;
1702
2494
goto end;
1703
2495
}
1704
2496
}
1705
2497
1706
2498
{
1707
2499
/* Work around Debian bug #633582:
1708
2500
<http://bugs.debian.org/633582> */
1709
2501
1710
/* Re-raise priviliges */
1711
errno = 0;
1712
ret = seteuid(0);
1713
if(ret == -1){
1714
perror_plus("seteuid");
2502
/* Re-raise privileges */
2503
ret_errno = raise_privileges();
2504
if(ret_errno != 0){
2505
errno = ret_errno;
2506
perror_plus("Failed to raise privileges");
1715
2507
} else {
1716
2508
struct stat st;
1717
2509
1732
2524
}
1733
2525
}
1734
2526
}
1735
TEMP_FAILURE_RETRY(close(seckey_fd));
2527
close(seckey_fd);
1736
2528
}
1737
2529
}
1738
2530
1739
2531
if(strcmp(pubkey, PATHDIR "/" PUBKEY) == 0){
1740
2532
int pubkey_fd = open(pubkey, O_RDONLY);
1741
2533
if(pubkey_fd == -1){
1753
2545
}
1754
2546
}
1755
2547
}
1756
TEMP_FAILURE_RETRY(close(pubkey_fd));
1757
}
1758
}
1759
2548
close(pubkey_fd);
2549
}
2550
}
2551
2552
if(dh_params_file != NULL
2553
and strcmp(dh_params_file, PATHDIR "/dhparams.pem" ) == 0){
2554
int dhparams_fd = open(dh_params_file, O_RDONLY);
2555
if(dhparams_fd == -1){
2556
perror_plus("open");
2557
} else {
2558
ret = (int)TEMP_FAILURE_RETRY(fstat(dhparams_fd, &st));
2559
if(ret == -1){
2560
perror_plus("fstat");
2561
} else {
2562
if(S_ISREG(st.st_mode)
2563
and st.st_uid == 0 and st.st_gid == 0){
2564
ret = fchown(dhparams_fd, uid, gid);
2565
if(ret == -1){
2566
perror_plus("fchown");
2567
}
2568
}
2569
}
2570
close(dhparams_fd);
2571
}
2572
}
2573
1760
2574
/* Lower privileges */
1761
errno = 0;
1762
ret = seteuid(uid);
1763
if(ret == -1){
1764
perror_plus("seteuid");
2575
ret_errno = lower_privileges();
2576
if(ret_errno != 0){
2577
errno = ret_errno;
2578
perror_plus("Failed to lower privileges");
2579
}
2580
}
2581
}
2582
2583
/* Remove invalid interface names (except "none") */
2584
{
2585
char *interface = NULL;
2586
while((interface = argz_next(mc.interfaces, mc.interfaces_size,
2587
interface))){
2588
if(strcmp(interface, "none") != 0
2589
and if_nametoindex(interface) == 0){
2590
if(interface[0] != '\0'){
2591
fprintf_plus(stderr, "Not using nonexisting interface"
2592
" \"%s\"\n", interface);
2593
}
2594
argz_delete(&mc.interfaces, &mc.interfaces_size, interface);
2595
interface = NULL;
1765
2596
}
1766
2597
}
1767
2598
}
1768
2599
1769
2600
/* Run network hooks */
1770
if(not run_network_hooks("start", interface, delay)){
1771
goto end;
2601
{
2602
if(mc.interfaces != NULL){
2603
interfaces_hooks = malloc(mc.interfaces_size);
2604
if(interfaces_hooks == NULL){
2605
perror_plus("malloc");
2606
goto end;
2607
}
2608
memcpy(interfaces_hooks, mc.interfaces, mc.interfaces_size);
2609
argz_stringify(interfaces_hooks, mc.interfaces_size, (int)',');
2610
}
2611
run_network_hooks("start", interfaces_hooks != NULL ?
2612
interfaces_hooks : "", delay);
1772
2613
}
1773
2614
1774
2615
if(not debug){
1775
2616
avahi_set_log_function(empty_log);
1776
2617
}
1777
2618
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_plus(stderr, "Using interface \"%s\"\n", interface);
1794
}
1795
if(interface == NULL){
1796
perror_plus("malloc");
1797
free(direntries);
1798
exitcode = EXIT_FAILURE;
1799
goto end;
1800
}
1801
free(direntries);
1802
} else {
1803
free(direntries);
1804
fprintf_plus(stderr, "Could not find a network interface\n");
1805
exitcode = EXIT_FAILURE;
1806
goto end;
1807
}
1808
}
1809
1810
2619
/* Initialize Avahi early so avahi_simple_poll_quit() can be called
1811
2620
from the signal handler */
1812
2621
/* Initialize the pseudo-RNG for Avahi */
1813
2622
srand((unsigned int) time(NULL));
1814
mc.simple_poll = avahi_simple_poll_new();
1815
if(mc.simple_poll == NULL){
2623
simple_poll = avahi_simple_poll_new();
2624
if(simple_poll == NULL){
1816
2625
fprintf_plus(stderr,
1817
2626
"Avahi: Failed to create simple poll object.\n");
1818
2627
exitcode = EX_UNAVAILABLE;
1882
2691
}
1883
2692
}
1884
2693
1885
/* If the interface is down, bring it up */
1886
if(strcmp(interface, "none") != 0){
1887
if_index = (AvahiIfIndex) if_nametoindex(interface);
1888
if(if_index == 0){
1889
fprintf_plus(stderr, "No such interface: \"%s\"\n", interface);
1890
exitcode = EX_UNAVAILABLE;
1891
goto end;
1892
}
1893
1894
if(quit_now){
1895
goto end;
1896
}
1897
1898
/* Re-raise priviliges */
1899
errno = 0;
1900
ret = seteuid(0);
1901
if(ret == -1){
1902
perror_plus("seteuid");
1903
}
1904
1905
#ifdef __linux__
1906
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1907
messages about the network interface to mess up the prompt */
1908
ret = klogctl(8, NULL, 5);
1909
bool restore_loglevel = true;
1910
if(ret == -1){
1911
restore_loglevel = false;
1912
perror_plus("klogctl");
1913
}
1914
#endif /* __linux__ */
1915
1916
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1917
if(sd < 0){
1918
perror_plus("socket");
1919
exitcode = EX_OSERR;
1920
#ifdef __linux__
1921
if(restore_loglevel){
1922
ret = klogctl(7, NULL, 0);
1923
if(ret == -1){
1924
perror_plus("klogctl");
1925
}
1926
}
1927
#endif /* __linux__ */
1928
/* Lower privileges */
1929
errno = 0;
1930
ret = seteuid(uid);
1931
if(ret == -1){
1932
perror_plus("seteuid");
1933
}
1934
goto end;
1935
}
1936
strcpy(network.ifr_name, interface);
1937
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1938
if(ret == -1){
1939
perror_plus("ioctl SIOCGIFFLAGS");
1940
#ifdef __linux__
1941
if(restore_loglevel){
1942
ret = klogctl(7, NULL, 0);
1943
if(ret == -1){
1944
perror_plus("klogctl");
1945
}
1946
}
1947
#endif /* __linux__ */
1948
exitcode = EX_OSERR;
1949
/* Lower privileges */
1950
errno = 0;
1951
ret = seteuid(uid);
1952
if(ret == -1){
1953
perror_plus("seteuid");
1954
}
1955
goto end;
1956
}
1957
if((network.ifr_flags & IFF_UP) == 0){
1958
network.ifr_flags |= IFF_UP;
1959
take_down_interface = true;
1960
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1961
if(ret == -1){
1962
take_down_interface = false;
1963
perror_plus("ioctl SIOCSIFFLAGS +IFF_UP");
1964
exitcode = EX_OSERR;
1965
#ifdef __linux__
1966
if(restore_loglevel){
1967
ret = klogctl(7, NULL, 0);
1968
if(ret == -1){
1969
perror_plus("klogctl");
2694
/* If no interfaces were specified, make a list */
2695
if(mc.interfaces == NULL){
2696
struct dirent **direntries = NULL;
2697
/* Look for any good interfaces */
2698
ret = scandir(sys_class_net, &direntries, good_interface,
2699
alphasort);
2700
if(ret >= 1){
2701
/* Add all found interfaces to interfaces list */
2702
for(int i = 0; i < ret; ++i){
2703
ret_errno = argz_add(&mc.interfaces, &mc.interfaces_size,
2704
direntries[i]->d_name);
2705
if(ret_errno != 0){
2706
errno = ret_errno;
2707
perror_plus("argz_add");
2708
free(direntries[i]);
2709
continue;
2710
}
2711
if(debug){
2712
fprintf_plus(stderr, "Will use interface \"%s\"\n",
2713
direntries[i]->d_name);
2714
}
2715
free(direntries[i]);
2716
}
2717
free(direntries);
2718
} else {
2719
if(ret == 0){
2720
free(direntries);
2721
}
2722
fprintf_plus(stderr, "Could not find a network interface\n");
2723
exitcode = EXIT_FAILURE;
2724
goto end;
2725
}
2726
}
2727
2728
/* Bring up interfaces which are down, and remove any "none"s */
2729
{
2730
char *interface = NULL;
2731
while((interface = argz_next(mc.interfaces, mc.interfaces_size,
2732
interface))){
2733
/* If interface name is "none", stop bringing up interfaces.
2734
Also remove all instances of "none" from the list */
2735
if(strcmp(interface, "none") == 0){
2736
argz_delete(&mc.interfaces, &mc.interfaces_size,
2737
interface);
2738
interface = NULL;
2739
while((interface = argz_next(mc.interfaces,
2740
mc.interfaces_size, interface))){
2741
if(strcmp(interface, "none") == 0){
2742
argz_delete(&mc.interfaces, &mc.interfaces_size,
2743
interface);
2744
interface = NULL;
1970
2745
}
1971
2746
}
1972
#endif /* __linux__ */
1973
/* Lower privileges */
1974
errno = 0;
1975
ret = seteuid(uid);
1976
if(ret == -1){
1977
perror_plus("seteuid");
1978
}
1979
goto end;
1980
}
1981
}
1982
/* Sleep checking until interface is running.
1983
Check every 0.25s, up to total time of delay */
1984
for(int i=0; i < delay * 4; i++){
1985
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1986
if(ret == -1){
1987
perror_plus("ioctl SIOCGIFFLAGS");
1988
} else if(network.ifr_flags & IFF_RUNNING){
1989
2747
break;
1990
2748
}
1991
struct timespec sleeptime = { .tv_nsec = 250000000 };
1992
ret = nanosleep(&sleeptime, NULL);
1993
if(ret == -1 and errno != EINTR){
1994
perror_plus("nanosleep");
1995
}
1996
}
1997
if(not take_down_interface){
1998
/* We won't need the socket anymore */
1999
ret = (int)TEMP_FAILURE_RETRY(close(sd));
2000
if(ret == -1){
2001
perror_plus("close");
2002
}
2003
}
2004
#ifdef __linux__
2005
if(restore_loglevel){
2006
/* Restores kernel loglevel to default */
2007
ret = klogctl(7, NULL, 0);
2008
if(ret == -1){
2009
perror_plus("klogctl");
2010
}
2011
}
2012
#endif /* __linux__ */
2013
/* Lower privileges */
2014
errno = 0;
2015
/* Lower privileges */
2016
ret = seteuid(uid);
2017
if(ret == -1){
2018
perror_plus("seteuid");
2019
}
2749
bool interface_was_up = interface_is_up(interface);
2750
errno = bring_up_interface(interface, delay);
2751
if(not interface_was_up){
2752
if(errno != 0){
2753
fprintf_plus(stderr, "Failed to bring up interface \"%s\":"
2754
" %s\n", interface, strerror(errno));
2755
} else {
2756
errno = argz_add(&interfaces_to_take_down,
2757
&interfaces_to_take_down_size,
2758
interface);
2759
if(errno != 0){
2760
perror_plus("argz_add");
2761
}
2762
}
2763
}
2764
}
2765
if(debug and (interfaces_to_take_down == NULL)){
2766
fprintf_plus(stderr, "No interfaces were brought up\n");
2767
}
2768
}
2769
2770
/* If we only got one interface, explicitly use only that one */
2771
if(argz_count(mc.interfaces, mc.interfaces_size) == 1){
2772
if(debug){
2773
fprintf_plus(stderr, "Using only interface \"%s\"\n",
2774
mc.interfaces);
2775
}
2776
if_index = (AvahiIfIndex)if_nametoindex(mc.interfaces);
2020
2777
}
2021
2778
2022
2779
if(quit_now){
2023
2780
goto end;
2024
2781
}
2025
2782
2026
ret = init_gnutls_global(pubkey, seckey);
2783
ret = init_gnutls_global(pubkey, seckey, dh_params_file, &mc);
2027
2784
if(ret == -1){
2028
2785
fprintf_plus(stderr, "init_gnutls_global failed\n");
2029
2786
exitcode = EX_UNAVAILABLE;
2036
2793
goto end;
2037
2794
}
2038
2795
2039
if(mkdtemp(tempdir) == NULL){
2796
/* Try /run/tmp before /tmp */
2797
tempdir = mkdtemp(run_tempdir);
2798
if(tempdir == NULL and errno == ENOENT){
2799
if(debug){
2800
fprintf_plus(stderr, "Tempdir %s did not work, trying %s\n",
2801
run_tempdir, old_tempdir);
2802
}
2803
tempdir = mkdtemp(old_tempdir);
2804
}
2805
if(tempdir == NULL){
2040
2806
perror_plus("mkdtemp");
2041
2807
goto end;
2042
2808
}
2043
tempdir_created = true;
2044
2809
2045
2810
if(quit_now){
2046
2811
goto end;
2047
2812
}
2048
2813
2049
if(not init_gpgme(pubkey, seckey, tempdir)){
2814
if(not init_gpgme(pubkey, seckey, tempdir, &mc)){
2050
2815
fprintf_plus(stderr, "init_gpgme failed\n");
2051
2816
exitcode = EX_UNAVAILABLE;
2052
2817
goto end;
2062
2827
/* Connect directly, do not use Zeroconf */
2063
2828
/* (Mainly meant for debugging) */
2064
2829
char *address = strrchr(connect_to, ':');
2830
2065
2831
if(address == NULL){
2066
2832
fprintf_plus(stderr, "No colon in address\n");
2067
2833
exitcode = EX_USAGE;
2072
2838
goto end;
2073
2839
}
2074
2840
2075
uint16_t port;
2841
in_port_t port;
2076
2842
errno = 0;
2077
2843
tmpmax = strtoimax(address+1, &tmp, 10);
2078
2844
if(errno != 0 or tmp == address+1 or *tmp != '\0'
2079
or tmpmax != (uint16_t)tmpmax){
2845
or tmpmax != (in_port_t)tmpmax){
2080
2846
fprintf_plus(stderr, "Bad port number\n");
2081
2847
exitcode = EX_USAGE;
2082
2848
goto end;
2083
2849
}
2084
2850
2085
2851
if(quit_now){
2086
2852
goto end;
2087
2853
}
2088
2854
2089
port = (uint16_t)tmpmax;
2855
port = (in_port_t)tmpmax;
2090
2856
*address = '\0';
2091
2857
/* Colon in address indicates IPv6 */
2092
2858
int af;
2108
2874
}
2109
2875
2110
2876
while(not quit_now){
2111
ret = start_mandos_communication(address, port, if_index, af);
2877
ret = start_mandos_communication(address, port, if_index, af,
2878
&mc);
2112
2879
if(quit_now or ret == 0){
2113
2880
break;
2114
2881
}
2116
2883
fprintf_plus(stderr, "Retrying in %d seconds\n",
2117
2884
(int)retry_interval);
2118
2885
}
2119
sleep((int)retry_interval);
2886
sleep((unsigned int)retry_interval);
2120
2887
}
2121
2888
2122
if (not quit_now){
2889
if(not quit_now){
2123
2890
exitcode = EXIT_SUCCESS;
2124
2891
}
2125
2892
2140
2907
config.publish_domain = 0;
2141
2908
2142
2909
/* Allocate a new server */
2143
mc.server = avahi_server_new(avahi_simple_poll_get
2144
(mc.simple_poll), &config, NULL,
2145
NULL, &error);
2910
mc.server = avahi_server_new(avahi_simple_poll_get(simple_poll),
2911
&config, NULL, NULL, &ret_errno);
2146
2912
2147
2913
/* Free the Avahi configuration data */
2148
2914
avahi_server_config_free(&config);
2151
2917
/* Check if creating the Avahi server object succeeded */
2152
2918
if(mc.server == NULL){
2153
2919
fprintf_plus(stderr, "Failed to create Avahi server: %s\n",
2154
avahi_strerror(error));
2920
avahi_strerror(ret_errno));
2155
2921
exitcode = EX_UNAVAILABLE;
2156
2922
goto end;
2157
2923
}
2163
2929
/* Create the Avahi service browser */
2164
2930
sb = avahi_s_service_browser_new(mc.server, if_index,
2165
2931
AVAHI_PROTO_UNSPEC, "_mandos._tcp",
2166
NULL, 0, browse_callback, NULL);
2932
NULL, 0, browse_callback,
2933
(void *)&mc);
2167
2934
if(sb == NULL){
2168
2935
fprintf_plus(stderr, "Failed to create service browser: %s\n",
2169
2936
avahi_strerror(avahi_server_errno(mc.server)));
2180
2947
if(debug){
2181
2948
fprintf_plus(stderr, "Starting Avahi loop search\n");
2182
2949
}
2183
2184
ret = avahi_loop_with_timeout(mc.simple_poll,
2185
(int)(retry_interval * 1000));
2950
2951
ret = avahi_loop_with_timeout(simple_poll,
2952
(int)(retry_interval * 1000), &mc);
2186
2953
if(debug){
2187
2954
fprintf_plus(stderr, "avahi_loop_with_timeout exited %s\n",
2188
2955
(ret == 0) ? "successfully" : "with error");
2195
2962
}
2196
2963
2197
2964
/* Cleanup things */
2965
free(mc.interfaces);
2966
2198
2967
if(sb != NULL)
2199
2968
avahi_s_service_browser_free(sb);
2200
2969
2201
2970
if(mc.server != NULL)
2202
2971
avahi_server_free(mc.server);
2203
2972
2204
if(mc.simple_poll != NULL)
2205
avahi_simple_poll_free(mc.simple_poll);
2973
if(simple_poll != NULL)
2974
avahi_simple_poll_free(simple_poll);
2206
2975
2207
2976
if(gnutls_initialized){
2208
2977
gnutls_certificate_free_credentials(mc.cred);
2220
2989
mc.current_server->prev->next = NULL;
2221
2990
while(mc.current_server != NULL){
2222
2991
server *next = mc.current_server->next;
2992
#ifdef __GNUC__
2993
#pragma GCC diagnostic push
2994
#pragma GCC diagnostic ignored "-Wcast-qual"
2995
#endif
2996
free((char *)(mc.current_server->ip));
2997
#ifdef __GNUC__
2998
#pragma GCC diagnostic pop
2999
#endif
2223
3000
free(mc.current_server);
2224
3001
mc.current_server = next;
2225
3002
}
2226
3003
}
2227
3004
2228
/* Run network hooks */
2229
run_network_hooks("stop", interface, delay);
2230
2231
/* Re-raise priviliges */
3005
/* Re-raise privileges */
2232
3006
{
2233
errno = 0;
2234
ret = seteuid(0);
2235
if(ret == -1){
2236
perror_plus("seteuid");
3007
ret_errno = raise_privileges();
3008
if(ret_errno != 0){
3009
errno = ret_errno;
3010
perror_plus("Failed to raise privileges");
3011
} else {
3012
3013
/* Run network hooks */
3014
run_network_hooks("stop", interfaces_hooks != NULL ?
3015
interfaces_hooks : "", delay);
3016
3017
/* Take down the network interfaces which were brought up */
3018
{
3019
char *interface = NULL;
3020
while((interface=argz_next(interfaces_to_take_down,
3021
interfaces_to_take_down_size,
3022
interface))){
3023
ret_errno = take_down_interface(interface);
3024
if(ret_errno != 0){
3025
errno = ret_errno;
3026
perror_plus("Failed to take down interface");
3027
}
3028
}
3029
if(debug and (interfaces_to_take_down == NULL)){
3030
fprintf_plus(stderr, "No interfaces needed to be taken"
3031
" down\n");
3032
}
3033
}
2237
3034
}
2238
3035
2239
/* Take down the network interface */
2240
if(take_down_interface and geteuid() == 0){
2241
ret = ioctl(sd, SIOCGIFFLAGS, &network);
2242
if(ret == -1){
2243
perror_plus("ioctl SIOCGIFFLAGS");
2244
} else if(network.ifr_flags & IFF_UP){
2245
network.ifr_flags &= ~(short)IFF_UP; /* clear flag */
2246
ret = ioctl(sd, SIOCSIFFLAGS, &network);
2247
if(ret == -1){
2248
perror_plus("ioctl SIOCSIFFLAGS -IFF_UP");
2249
}
2250
}
2251
ret = (int)TEMP_FAILURE_RETRY(close(sd));
2252
if(ret == -1){
2253
perror_plus("close");
2254
}
3036
ret_errno = lower_privileges_permanently();
3037
if(ret_errno != 0){
3038
errno = ret_errno;
3039
perror_plus("Failed to lower privileges permanently");
2255
3040
}
2256
3041
}
2257
/* Lower privileges permanently */
2258
errno = 0;
2259
ret = setuid(uid);
2260
if(ret == -1){
2261
perror_plus("setuid");
2262
}
3042
3043
free(interfaces_to_take_down);
3044
free(interfaces_hooks);
2263
3045
2264
3046
/* Removes the GPGME temp directory and all files inside */
2265
if(tempdir_created){
3047
if(tempdir != NULL){
2266
3048
struct dirent **direntries = NULL;
2267
struct dirent *direntry = NULL;
2268
int numentries = scandir(tempdir, &direntries, notdotentries,
2269
alphasort);
2270
if (numentries > 0){
2271
for(int i = 0; i < numentries; i++){
2272
direntry = direntries[i];
2273
char *fullname = NULL;
2274
ret = asprintf(&fullname, "%s/%s", tempdir,
2275
direntry->d_name);
2276
if(ret < 0){
2277
perror_plus("asprintf");
2278
continue;
2279
}
2280
ret = remove(fullname);
2281
if(ret == -1){
2282
fprintf_plus(stderr, "remove(\"%s\"): %s\n", fullname,
2283
strerror(errno));
2284
}
2285
free(fullname);
3049
int tempdir_fd = (int)TEMP_FAILURE_RETRY(open(tempdir, O_RDONLY
3050
| O_NOFOLLOW
3051
| O_DIRECTORY
3052
| O_PATH));
3053
if(tempdir_fd == -1){
3054
perror_plus("open");
3055
} else {
3056
#ifdef __GLIBC__
3057
#if __GLIBC_PREREQ(2, 15)
3058
int numentries = scandirat(tempdir_fd, ".", &direntries,
3059
notdotentries, alphasort);
3060
#else /* not __GLIBC_PREREQ(2, 15) */
3061
int numentries = scandir(tempdir, &direntries, notdotentries,
3062
alphasort);
3063
#endif /* not __GLIBC_PREREQ(2, 15) */
3064
#else /* not __GLIBC__ */
3065
int numentries = scandir(tempdir, &direntries, notdotentries,
3066
alphasort);
3067
#endif /* not __GLIBC__ */
3068
if(numentries >= 0){
3069
for(int i = 0; i < numentries; i++){
3070
ret = unlinkat(tempdir_fd, direntries[i]->d_name, 0);
3071
if(ret == -1){
3072
fprintf_plus(stderr, "unlinkat(open(\"%s\", O_RDONLY),"
3073
" \"%s\", 0): %s\n", tempdir,
3074
direntries[i]->d_name, strerror(errno));
3075
}
3076
free(direntries[i]);
3077
}
3078
3079
/* need to clean even if 0 because man page doesn't specify */
3080
free(direntries);
3081
if(numentries == -1){
3082
perror_plus("scandir");
3083
}
3084
ret = rmdir(tempdir);
3085
if(ret == -1 and errno != ENOENT){
3086
perror_plus("rmdir");
3087
}
2286
3088
}
2287
}
2288
2289
/* need to clean even if 0 because man page doesn't specify */
2290
free(direntries);
2291
if (numentries == -1){
2292
perror_plus("scandir");
2293
}
2294
ret = rmdir(tempdir);
2295
if(ret == -1 and errno != ENOENT){
2296
perror_plus("rmdir");
3089
close(tempdir_fd);
2297
3090
}
2298
3091
}
2299
3092
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0