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