43
43
stdout, ferror(), remove() */
44
44
#include <stdint.h> /* uint16_t, uint32_t */
45
45
#include <stddef.h> /* NULL, size_t, ssize_t */
46
#include <stdlib.h> /* free(), EXIT_SUCCESS, EXIT_FAILURE,
46
#include <stdlib.h> /* free(), EXIT_SUCCESS, srand(),
48
48
#include <stdbool.h> /* bool, false, true */
49
49
#include <string.h> /* memset(), strcmp(), strlen(),
50
50
strerror(), asprintf(), strcpy() */
71
71
INET_ADDRSTRLEN, INET6_ADDRSTRLEN
73
73
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
74
getuid(), getgid(), setuid(),
74
getuid(), getgid(), seteuid(),
76
76
#include <arpa/inet.h> /* inet_pton(), htons */
77
77
#include <iso646.h> /* not, or, and */
78
78
#include <argp.h> /* struct argp_option, error_t, struct
82
82
#include <signal.h> /* sigemptyset(), sigaddset(),
83
83
sigaction(), SIGTERM, sig_atomic_t,
85
#include <sysexits.h> /* EX_OSERR, EX_USAGE, EX_UNAVAILABLE,
86
EX_NOHOST, EX_IOERR, EX_PROTOCOL */
87
89
#include <sys/klog.h> /* klogctl() */
142
144
.dh_bits = 1024, .priority = "SECURE256"
143
145
":!CTYPE-X.509:+CTYPE-OPENPGP" };
147
sig_atomic_t quit_now = 0;
148
int signal_received = 0;
146
151
* Make additional room in "buffer" for at least BUFFER_SIZE more
147
152
* bytes. "buffer_capacity" is how much is currently allocated,
474
479
static int init_gnutls_session(gnutls_session_t *session){
476
481
/* GnuTLS session creation */
477
ret = gnutls_init(session, GNUTLS_SERVER);
483
ret = gnutls_init(session, GNUTLS_SERVER);
487
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
478
488
if(ret != GNUTLS_E_SUCCESS){
479
489
fprintf(stderr, "Error in GnuTLS session initialization: %s\n",
480
490
safer_gnutls_strerror(ret));
485
ret = gnutls_priority_set_direct(*session, mc.priority, &err);
496
ret = gnutls_priority_set_direct(*session, mc.priority, &err);
498
gnutls_deinit(*session);
501
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
486
502
if(ret != GNUTLS_E_SUCCESS){
487
503
fprintf(stderr, "Syntax error at: %s\n", err);
488
504
fprintf(stderr, "GnuTLS error: %s\n",
495
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
512
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
515
gnutls_deinit(*session);
518
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
497
519
if(ret != GNUTLS_E_SUCCESS){
498
520
fprintf(stderr, "Error setting GnuTLS credentials: %s\n",
499
521
safer_gnutls_strerror(ret));
504
526
/* ignore client certificate if any. */
505
gnutls_certificate_server_set_request(*session,
527
gnutls_certificate_server_set_request(*session, GNUTLS_CERT_IGNORE);
508
529
gnutls_dh_set_prime_bits(*session, mc.dh_bits);
514
535
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
515
536
__attribute__((unused)) const char *txt){}
517
sig_atomic_t quit_now = 0;
518
int signal_received = 0;
520
538
/* Called when a Mandos server is found */
521
539
static int start_mandos_communication(const char *ip, uint16_t port,
522
540
AvahiIfIndex if_index,
528
546
struct sockaddr_in6 in6;
530
548
char *buffer = NULL;
531
char *decrypted_buffer;
549
char *decrypted_buffer = NULL;
532
550
size_t buffer_length = 0;
533
551
size_t buffer_capacity = 0;
536
554
gnutls_session_t session;
537
555
int pf; /* Protocol family */
602
628
if(if_index == AVAHI_IF_UNSPEC){
603
629
fprintf(stderr, "An IPv6 link-local address is incomplete"
604
630
" without a network interface\n");
608
634
/* Set the network interface number as scope */
767
805
ret = gnutls_handshake(session);
772
811
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
774
813
fprintf(stderr, "*** GnuTLS Re-handshake failed ***\n");
775
814
gnutls_perror(ret);
781
820
fprintf(stderr, "Unknown error while reading data from"
782
821
" encrypted session with Mandos server\n");
784
822
gnutls_bye(session, GNUTLS_SHUT_RDWR);
800
gnutls_bye(session, GNUTLS_SHUT_RDWR);
841
ret = gnutls_bye(session, GNUTLS_SHUT_RDWR);
846
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
806
848
if(buffer_length > 0){
807
849
ssize_t decrypted_buffer_size;
820
863
(size_t)decrypted_buffer_size - written,
822
865
if(ret == 0 and ferror(stdout)){
824
868
fprintf(stderr, "Error writing encrypted data: %s\n",
825
869
strerror(errno));
830
874
written += (size_t)ret;
832
free(decrypted_buffer);
840
880
/* Shutdown procedure */
845
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
850
gnutls_deinit(session);
885
free(decrypted_buffer);
888
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
896
gnutls_deinit(session);
995
1044
bool gpgme_initialized = false;
996
1045
float delay = 2.5f;
998
struct sigaction old_sigterm_action;
1047
struct sigaction old_sigterm_action = { .sa_handler = SIG_DFL };
999
1048
struct sigaction sigterm_action = { .sa_handler = handle_sigterm };
1053
/* Lower any group privileges we might have, just to be safe */
1060
/* Lower user privileges (temporarily) */
1002
1072
struct argp_option options[] = {
1003
1073
{ .name = "debug", .key = 128,
1032
1102
.arg = "SECONDS",
1033
1103
.doc = "Maximum delay to wait for interface startup",
1106
* These reproduce what we would get without ARGP_NO_HELP
1108
{ .name = "help", .key = '?',
1109
.doc = "Give this help list", .group = -1 },
1110
{ .name = "usage", .key = -3,
1111
.doc = "Give a short usage message", .group = -1 },
1112
{ .name = "version", .key = 'V',
1113
.doc = "Print program version", .group = -1 },
1035
1114
{ .name = NULL }
1038
1117
error_t parse_opt(int key, char *arg,
1039
1118
struct argp_state *state){
1041
1121
case 128: /* --debug */
1058
1138
tmpmax = strtoimax(arg, &tmp, 10);
1059
1139
if(errno != 0 or tmp == arg or *tmp != '\0'
1060
1140
or tmpmax != (typeof(mc.dh_bits))tmpmax){
1061
fprintf(stderr, "Bad number of DH bits\n");
1141
argp_error(state, "Bad number of DH bits");
1064
1143
mc.dh_bits = (typeof(mc.dh_bits))tmpmax;
1071
1150
delay = strtof(arg, &tmp);
1072
1151
if(errno != 0 or tmp == arg or *tmp != '\0'){
1073
fprintf(stderr, "Bad delay\n");
1152
argp_error(state, "Bad delay");
1156
* These reproduce what we would get without ARGP_NO_HELP
1158
case '?': /* --help */
1159
argp_state_help(state, state->out_stream,
1160
(ARGP_HELP_STD_HELP | ARGP_HELP_EXIT_ERR)
1161
& ~(unsigned int)ARGP_HELP_EXIT_OK);
1162
case -3: /* --usage */
1163
argp_state_help(state, state->out_stream,
1164
ARGP_HELP_USAGE | ARGP_HELP_EXIT_ERR);
1165
case 'V': /* --version */
1166
fprintf(state->out_stream, "%s\n", argp_program_version);
1167
exit(argp_err_exit_status);
1082
1170
return ARGP_ERR_UNKNOWN;
1087
1175
struct argp argp = { .options = options, .parser = parse_opt,
1088
1176
.args_doc = "",
1089
1177
.doc = "Mandos client -- Get and decrypt"
1090
1178
" passwords from a Mandos server" };
1091
ret = argp_parse(&argp, argc, argv, 0, 0, NULL);
1092
if(ret == ARGP_ERR_UNKNOWN){
1093
fprintf(stderr, "Unknown error while parsing arguments\n");
1094
exitcode = EXIT_FAILURE;
1179
ret = argp_parse(&argp, argc, argv,
1180
ARGP_IN_ORDER | ARGP_NO_HELP, 0, NULL);
1187
perror("argp_parse");
1188
exitcode = EX_OSERR;
1191
exitcode = EX_USAGE;
1107
1204
mc.simple_poll = avahi_simple_poll_new();
1108
1205
if(mc.simple_poll == NULL){
1109
1206
fprintf(stderr, "Avahi: Failed to create simple poll object.\n");
1110
exitcode = EXIT_FAILURE;
1207
exitcode = EX_UNAVAILABLE;
1115
1212
ret = sigaddset(&sigterm_action.sa_mask, SIGINT);
1117
1214
perror("sigaddset");
1118
exitcode = EXIT_FAILURE;
1215
exitcode = EX_OSERR;
1121
1218
ret = sigaddset(&sigterm_action.sa_mask, SIGHUP);
1123
1220
perror("sigaddset");
1124
exitcode = EXIT_FAILURE;
1221
exitcode = EX_OSERR;
1127
1224
ret = sigaddset(&sigterm_action.sa_mask, SIGTERM);
1129
1226
perror("sigaddset");
1130
exitcode = EXIT_FAILURE;
1227
exitcode = EX_OSERR;
1133
1230
/* Need to check if the handler is SIG_IGN before handling:
1137
1234
ret = sigaction(SIGINT, NULL, &old_sigterm_action);
1139
1236
perror("sigaction");
1140
return EXIT_FAILURE;
1142
1239
if(old_sigterm_action.sa_handler != SIG_IGN){
1143
1240
ret = sigaction(SIGINT, &sigterm_action, NULL);
1145
1242
perror("sigaction");
1146
exitcode = EXIT_FAILURE;
1243
exitcode = EX_OSERR;
1150
1247
ret = sigaction(SIGHUP, NULL, &old_sigterm_action);
1152
1249
perror("sigaction");
1153
return EXIT_FAILURE;
1155
1252
if(old_sigterm_action.sa_handler != SIG_IGN){
1156
1253
ret = sigaction(SIGHUP, &sigterm_action, NULL);
1158
1255
perror("sigaction");
1159
exitcode = EXIT_FAILURE;
1256
exitcode = EX_OSERR;
1163
1260
ret = sigaction(SIGTERM, NULL, &old_sigterm_action);
1165
1262
perror("sigaction");
1166
return EXIT_FAILURE;
1168
1265
if(old_sigterm_action.sa_handler != SIG_IGN){
1169
1266
ret = sigaction(SIGTERM, &sigterm_action, NULL);
1171
1268
perror("sigaction");
1172
exitcode = EXIT_FAILURE;
1269
exitcode = EX_OSERR;
1287
/* Re-raise priviliges */
1190
1294
#ifdef __linux__
1191
1295
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1192
messages to mess up the prompt */
1296
messages about the network interface to mess up the prompt */
1193
1297
ret = klogctl(8, NULL, 5);
1194
1298
bool restore_loglevel = true;
1303
1422
ret = init_gnutls_global(pubkey, seckey);
1305
1424
fprintf(stderr, "init_gnutls_global failed\n");
1306
exitcode = EXIT_FAILURE;
1425
exitcode = EX_UNAVAILABLE;
1309
1428
gnutls_initialized = true;
1327
1446
if(not init_gpgme(pubkey, seckey, tempdir)){
1328
1447
fprintf(stderr, "init_gpgme failed\n");
1329
exitcode = EXIT_FAILURE;
1448
exitcode = EX_UNAVAILABLE;
1332
1451
gpgme_initialized = true;
1474
1611
/* Take down the network interface */
1475
1612
if(take_down_interface){
1476
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1613
/* Re-raise priviliges */
1478
perror("ioctl SIOCGIFFLAGS");
1479
} else if(network.ifr_flags & IFF_UP) {
1480
network.ifr_flags &= ~IFF_UP; /* clear flag */
1481
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1483
perror("ioctl SIOCSIFFLAGS");
1486
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1620
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1622
perror("ioctl SIOCGIFFLAGS");
1623
} else if(network.ifr_flags & IFF_UP) {
1624
network.ifr_flags &= ~(short)IFF_UP; /* clear flag */
1625
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1627
perror("ioctl SIOCSIFFLAGS");
1630
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1634
/* Lower privileges permanently */
1537
1688
sigemptyset(&old_sigterm_action.sa_mask);
1538
1689
old_sigterm_action.sa_handler = SIG_DFL;
1539
ret = sigaction(signal_received, &old_sigterm_action, NULL);
1690
ret = (int)TEMP_FAILURE_RETRY(sigaction(signal_received,
1691
&old_sigterm_action,
1541
1694
perror("sigaction");
1543
raise(signal_received);
1697
ret = raise(signal_received);
1698
} while(ret != 0 and errno == EINTR);
1703
TEMP_FAILURE_RETRY(pause());
1546
1706
return exitcode;