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, srand(),
46
#include <stdlib.h> /* free(), EXIT_SUCCESS, EXIT_FAILURE,
48
48
#include <stdbool.h> /* bool, false, true */
49
49
#include <string.h> /* memset(), strcmp(), strlen(),
50
50
strerror(), asprintf(), strcpy() */
73
73
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
74
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 */
89
87
#include <sys/klog.h> /* klogctl() */
144
142
.dh_bits = 1024, .priority = "SECURE256"
145
143
":!CTYPE-X.509:+CTYPE-OPENPGP" };
147
sig_atomic_t quit_now = 0;
148
int signal_received = 0;
151
146
* Make additional room in "buffer" for at least BUFFER_SIZE more
152
147
* bytes. "buffer_capacity" is how much is currently allocated,
481
476
/* GnuTLS session creation */
483
478
ret = gnutls_init(session, GNUTLS_SERVER);
487
479
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
488
480
if(ret != GNUTLS_E_SUCCESS){
489
481
fprintf(stderr, "Error in GnuTLS session initialization: %s\n",
496
488
ret = gnutls_priority_set_direct(*session, mc.priority, &err);
498
gnutls_deinit(*session);
501
489
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
502
490
if(ret != GNUTLS_E_SUCCESS){
503
491
fprintf(stderr, "Syntax error at: %s\n", err);
512
500
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
515
gnutls_deinit(*session);
518
502
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
519
503
if(ret != GNUTLS_E_SUCCESS){
520
504
fprintf(stderr, "Error setting GnuTLS credentials: %s\n",
535
519
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
536
520
__attribute__((unused)) const char *txt){}
522
sig_atomic_t quit_now = 0;
523
int signal_received = 0;
538
525
/* Called when a Mandos server is found */
539
526
static int start_mandos_communication(const char *ip, uint16_t port,
540
527
AvahiIfIndex if_index,
546
533
struct sockaddr_in6 in6;
548
535
char *buffer = NULL;
549
char *decrypted_buffer = NULL;
536
char *decrypted_buffer;
550
537
size_t buffer_length = 0;
551
538
size_t buffer_capacity = 0;
554
541
gnutls_session_t session;
555
542
int pf; /* Protocol family */
628
607
if(if_index == AVAHI_IF_UNSPEC){
629
608
fprintf(stderr, "An IPv6 link-local address is incomplete"
630
609
" without a network interface\n");
634
613
/* Set the network interface number as scope */
805
772
ret = gnutls_handshake(session);
811
777
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
813
779
fprintf(stderr, "*** GnuTLS Re-handshake failed ***\n");
814
780
gnutls_perror(ret);
820
786
fprintf(stderr, "Unknown error while reading data from"
821
787
" encrypted session with Mandos server\n");
822
789
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);
805
gnutls_bye(session, GNUTLS_SHUT_RDWR);
848
811
if(buffer_length > 0){
849
812
ssize_t decrypted_buffer_size;
863
825
(size_t)decrypted_buffer_size - written,
865
827
if(ret == 0 and ferror(stdout)){
868
829
fprintf(stderr, "Error writing encrypted data: %s\n",
869
830
strerror(errno));
874
835
written += (size_t)ret;
837
free(decrypted_buffer);
880
845
/* Shutdown procedure */
885
free(decrypted_buffer);
888
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
896
gnutls_deinit(session);
850
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
855
gnutls_deinit(session);
1102
1058
.arg = "SECONDS",
1103
1059
.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 },
1114
1061
{ .name = NULL }
1117
1064
error_t parse_opt(int key, char *arg,
1118
1065
struct argp_state *state){
1121
1067
case 128: /* --debug */
1138
1084
tmpmax = strtoimax(arg, &tmp, 10);
1139
1085
if(errno != 0 or tmp == arg or *tmp != '\0'
1140
1086
or tmpmax != (typeof(mc.dh_bits))tmpmax){
1141
argp_error(state, "Bad number of DH bits");
1087
fprintf(stderr, "Bad number of DH bits\n");
1143
1090
mc.dh_bits = (typeof(mc.dh_bits))tmpmax;
1150
1097
delay = strtof(arg, &tmp);
1151
1098
if(errno != 0 or tmp == arg or *tmp != '\0'){
1152
argp_error(state, "Bad delay");
1099
fprintf(stderr, "Bad delay\n");
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);
1170
1108
return ARGP_ERR_UNKNOWN;
1175
1113
struct argp argp = { .options = options, .parser = parse_opt,
1176
1114
.args_doc = "",
1177
1115
.doc = "Mandos client -- Get and decrypt"
1178
1116
" passwords from a Mandos server" };
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;
1117
ret = argp_parse(&argp, argc, argv, 0, 0, NULL);
1118
if(ret == ARGP_ERR_UNKNOWN){
1119
fprintf(stderr, "Unknown error while parsing arguments\n");
1120
exitcode = EXIT_FAILURE;
1204
1133
mc.simple_poll = avahi_simple_poll_new();
1205
1134
if(mc.simple_poll == NULL){
1206
1135
fprintf(stderr, "Avahi: Failed to create simple poll object.\n");
1207
exitcode = EX_UNAVAILABLE;
1136
exitcode = EXIT_FAILURE;
1212
1141
ret = sigaddset(&sigterm_action.sa_mask, SIGINT);
1214
1143
perror("sigaddset");
1215
exitcode = EX_OSERR;
1144
exitcode = EXIT_FAILURE;
1218
1147
ret = sigaddset(&sigterm_action.sa_mask, SIGHUP);
1220
1149
perror("sigaddset");
1221
exitcode = EX_OSERR;
1150
exitcode = EXIT_FAILURE;
1224
1153
ret = sigaddset(&sigterm_action.sa_mask, SIGTERM);
1226
1155
perror("sigaddset");
1227
exitcode = EX_OSERR;
1156
exitcode = EXIT_FAILURE;
1230
1159
/* Need to check if the handler is SIG_IGN before handling:
1234
1163
ret = sigaction(SIGINT, NULL, &old_sigterm_action);
1236
1165
perror("sigaction");
1166
return EXIT_FAILURE;
1239
1168
if(old_sigterm_action.sa_handler != SIG_IGN){
1240
1169
ret = sigaction(SIGINT, &sigterm_action, NULL);
1242
1171
perror("sigaction");
1243
exitcode = EX_OSERR;
1172
exitcode = EXIT_FAILURE;
1247
1176
ret = sigaction(SIGHUP, NULL, &old_sigterm_action);
1249
1178
perror("sigaction");
1179
return EXIT_FAILURE;
1252
1181
if(old_sigterm_action.sa_handler != SIG_IGN){
1253
1182
ret = sigaction(SIGHUP, &sigterm_action, NULL);
1255
1184
perror("sigaction");
1256
exitcode = EX_OSERR;
1185
exitcode = EXIT_FAILURE;
1260
1189
ret = sigaction(SIGTERM, NULL, &old_sigterm_action);
1262
1191
perror("sigaction");
1192
return EXIT_FAILURE;
1265
1194
if(old_sigterm_action.sa_handler != SIG_IGN){
1266
1195
ret = sigaction(SIGTERM, &sigterm_action, NULL);
1268
1197
perror("sigaction");
1269
exitcode = EX_OSERR;
1198
exitcode = EXIT_FAILURE;
1294
1223
#ifdef __linux__
1295
1224
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1296
messages about the network interface to mess up the prompt */
1225
messages to mess up the prompt */
1297
1226
ret = klogctl(8, NULL, 5);
1298
1227
bool restore_loglevel = true;
1422
1351
ret = init_gnutls_global(pubkey, seckey);
1424
1353
fprintf(stderr, "init_gnutls_global failed\n");
1425
exitcode = EX_UNAVAILABLE;
1354
exitcode = EXIT_FAILURE;
1428
1357
gnutls_initialized = true;
1446
1375
if(not init_gpgme(pubkey, seckey, tempdir)){
1447
1376
fprintf(stderr, "init_gpgme failed\n");
1448
exitcode = EX_UNAVAILABLE;
1377
exitcode = EXIT_FAILURE;
1451
1380
gpgme_initialized = true;
1622
1533
perror("ioctl SIOCGIFFLAGS");
1623
1534
} else if(network.ifr_flags & IFF_UP) {
1624
network.ifr_flags &= ~(short)IFF_UP; /* clear flag */
1535
network.ifr_flags &= ~IFF_UP; /* clear flag */
1625
1536
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1627
1538
perror("ioctl SIOCSIFFLAGS");
1688
1599
sigemptyset(&old_sigterm_action.sa_mask);
1689
1600
old_sigterm_action.sa_handler = SIG_DFL;
1690
ret = (int)TEMP_FAILURE_RETRY(sigaction(signal_received,
1691
&old_sigterm_action,
1601
ret = sigaction(signal_received, &old_sigterm_action, NULL);
1694
1603
perror("sigaction");
1697
ret = raise(signal_received);
1698
} while(ret != 0 and errno == EINTR);
1703
TEMP_FAILURE_RETRY(pause());
1605
raise(signal_received);
1706
1608
return exitcode;