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() */
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,
87
88
EX_NOHOST, EX_IOERR, EX_PROTOCOL */
88
89
#include <sys/wait.h> /* waitpid(), WIFEXITED(),
89
90
WEXITSTATUS(), WTERMSIG() */
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() */
90
98
91
99
#ifdef __linux__
92
100
#include <sys/klog.h> /* klogctl() */
134
142
static const char sys_class_net[] = "/sys/class/net";
135
143
char *connect_to = NULL;
136
144
const char *hookdir = HOOKDIR;
145
int hookdir_fd = -1;
146
uid_t uid = 65534;
147
gid_t gid = 65534;
137
148
138
149
/* Doubly linked list that need to be circularly linked when used */
139
150
typedef struct server{
140
151
const char *ip;
141
uint16_t port;
152
in_port_t port;
142
153
AvahiIfIndex if_index;
143
154
int af;
144
155
struct timespec last_seen;
148
159
149
160
/* Used for passing in values through the Avahi callback functions */
150
161
typedef struct {
151
AvahiSimplePoll *simple_poll;
152
162
AvahiServer *server;
153
163
gnutls_certificate_credentials_t cred;
154
164
unsigned int dh_bits;
156
166
const char *priority;
157
167
gpgme_ctx_t ctx;
158
168
server *current_server;
169
char *interfaces;
170
size_t interfaces_size;
159
171
} mandos_context;
160
172
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 };
173
/* global so signal handler can reach it*/
174
AvahiSimplePoll *simple_poll;
166
175
167
176
sig_atomic_t quit_now = 0;
168
177
int signal_received = 0;
169
178
170
179
/* Function to use when printing errors */
171
180
void perror_plus(const char *print_text){
181
int e = errno;
172
182
fprintf(stderr, "Mandos plugin %s: ",
173
183
program_invocation_short_name);
184
errno = e;
174
185
perror(print_text);
175
186
}
176
187
188
__attribute__((format (gnu_printf, 2, 3), nonnull))
177
189
int fprintf_plus(FILE *stream, const char *format, ...){
178
190
va_list ap;
179
191
va_start (ap, format);
180
192
181
193
TEMP_FAILURE_RETRY(fprintf(stream, "Mandos plugin %s: ",
182
194
program_invocation_short_name));
183
return TEMP_FAILURE_RETRY(vfprintf(stream, format, ap));
195
return (int)TEMP_FAILURE_RETRY(vfprintf(stream, format, ap));
184
196
}
185
197
186
198
/*
188
200
* bytes. "buffer_capacity" is how much is currently allocated,
189
201
* "buffer_length" is how much is already used.
190
202
*/
203
__attribute__((nonnull, warn_unused_result))
191
204
size_t incbuffer(char **buffer, size_t buffer_length,
192
205
size_t buffer_capacity){
193
206
if(buffer_length + BUFFER_SIZE > buffer_capacity){
194
*buffer = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
195
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;
196
213
return 0;
197
214
}
215
*buffer = new_buf;
198
216
buffer_capacity += BUFFER_SIZE;
199
217
}
200
218
return buffer_capacity;
201
219
}
202
220
203
221
/* Add server to set of servers to retry periodically */
204
int add_server(const char *ip, uint16_t port, AvahiIfIndex if_index,
205
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){
206
225
int ret;
207
226
server *new_server = malloc(sizeof(server));
208
227
if(new_server == NULL){
209
228
perror_plus("malloc");
210
return -1;
229
return false;
211
230
}
212
231
*new_server = (server){ .ip = strdup(ip),
213
232
.port = port,
215
234
.af = af };
216
235
if(new_server->ip == NULL){
217
236
perror_plus("strdup");
218
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;
219
253
}
220
254
/* Special case of first server */
221
if (mc.current_server == NULL){
255
if(*current_server == NULL){
222
256
new_server->next = new_server;
223
257
new_server->prev = new_server;
224
mc.current_server = new_server;
225
/* Place the new server last in the list */
258
*current_server = new_server;
226
259
} else {
227
new_server->next = mc.current_server;
228
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;
229
263
new_server->prev->next = new_server;
230
mc.current_server->prev = new_server;
231
}
232
ret = clock_gettime(CLOCK_MONOTONIC, &mc.current_server->last_seen);
233
if(ret == -1){
234
perror_plus("clock_gettime");
235
return -1;
236
}
237
return 0;
264
(*current_server)->prev = new_server;
265
}
266
return true;
238
267
}
239
268
240
269
/*
241
270
* Initialize GPGME.
242
271
*/
243
static bool init_gpgme(const char *seckey, const char *pubkey,
244
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){
245
277
gpgme_error_t rc;
246
278
gpgme_engine_info_t engine_info;
247
279
248
249
280
/*
250
281
* Helper function to insert pub and seckey to the engine keyring.
251
282
*/
252
bool import_key(const char *filename){
283
bool import_key(const char * const filename){
253
284
int ret;
254
285
int fd;
255
286
gpgme_data_t pgp_data;
267
298
return false;
268
299
}
269
300
270
rc = gpgme_op_import(mc.ctx, pgp_data);
301
rc = gpgme_op_import(mc->ctx, pgp_data);
271
302
if(rc != GPG_ERR_NO_ERROR){
272
303
fprintf_plus(stderr, "bad gpgme_op_import: %s: %s\n",
273
304
gpgme_strsource(rc), gpgme_strerror(rc));
274
305
return false;
275
306
}
276
307
277
ret = (int)TEMP_FAILURE_RETRY(close(fd));
308
ret = close(fd);
278
309
if(ret == -1){
279
310
perror_plus("close");
280
311
}
317
348
}
318
349
319
350
/* Create new GPGME "context" */
320
rc = gpgme_new(&(mc.ctx));
351
rc = gpgme_new(&(mc->ctx));
321
352
if(rc != GPG_ERR_NO_ERROR){
322
353
fprintf_plus(stderr, "Mandos plugin mandos-client: "
323
354
"bad gpgme_new: %s: %s\n", gpgme_strsource(rc),
336
367
* Decrypt OpenPGP data.
337
368
* Returns -1 on error
338
369
*/
370
__attribute__((nonnull, warn_unused_result))
339
371
static ssize_t pgp_packet_decrypt(const char *cryptotext,
340
372
size_t crypto_size,
341
char **plaintext){
373
char **plaintext,
374
mandos_context *mc){
342
375
gpgme_data_t dh_crypto, dh_plain;
343
376
gpgme_error_t rc;
344
377
ssize_t ret;
370
403
371
404
/* Decrypt data from the cryptotext data buffer to the plaintext
372
405
data buffer */
373
rc = gpgme_op_decrypt(mc.ctx, dh_crypto, dh_plain);
406
rc = gpgme_op_decrypt(mc->ctx, dh_crypto, dh_plain);
374
407
if(rc != GPG_ERR_NO_ERROR){
375
408
fprintf_plus(stderr, "bad gpgme_op_decrypt: %s: %s\n",
376
409
gpgme_strsource(rc), gpgme_strerror(rc));
377
410
plaintext_length = -1;
378
411
if(debug){
379
412
gpgme_decrypt_result_t result;
380
result = gpgme_op_decrypt_result(mc.ctx);
413
result = gpgme_op_decrypt_result(mc->ctx);
381
414
if(result == NULL){
382
415
fprintf_plus(stderr, "gpgme_op_decrypt_result failed\n");
383
416
} else {
460
493
return plaintext_length;
461
494
}
462
495
463
static const char * safer_gnutls_strerror(int value){
464
const char *ret = gnutls_strerror(value); /* Spurious warning from
465
-Wunreachable-code */
466
if(ret == NULL)
467
ret = "(unknown)";
468
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);
469
507
}
470
508
471
509
/* GnuTLS log function callback */
510
__attribute__((nonnull))
472
511
static void debuggnutls(__attribute__((unused)) int level,
473
512
const char* string){
474
513
fprintf_plus(stderr, "GnuTLS: %s", string);
475
514
}
476
515
516
__attribute__((nonnull, warn_unused_result))
477
517
static int init_gnutls_global(const char *pubkeyfilename,
478
const char *seckeyfilename){
518
const char *seckeyfilename,
519
const char *dhparamsfilename,
520
mandos_context *mc){
479
521
int ret;
522
unsigned int uret;
480
523
481
524
if(debug){
482
525
fprintf_plus(stderr, "Initializing GnuTLS\n");
498
541
}
499
542
500
543
/* OpenPGP credentials */
501
ret = gnutls_certificate_allocate_credentials(&mc.cred);
544
ret = gnutls_certificate_allocate_credentials(&mc->cred);
502
545
if(ret != GNUTLS_E_SUCCESS){
503
546
fprintf_plus(stderr, "GnuTLS memory error: %s\n",
504
547
safer_gnutls_strerror(ret));
514
557
}
515
558
516
559
ret = gnutls_certificate_set_openpgp_key_file
517
(mc.cred, pubkeyfilename, seckeyfilename,
560
(mc->cred, pubkeyfilename, seckeyfilename,
518
561
GNUTLS_OPENPGP_FMT_BASE64);
519
562
if(ret != GNUTLS_E_SUCCESS){
520
563
fprintf_plus(stderr,
526
569
}
527
570
528
571
/* GnuTLS server initialization */
529
ret = gnutls_dh_params_init(&mc.dh_params);
572
ret = gnutls_dh_params_init(&mc->dh_params);
530
573
if(ret != GNUTLS_E_SUCCESS){
531
574
fprintf_plus(stderr, "Error in GnuTLS DH parameter"
532
575
" initialization: %s\n",
533
576
safer_gnutls_strerror(ret));
534
577
goto globalfail;
535
578
}
536
ret = gnutls_dh_params_generate2(mc.dh_params, mc.dh_bits);
537
if(ret != GNUTLS_E_SUCCESS){
538
fprintf_plus(stderr, "Error in GnuTLS prime generation: %s\n",
539
safer_gnutls_strerror(ret));
540
goto globalfail;
541
}
542
543
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);
544
752
545
753
return 0;
546
754
547
755
globalfail:
548
756
549
gnutls_certificate_free_credentials(mc.cred);
757
gnutls_certificate_free_credentials(mc->cred);
550
758
gnutls_global_deinit();
551
gnutls_dh_params_deinit(mc.dh_params);
759
gnutls_dh_params_deinit(mc->dh_params);
552
760
return -1;
553
761
}
554
762
555
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){
556
766
int ret;
557
767
/* GnuTLS session creation */
558
768
do {
570
780
{
571
781
const char *err;
572
782
do {
573
ret = gnutls_priority_set_direct(*session, mc.priority, &err);
783
ret = gnutls_priority_set_direct(*session, mc->priority, &err);
574
784
if(quit_now){
575
785
gnutls_deinit(*session);
576
786
return -1;
587
797
588
798
do {
589
799
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
590
mc.cred);
800
mc->cred);
591
801
if(quit_now){
592
802
gnutls_deinit(*session);
593
803
return -1;
603
813
/* ignore client certificate if any. */
604
814
gnutls_certificate_server_set_request(*session, GNUTLS_CERT_IGNORE);
605
815
606
gnutls_dh_set_prime_bits(*session, mc.dh_bits);
607
608
816
return 0;
609
817
}
610
818
612
820
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
613
821
__attribute__((unused)) const char *txt){}
614
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
615
1041
/* Called when a Mandos server is found */
616
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,
617
1044
AvahiIfIndex if_index,
618
int af){
1045
int af, mandos_context *mc){
619
1046
int ret, tcp_sd = -1;
620
1047
ssize_t sret;
621
union {
622
struct sockaddr_in in;
623
struct sockaddr_in6 in6;
624
} to;
1048
struct sockaddr_storage to;
625
1049
char *buffer = NULL;
626
1050
char *decrypted_buffer = NULL;
627
1051
size_t buffer_length = 0;
630
1054
int retval = -1;
631
1055
gnutls_session_t session;
632
1056
int pf; /* Protocol family */
1057
bool route_added = false;
633
1058
634
1059
errno = 0;
635
1060
651
1076
return -1;
652
1077
}
653
1078
654
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);
655
1112
if(ret != 0){
656
1113
return -1;
657
1114
}
658
1115
659
1116
if(debug){
660
1117
fprintf_plus(stderr, "Setting up a TCP connection to %s, port %"
661
PRIu16 "\n", ip, port);
1118
PRIuMAX "\n", ip, (uintmax_t)port);
662
1119
}
663
1120
664
tcp_sd = socket(pf, SOCK_STREAM, 0);
1121
tcp_sd = socket(pf, SOCK_STREAM | SOCK_CLOEXEC, 0);
665
1122
if(tcp_sd < 0){
666
1123
int e = errno;
667
1124
perror_plus("socket");
674
1131
goto mandos_end;
675
1132
}
676
1133
677
memset(&to, 0, sizeof(to));
678
1134
if(af == AF_INET6){
679
to.in6.sin6_family = (sa_family_t)af;
680
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);
681
1138
} else { /* IPv4 */
682
to.in.sin_family = (sa_family_t)af;
683
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);
684
1142
}
685
1143
if(ret < 0 ){
686
1144
int e = errno;
695
1153
goto mandos_end;
696
1154
}
697
1155
if(af == AF_INET6){
698
to.in6.sin6_port = htons(port); /* Spurious warnings from
699
-Wconversion and
700
-Wunreachable-code */
701
702
if(IN6_IS_ADDR_LINKLOCAL /* Spurious warnings from */
703
(&to.in6.sin6_addr)){ /* -Wstrict-aliasing=2 or lower and
704
-Wunreachable-code*/
1156
((struct sockaddr_in6 *)&to)->sin6_port = htons(port);
1157
if(IN6_IS_ADDR_LINKLOCAL
1158
(&((struct sockaddr_in6 *)&to)->sin6_addr)){
705
1159
if(if_index == AVAHI_IF_UNSPEC){
706
1160
fprintf_plus(stderr, "An IPv6 link-local address is"
707
1161
" incomplete without a network interface\n");
709
1163
goto mandos_end;
710
1164
}
711
1165
/* Set the network interface number as scope */
712
to.in6.sin6_scope_id = (uint32_t)if_index;
1166
((struct sockaddr_in6 *)&to)->sin6_scope_id = (uint32_t)if_index;
713
1167
}
714
1168
} else {
715
to.in.sin_port = htons(port); /* Spurious warnings from
716
-Wconversion and
717
-Wunreachable-code */
1169
((struct sockaddr_in *)&to)->sin_port = htons(port);
718
1170
}
719
1171
720
1172
if(quit_now){
728
1180
if(if_indextoname((unsigned int)if_index, interface) == NULL){
729
1181
perror_plus("if_indextoname");
730
1182
} else {
731
fprintf_plus(stderr, "Connection to: %s%%%s, port %" PRIu16
732
"\n", ip, interface, port);
1183
fprintf_plus(stderr, "Connection to: %s%%%s, port %" PRIuMAX
1184
"\n", ip, interface, (uintmax_t)port);
733
1185
}
734
1186
} else {
735
fprintf_plus(stderr, "Connection to: %s, port %" PRIu16 "\n",
736
ip, port);
1187
fprintf_plus(stderr, "Connection to: %s, port %" PRIuMAX "\n",
1188
ip, (uintmax_t)port);
737
1189
}
738
1190
char addrstr[(INET_ADDRSTRLEN > INET6_ADDRSTRLEN) ?
739
1191
INET_ADDRSTRLEN : INET6_ADDRSTRLEN] = "";
740
const char *pcret;
741
if(af == AF_INET6){
742
pcret = inet_ntop(af, &(to.in6.sin6_addr), addrstr,
743
sizeof(addrstr));
744
} else {
745
pcret = inet_ntop(af, &(to.in.sin_addr), addrstr,
746
sizeof(addrstr));
747
}
748
if(pcret == NULL){
749
perror_plus("inet_ntop");
750
} else {
751
if(strcmp(addrstr, ip) != 0){
752
fprintf_plus(stderr, "Canonical address form: %s\n", addrstr);
753
}
754
}
755
}
756
757
if(quit_now){
758
errno = EINTR;
759
goto mandos_end;
760
}
761
762
if(af == AF_INET6){
763
ret = connect(tcp_sd, &to.in6, sizeof(to));
764
} else {
765
ret = connect(tcp_sd, &to.in, sizeof(to)); /* IPv4 */
766
}
767
if(ret < 0){
768
if ((errno != ECONNREFUSED and errno != ENETUNREACH) or debug){
769
int e = errno;
770
perror_plus("connect");
771
errno = e;
772
}
773
goto mandos_end;
774
}
775
776
if(quit_now){
777
errno = EINTR;
778
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;
779
1272
}
780
1273
781
1274
const char *out = mandos_protocol_version;
817
1310
goto mandos_end;
818
1311
}
819
1312
820
/* Spurious warning from -Wint-to-pointer-cast */
821
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);
822
1318
823
1319
if(quit_now){
824
1320
errno = EINTR;
929
1425
if(buffer_length > 0){
930
1426
ssize_t decrypted_buffer_size;
931
1427
decrypted_buffer_size = pgp_packet_decrypt(buffer, buffer_length,
932
&decrypted_buffer);
1428
&decrypted_buffer, mc);
933
1429
if(decrypted_buffer_size >= 0){
934
1430
935
1431
written = 0;
961
1457
962
1458
mandos_end:
963
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
}
964
1466
int e = errno;
965
1467
free(decrypted_buffer);
966
1468
free(buffer);
967
1469
if(tcp_sd >= 0){
968
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
1470
ret = close(tcp_sd);
969
1471
}
970
1472
if(ret == -1){
971
1473
if(e == 0){
983
1485
return retval;
984
1486
}
985
1487
1488
__attribute__((nonnull))
986
1489
static void resolve_callback(AvahiSServiceResolver *r,
987
1490
AvahiIfIndex interface,
988
1491
AvahiProtocol proto,
996
1499
AVAHI_GCC_UNUSED AvahiStringList *txt,
997
1500
AVAHI_GCC_UNUSED AvahiLookupResultFlags
998
1501
flags,
999
AVAHI_GCC_UNUSED void* userdata){
1000
assert(r);
1502
void *mc){
1503
if(r == NULL){
1504
return;
1505
}
1001
1506
1002
1507
/* Called whenever a service has been resolved successfully or
1003
1508
timed out */
1004
1509
1005
1510
if(quit_now){
1511
avahi_s_service_resolver_free(r);
1006
1512
return;
1007
1513
}
1008
1514
1012
1518
fprintf_plus(stderr, "(Avahi Resolver) Failed to resolve service "
1013
1519
"'%s' of type '%s' in domain '%s': %s\n", name, type,
1014
1520
domain,
1015
avahi_strerror(avahi_server_errno(mc.server)));
1521
avahi_strerror(avahi_server_errno
1522
(((mandos_context*)mc)->server)));
1016
1523
break;
1017
1524
1018
1525
case AVAHI_RESOLVER_FOUND:
1024
1531
PRIdMAX ") on port %" PRIu16 "\n", name,
1025
1532
host_name, ip, (intmax_t)interface, port);
1026
1533
}
1027
int ret = start_mandos_communication(ip, port, interface,
1028
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);
1029
1538
if(ret == 0){
1030
avahi_simple_poll_quit(mc.simple_poll);
1539
avahi_simple_poll_quit(simple_poll);
1031
1540
} else {
1032
ret = add_server(ip, port, interface,
1033
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
}
1034
1547
}
1035
1548
}
1036
1549
}
1046
1559
const char *domain,
1047
1560
AVAHI_GCC_UNUSED AvahiLookupResultFlags
1048
1561
flags,
1049
AVAHI_GCC_UNUSED void* userdata){
1050
assert(b);
1562
void *mc){
1563
if(b == NULL){
1564
return;
1565
}
1051
1566
1052
1567
/* Called whenever a new services becomes available on the LAN or
1053
1568
is removed from the LAN */
1061
1576
case AVAHI_BROWSER_FAILURE:
1062
1577
1063
1578
fprintf_plus(stderr, "(Avahi browser) %s\n",
1064
avahi_strerror(avahi_server_errno(mc.server)));
1065
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);
1066
1582
return;
1067
1583
1068
1584
case AVAHI_BROWSER_NEW:
1071
1587
the callback function is called the Avahi server will free the
1072
1588
resolver for us. */
1073
1589
1074
if(avahi_s_service_resolver_new(mc.server, interface, protocol,
1075
name, type, domain, protocol, 0,
1076
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)
1077
1594
fprintf_plus(stderr, "Avahi: Failed to resolve service '%s':"
1078
1595
" %s\n", name,
1079
avahi_strerror(avahi_server_errno(mc.server)));
1596
avahi_strerror(avahi_server_errno
1597
(((mandos_context*)mc)->server)));
1080
1598
break;
1081
1599
1082
1600
case AVAHI_BROWSER_REMOVE:
1101
1619
signal_received = sig;
1102
1620
int old_errno = errno;
1103
1621
/* set main loop to exit */
1104
if(mc.simple_poll != NULL){
1105
avahi_simple_poll_quit(mc.simple_poll);
1622
if(simple_poll != NULL){
1623
avahi_simple_poll_quit(simple_poll);
1106
1624
}
1107
1625
errno = old_errno;
1108
1626
}
1109
1627
1628
__attribute__((nonnull, warn_unused_result))
1110
1629
bool get_flags(const char *ifname, struct ifreq *ifr){
1111
1630
int ret;
1631
error_t ret_errno;
1112
1632
1113
1633
int s = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1114
1634
if(s < 0){
1635
ret_errno = errno;
1115
1636
perror_plus("socket");
1637
errno = ret_errno;
1116
1638
return false;
1117
1639
}
1118
1640
strcpy(ifr->ifr_name, ifname);
1119
1641
ret = ioctl(s, SIOCGIFFLAGS, ifr);
1120
1642
if(ret == -1){
1121
1643
if(debug){
1644
ret_errno = errno;
1122
1645
perror_plus("ioctl SIOCGIFFLAGS");
1646
errno = ret_errno;
1123
1647
}
1124
1648
return false;
1125
1649
}
1126
1650
return true;
1127
1651
}
1128
1652
1653
__attribute__((nonnull, warn_unused_result))
1129
1654
bool good_flags(const char *ifname, const struct ifreq *ifr){
1130
1655
1131
1656
/* Reject the loopback device */
1173
1698
* corresponds to an acceptable network device.
1174
1699
* (This function is passed to scandir(3) as a filter function.)
1175
1700
*/
1701
__attribute__((nonnull, warn_unused_result))
1176
1702
int good_interface(const struct dirent *if_entry){
1177
1703
if(if_entry->d_name[0] == '.'){
1178
1704
return 0;
1194
1720
}
1195
1721
1196
1722
/*
1197
* This function determines if a directory entry in /sys/class/net
1198
* corresponds to an acceptable network device which is up.
1199
* (This function is passed to scandir(3) as a filter function.)
1200
*/
1201
int up_interface(const struct dirent *if_entry){
1202
if(if_entry->d_name[0] == '.'){
1203
return 0;
1204
}
1205
1206
struct ifreq ifr;
1207
if(not get_flags(if_entry->d_name, &ifr)){
1208
if(debug){
1209
fprintf_plus(stderr, "Failed to get flags for interface "
1210
"\"%s\"\n", if_entry->d_name);
1211
}
1212
return 0;
1213
}
1214
1215
/* Reject down interfaces */
1216
if(not (ifr.ifr_flags & IFF_UP)){
1217
if(debug){
1218
fprintf_plus(stderr, "Rejecting down interface \"%s\"\n",
1219
if_entry->d_name);
1220
}
1221
return 0;
1222
}
1223
1224
/* Reject non-running interfaces */
1225
if(not (ifr.ifr_flags & IFF_RUNNING)){
1226
if(debug){
1227
fprintf_plus(stderr, "Rejecting non-running interface \"%s\"\n",
1228
if_entry->d_name);
1229
}
1230
return 0;
1231
}
1232
1233
if(not good_flags(if_entry->d_name, &ifr)){
1234
return 0;
1235
}
1236
return 1;
1237
}
1238
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))
1239
1757
int notdotentries(const struct dirent *direntry){
1240
1758
/* Skip "." and ".." */
1241
1759
if(direntry->d_name[0] == '.'
1248
1766
}
1249
1767
1250
1768
/* Is this directory entry a runnable program? */
1769
__attribute__((nonnull, warn_unused_result))
1251
1770
int runnable_hook(const struct dirent *direntry){
1252
1771
int ret;
1253
1772
size_t sret;
1261
1780
sret = strspn(direntry->d_name, "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
1262
1781
"abcdefghijklmnopqrstuvwxyz"
1263
1782
"0123456789"
1264
"_-");
1783
"_.-");
1265
1784
if((direntry->d_name)[sret] != '\0'){
1266
1785
/* Contains non-allowed characters */
1267
1786
if(debug){
1271
1790
return 0;
1272
1791
}
1273
1792
1274
char *fullname = NULL;
1275
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1276
if(ret < 0){
1277
perror_plus("asprintf");
1278
return 0;
1279
}
1280
1281
ret = stat(fullname, &st);
1793
ret = fstatat(hookdir_fd, direntry->d_name, &st, 0);
1282
1794
if(ret == -1){
1283
1795
if(debug){
1284
1796
perror_plus("Could not stat hook");
1308
1820
return 1;
1309
1821
}
1310
1822
1311
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){
1312
1826
int ret;
1313
1827
struct timespec now;
1314
1828
struct timespec waited_time;
1315
1829
intmax_t block_time;
1316
1830
1317
1831
while(true){
1318
if(mc.current_server == NULL){
1319
if (debug){
1832
if(mc->current_server == NULL){
1833
if(debug){
1320
1834
fprintf_plus(stderr, "Wait until first server is found."
1321
1835
" No timeout!\n");
1322
1836
}
1323
1837
ret = avahi_simple_poll_iterate(s, -1);
1324
1838
} else {
1325
if (debug){
1839
if(debug){
1326
1840
fprintf_plus(stderr, "Check current_server if we should run"
1327
1841
" it, or wait\n");
1328
1842
}
1335
1849
/* Calculating in ms how long time between now and server
1336
1850
who we visted longest time ago. Now - last seen. */
1337
1851
waited_time.tv_sec = (now.tv_sec
1338
- mc.current_server->last_seen.tv_sec);
1852
- mc->current_server->last_seen.tv_sec);
1339
1853
waited_time.tv_nsec = (now.tv_nsec
1340
- mc.current_server->last_seen.tv_nsec);
1854
- mc->current_server->last_seen.tv_nsec);
1341
1855
/* total time is 10s/10,000ms.
1342
1856
Converting to s from ms by dividing by 1,000,
1343
1857
and ns to ms by dividing by 1,000,000. */
1345
1859
- ((intmax_t)waited_time.tv_sec * 1000))
1346
1860
- ((intmax_t)waited_time.tv_nsec / 1000000));
1347
1861
1348
if (debug){
1862
if(debug){
1349
1863
fprintf_plus(stderr, "Blocking for %" PRIdMAX " ms\n",
1350
1864
block_time);
1351
1865
}
1352
1866
1353
1867
if(block_time <= 0){
1354
ret = start_mandos_communication(mc.current_server->ip,
1355
mc.current_server->port,
1356
mc.current_server->if_index,
1357
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);
1358
1872
if(ret == 0){
1359
avahi_simple_poll_quit(mc.simple_poll);
1873
avahi_simple_poll_quit(s);
1360
1874
return 0;
1361
1875
}
1362
1876
ret = clock_gettime(CLOCK_MONOTONIC,
1363
&mc.current_server->last_seen);
1877
&mc->current_server->last_seen);
1364
1878
if(ret == -1){
1365
1879
perror_plus("clock_gettime");
1366
1880
return -1;
1367
1881
}
1368
mc.current_server = mc.current_server->next;
1882
mc->current_server = mc->current_server->next;
1369
1883
block_time = 0; /* Call avahi to find new Mandos
1370
1884
servers, but don't block */
1371
1885
}
1373
1887
ret = avahi_simple_poll_iterate(s, (int)block_time);
1374
1888
}
1375
1889
if(ret != 0){
1376
if (ret > 0 or errno != EINTR){
1890
if(ret > 0 or errno != EINTR){
1377
1891
return (ret != 1) ? ret : 0;
1378
1892
}
1379
1893
}
1380
1894
}
1381
1895
}
1382
1896
1383
bool run_network_hooks(const char *mode, const char *interface,
1897
__attribute__((nonnull))
1898
void run_network_hooks(const char *mode, const char *interface,
1384
1899
const float delay){
1385
struct dirent **direntries;
1386
struct dirent *direntry;
1387
int ret;
1388
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1389
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__ */
1390
1928
if(numhooks == -1){
1391
1929
perror_plus("scandir");
1392
} else {
1393
int devnull = open("/dev/null", O_RDONLY);
1394
for(int i = 0; i < numhooks; i++){
1395
direntry = direntries[i];
1396
char *fullname = NULL;
1397
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1398
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){
1399
1991
perror_plus("asprintf");
1400
continue;
1401
}
1402
if(debug){
1403
fprintf_plus(stderr, "Running network hook \"%s\"\n",
1404
direntry->d_name);
1405
}
1406
pid_t hook_pid = fork();
1407
if(hook_pid == 0){
1408
/* Child */
1409
dup2(devnull, STDIN_FILENO);
1410
close(devnull);
1411
dup2(STDERR_FILENO, STDOUT_FILENO);
1412
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1413
if(ret == -1){
1414
perror_plus("setenv");
1415
return false;
1416
}
1417
ret = setenv("DEVICE", interface, 1);
1418
if(ret == -1){
1419
perror_plus("setenv");
1420
return false;
1421
}
1422
ret = setenv("VERBOSE", debug ? "1" : "0", 1);
1423
if(ret == -1){
1424
perror_plus("setenv");
1425
return false;
1426
}
1427
ret = setenv("MODE", mode, 1);
1428
if(ret == -1){
1429
perror_plus("setenv");
1430
return false;
1431
}
1432
char *delaystring;
1433
ret = asprintf(&delaystring, "%f", delay);
1434
if(ret == -1){
1435
perror_plus("asprintf");
1436
return false;
1437
}
1438
ret = setenv("DELAY", delaystring, 1);
1439
if(ret == -1){
1440
free(delaystring);
1441
perror_plus("setenv");
1442
return false;
1443
}
1992
_exit(EX_OSERR);
1993
}
1994
ret = setenv("DELAY", delaystring, 1);
1995
if(ret == -1){
1444
1996
free(delaystring);
1445
ret = execl(fullname, direntry->d_name, mode, NULL);
1446
perror_plus("execl");
1447
} else {
1448
int status;
1449
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
1450
perror_plus("waitpid");
1451
free(fullname);
1452
continue;
1453
}
1454
if(WIFEXITED(status)){
1455
if(WEXITSTATUS(status) != 0){
1456
fprintf_plus(stderr, "Warning: network hook \"%s\" exited"
1457
" with status %d\n", direntry->d_name,
1458
WEXITSTATUS(status));
1459
free(fullname);
1460
continue;
1461
}
1462
} else if(WIFSIGNALED(status)){
1463
fprintf_plus(stderr, "Warning: network hook \"%s\" died by"
1464
" signal %d\n", direntry->d_name,
1465
WTERMSIG(status));
1466
free(fullname);
1467
continue;
1468
} else {
1469
fprintf_plus(stderr, "Warning: network hook \"%s\""
1470
" crashed\n", direntry->d_name);
1471
free(fullname);
1472
continue;
1473
}
1474
}
1475
free(fullname);
1476
if(debug){
1477
fprintf_plus(stderr, "Network hook \"%s\" ran successfully\n",
1478
direntry->d_name);
1479
}
1480
}
1481
close(devnull);
1482
}
1483
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;
1484
2287
}
1485
2288
1486
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 };
1487
2295
AvahiSServiceBrowser *sb = NULL;
1488
int error;
2296
error_t ret_errno;
1489
2297
int ret;
1490
2298
intmax_t tmpmax;
1491
2299
char *tmp;
1492
2300
int exitcode = EXIT_SUCCESS;
1493
const char *interface = "";
1494
struct ifreq network;
1495
int sd = -1;
1496
bool take_down_interface = false;
1497
uid_t uid;
1498
gid_t gid;
1499
char tempdir[] = "/tmp/mandosXXXXXX";
1500
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;
1501
2306
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
1502
2307
const char *seckey = PATHDIR "/" SECKEY;
1503
2308
const char *pubkey = PATHDIR "/" PUBKEY;
2309
const char *dh_params_file = NULL;
2310
char *interfaces_hooks = NULL;
1504
2311
1505
2312
bool gnutls_initialized = false;
1506
2313
bool gpgme_initialized = false;
1558
2365
.doc = "Bit length of the prime number used in the"
1559
2366
" Diffie-Hellman key exchange",
1560
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 },
1561
2373
{ .name = "priority", .key = 130,
1562
2374
.arg = "STRING",
1563
2375
.doc = "GnuTLS priority string for the TLS handshake",
1568
2380
.group = 2 },
1569
2381
{ .name = "retry", .key = 132,
1570
2382
.arg = "SECONDS",
1571
.doc = "Retry interval used when denied by the mandos server",
2383
.doc = "Retry interval used when denied by the Mandos server",
1572
2384
.group = 2 },
1573
2385
{ .name = "network-hook-dir", .key = 133,
1574
2386
.arg = "DIR",
1597
2409
connect_to = arg;
1598
2410
break;
1599
2411
case 'i': /* --interface */
1600
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
}
1601
2417
break;
1602
2418
case 's': /* --seckey */
1603
2419
seckey = arg;
1614
2430
}
1615
2431
mc.dh_bits = (typeof(mc.dh_bits))tmpmax;
1616
2432
break;
2433
case 134: /* --dh-params */
2434
dh_params_file = arg;
2435
break;
1617
2436
case 130: /* --priority */
1618
2437
mc.priority = arg;
1619
2438
break;
1646
2465
argp_state_help(state, state->out_stream,
1647
2466
ARGP_HELP_USAGE | ARGP_HELP_EXIT_ERR);
1648
2467
case 'V': /* --version */
1649
fprintf_plus(state->out_stream,
1650
"Mandos plugin mandos-client: ");
1651
2468
fprintf_plus(state->out_stream, "%s\n", argp_program_version);
1652
2469
exit(argp_err_exit_status);
1653
2470
break;
1677
2494
goto end;
1678
2495
}
1679
2496
}
1680
1681
if(getuid() == 0){
2497
2498
{
1682
2499
/* Work around Debian bug #633582:
1683
2500
<http://bugs.debian.org/633582> */
1684
struct stat st;
1685
1686
/* Re-raise priviliges */
1687
errno = 0;
1688
ret = seteuid(0);
1689
if(ret == -1){
1690
perror_plus("seteuid");
1691
}
1692
1693
if(strcmp(seckey, PATHDIR "/" SECKEY) == 0){
1694
int seckey_fd = open(seckey, O_RDONLY);
1695
if(seckey_fd == -1){
1696
perror_plus("open");
1697
} else {
1698
ret = (int)TEMP_FAILURE_RETRY(fstat(seckey_fd, &st));
1699
if(ret == -1){
1700
perror_plus("fstat");
1701
} else {
1702
if(S_ISREG(st.st_mode)
1703
and st.st_uid == 0 and st.st_gid == 0){
1704
ret = fchown(seckey_fd, uid, gid);
1705
if(ret == -1){
1706
perror_plus("fchown");
1707
}
1708
}
1709
}
1710
TEMP_FAILURE_RETRY(close(seckey_fd));
1711
}
1712
}
1713
1714
if(strcmp(pubkey, PATHDIR "/" PUBKEY) == 0){
1715
int pubkey_fd = open(pubkey, O_RDONLY);
1716
if(pubkey_fd == -1){
1717
perror_plus("open");
1718
} else {
1719
ret = (int)TEMP_FAILURE_RETRY(fstat(pubkey_fd, &st));
1720
if(ret == -1){
1721
perror_plus("fstat");
1722
} else {
1723
if(S_ISREG(st.st_mode)
1724
and st.st_uid == 0 and st.st_gid == 0){
1725
ret = fchown(pubkey_fd, uid, gid);
1726
if(ret == -1){
1727
perror_plus("fchown");
1728
}
1729
}
1730
}
1731
TEMP_FAILURE_RETRY(close(pubkey_fd));
1732
}
1733
}
1734
1735
/* Lower privileges */
1736
errno = 0;
1737
ret = seteuid(uid);
1738
if(ret == -1){
1739
perror_plus("seteuid");
2501
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");
2507
} else {
2508
struct stat st;
2509
2510
if(strcmp(seckey, PATHDIR "/" SECKEY) == 0){
2511
int seckey_fd = open(seckey, O_RDONLY);
2512
if(seckey_fd == -1){
2513
perror_plus("open");
2514
} else {
2515
ret = (int)TEMP_FAILURE_RETRY(fstat(seckey_fd, &st));
2516
if(ret == -1){
2517
perror_plus("fstat");
2518
} else {
2519
if(S_ISREG(st.st_mode)
2520
and st.st_uid == 0 and st.st_gid == 0){
2521
ret = fchown(seckey_fd, uid, gid);
2522
if(ret == -1){
2523
perror_plus("fchown");
2524
}
2525
}
2526
}
2527
close(seckey_fd);
2528
}
2529
}
2530
2531
if(strcmp(pubkey, PATHDIR "/" PUBKEY) == 0){
2532
int pubkey_fd = open(pubkey, O_RDONLY);
2533
if(pubkey_fd == -1){
2534
perror_plus("open");
2535
} else {
2536
ret = (int)TEMP_FAILURE_RETRY(fstat(pubkey_fd, &st));
2537
if(ret == -1){
2538
perror_plus("fstat");
2539
} else {
2540
if(S_ISREG(st.st_mode)
2541
and st.st_uid == 0 and st.st_gid == 0){
2542
ret = fchown(pubkey_fd, uid, gid);
2543
if(ret == -1){
2544
perror_plus("fchown");
2545
}
2546
}
2547
}
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
2574
/* Lower privileges */
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;
2596
}
1740
2597
}
1741
2598
}
1742
2599
1743
2600
/* Run network hooks */
1744
2601
{
1745
if(getuid() == 0){
1746
/* Re-raise priviliges */
1747
errno = 0;
1748
ret = seteuid(0);
1749
if(ret == -1){
1750
perror_plus("seteuid");
1751
}
1752
}
1753
if(not run_network_hooks("start", interface, delay)){
1754
goto end;
1755
}
1756
if(getuid() == 0){
1757
/* Lower privileges */
1758
errno = 0;
1759
ret = seteuid(uid);
1760
if(ret == -1){
1761
perror_plus("seteuid");
1762
}
1763
}
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);
1764
2613
}
1765
2614
1766
2615
if(not debug){
1767
2616
avahi_set_log_function(empty_log);
1768
2617
}
1769
2618
1770
if(interface[0] == '\0'){
1771
struct dirent **direntries;
1772
/* First look for interfaces that are up */
1773
ret = scandir(sys_class_net, &direntries, up_interface,
1774
alphasort);
1775
if(ret == 0){
1776
/* No up interfaces, look for any good interfaces */
1777
free(direntries);
1778
ret = scandir(sys_class_net, &direntries, good_interface,
1779
alphasort);
1780
}
1781
if(ret >= 1){
1782
/* Pick the first interface returned */
1783
interface = strdup(direntries[0]->d_name);
1784
if(debug){
1785
fprintf_plus(stderr, "Using interface \"%s\"\n", interface);
1786
}
1787
if(interface == NULL){
1788
perror_plus("malloc");
1789
free(direntries);
1790
exitcode = EXIT_FAILURE;
1791
goto end;
1792
}
1793
free(direntries);
1794
} else {
1795
free(direntries);
1796
fprintf_plus(stderr, "Could not find a network interface\n");
1797
exitcode = EXIT_FAILURE;
1798
goto end;
1799
}
1800
}
1801
1802
2619
/* Initialize Avahi early so avahi_simple_poll_quit() can be called
1803
2620
from the signal handler */
1804
2621
/* Initialize the pseudo-RNG for Avahi */
1805
2622
srand((unsigned int) time(NULL));
1806
mc.simple_poll = avahi_simple_poll_new();
1807
if(mc.simple_poll == NULL){
2623
simple_poll = avahi_simple_poll_new();
2624
if(simple_poll == NULL){
1808
2625
fprintf_plus(stderr,
1809
2626
"Avahi: Failed to create simple poll object.\n");
1810
2627
exitcode = EX_UNAVAILABLE;
1874
2691
}
1875
2692
}
1876
2693
1877
/* If the interface is down, bring it up */
1878
if(strcmp(interface, "none") != 0){
1879
if_index = (AvahiIfIndex) if_nametoindex(interface);
1880
if(if_index == 0){
1881
fprintf_plus(stderr, "No such interface: \"%s\"\n", interface);
1882
exitcode = EX_UNAVAILABLE;
1883
goto end;
1884
}
1885
1886
if(quit_now){
1887
goto end;
1888
}
1889
1890
/* Re-raise priviliges */
1891
errno = 0;
1892
ret = seteuid(0);
1893
if(ret == -1){
1894
perror_plus("seteuid");
1895
}
1896
1897
#ifdef __linux__
1898
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1899
messages about the network interface to mess up the prompt */
1900
ret = klogctl(8, NULL, 5);
1901
bool restore_loglevel = true;
1902
if(ret == -1){
1903
restore_loglevel = false;
1904
perror_plus("klogctl");
1905
}
1906
#endif /* __linux__ */
1907
1908
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1909
if(sd < 0){
1910
perror_plus("socket");
1911
exitcode = EX_OSERR;
1912
#ifdef __linux__
1913
if(restore_loglevel){
1914
ret = klogctl(7, NULL, 0);
1915
if(ret == -1){
1916
perror_plus("klogctl");
1917
}
1918
}
1919
#endif /* __linux__ */
1920
/* Lower privileges */
1921
errno = 0;
1922
ret = seteuid(uid);
1923
if(ret == -1){
1924
perror_plus("seteuid");
1925
}
1926
goto end;
1927
}
1928
strcpy(network.ifr_name, interface);
1929
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1930
if(ret == -1){
1931
perror_plus("ioctl SIOCGIFFLAGS");
1932
#ifdef __linux__
1933
if(restore_loglevel){
1934
ret = klogctl(7, NULL, 0);
1935
if(ret == -1){
1936
perror_plus("klogctl");
1937
}
1938
}
1939
#endif /* __linux__ */
1940
exitcode = EX_OSERR;
1941
/* Lower privileges */
1942
errno = 0;
1943
ret = seteuid(uid);
1944
if(ret == -1){
1945
perror_plus("seteuid");
1946
}
1947
goto end;
1948
}
1949
if((network.ifr_flags & IFF_UP) == 0){
1950
network.ifr_flags |= IFF_UP;
1951
take_down_interface = true;
1952
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1953
if(ret == -1){
1954
take_down_interface = false;
1955
perror_plus("ioctl SIOCSIFFLAGS +IFF_UP");
1956
exitcode = EX_OSERR;
1957
#ifdef __linux__
1958
if(restore_loglevel){
1959
ret = klogctl(7, NULL, 0);
1960
if(ret == -1){
1961
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;
1962
2745
}
1963
2746
}
1964
#endif /* __linux__ */
1965
/* Lower privileges */
1966
errno = 0;
1967
ret = seteuid(uid);
1968
if(ret == -1){
1969
perror_plus("seteuid");
1970
}
1971
goto end;
1972
}
1973
}
1974
/* Sleep checking until interface is running.
1975
Check every 0.25s, up to total time of delay */
1976
for(int i=0; i < delay * 4; i++){
1977
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1978
if(ret == -1){
1979
perror_plus("ioctl SIOCGIFFLAGS");
1980
} else if(network.ifr_flags & IFF_RUNNING){
1981
2747
break;
1982
2748
}
1983
struct timespec sleeptime = { .tv_nsec = 250000000 };
1984
ret = nanosleep(&sleeptime, NULL);
1985
if(ret == -1 and errno != EINTR){
1986
perror_plus("nanosleep");
1987
}
1988
}
1989
if(not take_down_interface){
1990
/* We won't need the socket anymore */
1991
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1992
if(ret == -1){
1993
perror_plus("close");
1994
}
1995
}
1996
#ifdef __linux__
1997
if(restore_loglevel){
1998
/* Restores kernel loglevel to default */
1999
ret = klogctl(7, NULL, 0);
2000
if(ret == -1){
2001
perror_plus("klogctl");
2002
}
2003
}
2004
#endif /* __linux__ */
2005
/* Lower privileges */
2006
errno = 0;
2007
/* Lower privileges */
2008
ret = seteuid(uid);
2009
if(ret == -1){
2010
perror_plus("seteuid");
2011
}
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);
2012
2777
}
2013
2778
2014
2779
if(quit_now){
2015
2780
goto end;
2016
2781
}
2017
2782
2018
ret = init_gnutls_global(pubkey, seckey);
2783
ret = init_gnutls_global(pubkey, seckey, dh_params_file, &mc);
2019
2784
if(ret == -1){
2020
2785
fprintf_plus(stderr, "init_gnutls_global failed\n");
2021
2786
exitcode = EX_UNAVAILABLE;
2028
2793
goto end;
2029
2794
}
2030
2795
2031
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){
2032
2806
perror_plus("mkdtemp");
2033
2807
goto end;
2034
2808
}
2035
tempdir_created = true;
2036
2809
2037
2810
if(quit_now){
2038
2811
goto end;
2039
2812
}
2040
2813
2041
if(not init_gpgme(pubkey, seckey, tempdir)){
2814
if(not init_gpgme(pubkey, seckey, tempdir, &mc)){
2042
2815
fprintf_plus(stderr, "init_gpgme failed\n");
2043
2816
exitcode = EX_UNAVAILABLE;
2044
2817
goto end;
2054
2827
/* Connect directly, do not use Zeroconf */
2055
2828
/* (Mainly meant for debugging) */
2056
2829
char *address = strrchr(connect_to, ':');
2830
2057
2831
if(address == NULL){
2058
2832
fprintf_plus(stderr, "No colon in address\n");
2059
2833
exitcode = EX_USAGE;
2064
2838
goto end;
2065
2839
}
2066
2840
2067
uint16_t port;
2841
in_port_t port;
2068
2842
errno = 0;
2069
2843
tmpmax = strtoimax(address+1, &tmp, 10);
2070
2844
if(errno != 0 or tmp == address+1 or *tmp != '\0'
2071
or tmpmax != (uint16_t)tmpmax){
2845
or tmpmax != (in_port_t)tmpmax){
2072
2846
fprintf_plus(stderr, "Bad port number\n");
2073
2847
exitcode = EX_USAGE;
2074
2848
goto end;
2075
2849
}
2076
2850
2077
2851
if(quit_now){
2078
2852
goto end;
2079
2853
}
2080
2854
2081
port = (uint16_t)tmpmax;
2855
port = (in_port_t)tmpmax;
2082
2856
*address = '\0';
2083
2857
/* Colon in address indicates IPv6 */
2084
2858
int af;
2100
2874
}
2101
2875
2102
2876
while(not quit_now){
2103
ret = start_mandos_communication(address, port, if_index, af);
2877
ret = start_mandos_communication(address, port, if_index, af,
2878
&mc);
2104
2879
if(quit_now or ret == 0){
2105
2880
break;
2106
2881
}
2108
2883
fprintf_plus(stderr, "Retrying in %d seconds\n",
2109
2884
(int)retry_interval);
2110
2885
}
2111
sleep((int)retry_interval);
2886
sleep((unsigned int)retry_interval);
2112
2887
}
2113
2888
2114
if (not quit_now){
2889
if(not quit_now){
2115
2890
exitcode = EXIT_SUCCESS;
2116
2891
}
2117
2892
2132
2907
config.publish_domain = 0;
2133
2908
2134
2909
/* Allocate a new server */
2135
mc.server = avahi_server_new(avahi_simple_poll_get
2136
(mc.simple_poll), &config, NULL,
2137
NULL, &error);
2910
mc.server = avahi_server_new(avahi_simple_poll_get(simple_poll),
2911
&config, NULL, NULL, &ret_errno);
2138
2912
2139
2913
/* Free the Avahi configuration data */
2140
2914
avahi_server_config_free(&config);
2143
2917
/* Check if creating the Avahi server object succeeded */
2144
2918
if(mc.server == NULL){
2145
2919
fprintf_plus(stderr, "Failed to create Avahi server: %s\n",
2146
avahi_strerror(error));
2920
avahi_strerror(ret_errno));
2147
2921
exitcode = EX_UNAVAILABLE;
2148
2922
goto end;
2149
2923
}
2155
2929
/* Create the Avahi service browser */
2156
2930
sb = avahi_s_service_browser_new(mc.server, if_index,
2157
2931
AVAHI_PROTO_UNSPEC, "_mandos._tcp",
2158
NULL, 0, browse_callback, NULL);
2932
NULL, 0, browse_callback,
2933
(void *)&mc);
2159
2934
if(sb == NULL){
2160
2935
fprintf_plus(stderr, "Failed to create service browser: %s\n",
2161
2936
avahi_strerror(avahi_server_errno(mc.server)));
2172
2947
if(debug){
2173
2948
fprintf_plus(stderr, "Starting Avahi loop search\n");
2174
2949
}
2175
2176
ret = avahi_loop_with_timeout(mc.simple_poll,
2177
(int)(retry_interval * 1000));
2950
2951
ret = avahi_loop_with_timeout(simple_poll,
2952
(int)(retry_interval * 1000), &mc);
2178
2953
if(debug){
2179
2954
fprintf_plus(stderr, "avahi_loop_with_timeout exited %s\n",
2180
2955
(ret == 0) ? "successfully" : "with error");
2187
2962
}
2188
2963
2189
2964
/* Cleanup things */
2965
free(mc.interfaces);
2966
2190
2967
if(sb != NULL)
2191
2968
avahi_s_service_browser_free(sb);
2192
2969
2193
2970
if(mc.server != NULL)
2194
2971
avahi_server_free(mc.server);
2195
2972
2196
if(mc.simple_poll != NULL)
2197
avahi_simple_poll_free(mc.simple_poll);
2973
if(simple_poll != NULL)
2974
avahi_simple_poll_free(simple_poll);
2198
2975
2199
2976
if(gnutls_initialized){
2200
2977
gnutls_certificate_free_credentials(mc.cred);
2212
2989
mc.current_server->prev->next = NULL;
2213
2990
while(mc.current_server != NULL){
2214
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
2215
3000
free(mc.current_server);
2216
3001
mc.current_server = next;
2217
3002
}
2218
3003
}
2219
3004
2220
/* Re-raise priviliges */
3005
/* Re-raise privileges */
2221
3006
{
2222
if(getuid() == 0){
2223
errno = 0;
2224
ret = seteuid(0);
2225
if(ret == -1){
2226
perror_plus("seteuid");
2227
}
2228
}
2229
2230
/* Run network hooks */
2231
run_network_hooks("stop", interface, delay);
2232
2233
/* Take down the network interface */
2234
if(take_down_interface and geteuid() == 0){
2235
ret = ioctl(sd, SIOCGIFFLAGS, &network);
2236
if(ret == -1){
2237
perror_plus("ioctl SIOCGIFFLAGS");
2238
} else if(network.ifr_flags & IFF_UP){
2239
network.ifr_flags &= ~(short)IFF_UP; /* clear flag */
2240
ret = ioctl(sd, SIOCSIFFLAGS, &network);
2241
if(ret == -1){
2242
perror_plus("ioctl SIOCSIFFLAGS -IFF_UP");
2243
}
2244
}
2245
ret = (int)TEMP_FAILURE_RETRY(close(sd));
2246
if(ret == -1){
2247
perror_plus("close");
2248
}
2249
}
2250
}
2251
if(getuid() == 0){
2252
/* Lower privileges permanently */
2253
errno = 0;
2254
ret = setuid(uid);
2255
if(ret == -1){
2256
perror_plus("setuid");
2257
}
2258
}
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
}
3034
}
3035
3036
ret_errno = lower_privileges_permanently();
3037
if(ret_errno != 0){
3038
errno = ret_errno;
3039
perror_plus("Failed to lower privileges permanently");
3040
}
3041
}
3042
3043
free(interfaces_to_take_down);
3044
free(interfaces_hooks);
2259
3045
2260
3046
/* Removes the GPGME temp directory and all files inside */
2261
if(tempdir_created){
3047
if(tempdir != NULL){
2262
3048
struct dirent **direntries = NULL;
2263
struct dirent *direntry = NULL;
2264
int numentries = scandir(tempdir, &direntries, notdotentries,
2265
alphasort);
2266
if (numentries > 0){
2267
for(int i = 0; i < numentries; i++){
2268
direntry = direntries[i];
2269
char *fullname = NULL;
2270
ret = asprintf(&fullname, "%s/%s", tempdir,
2271
direntry->d_name);
2272
if(ret < 0){
2273
perror_plus("asprintf");
2274
continue;
2275
}
2276
ret = remove(fullname);
2277
if(ret == -1){
2278
fprintf_plus(stderr, "remove(\"%s\"): %s\n", fullname,
2279
strerror(errno));
2280
}
2281
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
}
2282
3088
}
2283
}
2284
2285
/* need to clean even if 0 because man page doesn't specify */
2286
free(direntries);
2287
if (numentries == -1){
2288
perror_plus("scandir");
2289
}
2290
ret = rmdir(tempdir);
2291
if(ret == -1 and errno != ENOENT){
2292
perror_plus("rmdir");
3089
close(tempdir_fd);
2293
3090
}
2294
3091
}
2295
3092
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0